uint32_t type,
bool pod)
{
- cout << "LV2 PERSIST STORE " << key
- << " = " << value
- << " :: " << type
- << " POD: " << pod << endl;
+ DEBUG_TRACE(DEBUG::LV2, string_compose("persist store %1\n",
+ _uri_map.id_to_uri(NULL, key)));
PersistState* state = (PersistState*)callback_data;
state->add_uri(key, _uri_map.id_to_uri(NULL, key));
uint32_t* type,
bool* pod)
{
- cout << "LV2 PERSIST RETRIEVE " << _uri_map.id_to_uri(NULL, key) << endl;
+ DEBUG_TRACE(DEBUG::LV2, string_compose("persist retrieve %1\n",
+ _uri_map.id_to_uri(NULL, key)));
PersistState* state = (PersistState*)callback_data;
PersistState::Values::const_iterator i = state->values.find(key);
// Write all referenced URIs to state file
for (PersistState::URIs::const_iterator i = state.uris.begin();
i != state.uris.end(); ++i) {
- rdff_write_uri(file, i->first,
- i->second.c_str(), i->second.length() + 1);
+ rdff_write_uri(file,
+ i->first,
+ i->second.length(),
+ i->second.c_str());
}
// Write all values to state file
i != state.values.end(); ++i) {
const uint32_t key = i->first;
const PersistValue& val = i->second;
- rdff_write_value(file,
- key,
- val.value,
- val.size,
- val.type);
+ rdff_write_triple(file,
+ 0,
+ key,
+ val.type,
+ val.size,
+ val.value);
}
// Close state file
printf("READ URI %u: %s\n", body->id, body->uri);
state.add_uri(body->id, body->uri);
} else if (!strncmp(chunk->type, "KVAL", 4)) {
- RDFFValueChunk* body = (RDFFValueChunk*)chunk->data;
+ RDFFTripleChunk* body = (RDFFTripleChunk*)chunk->data;
printf("READ VAL %u = %s (size: %u type: %u)\n",
- body->key, body->value, body->size, body->type);
- state.add_value(body->key,
- body->value,
- body->size,
- body->type,
+ body->predicate, body->object,
+ body->object_size, body->object_type);
+ state.add_value(body->predicate,
+ body->object,
+ body->object_size,
+ body->object_type,
true);
}
}
#define CHUNK_ID_LEN 4
static const char FILE_TYPE[CHUNK_ID_LEN] = "RDFF"; /* RDFF File ID */
-static const char CHUNK_KVAL[CHUNK_ID_LEN] = "KVAL"; /* Key/Value Chunk ID */
-static const char CHUNK_URID[CHUNK_ID_LEN] = "URID"; /* URI-ID Chunk ID*/
+static const char CHUNK_TRIP[CHUNK_ID_LEN] = "trip"; /* Triple Chunk ID */
+static const char CHUNK_URID[CHUNK_ID_LEN] = "urid"; /* URI-ID Chunk ID*/
struct _RDFF {
FILE* fd;
RDFFStatus
rdff_write_uri(RDFF file,
uint32_t id,
- const char* uri,
- uint32_t len)
+ uint32_t len,
+ const char* uri)
{
const uint32_t chunk_size = sizeof(id) + len + 1;
WRITE(CHUNK_URID, CHUNK_ID_LEN, 1, file->fd);
}
RDFFStatus
-rdff_write_value(RDFF file,
- uint32_t key,
- const void* value,
- uint32_t size,
- uint32_t type)
+rdff_write_triple(RDFF file,
+ uint32_t subject,
+ uint32_t predicate,
+ uint32_t object_type,
+ uint32_t object_size,
+ const void* object)
{
- const uint32_t chunk_size = sizeof(key) + sizeof(type) + sizeof(size) + size;
- WRITE(CHUNK_KVAL, CHUNK_ID_LEN, 1, file->fd);
- WRITE(&chunk_size, sizeof(chunk_size), 1, file->fd);
- WRITE(&key, sizeof(key), 1, file->fd);
- WRITE(&type, sizeof(type), 1, file->fd);
- WRITE(&size, sizeof(size), 1, file->fd);
- WRITE(value, size, 1, file->fd);
- if ((size % 2)) {
+ const uint32_t chunk_size = sizeof(RDFFTripleChunk) + object_size;
+ WRITE(CHUNK_TRIP, CHUNK_ID_LEN, 1, file->fd);
+ WRITE(&chunk_size, sizeof(chunk_size), 1, file->fd);
+ WRITE(&subject, sizeof(subject), 1, file->fd);
+ WRITE(&predicate, sizeof(predicate), 1, file->fd);
+ WRITE(&object_type, sizeof(object_type), 1, file->fd);
+ WRITE(&object_size, sizeof(object_size), 1, file->fd);
+ WRITE(object, object_size, 1, file->fd);
+ if ((object_size % 2)) {
WRITE("", 1, 1, file->fd); /* write pad */
}
file->size += 8 + chunk_size;
char uri[64];
for (int i = 0; i < N_URIS; ++i) {
snprintf(uri, sizeof(uri), "http://example.org/uri%02d", i + 1);
- rdff_write_uri(file, i + 1, uri, strlen(uri) + 1);
+ rdff_write_uri(file, i + 1, strlen(uri), uri);
}
char val[6];
for (int i = 0; i < N_RECORDS; ++i) {
snprintf(val, sizeof(val), "VAL%02d", i);
- rdff_write_value(file,
- rand() % N_URIS,
- val,
- sizeof(val),
- 0);
+ rdff_write_triple(file,
+ 0,
+ rand() % N_URIS,
+ 0,
+ sizeof(val),
+ val);
}
rdff_close(file);
chunk->size = 0;
for (int i = 0; i < N_URIS; ++i) {
if (rdff_read_chunk(file, &chunk)
- || strncmp(chunk->type, "URID", 4)) {
- fprintf(stderr, "error: expected URID chunk\n");
+ || strncmp(chunk->type, CHUNK_URID, 4)) {
+ fprintf(stderr, "error: expected %s chunk\n", CHUNK_URID);
goto fail;
}
RDFFURIChunk* body = (RDFFURIChunk*)chunk->data;
for (int i = 0; i < N_RECORDS; ++i) {
if (rdff_read_chunk(file, &chunk)
- || strncmp(chunk->type, "KVAL", 4)) {
- fprintf(stderr, "error: expected KVAL chunk\n");
+ || strncmp(chunk->type, CHUNK_TRIP, 4)) {
+ fprintf(stderr, "error: expected %s chunk\n", CHUNK_TRIP);
goto fail;
}
- RDFFValueChunk* body = (RDFFValueChunk*)chunk->data;
- printf("KEY %d = %s\n", body->key, body->value);
+ RDFFTripleChunk* body = (RDFFTripleChunk*)chunk->data;
+ printf("KEY %d = %s\n", body->predicate, body->object);
}
free(chunk);
} PACKED RDFFChunk;
/**
- Body of a URID chunk.
+ Body of a RDFF "urid" chunk.
*/
typedef struct {
uint32_t id; /**< Numeric ID of URI in this RDFF. */
} PACKED RDFFURIChunk;
/**
- Body of a KVAL chunk.
+ Body of a RDFF "trip" chunk.
*/
typedef struct {
- uint32_t key; /**< Predicate URI ID. */
- uint32_t type; /**< Type URI ID. */
- uint32_t size; /**< Size of object data. */
- char value[]; /**< Object data. */
-} PACKED RDFFValueChunk;
+ uint32_t subject; /**< Subject URI ID. */
+ uint32_t predicate; /**< Predicate URI ID. */
+ uint32_t object_type; /**< Object type URI ID. */
+ uint32_t object_size; /**< Size of object data. */
+ char object[]; /**< Object data. */
+} PACKED RDFFTripleChunk;
/**
Open/Create a new RDFF file.
RDFFStatus
rdff_write_uri(RDFF file,
uint32_t id,
- const char* uri,
- uint32_t len);
+ uint32_t len,
+ const char* uri);
/**
Write a key/value record to @a file.
*/
RDFFStatus
-rdff_write_value(RDFF file,
- uint32_t key,
- const void* value,
- uint32_t size,
- uint32_t type);
+rdff_write_triple(RDFF file,
+ uint32_t subject,
+ uint32_t predicate,
+ uint32_t object_type,
+ uint32_t object_size,
+ const void* object);
/**
Read a chunk from @a file.