Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix minor pylint messages related to your pull request and merge pika master #1

Merged
merged 51 commits into from
Feb 27, 2018

Conversation

vitaly-krugl
Copy link

@vitaly-krugl vitaly-krugl commented Feb 27, 2018

@darcoli, my specific changes are in commit 066ce02. The rest is just merging of pika master with your PR.

Close ioloop when cleaning up an instance of BlockingConnection.
Fix/suppress several pylint findings.
…adsafe

being called from same and from another thread
…notherThread with debug logging to help debug test failure.
… new "ack from other thread" BlockingConnection tests.
… so that

these IOLoops may be closed to release resources without risking closing of singletons
which would break subsequent tests (since some adapters, such as torndado and asyncio
make use of the singletons)
…orresponding RresourceWarning messages when running Python3 tests
…p.stop and _PollerBase.stop.

Technically, IOLoop.add_callback_threadsafe should be the only thread-safe method that can be used
to delegate other non-thread-safe methods similarly to other asynchronous frameworks (twisted, tornado, etc.)
from a different thread than IOLoop is running in. Add an example of calling
it via `add_callback_threadsafe()`.

Use `add_callback_threadsafe()` to invoke ioloop.stop() from another thread in
unit/select_connection_ioloop_tests.py
vitaly-krugl and others added 21 commits February 16, 2018 18:37
…plified

TestConsumeGeneratorCancelEncountersCancelFromBroker
…ven error-prone feature

with inconsistent default values across adapters and all of our examples set it to False
for any adapter where it defaulted to True because it interferes with typial logic. Apps
can stop their ioloop easily from connection-provided callbacks if they wish.
…ally committed to wrong branch

This reverts commit 3ca1365.
…lose

Eliminate the `stop_ioloop_on_close` arg from all async connection adapters
closed before the call(s) to start() unwind.

Implemented select_connection IOLoop tests:
IOLoopCloseAfterStartReturnsTestSelect
IOLoopCloseBeforeStartReturnsTestSelect
IOLoopThreadStopTestSelect

Implemented additaionl tests in acceptance/async_adapter_tests.py:
TestAddCallbackThreadsafeRequestBeforeIOLoopStarts
TestIOLoopStopBeforeIOLoopStarts
…callback

Trying to debug Updates were rejected because the remote contains work that you do not have locally.
not channels or the connection is still opening, in which case there
should be no channels.
closing the async connection before it is established to avoid
triggering logic in the close code path that isn't ready to deal with it.
…estIOLoopStopBeforeIOLoopStarts acceptance test.
Implement add_callback_threadsafe in all connection adapters
…nnel.py.

Inline unnecessary method `Connection._remove_callback()`.
…-docs

Improved arg documentation of some callbacks in connection.py and channel.py
…celing-in-generator

Implemented BlockingConnection acceptance tests for the consume generator encountering server's Basic.Cancel
@vitaly-krugl vitaly-krugl changed the title Fix minor pylint messages related to your pull request Fix minor pylint messages related to your pull request and merge pika master Feb 27, 2018
@darcoli darcoli merged commit 783aa97 into darcoli:master Feb 27, 2018
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants