<div dir="ltr">The recently landed pull request #<a href="https://github.com/zeromq/libzmq/pull/1161">1161</a> would now seem to preclude forwarding on metadata to a PAIR socket.</div><div class="gmail_extra"><br><br><div class="gmail_quote">
On Mon, Aug 11, 2014 at 11:23 AM, Thomas Rodgers <span dir="ltr"><<a href="mailto:rodgert@twrodgers.com" target="_blank">rodgert@twrodgers.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
<div dir="ltr"><div class=""><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-color:rgb(204,204,204);border-left-style:solid;padding-left:1ex"><span style="font-family:arial,sans-serif;font-size:12.800000190734863px">1) I want to use CURVE and zmq_msg_gets()</span><br style="font-family:arial,sans-serif;font-size:12.800000190734863px">

<br style="font-family:arial,sans-serif;font-size:12.800000190734863px"><span style="font-family:arial,sans-serif;font-size:12.800000190734863px">When I recv() a message on the ROUTER socket it has metadata attached</span><br style="font-family:arial,sans-serif;font-size:12.800000190734863px">

<span style="font-family:arial,sans-serif;font-size:12.800000190734863px">to it. Can I (and how) forward this message across the PAIR socket savely</span><br style="font-family:arial,sans-serif;font-size:12.800000190734863px">

<span style="font-family:arial,sans-serif;font-size:12.800000190734863px">keeping the metadata pointer intact so the app can still call</span><br style="font-family:arial,sans-serif;font-size:12.800000190734863px"><span style="font-family:arial,sans-serif;font-size:12.800000190734863px">zmq_msg_gets() on it?</span></blockquote>

<div><br></div></div><div>caveat; I haven't tried it, but I did not see anything obvious in the implementation that would preclude metadata attached to a message from being forwarded over a PAIR socket by simply sending the received message.  The underlying pipe just copies the msg struct by-value to a queue then calls init(), resetting the supplied message to an empty state, without messing with the refcount on the attached metadata.  The receiving side will take ownership of the associated metadata reference when it dequeues the message.</div>

<div><br></div></div><div class="HOEnZb"><div class="h5"><div class="gmail_extra"><br><br><div class="gmail_quote">On Mon, Aug 11, 2014 at 10:14 AM, Goswin von Brederlow <span dir="ltr"><<a href="mailto:goswin-v-b@web.de" target="_blank">goswin-v-b@web.de</a>></span> wrote:<br>

<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Hi,<br>
<br>
I hope you don't mind but I want to brainstorm a bit.<br>
<br>
I want a generic solution to handle heartbeats that I can reuse in<br>
different applications. The most transparent way for this seems to be<br>
to create a seperate thread for it. So the design looks something like<br>
this:<br>
<br>
[client] PAIR <--inproc--> [heartbeat thread] PAIR-DEALER <--tcp--><br>
<br>
and<br>
<br>
<--tcp--> ROUTER-PAIR [heartbeat thread] <--inproc--> PAIR [server]<br>
<br>
<br>
The heartbeat thread just forwards messages between the app and the<br>
outside world and back monitoring the traffic. And when there is no<br>
traffic it inserts heartbeats at regular intervals. It also filters<br>
out incoming heartbeats from the outside world.<br>
<br>
So far this is pretty simple. But now for the interesting parts:<br>
<br>
1) I want to use CURVE and zmq_msg_gets()<br>
<br>
When I recv() a message on the ROUTER socket it has metadata attached<br>
to it. Can I (and how) forward this message across the PAIR socket savely<br>
keeping the metadata pointer intact so the app can still call<br>
zmq_msg_gets() on it?<br>
<br>
2) I want to report disapeared peers to the app<br>
<br>
Basically I have normal messages and control/monitoring messages. I've<br>
been thinking that on a ROUTER socket each message starts with an<br>
identity frame. So I could send a 0 frame to indicate the message is a<br>
control message.<br>
<br>
But what do I do with the client? I can't use the same with a DEALER<br>
socket. I would have to prefix every message with 0 (control) or 1<br>
(data) and that would need change the application. I couldn't just<br>
plug in or remove the heartbeat without rewriting the message parsing.<br>
<br>
A short time ago we talked about using some bit in the message itself<br>
to say wether it is a control message or normal and having in-band<br>
control messages for connect/dicsonnect and so on. Maybe it would be a<br>
good time to design and implement something like that now and use it<br>
here?<br>
<br>
2b) Combining 2 and 1. Can I set my own metadata for control messages?<br>
<br>
I think the lack of a User-Id on a message could be used to identify<br>
control messages. Right?<br>
<br>
3) I want to connect/disconnect/bind/unbind or set HWM and so on<br>
<br>
The app and the DEALER/ROUTER sockets are in different threads. This<br>
makes modifying them directly impossible (never share a socket between<br>
threads, right?).<br>
<br>
So this would also need some form of control message but going the<br>
other way this time.<br>
<br>
Should this be just a custom control message that is specific to my<br>
use case or would it make sense to define a set of control messages<br>
for all the socket operations in zmq so other use cases use the same<br>
syntax? I'm thinking this could be reusable for proxies.<br>
<br>
MfG<br>
        Goswin<br>
_______________________________________________<br>
zeromq-dev mailing list<br>
<a href="mailto:zeromq-dev@lists.zeromq.org" target="_blank">zeromq-dev@lists.zeromq.org</a><br>
<a href="http://lists.zeromq.org/mailman/listinfo/zeromq-dev" target="_blank">http://lists.zeromq.org/mailman/listinfo/zeromq-dev</a><br>
</blockquote></div><br></div>
</div></div></blockquote></div><br></div>