3369 Commits

Author SHA1 Message Date
Alice Ryhl
a26fc9c9f9
chore: prepare Tokio v1.28.1 (#5679) tokio-1.28.1 2023-05-10 10:44:04 +02:00
Dirkjan Ochtman
f2d033e454
build: fix warnings in AS_FD_PROBE (#5677) 2023-05-09 21:57:35 +02:00
Alice Ryhl
f21d596099
chore: prepare Tokio v1.28.0 (#5650) tokio-1.28.0 2023-04-25 20:21:00 +02:00
Alice Ryhl
66c62a4b74
chore: prepare tokio-macros v2.1.0 (#5649) tokio-macros-2.1.0 2023-04-25 17:07:08 +02:00
Predrag Gruevski
a86c052218
ci: use cargo-semver-checks GitHub Action (#5648) 2023-04-25 00:17:17 +02:00
Debadree Chatterjee
c1778eda38
sync: add watch::Receiver::wait_for (#5611) 2023-04-24 15:48:07 +02:00
Fergus Mitchell
11b8807544
sync: improve Debug impl for RwLock (#5647) 2023-04-24 15:39:42 +02:00
jrray
e789b61424
stream: add StreamExt::timeout_repeating (#5577) 2023-04-24 09:27:24 +02:00
Burkhard Mittelbach
2cd4f4ab46
stream: add "full" feature flag (#5639) 2023-04-23 13:59:49 +02:00
Taiki Endo
b6bbe5f487
Revert "macros: hide internal constant in select! macro (#5617)" (#5637)
This reverts commit cf9a03c107ea523480e03234aff422905abaf8d7.
2023-04-23 20:38:50 +09:00
Denis Kayshev
57ba4a4b10
sync: fix typo in Semaphore::MAX_PERMITS (#5645) 2023-04-22 18:52:07 +02:00
Alice Ryhl
5e6c6bdafd
chore: fix compiler output changes in rustc 1.69 (#5643) 2023-04-21 07:10:55 +00:00
Alice Ryhl
77e3911806
chore: remove ntapi dev-dependency (#5642) 2023-04-21 08:38:46 +02:00
Alice Ryhl
b9868b23aa
rt: fix spurious yield_defers_until_park test (#5634) 2023-04-20 18:00:33 +02:00
Adam Chalmers
623483c81f
docs: fix typo in #[tokio::test] docs (#5636)
Both current- and multi-thread runtime claimed to be the default, but only current thread actually is.
2023-04-20 14:12:43 +00:00
Sigurd
5cef6eba7b
sync: improve CancellationToken doc on child tokens (#5632) 2023-04-19 17:42:32 +02:00
Tymoteusz Wiśniewski
db543639e1
sync: reduce contention in Notify (#5503) 2023-04-19 13:07:10 +02:00
isabelleatkins
9f9e596eec
time: fix panic in DelayQueue (#5630) 2023-04-17 20:51:42 +00:00
Jake Goulding
f6cb6e084b
task: add JoinSet::spawn_blocking (#5612) 2023-04-17 08:20:27 +00:00
Timmy Xiao
7aea597a8f
io: make read_to_end not grow unnecessarily (#5610) 2023-04-16 20:23:53 +02:00
Aviram Hassan
9507f8b374
stream: add StreamNotifyClose (#4851) 2023-04-16 15:04:00 +00:00
Folkert de Vries
6037faeede
io: add AsyncFd::async_io (#5542) 2023-04-16 16:27:58 +02:00
Tymoteusz Wiśniewski
8497f379b5
sync: avoid deadlocks in broadcast with custom wakers (#5578) 2023-04-16 16:22:38 +02:00
Hayden Stainsby
1b22cbfd33
readme: update clippy version in contrib guide (#5623)
In CI, we are using a newer version of Clippy than what is stated in the
contributions guide.

Additionally, it is no longer necessary to use Clippy from the MSRV. As
of Clippy 1.64, the `rust-version` field in Cargo.toml is respected.

The text and the command have been updated to reflect the current state
of CI and best practices.
2023-04-16 15:46:01 +02:00
Jens Reidel
effead29d1
time: add DelayQueue::peek (#5569)
Signed-off-by: Jens Reidel <adrian@travitia.xyz>
2023-04-16 09:43:03 +02:00
Alexander van Ratingen
3b16564ce0
sync: add OwnedSemaphorePermit::semaphore (#5618) 2023-04-15 20:55:39 +02:00
John-John Tedro
fc1e03f91b
macros: make entrypoints more efficient (#5621) 2023-04-15 20:55:00 +02:00
John-John Tedro
ea5d448ee8
ci: gate costly checks behind basic ones (#5622) 2023-04-15 20:16:42 +02:00
Iron(III) Oxide
abc93f615e
fuzz: fix fuzz warnings (#5614) 2023-04-13 16:07:12 +02:00
mTsBucy1
cf9a03c107
macros: hide internal constant in select! macro (#5617) 2023-04-12 21:32:38 +09:00
Alice Ryhl
3b45e8614d
stream: update StreamMap fuzz test (#5600)
This fuzz test touches some quadratic time code paths. This changes the
test to limit the test size so that the test doesn't time out.
2023-04-11 10:40:10 +02:00
Alice Ryhl
b02c550c52
ci: fix FreeBSD ci (#5613) 2023-04-10 15:26:59 +02:00
Oddbjørn Grødem
03912b9cf7
sync: add same_channel to broadcast channel (#5607) 2023-04-07 14:18:47 +02:00
Daniel Sedlak
d4afbad6e5
tokio: fix typos (#5604) 2023-04-06 14:29:12 +02:00
Daniel Netzer
b1ca0d8b12
ci: fix typo in ci.yml (#5599) 2023-04-05 09:35:47 +00:00
Iron(III) Oxide
16cdb109f4
io: impl BufMut for ReadBuf (#5590) 2023-04-04 22:00:41 +02:00
Taiki Endo
88445e762c
deps: update windows-sys to 0.48 (#5591) 2023-04-02 09:31:27 +02:00
teor
3c403d6ee8
coop: fix typo in poll_proceed() doc comment (#5589) 2023-03-30 13:25:05 +02:00
Dmitry Rodionov
d63d659078
sync: fix typo in tokio::sync::Sender docs (#5587) 2023-03-29 18:05:24 +00:00
Flavio Bizzarri
b31f1a4662
net: add recv_buf for UdpSocket and UnixDatagram (#5583) 2023-03-28 18:17:22 +00:00
Qiu Chaofan
663e56e983
net: support AIX get_peer_cred (#5065) 2023-03-28 11:25:12 +02:00
Alice Ryhl
1df874ead4
chore: prepare Tokio v1.27.0 (#5584) tokio-1.27.0 2023-03-27 23:55:48 +02:00
Alice Ryhl
614fe357fc
chore: prepare tokio-macros v2.0.0 (#5580) tokio-macros-2.0.0 2023-03-27 22:45:54 +02:00
sgasse
68b02db154
time: fix wake-up with interval on Ready (#5553)
When `tokio::time::Interval::poll_tick()` returns `Poll::Pending`, it
schedules itself for being woken up again through the waker of the
passed context, which is correct behavior.

However when `Poll::Ready(_)` is returned, the interval timer should be
reset but not scheduled to be woken up again as this is up to the
caller.

This commit fixes the bug by introducing a `reset_without_reregister`
method on `TimerEntry` which is called by `Intervall::poll_tick(cx)` in
case the delay poll returns `Poll::Ready(_)`.

Co-authored-by: Simon B. Gasse <sgasse@users.noreply.github.com>
2023-03-27 17:39:53 +02:00
Alice Ryhl
822af18cf5
sync: fix Semaphore::MAX_PERMITS test (#5582) 2023-03-25 18:09:05 +00:00
David Pedersen
92d33b7181
macros: update syn (#5572) 2023-03-23 23:38:59 +01:00
Marcelo Diop-Gonzalez
1cb7bf11b3
time: clean up redundant check in Wheel::poll() (#5574)
The condition checked in the and_then() call is the same as is checked
in the match below, so we can clean it up by just matching on
next_expiration() directly.
2023-03-23 09:53:54 -07:00
João Marcos
768ede65c1
io: refer to ReaderStream and StreamReader in module docs (#5576) 2023-03-23 15:31:40 +00:00
João Marcos
54a394696f
io: add details to docs of tokio::io::copy[_buf] (#5575) 2023-03-23 15:19:51 +00:00
Hayden Stainsby
35dd635630
tracing: fix spawn_blocking location fields (#5573)
In a previous PR (#4128), the `spawn.location` field on task spans was
structured into 3 separate fields for the `file`, `line`, and `col`.
There is a separately created span for blocking tasks which was missed.

This caused tasks created with `spawn_blocking` to appear in
`tokio-console` without a location, but with an additional "free form"
field containing the formatted source code location.

This change modifies this span to use the same format. The span creation
needs to be separate from the other task spans because it records the
function name. This information is useful in the `spawn_blocking` case,
but can be "catastrophically long" in the `async fn` case and was
removed in #3074.
2023-03-22 22:08:01 +01:00