Changeset 1431d991f15fe5e02906e85dc4721a1a99f2eeb1

Timestamp:

06/04/08 21:51:48 (5 years ago)

Author:

Theo Schlossnagle <jesus@omniti.com>

git-committer:

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

git-parent:

[db9f2be897dce90ece1f1f845c102c811a287b74]

git-author:

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

Message:

fix pipelining, refs #28

Files:

• src/modules/lua_noit.c (modified) (1 diff)

src/modules/lua_noit.c

@@ -215 +215 @@
-  cl->read_goal = 0;
-  cl->read_terminator = NULL;
-
-
+
+
+
-    cl->read_goal = lua_tointeger(L, 1);
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    cl->read_terminator = lua_tostring(L, 1);
+    fprintf(stderr, " read wants up to [%s]\n", cl->read_terminator);
+    if(cl->read_sofar) {
+      const char *cp;
+      /* Ugh... inernalism */
+      cp = strnstr(cl->inbuff.buffer, cl->read_terminator, cl->read_sofar);
+      if(cp) {
+        /* Here we matched... and we _know_ that someone actually wants:
+         * strlen(cl->read_terminator) + cp - cl->inbuff.buffer bytes...
+         * give it to them.
+         */
+        cl->read_goal = strlen(cl->read_terminator) + cp - cl->inbuff.buffer;
+        cl->read_terminator = NULL;
+        assert(cl->read_goal <= cl->read_sofar);
+        goto i_know_better;
+      }
+    }
+  }
-
-  e->callback = noit_lua_socket_read_complete;