Code

Tokio Porting#566

Code

Merged

Mallets merged 120 commits intoeclipse-zenoh:tokio-portingeclipse-zenoh/zenoh:tokio-portingfrom YuanYuYuan:PR/tokio-portingYuanYuYuan/zenoh:PR/tokio-portingCopy head branch name to clipboardMar 5, 2024

+3,722-4,147

Commits

Commits on Mar 5, 2024

• Tokio porting in zenoh-link

  YuanYuYuan

  committed
  788d250

• Porting further for transport

  YuanYuYuan

  committed
  64a87c2

• Work around mixed runtime problem in async drop

  YuanYuYuan

  committed
  4e1891a

• No need to await for tcp addresses anymore

  YuanYuYuan

  committed
  219ea9b

• Use tokio runtime for the TX worker

  YuanYuYuan

  committed
  dc1a096

• Replace all underlying runtime to tokio

  YuanYuYuan

  committed
  8795b31

• Tidy codes

  YuanYuYuan

  committed
  fdbf103

• Add WIP lowlatency

  YuanYuYuan

  committed
  673fd93

• Finished the porting of pipelien. Note the usage of spawn_blocking

  YuanYuYuan

  committed
  ea15fc4

• Tokio porting on unixpipe

  YuanYuYuan

  committed
  a485b92

• Use async_global_executor::block_on

  YuanYuYuan

  committed
  15d3d16

• work around the potential blocking task in unixpipe

  YuanYuYuan

  committed
  ec0923e

• Replace Async<File>

  YuanYuYuan

  committed
  c65936e

• Replace Async<File> by AsyncFd<File>

  YuanYuYuan

  committed
  48d5655

• Fix the runtime problem while dropping

  YuanYuYuan

  committed
  15b32e1

• Use ZRuntime. Note that low_latency_transport doesn't work

  YuanYuYuan

  committed
  05f1d96

• Test with dashmap. There seems to be a deadlock while P2P scouting

  YuanYuYuan

  committed
  a617473

• 1. Remove unneccessary async to solve block_on

  Show description for 86d560a
  YuanYuYuan

  committed
  86d560a

• Address block_on issues in unixpipe and low-latency transport

  YuanYuYuan

  committed
  5aa631e

• Fix bug

  YuanYuYuan

  committed
  d8e1c48

• Use deref to call ZRuntime and tidy up unused imports

  YuanYuYuan

  committed
  e77c013

• Try with interval

  YuanYuYuan

  committed
  117b8c1

• Use TX runtime only

  YuanYuYuan

  committed
  a50f7fb

• Ignore files starting with underscore

  YuanYuYuan

  committed
  3009aa9

• Use all ZRuntimes

  YuanYuYuan

  committed
  afce57e

• Fix the busy loop in unixpipe

  YuanYuYuan

  committed
  47f7570

• Unifty the ztimeout macro and remove the zasync_executor_init

  YuanYuYuan

  committed
  1833b63

• Port zenoh/tests to tokio

  YuanYuYuan

  committed
  dbb9c9a

• Fix the nested block_on issue

  YuanYuYuan

  committed
  7016241

• Remove trailing whitespaces

  YuanYuYuan

  committed
  d84da6c

• Fix the tests in io/zenoh-transport

  YuanYuYuan

  committed
  d852b45

• Remove async-std in zenoh/zenoh

  YuanYuYuan

  committed
  03d7269

• Remove async-std in zenohd

  YuanYuYuan

  committed
  93c941f

• WIP on tests of I/O

  YuanYuYuan

  committed
  6b3ef9e

• Pass all tests in io and zenoh

  YuanYuYuan

  committed
  036b1f5

• cargo fmt

  YuanYuYuan

  committed
  67ac4bf

• remove unused dashmap

  YuanYuYuan

  committed
  cd60d74

• Finish the porting on examples

  YuanYuYuan

  committed
  51012de

• Make from_config async again

  YuanYuYuan

  committed
  ef54fef

• Use tokio::net::lookup_host to convert the address to socket addresses asynchronously

  YuanYuYuan

  committed
  beb461a

• Porting on zenoh-link-ws

  YuanYuYuan

  committed
  878f60e

• Cargo fmt

  YuanYuYuan

  committed
  e0206e4

• Remove commented lines

  YuanYuYuan

  committed
  c370c30

• Tokio porting on serial

  YuanYuYuan

  committed
  2550c0d

• Tidy up

  YuanYuYuan

  committed
  fe65a42

• Add a throughput quick test script

  YuanYuYuan

  committed
  7d6beb7

• Tokio porting on udp

  YuanYuYuan

  committed
  5bfdaa5

• Update Cargo.lock

  YuanYuYuan

  committed
  5072bb3

• Correct the comment

  YuanYuYuan

  committed
  cf884af

• Correctly return the result

  YuanYuYuan

  committed
  8955c8d

• Porting on zenoh-link-unixsocket_stream

  YuanYuYuan

  committed
  35a8e53

• Correct the feature flag of tokio-util

  YuanYuYuan

  committed
  b542ffb

• Port link-tls to tokio and bump workspace rustls to 0.22.2

  YuanYuYuan

  committed
  2f69aab

• Port link-quic to tokio

  YuanYuYuan

  committed
  c77a04b

• Turn get_listeners and get_locators into async calls. Use AsyncMutex and AsyncRwLock explicitly

  YuanYuYuan

  committed
  bde47eb

• Tidy up ZRuntimes

  YuanYuYuan

  committed
  8cb14c4

• Tokio porting on zenoh-plugin-storage-manager

  YuanYuYuan

  committed
  afc91b3

• Refine ZRuntime

  YuanYuYuan

  committed
  e3a0ec5

