Changeset a7ed2df4af73c424e86f7d049a4b2e76a629b2f2

Timestamp:

05/04/09 04:18:14 (4 years ago)

Author:

Theo Schlossnagle <jesus@omniti.com>

git-committer:

Theo Schlossnagle <jesus@omniti.com> 1241410694 +0000

git-parent:

[85630250d38266fa902fea78b996af7521d31ebc]

git-author:

Theo Schlossnagle <jesus@omniti.com> 1241410694 +0000

Message:

closes #117, this hooks the ops

Files:

• src/stratcon_datastore.c (modified) (3 diffs)
• src/stratcon_datastore.h (modified) (1 diff)

src/stratcon_datastore.c

@@ -31 +31 @@
-static char *config_insert = NULL;
-static const char *config_insert_conf = "/stratcon/database/statements/config";
+
+static struct datastore_onlooker_list {
+  void (*dispatch)(stratcon_datastore_op_t, struct sockaddr *, void *);
+  struct datastore_onlooker_list *next;
+} *onlookers = NULL;
-
-#define GET_QUERY(a) do { \
@@ -577 +582 @@
-  eventer_t e;
-  ds_job_detail *dsjd;
+  struct datastore_onlooker_list *nnode;
+
+  for(nnode = onlookers; nnode; nnode = nnode->next)
+    nnode->dispatch(op,remote,operand);
-
-  cq = __get_conn_q_for_remote(remote);
@@ -636 +645 @@
-  return rv;
-}
+
+void
+stratcon_datastore_register_onlooker(void (*f)(stratcon_datastore_op_t,
+                                               struct sockaddr *, void *)) {
+  struct datastore_onlooker_list *nnode;
+  nnode = calloc(1, sizeof(*nnode));
+  nnode->dispatch = f;
+  nnode->next = onlookers;
+  while(noit_atomic_casptr((void **)&onlookers, nnode, nnode->next) != nnode->next)
+    nnode->next = onlookers;
+}

src/stratcon_datastore.h

@@ -25 +25 @@
-                          struct sockaddr *, void *);
-
+API_EXPORT(void)
+  stratcon_datastore_register_onlooker(void (*f)(stratcon_datastore_op_t,
+                                                 struct sockaddr *, void *));
+
-API_EXPORT(int)
-  stratcon_datastore_saveconfig(void *unused);