Changeset 2bdd297562b53dbee111cfefd2101bb9eb99d036

Timestamp:

06/24/08 17:25:13 (5 years ago)

Author:

Theo Schlossnagle <jesus@omniti.com>

git-committer:

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

git-parent:

[42acb3f97cfb6da615fe7d1186a1e052eeec72fd]

git-author:

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

Message:

fixes #35

Files:

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

src/noit_jlog_listener.c

@@ -14 +14 @@
-#include <unistd.h>
-#include <sys/ioctl.h>
+#define MAX_ROWS_AT_ONCE 1000
+#define DEFAULT_SECONDS_BETWEEN_BATCHES 5
-
-void
@@ -89 +91 @@
-  while(1) {
-    jlog_id client_chkpt;
+    int sleeptime = DEFAULT_SECONDS_BETWEEN_BATCHES;
-    jlog_get_checkpoint(jcl->jlog, ac->remote_cn, &jcl->chkpt);
-    jcl->count = jlog_ctx_read_interval(jcl->jlog, &jcl->start, &jcl->finish);
+    if(jcl->count > MAX_ROWS_AT_ONCE) {
+      /* Artificially set down the range to make the batches a bit easier
+       * to handle on the stratcond/postgres end.
+       * However, we must have more data, so drop the sleeptime to 0
+       */
+      jcl->count = MAX_ROWS_AT_ONCE;
+      jcl->finish.marker = jcl->start.marker + jcl->count;
+      sleeptime = 0;
+    }
-    if(jcl->count > 0) {
-      if(noit_jlog_push(e, jcl)) {
@@ -119 +131 @@
-      jlog_ctx_read_checkpoint(jcl->jlog, &jcl->chkpt);
-    }
-sleep(5
+if(sleeptime) sleep(sleeptime
-  }
-

src/stratcon_datastore.c

@@ -162 +162 @@
-                  raddr, sizeof(raddr));
-        break;
+      default:
+        noitL(noit_error, "remote address of family %d\n", r->sa_family);
-    }
-