• Enable the std feature of zenoh-result to convert std::io::Result

  YuanYuYuan

  committed
  fbdb2d7

• Tokio porting on zenoh-sync

  YuanYuYuan

  committed
  62c02b7

• tokio porting on object_pool

  YuanYuYuan

  committed
  8b275b9

• tokio porting on plugins

  YuanYuYuan

  committed
  68d7cbf

• tokio porting on zenoh-ext

  YuanYuYuan

  committed
  6b4770b

• Upgrade a few dependencies

  YuanYuYuan

  committed
  b80d6d0

• Tokio porting on doc

  YuanYuYuan

  committed
  dbb39b5

• Add the missing io trait

  YuanYuYuan

  committed
  c56a38b

• Skip those troublesome tests

  YuanYuYuan

  committed
  cad506c

• Remove the unneeded ASYNC_STD_THREAD_COUNT

  YuanYuYuan

  committed
  a9aa656

• Cargo fmt

  YuanYuYuan

  committed
  e35393d

• Use the environmental variable to configure ZRuntime

  YuanYuYuan

  committed
  92ca911

• Cargo fmt

  YuanYuYuan

  committed
  1fea11d

• Tidy up tokio features

  YuanYuYuan

  committed
  80e94e4

• Add the std feature used in zenoh-result

  YuanYuYuan

  committed
  c934201

• Fix matching_status_* failures

  YuanYuYuan

  committed
  f1b2571

• Speed up routing test and work around the failure of three_node_combination test

  YuanYuYuan

  committed
  52677ad

• Halve the chunk size

  YuanYuYuan

  committed
  2e8b1b9

• Cargo clippy

  YuanYuYuan

  committed
  08412a3

• Prevent the race condition

  YuanYuYuan

  committed
  d0af037

• Turn three_node_combination into a sequential test

  YuanYuYuan

  committed
  35cd0d8

• Introduce CancellationToken to terminate anyway

  YuanYuYuan

  committed
  2fb6303

• It turns out to be the large size payload fail the test.

  YuanYuYuan

  committed
  8f21e52

• Fix deadlock by reintroducing five ZRuntimes

  YuanYuYuan

  committed
  5ea6ebd

• Revert the tokio-porting on plugins since it cause a deadlock in routing test

  YuanYuYuan

  committed
  80eeda0

• Adjust the ZRuntime properly to fix the deadlock in routing test

  YuanYuYuan

  committed
  6532eb2

• Align plugins to the main as we would skip them in tokio porting

  YuanYuYuan

  committed
  6051a21

• Apply Luca's patch of object_pool to make it sync only

  YuanYuYuan

  committed
  cffc166

• Fix bug in matching

  YuanYuYuan

  committed
  4eb792a

• Cargo clippy

  YuanYuYuan

  committed
  7869d4e

• Add back TimedEvent to be compatible with plugins

  YuanYuYuan

  committed
  2d27f89

• Fix tests

  YuanYuYuan

  committed
  6b25df1

• Quickfix for plugins

  YuanYuYuan

  committed
  99a6ab4

• Rename token name

  YuanYuYuan

  committed
  3a98ada

• Remove the unused Signal

  YuanYuYuan

  committed
  1f0947a

• Introduce TaskTracker and CancellationToken into zenoh-link-tcp

  YuanYuYuan

  committed
  7d7db2f

• Let's use ZRuntime::Reception to handle accept_task

  YuanYuYuan

  committed
  fe8c4bf

• Refine the testing scripts

  YuanYuYuan

  committed
  bb871e2

• Let CI decide the minimal number of ZRuntime threads

  YuanYuYuan

  committed
  86fdeb2

• Make it easier to pass the test

  YuanYuYuan

  committed
  1f25ea4

• Revert "Let CI decide the minimal number of ZRuntime threads" since this

  Show description for a73bf79
  YuanYuYuan

  committed
  a73bf79

• Cargo fmt & clippy

  YuanYuYuan

  committed
  a5abc53

• Make cargo nextest more resilient

  YuanYuYuan

  committed
  c2faa7f

• Cargo fmt & clippy & doc test

  YuanYuYuan

  committed
  a3dbcec

• Add the missing Windows snippet

  YuanYuYuan

  committed
  90ce0bc

• Fix after rebase

  YuanYuYuan

  committed
  1756d23

• Remove the unneeded async-std

  YuanYuYuan

  committed
  e409ab3

• Rename ZRuntime::Reception to ZRuntime::Acceptor

  YuanYuYuan

  committed
  06f69f0

• Refine the PR

  YuanYuYuan

  committed
  eccf347

• Use tokio::time and slow down the message rate to 500 Hz in the downsampler test

  YuanYuYuan

  committed
  9e08926

• Fix tokio::time and use tokio socket bind_device

  YuanYuYuan

  committed
  c65934e

• Fix cargo clippy

  YuanYuYuan

  committed
  c2cc87c

• Cargo fmt

  YuanYuYuan

  committed
  8624428

• Add the warning of 2ms resolution issue of tokio

  YuanYuYuan

  committed
  6591e75

• Address the unused variables

  YuanYuYuan

  committed
  c3d710b

• Correct the error types

  YuanYuYuan

  committed
  609da62

• Address the platform compiling issue

  YuanYuYuan

  committed
  a012ea2

• Use warning while binding the interface

  YuanYuYuan

  committed
  483cd93

• Fix cargo clippy

  YuanYuYuan

  committed
  20310ee

• Use JoinHandle to manage the listening task

  YuanYuYuan

  committed
  4774c67

• Refine the TODO comments

  YuanYuYuan

  committed
  15f11b9

• Merge branch 'tokio-porting' into PR/tokio-porting

  Mallets

  authored
  d576751