[Bro] Trouble passing a message between two local endpoints.
capn.freako at gmail.com
Fri Aug 14 11:16:29 PDT 2015
Davids-MacBook-Air-2:broker-haskell dbanas$ ./a.out
There are 1 messages.
Thanks, so much, for hand holding me through this, Jon!
Have a great weekend,
On Aug 14, 2015, at 7:57 AM, Siwek, Jon <jsiwek at illinois.edu> wrote:
>> On Aug 13, 2015, at 8:52 PM, David Banas <capn.freako at gmail.com> wrote:
>> broker_deque_of_message* msg_list = broker_message_queue_want_pop(q);
> This ends up checking for messages while the one you just sent is still in-flight. Try changing it to use “broker_message_queue_need_pop(q)”. That version will block until at least one message can be retrieved from the queue.
> Alternatively, what you may want in a real application is integrate the “want_pop” version into a poll()/select() loop so you get signaled when something is actually available to retrieve.
> - Jon
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the Bro