X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=bluesky%2Fstore-kv.cc;h=de16832d50d30718f1b72b967728144419dca6c1;hb=8a2da0db5d5f4f599486876396883f6207ebec6a;hp=c1b052483a1b27a032d39ec53dd21c4e1a3d9380;hpb=bb92882c6f3b517f8a30c268792642870ac896d2;p=bluesky.git diff --git a/bluesky/store-kv.cc b/bluesky/store-kv.cc index c1b0524..de16832 100644 --- a/bluesky/store-kv.cc +++ b/bluesky/store-kv.cc @@ -58,15 +58,29 @@ static void kvstore_task(gpointer a, gpointer b) bluesky_store_async_unref(async); } -static gpointer kvstore_new() +static gpointer kvstore_new(const gchar *path) { + /* TODO: Right now we leak this memory. We should probably clean up in + * kvstore_destroy, but it's not a big deal. */ + const gchar *host = "127.0.0.1", *port = "9090"; + if (path != NULL) { + gchar **target = g_strsplit(path, ":", 0); + if (target[0] != NULL) { + host = target[0]; + if (target[1] != NULL) { + port = target[1]; + } + } + } + static volatile gsize once = 0; if (g_once_init_enter(&once)) { thread_pool = g_thread_pool_new(kvstore_task, NULL, -1, FALSE, NULL); g_once_init_leave(&once, 1); } - KeyValueClient *client = new KeyValueClient("127.0.0.1", "9090"); + g_print("kvstore: %s port %s\n", host, port); + KeyValueClient *client = new KeyValueClient(host, port); return client; }