I'm not sure but skimming your code you are mixing czmq sockets and zmq
poll method. If you want to use the zmp_poll method you can use
zsock_resolve on the czmq sockets
// Probe the supplied reference. If it looks like a zsock_t instance,
return
// the underlying libzmq socket handle; else if it looks like a file
// descriptor, return NULL; else if it looks like a libzmq socket handle,
// return the supplied value. Takes a polymorphic socket reference.
CZMQ_EXPORT void *
zsock_resolve (void *self);
Otherwise use the zpoller czmq class instead of zmq_poll
Rg,
Arnaud
On 04-07-2023 11:26, Chandrasekhar Nunna wrote:
hi all,
i am using zactor and in the call back i receive a pipe socket.
i create a router socket and polling this sockets for messages.
it is not working and giving -1 result as return value of zmq_poll;
what could be the problem?
void
echo_actor (zsock_t *pipe, void *args)
{
// need to implement...?
printf("thread id : %lu", GetCurrentThreadId());
server_t* self = server_new(pipe);
zmq_pollitem_t items[] =
{
{ self->pipe, 0, ZMQ_POLLIN, 0 },
{ self->router, 0, ZMQ_POLLIN, 0 }
};
self->monitor_at = zclock_time() + self->monitor;
while (!self->stopped && !zctx_interrupted)
{
// Calculate tickless timer, up to interval seconds
uint64_t tickless = zclock_time() + self->monitor;
uint64_t diff = (tickless - zclock_time()) * ZMQ_POLL_MSEC;
// Poll until at most next timer event
int rc = zmq_poll(items, 2, diff );
if (rc == -1)
{
break; // Context has been shut down
}
// Process incoming message from either socket
if (items[0].revents & ZMQ_POLLIN)
server_control_message(self);
if (items[1].revents & ZMQ_POLLIN)
server_client_message(self);
// If clock went past timeout, then monitor server
if (zclock_time() >= self->monitor_at)
{
printf("clock went past timeout, need to monitor the server");
}
}
server_destroy(&self);
}
int main()
{
zactor_t *actor = zactor_new (echo_actor, "Hello, World");
assert (actor);
zstr_sendx (actor, "ECHO", "This is a string", NULL);
char *string = zstr_recv (actor);
fprintf(stdout,"%s\n",string);
assert (streq (string, "This is a string"));
free (string);
zactor_destroy (&actor);
}
_______________________________________________
zeromq-dev mailing list
[email protected]
https://lists.zeromq.org/mailman/listinfo/zeromq-dev
_______________________________________________
zeromq-dev mailing list
[email protected]
https://lists.zeromq.org/mailman/listinfo/zeromq-dev
