Re: [zeromq-dev] Resource temporarily unavailable") at src/err.cpp:83

2016-08-12 Thread Luca Boccassi
Or raise the number of file descriptors in the system.
Note that the setting is per-user, and you might have to raise the
hard limit. You can google for more details as it depends on your
system and distribution:
ulimit -n 
sysctl fs.file-max

On 12 August 2016 at 18:31, Marcin Romaszewicz  wrote:
> You are running out of file descriptors, most likely. Each outgoing
> connection requires a file descriptor, and 100k is a lot of sockets. Are you
> trying to make 100k ZMQ sockets? If  you are, just limit the number of
> outgoing sockets, and it should work. Only send 1000 at a time, for example.
>
> On Fri, Aug 12, 2016 at 5:26 AM, Ranjeet Kumar  wrote:
>>
>> Hi,
>>
>> I am using Zeromq 4.1.5 and czmq 3.0.2 version.
>> I am getting below exception every time when i am sending message to 100k
>> zmq dealer clients.
>> In my zmq server application I am having 2 threads. In main thread I am
>> listening via zmq router socket using poll, getting HB. And from other
>> thread I am getting
>> message that i need to send 100k zmq dealer clients. But as soon as count
>> reach near to 4-5k clients to send app get crashed. Please suggest I am in
>> deep trouble.
>>
>> #0  0x768f15f7 in raise () from /lib64/libc.so.6
>> #1  0x768f2ce8 in abort () from /lib64/libc.so.6
>> #2  0x77b8f769 in zmq::zmq_abort
>> (errmsg_=errmsg_@entry=0x76a3af60 "Resource temporarily unavailable") at
>> src/err.cpp:83
>> #3  0x77ba72f9 in zmq::signaler_t::recv (this=this@entry=0x60b8a0)
>> at src/signaler.cpp:282
>> #4  0x77b92f30 in zmq::mailbox_t::recv (this=this@entry=0x60b840,
>> cmd_=cmd_@entry=0x7490cbc0, timeout_=timeout_@entry=0) at
>> src/mailbox.cpp:87
>> #5  0x77ba8249 in zmq::socket_base_t::process_commands
>> (this=this@entry=0x60b480, timeout_=timeout_@entry=0,
>> throttle_=throttle_@entry=true)
>> at src/socket_base.cpp:1044
>> #6  0x77ba856b in zmq::socket_base_t::send
>> (this=this@entry=0x60b480, msg_=msg_@entry=0x7fffe800d714,
>> flags_=flags_@entry=2) at src/socket_base.cpp:829
>> #7  0x77bbe09c in s_sendmsg (s_=s_@entry=0x60b480,
>> msg_=msg_@entry=0x7fffe800d714, flags_=flags_@entry=2) at src/zmq.cpp:346
>> #8  0x77bbe41a in zmq_msg_send (msg_=msg_@entry=0x7fffe800d714,
>> s_=s_@entry=0x60b480, flags_=flags_@entry=2) at src/zmq.cpp:590
>> #9  0x77bbe42e in zmq_sendmsg (s_=s_@entry=0x60b480,
>> msg_=msg_@entry=0x7fffe800d714, flags_=flags_@entry=2) at src/zmq.cpp:355
>> #10 0x778ee693 in zframe_send (self_p=self_p@entry=0x7490cce8,
>> dest=dest@entry=0x60b480, flags=) at src/zframe.c:158
>> #11 0x778f7e1f in zmsg_send (self_p=0x7490cdc0,
>> dest=) at src/zmsg.c:140
>>
>>
>> Thanks
>> Ranjeet
>>
>> ___
>> zeromq-dev mailing list
>> zeromq-dev@lists.zeromq.org
>> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
>
>
> ___
> zeromq-dev mailing list
> zeromq-dev@lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Re: [zeromq-dev] Resource temporarily unavailable") at src/err.cpp:83

2016-08-12 Thread Marcin Romaszewicz
You are running out of file descriptors, most likely. Each outgoing
connection requires a file descriptor, and 100k is a lot of sockets. Are
you trying to make 100k ZMQ sockets? If  you are, just limit the number of
outgoing sockets, and it should work. Only send 1000 at a time, for example.

On Fri, Aug 12, 2016 at 5:26 AM, Ranjeet Kumar  wrote:

