X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=bluesky%2Fbluesky.h;h=7f237d30c73b9e64a613c38d6c2bf2f116ca6270;hb=a4e456f91da9819e5a1517d4e505816bb4aa1007;hp=9808434bbbc6f17e2a72ec25e802662d69d2a9d6;hpb=bc90f29d0c20f85e77761dbf2c43aec96848af36;p=bluesky.git diff --git a/bluesky/bluesky.h b/bluesky/bluesky.h index 9808434..7f237d3 100644 --- a/bluesky/bluesky.h +++ b/bluesky/bluesky.h @@ -17,6 +17,14 @@ extern "C" { #endif +/* Various options to tweak for performance benchmarking purposes. */ +typedef struct { + /* Perform all get/put operations synchronously. */ + int synchronous_stores; +} BlueSkyOptions; + +extern BlueSkyOptions bluesky_options; + /* BlueSky status and error codes. Various frontends should translate these to * the appropriate error code for whatever protocol they implement. */ typedef enum { @@ -38,6 +46,7 @@ typedef struct { } BlueSkyRCStr; BlueSkyRCStr *bluesky_string_new(gpointer data, gsize len); +BlueSkyRCStr *bluesky_string_new_from_gstring(GString *s); void bluesky_string_ref(BlueSkyRCStr *string); void bluesky_string_unref(BlueSkyRCStr *string); BlueSkyRCStr *bluesky_string_dup(BlueSkyRCStr *string); @@ -55,23 +64,6 @@ BlueSkyRCStr *bluesky_crypt_decrypt(BlueSkyRCStr *in, const uint8_t *key); /* Storage interface. This presents a key-value store abstraction, and can * have multiple implementations: in-memory, on-disk, in-cloud. */ -typedef struct { - /* Create a new store instance and return a handle to it. */ - gpointer (*create)(); - - /* Clean up any resources used by this store. */ - void (*destroy)(gpointer store); - - /* Fetch an item with the given name, or return NULL if not found. */ - BlueSkyRCStr * (*get)(gpointer store, const gchar *key); - - /* Store an item to the given key name. */ - void (*put)(gpointer store, const gchar *key, BlueSkyRCStr *val); -} BlueSkyStoreImplementation; - -void bluesky_store_register(const BlueSkyStoreImplementation *impl, - const gchar *name); - struct _BlueSkyStore; typedef struct _BlueSkyStore BlueSkyStore; @@ -149,6 +141,11 @@ typedef struct { * committed to stable storage. */ uint64_t change_count, change_commit; + /* Timestamp for controlling when modified data is flushed to stable + * storage. When an inode is first modified from a clean state, this is + * set to the current time. If the inode is clean, it is set to zero. */ + int64_t change_time; + int64_t atime; /* Microseconds since the Unix epoch */ int64_t ctime; int64_t mtime; @@ -218,6 +215,7 @@ void bluesky_directory_dump(BlueSkyInode *dir); void bluesky_block_touch(BlueSkyInode *inode, uint64_t i); void bluesky_block_fetch(BlueSkyFS *fs, BlueSkyBlock *block); void bluesky_block_flush(BlueSkyFS *fs, BlueSkyBlock *block); +void bluesky_file_flush(BlueSkyInode *inode); void bluesky_file_truncate(BlueSkyInode *inode, uint64_t size); void bluesky_file_write(BlueSkyInode *inode, uint64_t offset, const char *data, gint len);