|
|
@ -140,6 +140,7 @@ namespace Grpc.Core |
|
|
|
lock (myLock) |
|
|
|
lock (myLock) |
|
|
|
{ |
|
|
|
{ |
|
|
|
GrpcPreconditions.CheckState(!startRequested); |
|
|
|
GrpcPreconditions.CheckState(!startRequested); |
|
|
|
|
|
|
|
GrpcPreconditions.CheckState(!shutdownRequested); |
|
|
|
startRequested = true; |
|
|
|
startRequested = true; |
|
|
|
|
|
|
|
|
|
|
|
handle.Start(); |
|
|
|
handle.Start(); |
|
|
@ -203,7 +204,6 @@ namespace Grpc.Core |
|
|
|
{ |
|
|
|
{ |
|
|
|
lock (myLock) |
|
|
|
lock (myLock) |
|
|
|
{ |
|
|
|
{ |
|
|
|
GrpcPreconditions.CheckState(startRequested); |
|
|
|
|
|
|
|
GrpcPreconditions.CheckState(!shutdownRequested); |
|
|
|
GrpcPreconditions.CheckState(!shutdownRequested); |
|
|
|
shutdownRequested = true; |
|
|
|
shutdownRequested = true; |
|
|
|
} |
|
|
|
} |
|
|
@ -215,7 +215,6 @@ namespace Grpc.Core |
|
|
|
{ |
|
|
|
{ |
|
|
|
handle.CancelAllCalls(); |
|
|
|
handle.CancelAllCalls(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
await ShutdownCompleteOrEnvironmentDeadAsync().ConfigureAwait(false); |
|
|
|
await ShutdownCompleteOrEnvironmentDeadAsync().ConfigureAwait(false); |
|
|
|
|
|
|
|
|
|
|
|
DisposeHandle(); |
|
|
|
DisposeHandle(); |
|
|
|