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

chore: Fully upgrade to tokio 1.x #5872

Merged
merged 120 commits into from
Apr 2, 2021
Merged

chore: Fully upgrade to tokio 1.x #5872

merged 120 commits into from
Apr 2, 2021

Commits on Jan 5, 2021

  1. chore: begin upgrade to tokio 1.0.0 

    Some of the things left to do:

- [ ] Move to the new `tokio-openssl` API
- [ ] Figure out new way to do socket shutdown and keepalive
- [ ] Work around no `poll_ready` on new tokio channels for `Pipeline`
- [ ] General updates and cleanup

And some dependencies we're still waiting on upgrades from:

- [ ] `warp`
- [ ] `rusoto`
- [ ] `rdkafka`
- [ ] `bollard`
- [ ] `mongodb`

This is not a complete list, but covers most of the big ones I've run
into so far.

Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 5, 2021
    Configuration menu
    Copy the full SHA
    dcbd76d View commit details
    Browse the repository at this point in the history

Commits on Jan 11, 2021

  1. pin sleeps 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 11, 2021
    Configuration menu
    Copy the full SHA
    03000da View commit details
    Browse the repository at this point in the history

  2. fix AsyncRead usage 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 11, 2021
    Configuration menu
    Copy the full SHA
    3825dc5 View commit details
    Browse the repository at this point in the history

  3. remove hyper patch and stop using Resolver for http client 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 11, 2021
    Configuration menu
    Copy the full SHA
    28d64ba View commit details
    Browse the repository at this point in the history

Commits on Jan 13, 2021

  1. bump more deps 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 13, 2021
    Configuration menu
    Copy the full SHA
    0ccb1ef View commit details
    Browse the repository at this point in the history

Commits on Jan 19, 2021

  1. replace some usages of incoming 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 19, 2021
    Configuration menu
    Copy the full SHA
    939d953 View commit details
    Browse the repository at this point in the history

  2. update tokio-openssl api usage 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 19, 2021
    Configuration menu
    Copy the full SHA
    8caea51 View commit details
    Browse the repository at this point in the history

  3. try experimental sink alternative for socket source 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 19, 2021
    Configuration menu
    Copy the full SHA
    8ac1d19 View commit details
    Browse the repository at this point in the history

  4. temporarily comment out socket shutdown and keepalive 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 19, 2021
    Configuration menu
    Copy the full SHA
    d52a8ee View commit details
    Browse the repository at this point in the history

Commits on Jan 20, 2021

  1. more crate upgrades 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 20, 2021
    Configuration menu
    Copy the full SHA
    e9e9eb6 View commit details
    Browse the repository at this point in the history

Commits on Jan 25, 2021

  1. more crate upgrades 

    Signed-off-by: Luke Steensen <luke.steensen@gmail.com>
    @lukesteensen
    lukesteensen committed Jan 25, 2021
    Configuration menu
    Copy the full SHA
    f814f70 View commit details
    Browse the repository at this point in the history

Commits on Mar 2, 2021

  1. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 2, 2021
    Configuration menu
    Copy the full SHA
    fa0ad7b View commit details
    Browse the repository at this point in the history

Commits on Mar 12, 2021

  1. Upgrade to rdkafka 0.25.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    f7b4ca7 View commit details
    Browse the repository at this point in the history

  2. Fix more compiler errors 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    07b19c1 View commit details
    Browse the repository at this point in the history

  3. Remove bytes 0.5 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    f6fee83 View commit details
    Browse the repository at this point in the history

  4. Fix more compiler errors 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    750d747 View commit details
    Browse the repository at this point in the history

  5. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    4de48b1 View commit details
    Browse the repository at this point in the history

  6. Fix futures not being Send 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    6296f2a View commit details
    Browse the repository at this point in the history

  7. Fix incorrect future type 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    ba6c205 View commit details
    Browse the repository at this point in the history

  8. Resolve Send/Sync issues in futures 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    e47e0b1 View commit details
    Browse the repository at this point in the history

  9. Fix usage of rdkafka error code 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    5a3d0e9 View commit details
    Browse the repository at this point in the history

  10. Upgrade to bollard 0.10.1 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    4e95a98 View commit details
    Browse the repository at this point in the history

  11. Upgrade to prost 0.7.0 in libraries 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    2bbbc0c View commit details
    Browse the repository at this point in the history

  12. Add missing unwrap 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    b256879 View commit details
    Browse the repository at this point in the history

  13. Remove unneeded mut 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    8ec9907 View commit details
    Browse the repository at this point in the history

  14. Remove unused imports 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    49dd1f0 View commit details
    Browse the repository at this point in the history

  15. cargo fmt 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    df0b50b View commit details
    Browse the repository at this point in the history

  16. Fix moved value in future 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    51ddbaa View commit details
    Browse the repository at this point in the history

  17. Fix set_receive_buffer_size on TCP stream 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    8cdcd5b View commit details
    Browse the repository at this point in the history

  18. Fix tokio delay_for -> sleep 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    0b2f0a0 View commit details
    Browse the repository at this point in the history

  19. Fix core_threads -> worker_threads 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    f392acb View commit details
    Browse the repository at this point in the history

  20. Wrap into UnboundedReceiverStream 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    c266677 View commit details
    Browse the repository at this point in the history

  21. Wrap into ReceiverStream 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    c1429d7 View commit details
    Browse the repository at this point in the history

  22. Fix is_empty / migrate from deprecated try_recv 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 12, 2021
    Configuration menu
    Copy the full SHA
    e51d629 View commit details
    Browse the repository at this point in the history

