Add support for byterange requests in the storage layer.

[bluesky.git] / bluesky / bluesky-private.h

diff --git a/bluesky/bluesky-private.h b/bluesky/bluesky-private.h
index dfcb7c5..1574a54 100644 (file)
--- a/bluesky/bluesky-private.h
+++ b/bluesky/bluesky-private.h
@@ -101,8 +101,8 @@ typedef enum {
 } BlueSkyAsyncStatus;
 
 struct BlueSkyNotifierList;
-typedef struct _BlueSkyStoreAsync BlueSkyStoreAsync;
-struct _BlueSkyStoreAsync {
+typedef struct BlueSkyStoreAsync BlueSkyStoreAsync;
+struct BlueSkyStoreAsync {
     BlueSkyStore *store;
 
     GMutex *lock;
@@ -116,6 +116,14 @@ struct _BlueSkyStoreAsync {
     gchar *key;                 /* Key to read/write */
     BlueSkyRCStr *data;         /* Data read/to write */
 
+    /* For range requests on reads: starting byte offset and length; len 0
+     * implies reading to the end of the object.  At completion, the backend
+     * should set range_done if a range read was made; if not set the entire
+     * object was read and the storage layer will select out just the
+     * appropriate bytes. */
+    size_t start, len;
+    gboolean range_done;
+
     int result;                 /* Result code; 0 for success. */
     struct BlueSkyNotifierList *notifiers;
     gint notifier_count;
@@ -256,7 +264,7 @@ struct cloudlog_header {
 #define CLOUDLOG_CLOUD      0x02
 #define CLOUDLOG_CACHE      0x04
 #define CLOUDLOG_UNCOMMITTED 0x10
-struct _BlueSkyCloudLog {
+struct BlueSkyCloudLog {
     gint refcount;
     GMutex *lock;
     GCond *cond;
@@ -300,7 +308,7 @@ struct _BlueSkyCloudLog {
 };
 
 /* Serialize objects into a log segment to be written to the cloud. */
-struct _BlueSkyCloudLogState {
+struct BlueSkyCloudLogState {
     GString *data;
     BlueSkyCloudPointer location;
     GList *inode_list;
@@ -335,7 +343,7 @@ void bluesky_cloudlog_flush(BlueSkyFS *fs);
 uint32_t crc32c(uint32_t crc, const char *buf, unsigned int length);
 uint32_t crc32c_finalize(uint32_t crc);
 
-struct _BlueSkyLog {
+struct BlueSkyLog {
     BlueSkyFS *fs;
     char *log_directory;
     GAsyncQueue *queue;
@@ -362,7 +370,7 @@ struct _BlueSkyLog {
 /* An object for tracking log files which are stored locally--either the
  * journal for filesystem consistency or log segments which have been fetched
  * back from cloud storage. */
-struct _BlueSkyCacheFile {
+struct BlueSkyCacheFile {
     GMutex *lock;
     GCond *cond;
     gint refcount;