zmq:init(io_threads)

API.md

@@ -14,8 +14,7 @@ zmq.version()
 Initialises ØMQ context.
 See [zmq_init(3)](http://api.zeromq.org/zmq_init.html).
 
-zmq.init(app_threads, io_threads)  
-zmq.init(app_threads, io_threads, flags)
+zmq.init(io_threads)  
 
 ## term
 

examples/client.lua

@@ -20,7 +20,7 @@
 
 require("zmq")
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.REQ)
 
 s:connect("tcp://localhost:5555")

examples/client_multipart.lua

@@ -20,7 +20,7 @@
 
 require("zmq")
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.REQ)
 
 s:connect("tcp://localhost:5555")

examples/publiser.lua

@@ -20,7 +20,7 @@
 
 require("zmq")
 
-local ctx = zmq.init(1, 1, 0)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.PUB)
 
 s:bind("tcp://lo:5555")

examples/server.lua

@@ -20,7 +20,7 @@
 
 require("zmq")
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.REP)
 
 s:bind("tcp://lo:5555")

examples/server_multipart.lua

@@ -20,7 +20,7 @@
 
 require("zmq")
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.REP)
 
 s:bind("tcp://lo:5555")

examples/subscriber.lua

@@ -20,7 +20,7 @@
 
 require("zmq")
 
-local ctx = zmq.init(1, 1, 0)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.SUB)
 s:setopt(zmq.SUBSCRIBE, "")
 s:connect("tcp://localhost:5555")

perf/local_lat.lua

@@ -29,7 +29,7 @@ local bind_to = arg[1]
 local message_size = tonumber(arg[2])
 local roundtrip_count = tonumber(arg[3])
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.REP)
 s:bind(bind_to)
 

perf/local_thr.lua

@@ -29,7 +29,7 @@ local bind_to = arg[1]
 local message_size = tonumber(arg[2])
 local message_count = tonumber(arg[3])
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.SUB)
 s:setopt(zmq.SUBSCRIBE, "");
 s:bind(bind_to)

perf/remote_lat.lua

@@ -29,7 +29,7 @@ local connect_to = arg[1]
 local message_size = tonumber(arg[2])
 local roundtrip_count = tonumber(arg[3])
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.REQ)
 s:connect(connect_to)
 

perf/remote_thr.lua

@@ -29,7 +29,7 @@ local connect_to = arg[1]
 local message_size = tonumber(arg[2])
 local message_count = tonumber(arg[3])
 
-local ctx = zmq.init(1, 1)
+local ctx = zmq.init(1)
 local s = ctx:socket(zmq.PUB)
 s:connect(connect_to)
 

zmq.c

@@ -60,13 +60,9 @@ static int Lzmq_version(lua_State *L)
 
 static int Lzmq_init(lua_State *L)
 {
-    int app_threads = luaL_checkint(L, 1);
-    int io_threads = luaL_checkint(L, 2);
-    int flags = luaL_optint(L, 3, 0);
-
+    int io_threads = luaL_checkint(L, 1);
     zmq_ptr *ctx = lua_newuserdata(L, sizeof(zmq_ptr));
-
-    ctx->ptr = zmq_init(app_threads, io_threads, flags);
+    ctx->ptr = zmq_init(io_threads);
 
     if (!ctx->ptr) {
         return luaL_error(L, zmq_strerror(zmq_errno()));