Michael,
Or better yet, just send me the source code of the test and I'll run it on
our IB network.
Here you go! The first test is attached. It does zero-copy transfer. Run
it like this:
./local_lat tcp://192.168.0.111:5555 1000000 100
&
./remote_lat tcp://192.168.0.111:5555 1000000 100
Try it for 1, 2, 4, 8, ..., 256MB messages.
Adjust number of roundtrips in the test so that each test takes at least
some time (couple of seconds). For very large messages there's no point
in running for extended periods of time so decrease the roundtrip count
accordingly.
Copy version of the test will follow shorty.
Thanks!
Martin
/*
Copyright (c) 2007-2010 iMatix Corporation
This file is part of 0MQ.
0MQ is free software; you can redistribute it and/or modify it under
the terms of the Lesser GNU General Public License as published by
the Free Software Foundation; either version 3 of the License, or
(at your option) any later version.
0MQ is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
Lesser GNU General Public License for more details.
You should have received a copy of the Lesser GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include <zmq.hpp>
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <stddef.h>
int main (int argc, char *argv [])
{
if (argc != 4) {
printf ("usage: local_lat <bind-to> <message-size> "
"<roundtrip-count>\n");
return 1;
}
const char *bind_to = argv [1];
size_t message_size = (size_t) atoi (argv [2]);
int roundtrip_count = atoi (argv [3]);
zmq::context_t ctx (1, 1);
zmq::socket_t s (ctx, ZMQ_REP);
s.bind (bind_to);
for (int i = 0; i != roundtrip_count; i++) {
zmq::message_t msg;
s.recv (&msg);
assert (msg.size () == message_size);
s.send (msg);
}
zmq_sleep (1);
return 0;
}
/*
Copyright (c) 2007-2010 iMatix Corporation
This file is part of 0MQ.
0MQ is free software; you can redistribute it and/or modify it under
the terms of the Lesser GNU General Public License as published by
the Free Software Foundation; either version 3 of the License, or
(at your option) any later version.
0MQ is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
Lesser GNU General Public License for more details.
You should have received a copy of the Lesser GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include <zmq.hpp>
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <stddef.h>
#include <string.h>
int main (int argc, char *argv [])
{
if (argc != 4) {
printf ("usage: remote_lat <connect-to> <message-size> "
"<roundtrip-count>\n");
return 1;
}
const char *connect_to = argv [1];
size_t message_size = (size_t) atoi (argv [2]);
int roundtrip_count = atoi (argv [3]);
zmq::context_t ctx (1, 1);
zmq::socket_t s (ctx, ZMQ_REQ);
s.connect (connect_to);
void *buff = malloc (message_size);
assert (buff);
memset (buff, 0, message_size);
void *watch = zmq_stopwatch_start ();
for (int i = 0; i != roundtrip_count; i++) {
zmq::message_t msg1 (buff, message_size, NULL);
s.send (msg1);
zmq::message_t msg2;
s.recv (&msg2);
assert (msg2.size () == message_size);
}
unsigned long elapsed = zmq_stopwatch_stop (watch);
double latency = (double) elapsed / (roundtrip_count * 2);
printf ("message size: %d [B]\n", (int) message_size);
printf ("roundtrip count: %d\n", (int) roundtrip_count);
printf ("mean latency: %.3f [us]\n", (double) latency);
free (buff);
return 0;
}
_______________________________________________
zeromq-dev mailing list
[email protected]
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
