generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-04 07:27:26 +01:00
Code Issues Projects Releases Wiki Activity

throughput tests use P2P sockets consistently

Browse Source
This commit is contained in:
Martin Sustrik 2009-09-10 15:20:54 +02:00
parent 95944551be
commit 93e70ee583
5 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
perf/cpp/remote_thr.cpp
View File

@ -36,7 +36,7 @@ int main (int argc, char *argv [])
zmq::context_t ctx (1, 1);
zmq::socket_t s (ctx, ZMQ_REQ);
zmq::socket_t s (ctx, ZMQ_P2P);
s.connect (connect_to);
for (int i = 0; i != message_count; i++) {

2
perf/java/local_thr.java
View File

@ -35,7 +35,7 @@ class local_thr
org.zmq.Context ctx = new org.zmq.Context (1, 1);
org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.SUB);
org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.P2P);
s.bind (bindTo);
byte [] data = s.recv (0);

2
perf/java/remote_thr.java
View File

@ -36,7 +36,7 @@ class remote_thr
org.zmq.Context ctx = new org.zmq.Context (1, 1);
org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.PUB);
org.zmq.Socket s = new org.zmq.Socket (ctx, org.zmq.Socket.P2P);
s.connect (connectTo);
byte msg [] = new byte [messageSize];

2
perf/ruby/local_thr.rb
View File

@ -28,7 +28,7 @@ message_size = ARGV[1].to_i
message_count = ARGV[2].to_i
ctx = Context.new(1, 1)
s = Socket.new(ctx, SUB);
s = Socket.new(ctx, P2P);
s.bind(bind_to);
msg = s.recv(0)

2
perf/ruby/remote_thr.rb
View File

@ -28,7 +28,7 @@ message_size = ARGV[1].to_i
message_count = ARGV[2].to_i
ctx = Context.new(1, 1)
s = Socket.new(ctx, PUB);
s = Socket.new(ctx, P2P);
s.connect(connect_to);
msg = "#{'0'*message_size}"