Commits on Mar 13, 2021

  1. Use .next().await instead of .try_recv() 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    f282f11 View commit details
    Browse the repository at this point in the history

  2. Wrap into ReceiverStream (continued) 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    5d1ad1e View commit details
    Browse the repository at this point in the history

  3. Wrap into UnboundedReceiverStream (continued) 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    2e1deba View commit details
    Browse the repository at this point in the history

  4. Wrap into IntervalStream 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    1f9a807 View commit details
    Browse the repository at this point in the history

  5. Migrate usage of .into_future() -> .recv() 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    bfd428b View commit details
    Browse the repository at this point in the history

  6. Fix MockSourceConfig not being Send + Sync 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    82f5f02 View commit details
    Browse the repository at this point in the history

  7. Migrate to AsyncWriteExt::shutdown 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    8f1201d View commit details
    Browse the repository at this point in the history

  8. Migrate poll_next -> poll_recv 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    ce7ec6e View commit details
    Browse the repository at this point in the history

  9. Wrap into TcpListenerStream 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    7571379 View commit details
    Browse the repository at this point in the history

  10. Fix buffer related compiler errors 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    0ead572 View commit details
    Browse the repository at this point in the history

  11. Hack lifetime issue by blocking on thread 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    27ef6d8 View commit details
    Browse the repository at this point in the history

  12. Fix mutability issues 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    433ba9d View commit details
    Browse the repository at this point in the history

  13. Relax lifetime requirement in wait_with_timeout 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    8b4b140 View commit details
    Browse the repository at this point in the history

  14. Upgrade to tokio 1.3.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    50e65aa View commit details
    Browse the repository at this point in the history

  15. Implement poll_ready/try_flush in Pipeline using Sender::try_reserve 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 13, 2021
    Configuration menu
    Copy the full SHA
    aeb3db0 View commit details
    Browse the repository at this point in the history

Commits on Mar 14, 2021

  1. Implement poll_ready in Sink for BoundedSink using Sender::try_reserve 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    07ecfa2 View commit details
    Browse the repository at this point in the history

  2. Only signal close when 0 bytes have been read 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    e21d0c6 View commit details
    Browse the repository at this point in the history

  3. Poll stream shutdown without blocking the thread 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    c74a65b View commit details
    Browse the repository at this point in the history

  4. Try fixing stream shutdown 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    29236a3 View commit details
    Browse the repository at this point in the history

  5. Try making polled shutdown of stream work in tcp source 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    c2c9f57 View commit details
    Browse the repository at this point in the history

  6. Fix unused import warnings 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    e0478bc View commit details
    Browse the repository at this point in the history

  7. Fix unused variable warnings 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    42338dc View commit details
    Browse the repository at this point in the history

  8. Fix unused mut warnings 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    4c912a4 View commit details
    Browse the repository at this point in the history

  9. Fix unused Result warnings 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    a995768 View commit details
    Browse the repository at this point in the history

  10. Fix dead code warnings 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    94d18cf View commit details
    Browse the repository at this point in the history

  11. Fix usage of async child process API 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    40c722a View commit details
    Browse the repository at this point in the history

  12. Remove feature gate for udp module 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    1e9c817 View commit details
    Browse the repository at this point in the history

  13. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    43bd67e View commit details
    Browse the repository at this point in the history

  14. Remove faulty feature gate 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    21cf023 View commit details
    Browse the repository at this point in the history

  15. Remove unused import 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    bf1fa34 View commit details
    Browse the repository at this point in the history

  16. Add missing imports in test 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    b7d27a8 View commit details
    Browse the repository at this point in the history

  17. Fix compilation errors/warnings in benches 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    aad950a View commit details
    Browse the repository at this point in the history

  18. Fix compilation errors/warnings in integration tests 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    ee89a43 View commit details
    Browse the repository at this point in the history

  19. Temporarily make clippy happy 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    69ebfe8 View commit details
    Browse the repository at this point in the history

  20. Fix stream shutdown in async functions 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    c762c9d View commit details
    Browse the repository at this point in the history

  21. Fix unused import warning on Windows 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    42026ee View commit details
    Browse the repository at this point in the history

  22. Fix setting TCP keepalive 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    fa53330 View commit details
    Browse the repository at this point in the history

  23. Pin rdkafka dependency to git revision with aarch64 fix 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 14, 2021
    Configuration menu
    Copy the full SHA
    a97070d View commit details
    Browse the repository at this point in the history

