Bug 703200
| Summary: | Gofer not stopping reciever thread before closing session. | ||
|---|---|---|---|
| Product: | [Retired] Pulp | Reporter: | Jeff Ortel <jortel> |
| Component: | user-experience | Assignee: | Jeff Ortel <jortel> |
| Status: | CLOSED CURRENTRELEASE | QA Contact: | Preethi Thomas <pthomas> |
| Severity: | low | Docs Contact: | |
| Priority: | medium | ||
| Version: | unspecified | Keywords: | Triaged |
| Target Milestone: | --- | ||
| Target Release: | Sprint 23 | ||
| Hardware: | Unspecified | ||
| OS: | Unspecified | ||
| Whiteboard: | |||
| Fixed In Version: | Doc Type: | Bug Fix | |
| Doc Text: | Story Points: | --- | |
| Clone Of: | Environment: | ||
| Last Closed: | 2011-08-16 12:09:29 UTC | Type: | --- |
| Regression: | --- | Mount Type: | --- |
| Documentation: | --- | CRM: | |
| Verified Versions: | Category: | --- | |
| oVirt Team: | --- | RHEL 7.3 requirements from Atomic Host: | |
| Cloudforms Team: | --- | Target Upstream Version: | |
| Embargoed: | |||
| Bug Depends On: | |||
| Bug Blocks: | 647488 | ||
Fixed in 0.36 build 0.174 verified. Result in the log 2011-05-11 09:11:52,910 [INFO][10.16.79.198] deleted() @ pulp.py:186 - Artifacts deleted 2011-05-11 09:11:56,736 [INFO][pending:10.16.79.198] run() @ store.py:241 - stopped 2011-05-11 09:11:59,015 [INFO][10.16.79.198] run() @ consumer.py:77 - stopped 2011-05-11 09:11:59,064 [INFO][pulp-monitor] update() @ main.py:95 - uuid="10.16.79.198", detached [root@10 ~]# rpm -q pulp-client pulp-client-0.0.174-1.fc14.noarch [root@10 ~]# rpm -q gofer gofer-0.36-1.fc14.noarch Closing with Community Release 15 pulp-0.0.223-4. Closing with Community Release 15 pulp-0.0.223-4. |
Description of problem: In 0.35, the gofer consumer is not stopping the receiver thread. So, when the endpoint closes, it closes the session but the receiver thread continues to fetch() on the receiver. The following spam is generated in the log(s): 2011-05-09 10:16:24,879 [ERROR][test_consumer_jkig_multTest] run() @ consumer.py:72 - failed: Message(durable=True, properties={'x-amqp-0-10.routing-key': u'test_consumer_jkig_multTest'}, content='{\n "origin": "e6b5c14e-c079-4486-b623-c075cde7869d", \n "replyto": null, \n "request": {\n "classname": "Consumer", \n "kws": {}, \n "args": [\n "f0ad3930fd6a1c9aa7c539f99a96fe247354d717b759b85eadd7d86ef079a5fd"\n ], \n "method": "deleted"\n }, \n "window": {}, \n "secret": "f0ad3930fd6a1c9aa7c539f99a96fe247354d717b759b85eadd7d86ef079a5fd", \n "version": "0.2", \n "sn": "8de50fa4-c124-4841-899e-fe08212201fb", \n "any": null\n}') Traceback (most recent call last): File "/usr/lib/python2.6/site-packages/gofer/messaging/consumer.py", line 67, in run msg = self.__fetch(receiver) File "/usr/lib/python2.6/site-packages/gofer/messaging/consumer.py", line 99, in __fetch return receiver.fetch(timeout=self.WAIT) File "<string>", line 6, in fetch File "/usr/lib/python2.6/site-packages/qpid/messaging/endpoints.py", line 994, in fetch self._ecwait(lambda: self.linked) File "/usr/lib/python2.6/site-packages/qpid/messaging/endpoints.py", line 51, in _ecwait self.check_closed() File "/usr/lib/python2.6/site-packages/qpid/messaging/endpoints.py", line 963, in check_closed raise LinkClosed() Version-Release number of selected component (if applicable): 0.35 (gofer) How reproducible: Always Steps to Reproduce: 1. Create a consumer 2. Delete the consumer 3. Actual results: Spam Expected results: 2011-05-09 10:03:13,843 [INFO][jortel] deleted() @ pulp.py:186 - Artifacts deleted 2011-05-09 10:03:16,990 [INFO][pending:jortel] run() @ store.py:241 - stopped 2011-05-09 10:03:19,862 [INFO][jortel] run() @ consumer.py:77 - stopped 2011-05-09 10:03:19,882 [INFO][pulp-monitor] update() @ main.py:95 - uuid="jortel", detached Additional info: