Home
last modified time | relevance | path

Searched refs:ShuttingDown (Results 1 – 5 of 5) sorted by relevance

/external/rust/crates/tokio/src/io/util/
Dcopy_bidirectional.rs12 ShuttingDown(u64), enumerator
40 *state = TransferState::ShuttingDown(count); in transfer_one_direction()
42 TransferState::ShuttingDown(count) => { in transfer_one_direction()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DGrpcEnvironmentTest.cs86 GrpcEnvironment.ShuttingDown += handler; in ShuttingDownEventIsFired()
89 GrpcEnvironment.ShuttingDown -= handler; in ShuttingDownEventIsFired()
/external/crosvm/cros_async/src/blocking/
Dcancellable_pool.rs38 ShuttingDown, enumerator
291 if state.wind_down == WindDownStates::ShuttingDown { in shutdown_with_timeout()
297 state.wind_down = WindDownStates::ShuttingDown; in shutdown_with_timeout()
/external/rust/crates/tokio/src/runtime/blocking/
Dpool.rs136 ShuttingDown, enumerator
145 SpawnError::ShuttingDown => { in from()
307 Err(SpawnError::ShuttingDown) => join_handle, in spawn_blocking()
398 return Err(SpawnError::ShuttingDown); in spawn_task()
/external/grpc-grpc/src/csharp/Grpc.Core/
DGrpcEnvironment.cs295 public static event EventHandler ShuttingDown; event in Grpc.Core.GrpcEnvironment
395 await Task.Run(() => ShuttingDown?.Invoke(this, null)).ConfigureAwait(false); in ShutdownAsync()