BlueSkyCryptKeys *keys);
void bluesky_cloudlog_encrypt(GString *segment, BlueSkyCryptKeys *keys);
void bluesky_cloudlog_decrypt(char *segment, size_t len,
- BlueSkyCryptKeys *keys);
+ BlueSkyCryptKeys *keys,
+ BlueSkyRangeset *items);
/* Storage layer. Requests can be performed asynchronously, so these objects
* help keep track of operations in progress. */
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;
BlueSkyLog *log;
gboolean fetching, ready; // Cloud data: downloading or ready for use
int64_t atime; // Access time, for cache management
+ BlueSkyRangeset *items; // Locations of valid items
};
BlueSkyLog *bluesky_log_new(const char *log_directory);
BlueSkyCloudLog *bluesky_log_get_commit_point(BlueSkyFS *fs);
void bluesky_log_write_commit_point(BlueSkyFS *fs, BlueSkyCloudLog *marker);
-BlueSkyRCStr *bluesky_log_map_object(BlueSkyFS *fs, int log_dir, int log_seq,
- int log_offset, int log_size);
+BlueSkyRCStr *bluesky_log_map_object(BlueSkyFS *fs, int log_dir,
+ int log_seq, int log_offset, int log_size,
+ gboolean map_data);
void bluesky_mmap_unref(BlueSkyCacheFile *mmap);
void bluesky_cachefile_unref(BlueSkyCacheFile *cachefile);