Home
last modified time | relevance | path

Searched refs:CheckState (Results 1 – 16 of 16) sorted by relevance

/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DAsyncCallServer.cs105 GrpcPreconditions.CheckState(started); in SendInitialMetadataAsync()
106 …GrpcPreconditions.CheckState(!initialMetadataSent, "Response headers can only be sent once per cal… in SendInitialMetadataAsync()
107 …GrpcPreconditions.CheckState(streamingWritesCounter == 0, "Response headers can only be sent befor… in SendInitialMetadataAsync()
137 GrpcPreconditions.CheckState(started); in SendStatusFromServerAsync()
138 GrpcPreconditions.CheckState(!disposed); in SendStatusFromServerAsync()
139 … GrpcPreconditions.CheckState(!halfcloseRequested, "Can only send status from server once."); in SendStatusFromServerAsync()
194 … GrpcPreconditions.CheckState(!halfcloseRequested, "Response stream has already been completed."); in CheckSendAllowedOrEarlyResult()
195 GrpcPreconditions.CheckState(!finished, "Already finished."); in CheckSendAllowedOrEarlyResult()
196 …GrpcPreconditions.CheckState(streamingWriteTcs == null, "Only one write can be pending at a time"); in CheckSendAllowedOrEarlyResult()
197 GrpcPreconditions.CheckState(!disposed); in CheckSendAllowedOrEarlyResult()
DAsyncCallBase.cs79 GrpcPreconditions.CheckState(started); in Cancel()
122 GrpcPreconditions.CheckState(started); in SendMessageInternalAsync()
145 GrpcPreconditions.CheckState(started); in ReadMessageInternalAsync()
150 … GrpcPreconditions.CheckState(streamingReadTcs != null, "Call does not support streaming reads."); in ReadMessageInternalAsync()
154 … GrpcPreconditions.CheckState(streamingReadTcs == null, "Only one read can be pending at a time"); in ReadMessageInternalAsync()
155 GrpcPreconditions.CheckState(!disposed); in ReadMessageInternalAsync()
248 GrpcPreconditions.CheckState(!isStreamingWriteCompletionDelayed); in HandleSendFinished()
274 … GrpcPreconditions.CheckState(finished); // implied by !success && !delayCompletion && IsClient in HandleSendFinished()
DAsyncCall.cs90 GrpcPreconditions.CheckState(!started); in UnaryCall()
155 GrpcPreconditions.CheckState(!started); in UnaryCallAsync()
195 GrpcPreconditions.CheckState(!started); in ClientStreamingCallAsync()
231 GrpcPreconditions.CheckState(!started); in StartServerStreamingCall()
269 GrpcPreconditions.CheckState(!started); in StartDuplexStreamingCall()
316 GrpcPreconditions.CheckState(started); in SendCloseFromClientAsync()
370 …GrpcPreconditions.CheckState(finishedStatus.HasValue, "Status can only be accessed once the call h… in GetStatus()
383 …GrpcPreconditions.CheckState(finishedStatus.HasValue, "Trailers can only be accessed once the call… in GetTrailers()
450 … GrpcPreconditions.CheckState(!halfcloseRequested, "Request stream has already been completed."); in CheckSendPreconditionsClientSide()
451 …GrpcPreconditions.CheckState(streamingWriteTcs == null, "Only one write can be pending at a time."… in CheckSendPreconditionsClientSide()
DBatchContextSafeHandle.cs64 GrpcPreconditions.CheckState(returnToPoolAction == null); in SetReturnToPoolAction()
70 GrpcPreconditions.CheckState(completionCallbackData.Callback == null); in SetCompletionCallback()
DTimespec.cs129 GrpcPreconditions.CheckState(tv_nsec >= 0 && tv_nsec < NanosPerSecond); in ToDateTime()
130 GrpcPreconditions.CheckState(clock_type == ClockType.Realtime); in ToDateTime()
DGrpcThreadPool.cs79 GrpcPreconditions.CheckState(completionQueues == null, "Already started."); in Start()
94 GrpcPreconditions.CheckState(!stopRequested, "Stop already requested."); in StopAsync()
DCompletionQueueSafeHandle.cs108 GrpcPreconditions.CheckState(success, "Shutdown has already been called"); in BeginOp()
DRequestCallContextSafeHandle.cs56 GrpcPreconditions.CheckState(returnToPoolAction == null); in SetReturnToPoolAction()
DPlatformApis.cs173 GrpcPreconditions.CheckState(IsUnity, "Not running on Unity."); in GetUnityRuntimePlatform()
/external/grpc-grpc/src/csharp/Grpc.Core/
DServer.cs135 GrpcPreconditions.CheckState(!startRequested);
150 GrpcPreconditions.CheckState(!startRequested); in Start()
151 GrpcPreconditions.CheckState(!shutdownRequested); in Start()
198 GrpcPreconditions.CheckState(success); in AddCallReference()
214 GrpcPreconditions.CheckState(!shutdownRequested); in ShutdownInternalAsync()
259 GrpcPreconditions.CheckState(!startRequested); in AddServiceDefinitionInternal()
276 GrpcPreconditions.CheckState(!startRequested); in AddPortInternal()
DGrpcEnvironment.cs92 GrpcPreconditions.CheckState(refCount > 0); in ReleaseAsync()
209 …GrpcPreconditions.CheckState(instance == null, "Can only be set before GrpcEnvironment is initiali… in SetThreadPoolSize()
226 …GrpcPreconditions.CheckState(instance == null, "Can only be set before GrpcEnvironment is initiali… in SetCompletionQueueCount()
246 …GrpcPreconditions.CheckState(instance == null, "Can only be set before GrpcEnvironment is initiali… in SetHandlerInlining()
263 …GrpcPreconditions.CheckState(instance == null, "Can only be set before GrpcEnvironment is initiali… in SetBatchContextPoolParams()
283 …GrpcPreconditions.CheckState(instance == null, "Can only be set before GrpcEnvironment is initiali… in SetRequestCallContextPoolParams()
DChannelOptions.cs106 GrpcPreconditions.CheckState(type == OptionType.Integer);
118 GrpcPreconditions.CheckState(type == OptionType.String);
DMetadata.cs218 GrpcPreconditions.CheckState(!readOnly, "Object is read only"); in CheckWriteable()
308 … GrpcPreconditions.CheckState(!IsBinary, "Cannot access string value of a binary metadata entry");
DChannel.cs239 GrpcPreconditions.CheckState(!shutdownRequested); in ShutdownAsync()
290 GrpcPreconditions.CheckState(success); in AddCallReference()
/external/grpc-grpc/src/csharp/Grpc.Core/Utils/
DGrpcPreconditions.cs84 public static void CheckState(bool condition) in CheckState() method in Grpc.Core.Utils.GrpcPreconditions
97 public static void CheckState(bool condition, string errorMessage) in CheckState() method in Grpc.Core.Utils.GrpcPreconditions
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DWorkerServiceImpl.cs44 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunServer()
68 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunClient()