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.

Sign up for GitHub

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

Jump to bottom

Rework BatchedSend logic #661

Merged
merged 10 commits into from
Nov 16, 2016
Merged

Rework BatchedSend logic #661

merged 10 commits into from
Nov 16, 2016

Commits on Nov 14, 2016

  1. Rework BatchedSend logic 

    Does away with the timeout and looking up a private attribute on IOStream.
Refs PR dask#653.
    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    d8897a2 View commit details
    Browse the repository at this point in the history

  2. Address review comments

    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    1f931c0 View commit details
    Browse the repository at this point in the history

  3. Remove BatchedStream

    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    e746b32 View commit details
    Browse the repository at this point in the history

  4. Remove fragile wait on IOStream.write()

    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    6b6c492 View commit details
    Browse the repository at this point in the history

  5. Merge branch 'master' of https://github.com/dask/distributed into bat… 

    …ched_send
    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    1a2e190 View commit details
    Browse the repository at this point in the history

  6. Flush streams before closing to avoid losing messages. 

    @mrocklin
    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    ac1fbb1 View commit details
    Browse the repository at this point in the history

  7. Yield on the flush() call

    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    05b7c92 View commit details
    Browse the repository at this point in the history

  8. Avoid exposing close()

    @pitrou
    pitrou committed Nov 14, 2016
    Configuration menu
    Copy the full SHA
    eb6afe8 View commit details
    Browse the repository at this point in the history

Commits on Nov 15, 2016

  1. Fix name clash with close()

    @pitrou
    pitrou committed Nov 15, 2016
    Configuration menu
    Copy the full SHA
    b0e92f0 View commit details
    Browse the repository at this point in the history

  2. Add a large traffic jam test

    @pitrou
    pitrou committed Nov 15, 2016
    Configuration menu
    Copy the full SHA
    a22650d View commit details
    Browse the repository at this point in the history