Commits on Mar 15, 2021

  1. Fix import on Windows 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    5f84579 View commit details
    Browse the repository at this point in the history

  2. Fix feature gates on Windows 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    e3b1a4d View commit details
    Browse the repository at this point in the history

  3. Rework setting socket options with socket2 upgrade / allow setting op… 

    …tions on all OSs

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    60c727a View commit details
    Browse the repository at this point in the history

  4. Fix feature gates on Windows 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    c65db09 View commit details
    Browse the repository at this point in the history

  5. Fix unused mut warning on Windows 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    009fc05 View commit details
    Browse the repository at this point in the history

  6. Shutdown TCP stream synchronously 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    189caa5 View commit details
    Browse the repository at this point in the history

  7. Fix dead code warning 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    f041ae2 View commit details
    Browse the repository at this point in the history

  8. Fix dead code warning 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    0cc432d View commit details
    Browse the repository at this point in the history

  9. Use futures::channel::mpsc instead of sink wrappers around tokio::syn… 

    …c::mpsc

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    d5174f3 View commit details
    Browse the repository at this point in the history

  10. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 15, 2021
    Configuration menu
    Copy the full SHA
    d2fc17b View commit details
    Browse the repository at this point in the history

Commits on Mar 16, 2021

  1. Fix control channels being dropped and closed prematurely 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    873a081 View commit details
    Browse the repository at this point in the history

  2. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    c2408ba View commit details
    Browse the repository at this point in the history

  3. Fix control channel being prematurely closed by being moved and dropp… 

    …ed in closure

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    dee00de View commit details
    Browse the repository at this point in the history

  4. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    8f92641 View commit details
    Browse the repository at this point in the history

  5. Fix buffer capacities after switching from tokio::sync::mpsc to futur… 

    …es::sync::mpsc

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    468a087 View commit details
    Browse the repository at this point in the history

  6. Fix not simultaneously polling all channels 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    b6ac2b7 View commit details
    Browse the repository at this point in the history

  7. Fix poll_next being called in poll_close 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 16, 2021
    Configuration menu
    Copy the full SHA
    f482f95 View commit details
    Browse the repository at this point in the history

Commits on Mar 17, 2021

  1. Fix tests not being run in an async runtime 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    2746ba6 View commit details
    Browse the repository at this point in the history

  2. Fix shutdown by not calling poll_next in poll_flush 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    70f2e03 View commit details
    Browse the repository at this point in the history

  3. Fix shutdown of TCP stream / TCP socket source 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    a44aa5b View commit details
    Browse the repository at this point in the history

  4. Reintroduce processing of control messages in flush/close, but don't … 

    …poll after end

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    1508eb4 View commit details
    Browse the repository at this point in the history

  5. Protect control channel from being over-polled by using futures::stre… 

    …am::Fuse

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    09e9151 View commit details
    Browse the repository at this point in the history

  6. Fix stream not being flushed with shutdown signal 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    9b43bec View commit details
    Browse the repository at this point in the history

  7. Flush stream before shutdown 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    a7304cc View commit details
    Browse the repository at this point in the history

  8. Fix tests not fully collecting receiver after shutdown 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 17, 2021
    Configuration menu
    Copy the full SHA
    04f7714 View commit details
    Browse the repository at this point in the history

