#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
+#include <unistd.h>
#include <loc/libloc.h>
#include <loc/format.h>
struct loc_ctx* ctx;
int refcount;
+ FILE* file;
unsigned int version;
off_t vendor;
off_t description;
loc_stringpool_unref(db->pool);
+ // Close file
+ if (db->file)
+ fclose(db->file);
+
loc_unref(db->ctx);
free(db);
}
return __loc_database_add_as(db, as);
}
-static int loc_database_read_magic(struct loc_database* db, FILE* f) {
+static int loc_database_read_magic(struct loc_database* db) {
struct loc_database_magic magic;
// Read from file
- size_t bytes_read = fread(&magic, 1, sizeof(magic), f);
+ size_t bytes_read = fread(&magic, 1, sizeof(magic), db->file);
// Check if we have been able to read enough data
if (bytes_read < sizeof(magic)) {
}
static int loc_database_read_as_section_v0(struct loc_database* db,
- off_t as_offset, size_t as_length, FILE* f) {
+ off_t as_offset, size_t as_length) {
struct loc_database_as_v0 dbobj;
// Read from the start of the section
- int r = fseek(f, as_offset, SEEK_SET);
+ int r = fseek(db->file, as_offset, SEEK_SET);
if (r)
return r;
// Read all ASes
size_t as_count = as_length / sizeof(dbobj);
for (unsigned int i = 0; i < as_count; i++) {
- size_t bytes_read = fread(&dbobj, 1, sizeof(dbobj), f);
+ size_t bytes_read = fread(&dbobj, 1, sizeof(dbobj), db->file);
if (bytes_read < sizeof(dbobj)) {
ERROR(db->ctx, "Could not read an AS object\n");
return -ENOMSG;
return 0;
}
-static int loc_database_read_header_v0(struct loc_database* db, FILE* f) {
+static int loc_database_read_header_v0(struct loc_database* db) {
struct loc_database_header_v0 header;
// Read from file
- size_t size = fread(&header, 1, sizeof(header), f);
+ size_t size = fread(&header, 1, sizeof(header), db->file);
if (size < sizeof(header)) {
ERROR(db->ctx, "Could not read enough data for header\n");
off_t pool_offset = ntohl(header.pool_offset);
size_t pool_length = ntohl(header.pool_length);
- int r = loc_stringpool_read(db->pool, f, pool_offset, pool_length);
+ int r = loc_stringpool_read(db->pool, db->file, pool_offset, pool_length);
if (r)
return r;
off_t as_offset = ntohl(header.as_offset);
size_t as_length = ntohl(header.as_length);
- r = loc_database_read_as_section_v0(db, as_offset, as_length, f);
+ r = loc_database_read_as_section_v0(db, as_offset, as_length);
if (r)
return r;
return 0;
}
-static int loc_database_read_header(struct loc_database* db, FILE* f) {
+static int loc_database_read_header(struct loc_database* db) {
switch (db->version) {
case 0:
- return loc_database_read_header_v0(db, f);
+ return loc_database_read_header_v0(db);
default:
ERROR(db->ctx, "Incompatible database version: %u\n", db->version);
}
LOC_EXPORT int loc_database_read(struct loc_database* db, FILE* f) {
- int r = fseek(f, 0, SEEK_SET);
+ // Copy the file pointer and work on that so we don't care if
+ // the calling function closes the file
+ int fd = fileno(f);
+
+ // Make a copy
+ fd = dup(fd);
+
+ // Retrieve a file pointer
+ db->file = fdopen(fd, "r");
+ if (!db->file)
+ return -errno;
+
+ int r = fseek(db->file, 0, SEEK_SET);
if (r)
return r;
// Read magic bytes
- r = loc_database_read_magic(db, f);
+ r = loc_database_read_magic(db);
if (r)
return r;
// Read the header
- r = loc_database_read_header(db, f);
+ r = loc_database_read_header(db);
if (r)
return r;
magic->version = htons(LOC_DATABASE_VERSION);
}
+static void loc_database_align_page_boundary(off_t* offset, FILE* f) {
+ // Move to next page boundary
+ while (*offset % LOC_DATABASE_PAGE_SIZE > 0)
+ *offset += fwrite("", 1, 1, f);
+}
+
+static int loc_database_write_pool(struct loc_database* db, struct loc_database_header_v0* header, off_t* offset, FILE* f) {
+ // Save the offset of the pool section
+ DEBUG(db->ctx, "Pool starts at %jd bytes\n", *offset);
+ header->pool_offset = htonl(*offset);
+
+ // Write the pool
+ size_t pool_length = loc_stringpool_write(db->pool, f);
+ *offset += pool_length;
+
+ DEBUG(db->ctx, "Pool has a length of %zu bytes\n", pool_length);
+ header->pool_length = htonl(pool_length);
+
+ return 0;
+}
+
+static int loc_database_write_as_section(struct loc_database* db,
+ struct loc_database_header_v0* header, off_t* offset, FILE* f) {
+ DEBUG(db->ctx, "AS section starts at %jd bytes\n", *offset);
+ header->as_offset = htonl(*offset);
+
+ size_t as_length = 0;
+
+ struct loc_database_as_v0 dbas;
+ for (unsigned int i = 0; i < db->as_count; i++) {
+ // Convert AS into database format
+ loc_as_to_database_v0(db->as[i], &dbas);
+
+ // Write to disk
+ offset += fwrite(&dbas, 1, sizeof(dbas), f);
+ as_length += sizeof(dbas);
+ }
+
+ DEBUG(db->ctx, "AS section has a length of %zu bytes\n", as_length);
+ header->as_length = htonl(as_length);
+
+ return 0;
+}
+
LOC_EXPORT int loc_database_write(struct loc_database* db, FILE* f) {
struct loc_database_magic magic;
loc_database_make_magic(db, &magic);
}
offset += sizeof(header);
- // Write all ASes
- header.as_offset = htonl(offset);
-
- struct loc_database_as_v0 dbas;
- for (unsigned int i = 0; i < db->as_count; i++) {
- // Convert AS into database format
- loc_as_to_database_v0(db->as[i], &dbas);
+ loc_database_align_page_boundary(&offset, f);
- // Write to disk
- offset += fwrite(&dbas, 1, sizeof(dbas), f);
- }
- header.as_length = htonl(db->as_count * sizeof(dbas));
+ // Write pool
+ r = loc_database_write_pool(db, &header, &offset, f);
+ if (r)
+ return r;
- // Save the offset of the pool section
- DEBUG(db->ctx, "Pool starts at %jd bytes\n", offset);
- header.pool_offset = htonl(offset);
+ loc_database_align_page_boundary(&offset, f);
- // Size of the pool
- size_t pool_length = loc_stringpool_write(db->pool, f);
- DEBUG(db->ctx, "Pool has a length of %zu bytes\n", pool_length);
- header.pool_length = htonl(pool_length);
+ // Write all ASes
+ r = loc_database_write_as_section(db, &header, &offset, f);
+ if (r)
+ return r;
// Write the header
r = fseek(f, sizeof(magic), SEEK_SET);
projects / people / ms / libloc.git / blobdiff