jzmq poller performance

[youest]

Hi,
I wrote this test case to check the performance:

package alfred.mdp;

import org.junit.Test;
import org.zeromq.ZMQ;

import java.util.UUID;

import static org.junit.Assert.assertTrue;

/**
 */
public class ZeroMQPerformanceTest {

    private static final int N_MESSAGES = 100000;
    private static final String ADDR = "inproc://reqrep";
    private static final int POLLER_TIMEOUT = 250;

    @Test
    public void performanceTestWithPoller() {
        ZMQ.Context context = ZMQ.context(1);

        ZMQ.Socket in = context.socket(ZMQ.XREQ);
        in.bind(ADDR);

        ZMQ.Socket out = context.socket(ZMQ.XREP);
        out.connect(ADDR);

        ZMQ.Poller poller = context.poller();
        poller.register(out, ZMQ.Poller.POLLIN);
        poller.register(in, ZMQ.Poller.POLLIN);

        for (int i = 0; i < N_MESSAGES; i++) {
            byte[] req = UUID.randomUUID().toString().getBytes();
            assertTrue(in.send(req, 0));
        }

        for (int i = 0; i < N_MESSAGES; i++) {
            if (poller.poll(POLLER_TIMEOUT) > 0 && poller.pollin(0)) {
                out.recv(0);//id
                byte[] reqTmp = out.recv(0);
            }
        }
        long start = System.currentTimeMillis();
        for (int i = 0; i < N_MESSAGES; i++) {
            byte[] req = UUID.randomUUID().toString().getBytes();
            assertTrue(in.send(req, 0));
        }
        System.out.println("performanceTestWithPoller send:" + (System.currentTimeMillis() - start));
        start = System.currentTimeMillis();
        for (int i = 0; i < N_MESSAGES; i++) {
            if (poller.poll(POLLER_TIMEOUT) > 0 && poller.pollin(0)) {
                out.recv(0);//id
                byte[] reqTmp = out.recv(0);
            }
        }
        System.out.println("performanceTestWithPoller receive:" + (System.currentTimeMillis() - start));
    }

    @Test
    public void performanceTest() {
        ZMQ.Context context = ZMQ.context(1);

        ZMQ.Socket in = context.socket(ZMQ.XREQ);
        in.bind(ADDR);

        ZMQ.Socket out = context.socket(ZMQ.XREP);
        out.connect(ADDR);

        for (int i = 0; i < N_MESSAGES; i++) {
            byte[] req = UUID.randomUUID().toString().getBytes();
            assertTrue(in.send(req, 0));
        }

        for (int i = 0; i < N_MESSAGES; i++) {
            out.recv(0);//id
            byte[] reqTmp = out.recv(0);
        }
        long start = System.currentTimeMillis();
        for (int i = 0; i < N_MESSAGES; i++) {
            byte[] req = UUID.randomUUID().toString().getBytes();
            assertTrue(in.send(req, 0));
        }
        System.out.println("performanceTest send:" + (System.currentTimeMillis() - start));
        start = System.currentTimeMillis();
        for (int i = 0; i < N_MESSAGES; i++) {
            out.recv(0);//id
            byte[] reqTmp = out.recv(0);
        }
        System.out.println("performanceTest receive:" + (System.currentTimeMillis() - start));
    }
}

my results are:
performanceTestWithPoller send:787
performanceTestWithPoller receive:1338
performanceTest send:784
performanceTest receive:78

so why are there these differences on receive elapsed time?
is possible it's twenty times slower?

thanks in adv. for help.

Giuseppe

[gonzus]

This seems to have no specific relation with jzmq, other than the language used to implement your tests. I would advise to post your question on the 0MQ mailing list.

[youest]

Ok thanks ;)