Re: messenger fetch interrupt

2015-01-13 Thread Gordon Sim
On 01/13/2015 05:24 PM, Michael Ivanov wrote: Thtnks for reply, As regarding my expectations I guess that messenger waits for the next message using some system call, probably poll or select. I set empty signal handler for SIGUSR1 and when I want to interrupt the wait I use pthread_kill to send

Re: messenger fetch interrupt

2015-01-13 Thread Michael Ivanov
Thtnks for reply, As regarding my expectations I guess that messenger waits for the next message using some system call, probably poll or select. I set empty signal handler for SIGUSR1 and when I want to interrupt the wait I use pthread_kill to send SIGUSR1. The signal handler is invoked, I checke

Re: messenger fetch interrupt

2015-01-13 Thread Andrew Stitcher
On Mon, 2015-01-12 at 22:12 +0300, Michael Ivanov wrote: > Hallo, > > I am reading the messages from the queue as follows: > >Receiverr(_session.nextReceiver()); >Message message(r.fetch(Duration::FOREVER d)); > This sequence should be spending its time in the nextReceiver() cal

messenger fetch interrupt, followup

2015-01-12 Thread Michael Ivanov
Strange, I just changed the timeout from Duration::FOREVER to Duration(4000) but it still waits for the message forever, no exception is thrown in 4 seconds... > Hallo, > > I am reading the messages from the queue as follows: > >Receiverr(_session.nextReceiver()); >Message messa

messenger fetch interrupt

2015-01-12 Thread Michael Ivanov
Hallo, I am reading the messages from the queue as follows: Receiverr(_session.nextReceiver()); Message message(r.fetch(Duration::FOREVER d)); At some moment I want to interrupt the receiver using some signal. >From signal handler I invoke pthread_kill(SIGUSR1, pthread_self()) but