X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=bluesky%2Fbluesky-private.h;h=b77f819a391c3dcbeebc1d8f0c470ce9cfd45680;hb=8a2da0db5d5f4f599486876396883f6207ebec6a;hp=e51c40f74b6dbde1240425dc97da7ad83fbdcd07;hpb=a5b5871865301712bc22ffc3d86a425dc0b45991;p=bluesky.git diff --git a/bluesky/bluesky-private.h b/bluesky/bluesky-private.h index e51c40f..b77f819 100644 --- a/bluesky/bluesky-private.h +++ b/bluesky/bluesky-private.h @@ -27,7 +27,7 @@ BlueSkyFS *bluesky_new_fs(gchar *name); void bluesky_serialize_superblock(GString *out, BlueSkyFS *fs); BlueSkyFS *bluesky_deserialize_superblock(const gchar *buf); void bluesky_serialize_inode(GString *out, BlueSkyInode *inode); -BlueSkyInode *bluesky_deserialize_inode(BlueSkyFS *fs, const gchar *buf); +gboolean bluesky_deserialize_inode(BlueSkyInode *inode, const gchar *buf); /* Storage layer. Requests can be performed asynchronously, so these objects * help keep track of operations in progress. */ @@ -64,6 +64,8 @@ typedef struct { int result; /* Result code; 0 for success. */ struct BlueSkyNotifierList *notifiers; + bluesky_time_hires start_time; /* Time operation was submitted. */ + gpointer store_private; /* For use by the storage implementation */ } BlueSkyStoreAsync; @@ -81,7 +83,7 @@ struct BlueSkyNotifierList { /* The abstraction layer for storage, allowing multiple implementations. */ typedef struct { /* Create a new store instance and return a handle to it. */ - gpointer (*create)(); + gpointer (*create)(const gchar *path); /* Clean up any resources used by this store. */ void (*destroy)(gpointer store); @@ -98,6 +100,7 @@ void bluesky_store_register(const BlueSkyStoreImplementation *impl, const gchar *name); BlueSkyStoreAsync *bluesky_store_async_new(BlueSkyStore *store); +gpointer bluesky_store_async_get_handle(BlueSkyStoreAsync *async); void bluesky_store_async_ref(BlueSkyStoreAsync *async); void bluesky_store_async_unref(BlueSkyStoreAsync *async); void bluesky_store_async_wait(BlueSkyStoreAsync *async); @@ -112,6 +115,11 @@ void bluesky_store_add_barrier(BlueSkyStoreAsync *barrier, void bluesky_inode_start_sync(BlueSkyInode *inode, BlueSkyStoreAsync *barrier); +void bluesky_block_flush(BlueSkyFS *fs, BlueSkyBlock *block, + BlueSkyStoreAsync *barrier); +void bluesky_file_flush(BlueSkyInode *inode, BlueSkyStoreAsync *barrier); +void bluesky_file_drop_cached(BlueSkyInode *inode); + #ifdef __cplusplus } #endif