[
https://issues.apache.org/jira/browse/QPID-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14029327#comment-14029327
]
Pavel Moravec commented on QPID-5812:
-------------------------------------
Traceback:
File "<string>", line 6, in fetch
File "/usr/lib/python2.4/site-packages/qpid/messaging/endpoints.py", line
1021, in fetch
self._ecwait(lambda: not self.draining)
File "/usr/lib/python2.4/site-packages/qpid/messaging/endpoints.py", line 50,
in _ecwait
result = self._ewait(lambda: self.closed or predicate(), timeout)
File "/usr/lib/python2.4/site-packages/qpid/messaging/endpoints.py", line
973, in _ewait
result = self.session._ewait(lambda: self.error or predicate(), timeout)
File "/usr/lib/python2.4/site-packages/qpid/messaging/endpoints.py", line
566, in _ewait
result = self.connection._ewait(lambda: self.error or predicate(), timeout)
File "/usr/lib/python2.4/site-packages/qpid/messaging/endpoints.py", line
208, in _ewait
result = self._wait(lambda: self.error or predicate(), timeout)
File "/usr/lib/python2.4/site-packages/qpid/messaging/endpoints.py", line
193, in _wait
return self._waiter.wait(predicate, timeout=timeout)
File "/usr/lib/python2.4/site-packages/qpid/concurrency.py", line 57, in wait
self.condition.wait(3)
File "/usr/lib/python2.4/site-packages/qpid/concurrency.py", line 96, in wait
sw.wait(timeout)
File "/usr/lib/python2.4/site-packages/qpid/compat.py", line 53, in wait
ready, _, _ = select([self], [], [], timeout)
> python high level API client receiver.fetch(timeout=N) blocks forever in
> select() if broker is stopped (kill -STOP)
> --------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-5812
> URL: https://issues.apache.org/jira/browse/QPID-5812
> Project: Qpid
> Issue Type: Bug
> Components: Python Client
> Affects Versions: 0.28
> Reporter: Pavel Moravec
> Assignee: Pavel Moravec
> Priority: Trivial
> Labels: easyfix, easytest, patch,
> Fix For: Future
>
>
> Description of problem:
> python high level API client qpid.messaging.Receiver.fetch(timeout=N) blocks
> program execution forever if qpidd is stopped by kill -STOP `pidof qpidd`
> just before receiver call.
> Version-Release number of selected component (if applicable):
> (any)
> How reproducible:
> 100%
> Steps to Reproduce:
> 1. service qpidd restart
> 2. python # interacive shell, terminal A
> import qpid.messaging
> c=qpid.messaging.Connection('localhost')
> c.open()
> s=c.session();
> S=s.sender("ADDR; {create: sender}")
> S.send("sdfdsfdsfsd", timeout=5);
> R=s.receiver("ADDR; {create: sender}")
> 3. kill -STOP `pidof qpidd` #3 in terminal B
> 4. back in python terminal A
> R.fetch(timeout=5)
> Actual results:
> Call at step 4 blocking forever.
> Expected results:
> Call at step 4 blocking 5 secs.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
