Gonzalo,

> If Prog1 starts before Prog2, the messages are sent from Prog1 but nothing
> is received in Prog2.
>
> Is this expected? I want to have a sanity check before I start digging into
> it. Thanks.

That's not expected.  I'd suggest retesting with maint.  I've just
made a test case that works as expected.  It's attached.

-
Pieter Hintjens
iMatix - www.imatix.com

---


//
//
#include "zhelpers.h"

static void *
pub_thread (void *context) {
    void *pub = zmq_socket (context, ZMQ_PUB);
    zmq_connect (pub, "ipc://testcase.ipc");

    s_send (pub, "Test message 001");
    sleep (1);
    s_send (pub, "Test message 002");
    sleep (1);
    s_send (pub, "Test message 003");
    sleep (1);
    s_send (pub, "Test message 004");
    sleep (1);
    s_send (pub, "Test message 005");
    sleep (1);
    s_send (pub, "Test message 006");
    sleep (1);
    s_send (pub, "Test message 007");
    sleep (1);
    s_send (pub, "Test message 008");
    sleep (1);
    s_send (pub, "Test message 009");
    sleep (1);
    s_send (pub, "Test message 010");
    sleep (1);

    return (NULL);
}

static void *
sub_thread (void *context) {
    void *sub = zmq_socket (context, ZMQ_SUB);
    zmq_bind (sub, "ipc://testcase.ipc");
    zmq_setsockopt (sub, ZMQ_SUBSCRIBE, "", 0);

    while (1) {
        char *message = s_recv (sub);
        puts (message);
        free (message);
    }
    return (NULL);
}

int main (int argc, char *argv[])
{
    void *context = zmq_init (1);
    s_version ();

    pthread_t pub;
    pthread_create (&pub, NULL, pub_thread, context);

    sleep (1);

    pthread_t sub;
    pthread_create (&sub, NULL, sub_thread, context);

    sleep (10);
    return 0;
}
_______________________________________________
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Reply via email to