ZMQ’s implementation of PUB socket type does not allow for receive calls to be made (zmq_recv is disabled), hence why I am trying to figure out how does one trigger ZMQ to call “pgm_recv” on the PUB socket in order to get the PUB socket to processes received NAKs from a remote SUB socket? I have tried querying the PUB socket state via ZMQ_EVENTS to triggering the processing of any commands available for the socket however that does not seem to move the PGM state machine in terms of processing NAKs.
I am running both a PUB and SUB on the same application on the same host and although I see the same set of sockets being created at the PGM level for both PUB and SUB ZMQ sockets which includes multiple sockets binding to the same port, this does not appear to cause any issues in terms of my SUB socket able to receive multicast messages from a remote PUB and respond with unicast NAKs when data loss is detected. Any ideas as to how a user should get ZMQ lib to trigger NAKs processing for a PUB socket using either pgm/epgm transports? Thanks, Antonio Montero. From: zeromq-dev [mailto:[email protected]] On Behalf Of Steven McCoy Sent: Friday, March 23, 2018 9:55 AM To: ZeroMQ development list Subject: [External] Re: [zeromq-dev] A PGM/EPGM question You should check the PUB socket has a loop that is processing the incoming NAK requests, this is usually recv call based. The symptoms indicate that the protocol is operating TX-only. — Steve-o On Wed, Mar 21, 2018 at 19:50 Montero, Antonio UTC CCS <[email protected]<mailto:[email protected]>> wrote: Hello, I am having a bit of a hard time getting a ZMQ PUB socket reacting to PGM NAKs which means at this point I am not able to recover lost packets I have tried with both protocols: (pgm and epgm). Still getting the same result. I have a setup where I create both a PUB and SUB sockets in that order in the same ZMQ context running on the same host and connected to the same IPv6 multicast address and port. I have N nodes and each node has a PUB and SUB. All N nodes send messages asynchronously and all N nodes receive all messages. My multicast network is working fine whether I use pgm or epgm and all N nodes communicate with each other over IPv6 multicast. The issue I am having is when a packet loss occurs, a remote SUB sends a unicast NAK back to the source PUB however I am not seeing any NCF or RDATA being sent by the source PUB. I have verified that the packets in question are in fact still in the Tx Window as reported by the SPMs being sent by the source PUB. I have ongoing traffic on a periodic basis which triggers a send and receive respectably on the PUB and SUB sockets and I am clearing out the ZMQ_EVENTS after every send and/or receive. I also have a polling thread running every 150ms to check for ZMQ_EVENTS on both PUB and SUB. Nothing seems to work in terms of triggering the PUB to react and process the NAKs received from remote SUB. Looking at the code a bit I see this function zmq::pgm_socket_t::process_upstream but can’t tell if and how it is being triggered. It does not appear to be from my perspective. Any help or direction would be appreciated. Thanks. -- Antonio _______________________________________________ zeromq-dev mailing list [email protected]<mailto:[email protected]> https://lists.zeromq.org/mailman/listinfo/zeromq-dev<https://urldefense.proofpoint.com/v2/url?u=https-3A__lists.zeromq.org_mailman_listinfo_zeromq-2Ddev&d=DwMFaQ&c=ilBQI1lupc9Y65XwNblLtw&r=KE-_zI6ApNLT6qvQ1tC8zssu327OLN9lWlhIigWhJA4&m=AYMnN2d160L4oOUMYUzTsb0enU6l7vTnRPY_52rLMy0&s=LcJtAkEY4h2bzvGKaxr7OMpdGRbSSgLTF12pJkc7N70&e=>
_______________________________________________ zeromq-dev mailing list [email protected] https://lists.zeromq.org/mailman/listinfo/zeromq-dev