> Hi,
>
> I am using Zeromq 4.1.5 and czmq 3.0.2 version.
> I am getting below exception every time when i am sending message to 100k
> zmq dealer clients.
> In my zmq server application I am having 2 threads. In main thread I am
> listening via zmq router socket using poll, getting HB. And from other
> thread I am getting
> message that i need to send 100k zmq dealer clients. But as soon as count
> reach near to 4-5k clients to send app get crashed. Please suggest I am in
> deep trouble.
>
> #0  0x768f15f7 in raise () from /lib64/libc.so.6
> #1  0x768f2ce8 in abort () from /lib64/libc.so.6
> #2  0x77b8f769 in zmq::zmq_abort (errmsg_=errmsg_@entry=0x76a3af60
> "Resource temporarily unavailable") at src/err.cpp:83
> #3  0x77ba72f9 in zmq::signaler_t::recv (this=this@entry=0x60b8a0)
> at src/signaler.cpp:282
> #4  0x77b92f30 in zmq::mailbox_t::recv (this=this@entry=0x60b840,
> cmd_=cmd_@entry=0x7490cbc0, timeout_=timeout_@entry=0) at
> src/mailbox.cpp:87
> #5  0x77ba8249 in zmq::socket_base_t::process_commands
> (this=this@entry=0x60b480, timeout_=timeout_@entry=0,
> throttle_=throttle_@entry=true)
> at src/socket_base.cpp:1044
> #6  0x77ba856b in zmq::socket_base_t::send (this=this@entry=0x60b480,
> msg_=msg_@entry=0x7fffe800d714, flags_=flags_@entry=2) at
> src/socket_base.cpp:829
> #7  0x77bbe09c in s_sendmsg (s_=s_@entry=0x60b480, msg_=msg_@entry
> =0x7fffe800d714, flags_=flags_@entry=2) at src/zmq.cpp:346
> #8  0x77bbe41a in zmq_msg_send (msg_=msg_@entry=0x7fffe800d714,
> s_=s_@entry=0x60b480, flags_=flags_@entry=2) at src/zmq.cpp:590
> #9  0x77bbe42e in zmq_sendmsg (s_=s_@entry=0x60b480,
> msg_=msg_@entry=0x7fffe800d714, flags_=flags_@entry=2) at src/zmq.cpp:355
> #10 0x778ee693 in zframe_send (self_p=self_p@entry=0x7490cce8,
> dest=dest@entry=0x60b480, flags=) at src/zframe.c:158
> #11 0x778f7e1f in zmsg_send (self_p=0x7490cdc0,
> dest=) at src/zmsg.c:140
>
>
> Thanks
> Ranjeet
>
> ___
> zeromq-dev mailing list
> zeromq-dev@lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

Re: [zeromq-dev] Async Client Server

2016-08-12 Thread Kevin Sapper
Answer 1: Yes.
Answer 2: You can use any recv method in a loop or use the poller class.
Answer 3: The server workers send 0-4 replies per request.

2016-08-12 2:58 GMT+00:00 Kevin Meredith :

> Looking at http://zguide.zeromq.org/page:all#toc76:
>
>
> [image: Inline image 1]
> As I understand, the ROUTER needs to poll frequently to hear from each of
> its clients.
>
> Then, the ROUTER forwards any client message to the `DEALER`.
>
> Question 1: Is the ROUTER to DEALER connection asynchronous?
>
> Question 2: For the Server's DEALER to N DEALER Workers, must polling take
> place at the Server's DEALER?
>
> Looking at the book's text:
>
> > The clients send a request once per second, and get zero or more replies
> back.
>
> Question 3: I suppose the 0 comes from a Worker that dies, i.e. box/thread
> crashes? How could more than 1 reply return to the -Client?
>
> Thanks,
> Kevin
>
>
> ___
> zeromq-dev mailing list
> zeromq-dev@lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev
>
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev

[zeromq-dev] Resource temporarily unavailable") at src/err.cpp:83

2016-08-12 Thread Ranjeet Kumar
Hi,

I am using Zeromq 4.1.5 and czmq 3.0.2 version.
I am getting below exception every time when i am sending message to 100k
zmq dealer clients.
In my zmq server application I am having 2 threads. In main thread I am
listening via zmq router socket using poll, getting HB. And from other
thread I am getting
message that i need to send 100k zmq dealer clients. But as soon as count
reach near to 4-5k clients to send app get crashed. Please suggest I am in
deep trouble.

#0  0x768f15f7 in raise () from /lib64/libc.so.6
#1  0x768f2ce8 in abort () from /lib64/libc.so.6
#2  0x77b8f769 in zmq::zmq_abort (errmsg_=errmsg_@entry=0x76a3af60
"Resource temporarily unavailable") at src/err.cpp:83
#3  0x77ba72f9 in zmq::signaler_t::recv (this=this@entry=0x60b8a0)
at src/signaler.cpp:282
#4  0x77b92f30 in zmq::mailbox_t::recv (this=this@entry=0x60b840,
cmd_=cmd_@entry=0x7490cbc0, timeout_=timeout_@entry=0) at
src/mailbox.cpp:87
#5  0x77ba8249 in zmq::socket_base_t::process_commands
(this=this@entry=0x60b480, timeout_=timeout_@entry=0,
throttle_=throttle_@entry=true)
at src/socket_base.cpp:1044
#6  0x77ba856b in zmq::socket_base_t::send (this=this@entry=0x60b480,
msg_=msg_@entry=0x7fffe800d714, flags_=flags_@entry=2) at
src/socket_base.cpp:829
#7  0x77bbe09c in s_sendmsg (s_=s_@entry=0x60b480,
msg_=msg_@entry=0x7fffe800d714,
flags_=flags_@entry=2) at src/zmq.cpp:346
#8  0x77bbe41a in zmq_msg_send (msg_=msg_@entry=0x7fffe800d714,
s_=s_@entry=0x60b480, flags_=flags_@entry=2) at src/zmq.cpp:590
#9  0x77bbe42e in zmq_sendmsg (s_=s_@entry=0x60b480,
msg_=msg_@entry=0x7fffe800d714,
flags_=flags_@entry=2) at src/zmq.cpp:355
#10 0x778ee693 in zframe_send (self_p=self_p@entry=0x7490cce8,
dest=dest@entry=0x60b480, flags=) at src/zframe.c:158
#11 0x778f7e1f in zmsg_send (self_p=0x7490cdc0, dest=) at src/zmsg.c:140


Thanks
Ranjeet
___
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev