0c5db98b5f094dbaf0e8cdc9f40167ff0ef0d729
[bluesky.git] / bluesky / cloudlog.c
1 /* Blue Sky: File Systems in the Cloud
2  *
3  * Copyright (C) 2009  The Regents of the University of California
4  * Written by Michael Vrable <mvrable@cs.ucsd.edu>
5  *
6  * TODO: Licensing
7  */
8
9 #include <stdint.h>
10 #include <glib.h>
11 #include <string.h>
12
13 #include "bluesky-private.h"
14
15 /* The locations hash table in the file system is used to map objects to their locations.  Objects are named using 128- */
16
17 typedef struct {
18     BlueSkyCloudID id;
19
20     BlueSkyCloudPointer *cloud_loc;
21 } BlueSkyLocationEntry;
22
23 BlueSkyCloudID bluesky_cloudlog_new_id()
24 {
25     BlueSkyCloudID id;
26     bluesky_crypt_random_bytes((uint8_t *)&id.bytes, sizeof(id));
27     return id;
28 }
29
30 gboolean bluesky_cloudlog_equal(gconstpointer a, gconstpointer b)
31 {
32     BlueSkyCloudID *id1 = (BlueSkyCloudID *)a, *id2 = (BlueSkyCloudID *)b;
33
34     return memcmp(id1, id2, sizeof(BlueSkyCloudID)) == 0;
35 }
36
37 guint bluesky_cloudlog_hash(gconstpointer a)
38 {
39     BlueSkyCloudID *id = (BlueSkyCloudID *)a;
40
41     // Assume that bits in the ID are randomly chosen so that any subset of the
42     // bits can be used as a hash key.
43     return *(guint *)(&id->bytes);
44 }
45
46 /* Formatting of cloud log segments.  This handles grouping items together
47  * before writing a batch to the cloud, handling indirection through items like
48  * the inode map, etc. */
49
50 BlueSkyCloudLog *bluesky_cloudlog_new(BlueSkyFS *fs)
51 {
52     BlueSkyCloudLog *log = g_new0(BlueSkyCloudLog, 1);
53
54     log->fs = fs;
55     log->type = LOGTYPE_UNKNOWN;
56     log->id = bluesky_cloudlog_new_id();
57     g_atomic_int_set(&log->refcount, 1);
58
59     return log;
60 }
61
62 void bluesky_cloudlog_ref(BlueSkyCloudLog *log)
63 {
64     g_atomic_int_inc(&log->refcount);
65 }
66
67 void bluesky_cloudlog_unref(BlueSkyCloudLog *log)
68 {
69     if (g_atomic_int_dec_and_test(&log->refcount)) {
70         g_print("Cloud log refcount dropped to zero.\n");
71     }
72 }
73
74 /* Start a write of the object to the local log. */
75 BlueSkyLogItem *bluesky_cloudlog_sync(BlueSkyCloudLog *log)
76 {
77     BlueSkyLogItem *log_item = bluesky_log_item_new();
78     log_item->key = g_strdup("cloudlog");
79     log_item->data = log->data;
80     bluesky_string_ref(log->data);
81     bluesky_log_item_submit(log_item, log->fs->log);
82     return log_item;
83 }
84
85 /* Add the given entry to the global hash table containing cloud log entries.
86  * Takes ownership of the caller's reference. */
87 void bluesky_cloudlog_insert(BlueSkyCloudLog *log)
88 {
89     g_mutex_lock(log->fs->lock);
90     g_hash_table_insert(log->fs->locations, &log->id, log);
91     g_mutex_unlock(log->fs->lock);
92 }