'flags' parameter added to zmq_init

12 files changed, 12 insertions, 12 deletions

diff --git a/perf/c/local_lat.c b/perf/c/local_lat.c
index 86d4721..2cbae13 100644
--- a/perf/c/local_lat.c
+++ b/perf/c/local_lat.c
@@ -42,7 +42,7 @@ int main (int argc, char *argv [])
     message_size = atoi (argv [2]);
     roundtrip_count = atoi (argv [3]);
 
-    ctx = zmq_init (1, 1);
+    ctx = zmq_init (1, 1, 0);
     assert (ctx);
 
     s = zmq_socket (ctx, ZMQ_REP);
diff --git a/perf/c/local_thr.c b/perf/c/local_thr.c
index 9b94330..f9ab720 100644
--- a/perf/c/local_thr.c
+++ b/perf/c/local_thr.c
@@ -45,7 +45,7 @@ int main (int argc, char *argv [])
     message_size = atoi (argv [2]);
     message_count = atoi (argv [3]);
 
-    ctx = zmq_init (1, 1);
+    ctx = zmq_init (1, 1, 0);
     assert (ctx);
 
     s = zmq_socket (ctx, ZMQ_SUB);
diff --git a/perf/c/remote_lat.c b/perf/c/remote_lat.c
index 15dfc46..52aa071 100644
--- a/perf/c/remote_lat.c
+++ b/perf/c/remote_lat.c
@@ -46,7 +46,7 @@ int main (int argc, char *argv [])
     message_size = atoi (argv [2]);
     roundtrip_count = atoi (argv [3]);
 
-    ctx = zmq_init (1, 1);
+    ctx = zmq_init (1, 1, 0);
     assert (ctx);
 
     s = zmq_socket (ctx, ZMQ_REQ);
diff --git a/perf/c/remote_thr.c b/perf/c/remote_thr.c
index 8814e0f..fb685cd 100644
--- a/perf/c/remote_thr.c
+++ b/perf/c/remote_thr.c
@@ -42,7 +42,7 @@ int main (int argc, char *argv [])
     message_size = atoi (argv [2]);
     message_count = atoi (argv [3]);
 
-    ctx = zmq_init (1, 1);
+    ctx = zmq_init (1, 1, 0);
     assert (ctx);
 
     s = zmq_socket (ctx, ZMQ_PUB);
diff --git a/perf/java/local_lat.java b/perf/java/local_lat.java
index e7583cc..873f636 100644
--- a/perf/java/local_lat.java
+++ b/perf/java/local_lat.java
@@ -33,7 +33,7 @@ class local_lat
          int messageSize = Integer.parseInt (args [1]);
          int roundtripCount = Integer.parseInt (args [2]);
 
-         org.zmq.Context ctx = new org.zmq.Context (1, 1);
+         org.zmq.Context ctx = new org.zmq.Context (1, 1, 0);
 
          org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.REP);
          s.bind (bindTo);
diff --git a/perf/java/local_thr.java b/perf/java/local_thr.java
index 450aed5..2881a08 100644
--- a/perf/java/local_thr.java
+++ b/perf/java/local_thr.java
@@ -33,7 +33,7 @@ class local_thr
         long messageSize = Integer.parseInt (args [1]);
         long messageCount = Integer.parseInt (args [2]);
 
-        org.zmq.Context ctx = new org.zmq.Context (1, 1);
+        org.zmq.Context ctx = new org.zmq.Context (1, 1, 0);
 
         org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.SUB);
 
diff --git a/perf/java/remote_lat.java b/perf/java/remote_lat.java
index 28b2f76..905b82c 100644
--- a/perf/java/remote_lat.java
+++ b/perf/java/remote_lat.java
@@ -33,7 +33,7 @@ class remote_lat
          int messageSize = Integer.parseInt (args [1]);
          int roundtripCount = Integer.parseInt (args [2]);
 
-         org.zmq.Context ctx = new org.zmq.Context (1, 1);
+         org.zmq.Context ctx = new org.zmq.Context (1, 1, 0);
 
          org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.REQ);
          s.connect (connectTo);
diff --git a/perf/java/remote_thr.java b/perf/java/remote_thr.java
index 9182a8f..f696fc3 100644
--- a/perf/java/remote_thr.java
+++ b/perf/java/remote_thr.java
@@ -34,7 +34,7 @@ class remote_thr
         int messageSize = Integer.parseInt (args [1]);
         int messageCount = Integer.parseInt (args [2]);
 
-        org.zmq.Context ctx = new org.zmq.Context (1, 1);
+        org.zmq.Context ctx = new org.zmq.Context (1, 1, 0);
 
         org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.PUB);
 
diff --git a/perf/ruby/local_lat.rb b/perf/ruby/local_lat.rb
index b71af80..8806ccb 100644
--- a/perf/ruby/local_lat.rb
+++ b/perf/ruby/local_lat.rb
@@ -27,7 +27,7 @@ bind_to = ARGV[0]
 message_size = ARGV[1].to_i
 roundtrip_count = ARGV[2].to_i
 			
-ctx = Context.new(1, 1)
+ctx = Context.new(1, 1, 0)
 s = Socket.new(ctx, REP);
 s.bind(bind_to);
 
diff --git a/perf/ruby/local_thr.rb b/perf/ruby/local_thr.rb
index b916f2d..6d9d13f 100644
--- a/perf/ruby/local_thr.rb
+++ b/perf/ruby/local_thr.rb
@@ -27,7 +27,7 @@ bind_to = ARGV[0]
 message_size = ARGV[1].to_i
 message_count = ARGV[2].to_i
 					
-ctx = Context.new(1, 1)
+ctx = Context.new(1, 1, 0)
 s = Socket.new(ctx, SUB);
 s.setsockopt(SUBSCRIBE, "*");
 
diff --git a/perf/ruby/remote_lat.rb b/perf/ruby/remote_lat.rb
index 9387fe1..f5b438d 100644
--- a/perf/ruby/remote_lat.rb
+++ b/perf/ruby/remote_lat.rb
@@ -27,7 +27,7 @@ connect_to = ARGV[0]
 message_size = ARGV[1].to_i
 roundtrip_count = ARGV[2].to_i
 					
-ctx = Context.new(1, 1)
+ctx = Context.new(1, 1, 0)
 s = Socket.new(ctx, REQ);
 s.connect(connect_to);
 
diff --git a/perf/ruby/remote_thr.rb b/perf/ruby/remote_thr.rb
index ef93961..760ff88 100644
--- a/perf/ruby/remote_thr.rb
+++ b/perf/ruby/remote_thr.rb
@@ -27,7 +27,7 @@ connect_to = ARGV[0]
 message_size = ARGV[1].to_i
 message_count = ARGV[2].to_i
 			
-ctx = Context.new(1, 1)
+ctx = Context.new(1, 1, 0)
 s = Socket.new(ctx, PUB);
 
 #  Add your socket options here.