generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-10-20 05:49:07 +02:00
Code Issues Projects Releases Wiki Activity

win port for c and cpp perf tests

Browse Source
This commit is contained in:
unknown
2009-09-08 11:30:49 +02:00
parent b71c3005e6
commit ec6822a477
25 changed files with 1702 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
perf/cpp/local_thr.cpp
View File

@@ -22,8 +22,6 @@
#include <stdlib.h>
#include <assert.h>
#include <stddef.h>
#include <stdint.h>
#include <sys/time.h>
int main (int argc, char *argv [])
{
@@ -45,27 +43,17 @@ int main (int argc, char *argv [])
s.recv (&msg);
assert (msg.size () == message_size);
timeval start;
int rc = gettimeofday (&start, NULL);
assert (rc == 0);
void *watch = zmq_stopwatch_start ();
for (int i = 1; i != message_count; i++) {
s.recv (&msg);
assert (msg.size () == message_size);
}
timeval end;
rc = gettimeofday (&end, NULL);
assert (rc == 0);
unsigned long elapsed = zmq_stopwatch_stop (watch);
end.tv_sec -= start.tv_sec;
start.tv_sec = 0;
uint64_t elapsed = ((uint64_t) end.tv_sec * 1000000 + end.tv_usec) -
((uint64_t) start.tv_sec * 1000000 + start.tv_usec);
if (elapsed == 0)
elapsed = 1;
uint64_t throughput = (uint64_t) message_count * 1000000 / elapsed;
unsigned long throughput = (unsigned long)
((double) message_count / (double) elapsed * 1000000);
double megabits = (double) (throughput * message_size * 8) / 1000000;
printf ("message size: %d [B]\n", (int) message_size);