{
g_mutex_lock(top_async->lock);
- g_print("Completed a subrequest for %s\n", async->key);
-
/* This might be the second request to finish; in that case we don't do
* anything. */
if (top_async->status == ASYNC_RUNNING) {
switch (async->op) {
case STORE_OP_GET:
- g_print("Received multirequest for %s\n", async->key);
async->status = ASYNC_RUNNING;
async->exec_time = bluesky_now_hires();
for (int i = 0; i < 2; i++) {
}
}
+static char *multistore_lookup_last(gpointer store, const char *prefix)
+{
+ BlueSkyStore *base = (BlueSkyStore *)store;
+ return bluesky_store_lookup_last(base, prefix);
+}
+
static void multistore_cleanup(gpointer store, BlueSkyStoreAsync *async)
{
}
.destroy = multistore_destroy,
.submit = multistore_submit,
.cleanup = multistore_cleanup,
+ .lookup_last = multistore_lookup_last,
};
void bluesky_store_init_multi(void)