support growing the socket data buffer, and enable working bigdata socket test

4 files changed, 7 insertions, 7 deletions

diff --git a/tests/runner.py b/tests/runner.py
index e88388e7..a24f2d91 100755
--- a/tests/runner.py
+++ b/tests/runner.py
@@ -9307,7 +9307,7 @@ elif 'browser' in str(sys.argv):
       finally:
         self.clean_pids()
 
-    def zzztest_zz_websockets_bi_bigdata(self):
+    def test_zz_websockets_bi_bigdata(self):
       try:
         with self.WebsockHarness(3992, self.make_relay_server(3992, 3994)):
           with self.WebsockHarness(3994, no_server=True):
diff --git a/tests/socket_relay.py b/tests/socket_relay.py
index c7adcbfe..5b6403f9 100644
--- a/tests/socket_relay.py
+++ b/tests/socket_relay.py
@@ -29,15 +29,15 @@ class Listener(threading.Thread):
     conn, addr = s.accept()
     self.conn = conn
     while 1:
-      time.sleep(1)
+      time.sleep(0.5)
       print 'listener', port, 'waiting for data'
-      data = conn.recv(1024)
+      data = conn.recv(20*1024)
       if not data:
         continue
       while not self.other.conn:
         print 'listener', port, 'waiting for other connection in order to send data'
         time.sleep(1)
-      print 'listener', port, 'sending data', data
+      print 'listener', port, 'sending data', len(data)
       self.other.conn.send(data)
 
 in_listener = Listener()
diff --git a/tests/websockets_bi_bigdata.c b/tests/websockets_bi_bigdata.c
index 9e8635e3..5db2c951 100644
--- a/tests/websockets_bi_bigdata.c
+++ b/tests/websockets_bi_bigdata.c
@@ -127,7 +127,7 @@ int main(void)
                         "iframe.width = '40%';"
                         "document.body.appendChild(iframe);"
                         "console.log('added.');");
-  emscripten_set_main_loop(iter, 1, 0);
+  emscripten_set_main_loop(iter, 3, 0);
 #else
   while (!done) iter(NULL);
 #endif
diff --git a/tests/websockets_bigdata.h b/tests/websockets_bigdata.h
index fa1a6b17..17149ad6 100644
--- a/tests/websockets_bigdata.h
+++ b/tests/websockets_bigdata.h
@@ -1,11 +1,11 @@
 
 #include <stdlib.h>
 
-#define DATA_SIZE 1250
+#define DATA_SIZE (256*256*2)
 // 1500 fails
 
 char *generateData() {
-  char *ret = malloc(65536*2);
+  char *ret = malloc(256*256*2);
   char *curr = ret;
   for (int i = 0; i < 256; i++) {
     for (int j = 0; j < 256; j++) {