[zeromq-dev] Problem using inproc - What am I doing wrong?

[Michel Pelletier]

Are you running both programs from the same directory?  Your socket
path is relative, in which case they either need to be run from the
same location or provided an absolute ('ipc:///tmp/test') path.

-Michel

On Fri, Aug 24, 2012 at 2:54 PM, Iggy Philly <iggy.philly at hotmail.com> wrote:
> I'm trying a simple example using inproc but I'm obviously doing something
> wrong. My publisher socket sends a message out and the subscriber is polling
> but never sees anything. I'm sure it's something silly. Here's my code:
>
> #include <zmq.h>
> #include <iostream>
> #include <memory.h>
> #include <assert.h>
> using namespace std;
> static void* startTestThread(void* context)
> {
>   void* socket = zmq_socket(context, ZMQ_SUB);
>  assert(socket);
>  int ret = zmq_connect(socket, "inproc://test");
>  assert(ret == 0);
>  zmq_pollitem_t pollItem;
>  pollItem.socket = socket;
>  pollItem.events = 0;
>  pollItem.fd = 0;
>  pollItem.revents = ZMQ_POLLIN;
>  while (1)
>  {
>   cout << "polling..." << endl;
>   zmq_poll(&pollItem, 1, 1000);
>   if (pollItem.revents & ZMQ_POLLIN)
>   {
>    zmq_msg_t message;
>    zmq_msg_init(&message);
>    zmq_recvmsg(pollItem.socket, &message, ZMQ_DONTWAIT);
>    std::string* s = new std::string((char*)zmq_msg_data(&message),
> zmq_msg_size(&message));
>    zmq_msg_close(&message);
>    cout << "s = '" << s << "'" << endl;
>   }
>  }
> }
>
> int main()
> {
>  void* context = zmq_init(1);
>  void* socket = zmq_socket(context, ZMQ_PUB);
>  zmq_bind(socket, "inproc://test");
>  cout << "STARTING THREAD" << endl;
>  pthread_t testThread;
>  pthread_create(&testThread, NULL, startTestThread, context);
>  sleep(5);
>  cout << "Sending message...";
>  string s = "test";
>  zmq_msg_t msg;
>  zmq_msg_init_size(&msg, s.length());
>  memcpy(zmq_msg_data(&msg), s.c_str(), s.length());
>  zmq_sendmsg(socket, &msg, ZMQ_DONTWAIT);
>  zmq_msg_close(&msg);
>  cout << "done" << endl;
>  while (true);
> }
>
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>