Commits on Mar 18, 2021

  1. Synchronously assert on generator output 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 18, 2021
    Configuration menu
    Copy the full SHA
    149fb79 View commit details
    Browse the repository at this point in the history

  2. Move pipeline to channel with Sink API / tokio::sync::mpsc -> futures… 

    …::channel::mpsc

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 18, 2021
    Configuration menu
    Copy the full SHA
    c0666ef View commit details
    Browse the repository at this point in the history

  3. Component features cleanup 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 18, 2021
    Configuration menu
    Copy the full SHA
    d918ecd View commit details
    Browse the repository at this point in the history

  4. Fix compilation errors in integration tests 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 18, 2021
    Configuration menu
    Copy the full SHA
    f7fd87f View commit details
    Browse the repository at this point in the history

  5. Update the adaptive concurrency tests for new tokio timings 

    The tokio synthetic timer works subtly differently post-1.0, producing
slightly different timings. These minor changes adjust for those
timings.

Signed-off-by: Bruce Guenter <bruce.guenter@datadoghq.com>
    @bruceg
    bruceg committed Mar 18, 2021
    Configuration menu
    Copy the full SHA
    a7d1f54 View commit details
    Browse the repository at this point in the history

  6. Fix error return path on TLS handshake failure 

    Signed-off-by: Bruce Guenter <bruce.guenter@datadoghq.com>
    @bruceg
    bruceg committed Mar 18, 2021
    Configuration menu
    Copy the full SHA
    16d285b View commit details
    Browse the repository at this point in the history

Commits on Mar 19, 2021

  1. Move back to collect_ready as the receiver doesn't seem to have seman… 

    …tics of being closed

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 19, 2021
    Configuration menu
    Copy the full SHA
    f439d90 View commit details
    Browse the repository at this point in the history

  2. Move locking of mutex out of poll function 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 19, 2021
    Configuration menu
    Copy the full SHA
    7b76a82 View commit details
    Browse the repository at this point in the history

  3. Continue polling stream after shutting down TCP socket for correct fl… 

    …ushing behavior

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 19, 2021
    Configuration menu
    Copy the full SHA
    50951ca View commit details
    Browse the repository at this point in the history

  4. Expand a few more adaptive concurrency test parameters 

    Signed-off-by: Bruce Guenter <bruce.guenter@datadoghq.com>
    @bruceg
    bruceg committed Mar 19, 2021
    Configuration menu
    Copy the full SHA
    93b859b View commit details
    Browse the repository at this point in the history

  5. Upgrade rdkafka to 0.26.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 19, 2021
    Configuration menu
    Copy the full SHA
    c116340 View commit details
    Browse the repository at this point in the history

  6. Work around named pipes not being available, connect to Docker via HT… 

    …TP instead

Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 19, 2021
    Configuration menu
    Copy the full SHA
    d93da35 View commit details
    Browse the repository at this point in the history

Commits on Mar 20, 2021

  1. Constrain runtime worker threads when spawning from a forked process 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 20, 2021
    Configuration menu
    Copy the full SHA
    ef34698 View commit details
    Browse the repository at this point in the history

  2. Additionally constrain number of blocking threads 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 20, 2021
    Configuration menu
    Copy the full SHA
    1e6e0ba View commit details
    Browse the repository at this point in the history

Commits on Mar 26, 2021

  1. Remove unnecessary namespace qualifiers 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    Configuration menu
    Copy the full SHA
    1ee64e6 View commit details
    Browse the repository at this point in the history

  2. Remove intermediate variables 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    Configuration menu
    Copy the full SHA
    4465235 View commit details
    Browse the repository at this point in the history

  3. Remove explicitly passing number of threads (done by default) 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    Configuration menu
    Copy the full SHA
    fbf1860 View commit details
    Browse the repository at this point in the history

  4. Don't explicitly poll flush before shutdown (done implicitly) 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    Configuration menu
    Copy the full SHA
    efac5c3 View commit details
    Browse the repository at this point in the history

  5. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    Configuration menu
    Copy the full SHA
    2cf9032 View commit details
    Browse the repository at this point in the history

  6. Enable "warp" dependency with "api" feature 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    Configuration menu
    Copy the full SHA
    ddfbbe7 View commit details
    Browse the repository at this point in the history

  7. Replace stream! invocations with appropriate stream wrappers 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Mar 26, 2021
    1 Configuration menu
    Copy the full SHA
    fbb5a32 View commit details
    Browse the repository at this point in the history

Commits on Apr 1, 2021

  1. Disable API tests due to issues with rusty_fork 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Apr 1, 2021
    Configuration menu
    Copy the full SHA
    673e30a View commit details
    Browse the repository at this point in the history

  2. Merge remote-tracking branch 'origin/master' into tokio-1.0 

    Signed-off-by: Pablo Sichert <mail@pablosichert.com>
    @pablosichert
    pablosichert committed Apr 1, 2021
    Configuration menu
    Copy the full SHA
    f52e32f View commit details
    Browse the repository at this point in the history