[zeromq-dev] queue limits

[Pavel Gushcha]

I tried to use queue limits in my development. When i send messages between
different api_thread_t all works as i except. But with sending messages over
network i get some problems. My testcase:
1) prompt.cpp creates global exchange and sends about 100k messages (10000
bytes each).
2) display.cpp creates local queue with hwm 5/lwm 5, and binds it to global
exchange. After that display.cpp wait user input and is not receiving
messages.

prompt.cpp before blocking sent about 20000 messages. When i decrease
message size to 10-15 bytes, prompt.cpp can send about 60000 messages before
block.
I tried messages with size larger than 10kb and get same limit about 20000
messages (in this case my system use swap file, because there is no enough
ram).

I looked at memory consumption, and noticed, that prompt.cpp and display.cpp
consumes same amount memory (For 10000 bytes message size each process
consumes about 100mb, this is about half of 10000bytes*20000 messages).

This is bug, or i miss some details? I attached my testprograms.

PS: i made testcase with local exchange and global queue and get same
results.

Thanks for help!
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20090922/a5aa5927/attachment.htm>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: display.cpp
Type: text/x-c++src
Size: 1391 bytes
Desc: not available
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20090922/a5aa5927/attachment.cpp>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: prompt.cpp
Type: text/x-c++src
Size: 965 bytes
Desc: not available
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20090922/a5aa5927/attachment-0001.cpp>