Home
last modified time | relevance | path

Searched refs:GrpcPreconditions (Results 1 – 25 of 51) sorted by relevance

123

/external/grpc-grpc/src/csharp/Grpc.Core/
DGrpcEnvironment.cs92 GrpcPreconditions.CheckState(refCount > 0); in ReleaseAsync()
119 GrpcPreconditions.CheckNotNull(channel); in RegisterChannel()
128 GrpcPreconditions.CheckNotNull(channel); in UnregisterChannel()
129 …GrpcPreconditions.CheckArgument(registeredChannels.Remove(channel), "Channel not found in the regi… in UnregisterChannel()
137 GrpcPreconditions.CheckNotNull(server); in RegisterServer()
146 GrpcPreconditions.CheckNotNull(server); in UnregisterServer()
147 …GrpcPreconditions.CheckArgument(registeredServers.Remove(server), "Server not found in the registe… in UnregisterServer()
194 GrpcPreconditions.CheckNotNull(customLogger, "customLogger"); in SetLogger()
209 …GrpcPreconditions.CheckState(instance == null, "Can only be set before GrpcEnvironment is initiali… in SetThreadPoolSize()
210 … GrpcPreconditions.CheckArgument(threadCount > 0, "threadCount needs to be a positive number"); in SetThreadPoolSize()
[all …]
DMetadata.cs95 GrpcPreconditions.CheckNotNull(item); in Insert()
121 GrpcPreconditions.CheckNotNull(value);
132 GrpcPreconditions.CheckNotNull(item); in Add()
218 GrpcPreconditions.CheckState(!readOnly, "Object is read only"); in CheckWriteable()
249 GrpcPreconditions.CheckArgument(HasBinaryHeaderSuffix(this.key), in Entry()
252 GrpcPreconditions.CheckNotNull(valueBytes, "valueBytes"); in Entry()
265 GrpcPreconditions.CheckArgument(!HasBinaryHeaderSuffix(this.key), in Entry()
267 this.value = GrpcPreconditions.CheckNotNull(value, "value"); in Entry()
308 … GrpcPreconditions.CheckState(!IsBinary, "Cannot access string value of a binary metadata entry");
361 var normalized = GrpcPreconditions.CheckNotNull(key, "key").ToLowerInvariant(); in NormalizeKey()
[all …]
DServer.cs135 GrpcPreconditions.CheckState(!startRequested);
136 GrpcPreconditions.CheckArgument(value > 0);
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()
275 GrpcPreconditions.CheckNotNull(serverPort.Credentials, "serverPort"); in AddPortInternal()
276 GrpcPreconditions.CheckState(!startRequested); in AddPortInternal()
DChannelOptions.cs61 this.name = GrpcPreconditions.CheckNotNull(name, "name"); in ChannelOption()
62 this.stringValue = GrpcPreconditions.CheckNotNull(stringValue, "stringValue"); in ChannelOption()
73 this.name = GrpcPreconditions.CheckNotNull(name, "name"); in ChannelOption()
106 GrpcPreconditions.CheckState(type == OptionType.Integer);
118 GrpcPreconditions.CheckState(type == OptionType.String);
DMethod.cs94 this.serviceName = GrpcPreconditions.CheckNotNull(serviceName, "serviceName"); in Method()
95 this.name = GrpcPreconditions.CheckNotNull(name, "name"); in Method()
96 … this.requestMarshaller = GrpcPreconditions.CheckNotNull(requestMarshaller, "requestMarshaller"); in Method()
97 …this.responseMarshaller = GrpcPreconditions.CheckNotNull(responseMarshaller, "responseMarshaller"); in Method()
DCallInvocationDetails.cs73 this.channel = GrpcPreconditions.CheckNotNull(channel, "channel"); in CallInvocationDetails()
74 this.method = GrpcPreconditions.CheckNotNull(method, "method"); in CallInvocationDetails()
76 … this.requestMarshaller = GrpcPreconditions.CheckNotNull(requestMarshaller, "requestMarshaller"); in CallInvocationDetails()
77 …this.responseMarshaller = GrpcPreconditions.CheckNotNull(responseMarshaller, "responseMarshaller"); in CallInvocationDetails()
DAuthProperty.cs39 this.name = GrpcPreconditions.CheckNotNull(name); in AuthProperty()
40 this.valueBytes = GrpcPreconditions.CheckNotNull(valueBytes); in AuthProperty()
86 GrpcPreconditions.CheckNotNull(valueBytes); in Create()
DClientBase.cs108 this.configuration = GrpcPreconditions.CheckNotNull(configuration, "configuration"); in ClientBase()
161 … this.interceptor = GrpcPreconditions.CheckNotNull(interceptor, nameof(interceptor)); in ClientBaseConfigurationInterceptor()
203 … this.undecoratedCallInvoker = GrpcPreconditions.CheckNotNull(undecoratedCallInvoker); in ClientBaseConfiguration()
214 GrpcPreconditions.CheckNotNull(host, nameof(host)); in WithHost()
DChannelCredentials.cs195 this.channelCredentials = GrpcPreconditions.CheckNotNull(channelCredentials); in CompositeChannelCredentials()
196 this.callCredentials = GrpcPreconditions.CheckNotNull(callCredentials); in CompositeChannelCredentials()
197 …GrpcPreconditions.CheckArgument(channelCredentials.IsComposable, "Supplied channel credentials do … in CompositeChannelCredentials()
DChannel.cs69 this.target = GrpcPreconditions.CheckNotNull(target, "target"); in Channel()
152 GrpcPreconditions.CheckArgument(lastObservedState != ChannelState.Shutdown, in TryWaitForStateChangedAsync()
239 GrpcPreconditions.CheckState(!shutdownRequested); in ShutdownAsync()
290 GrpcPreconditions.CheckState(success); in AddCallReference()
DKeyCertificatePair.cs42 … this.certificateChain = GrpcPreconditions.CheckNotNull(certificateChain, "certificateChain"); in KeyCertificatePair()
43 this.privateKey = GrpcPreconditions.CheckNotNull(privateKey, "privateKey"); in KeyCertificatePair()
DAsyncAuthInterceptor.cs49 this.serviceUrl = GrpcPreconditions.CheckNotNull(serviceUrl); in AuthInterceptorContext()
50 this.methodName = GrpcPreconditions.CheckNotNull(methodName); in AuthInterceptorContext()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DAsyncCallServer.cs42 this.server = GrpcPreconditions.CheckNotNull(server); in AsyncCallServer()
69 GrpcPreconditions.CheckNotNull(call); in ServerSideCallAsync()
103 GrpcPreconditions.CheckNotNull(headers, "metadata"); in SendInitialMetadataAsync()
105 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()
[all …]
DAsyncCallBase.cs68 this.serializer = GrpcPreconditions.CheckNotNull(serializer); in AsyncCallBase()
69 this.deserializer = GrpcPreconditions.CheckNotNull(deserializer); in AsyncCallBase()
79 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()
DDefaultObjectPool.cs56 GrpcPreconditions.CheckArgument(sharedCapacity >= 0); in DefaultObjectPool()
57 GrpcPreconditions.CheckArgument(threadLocalCapacity >= 0); in DefaultObjectPool()
59 this.itemFactory = GrpcPreconditions.CheckNotNull(itemFactory, nameof(itemFactory)); in DefaultObjectPool()
133 GrpcPreconditions.CheckNotNull(item); in Return()
DBatchContextSafeHandle.cs64 GrpcPreconditions.CheckState(returnToPoolAction == null); in SetReturnToPoolAction()
70 GrpcPreconditions.CheckState(completionCallbackData.Callback == null); in SetCompletionCallback()
71 GrpcPreconditions.CheckNotNull(callback, nameof(callback)); in SetCompletionCallback()
DCompletionRegistry.cs47 this.environment = GrpcPreconditions.CheckNotNull(environment); in CompletionRegistry()
48 this.batchContextFactory = GrpcPreconditions.CheckNotNull(batchContextFactory); in CompletionRegistry()
49 … this.requestCallContextFactory = GrpcPreconditions.CheckNotNull(requestCallContextFactory); in CompletionRegistry()
DTimespec.cs129 GrpcPreconditions.CheckState(tv_nsec >= 0 && tv_nsec < NanosPerSecond); in ToDateTime()
130 GrpcPreconditions.CheckState(clock_type == ClockType.Realtime); in ToDateTime()
183 …GrpcPreconditions.CheckArgument(dateTime.Kind == DateTimeKind.Utc, "dateTime needs of kind DateTim… in FromDateTime()
/external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/
DServerServiceDefinitionExtensions.cs45 … GrpcPreconditions.CheckNotNull(serverServiceDefinition, nameof(serverServiceDefinition)); in Intercept()
46 GrpcPreconditions.CheckNotNull(interceptor, nameof(interceptor)); in Intercept()
68 … GrpcPreconditions.CheckNotNull(serverServiceDefinition, nameof(serverServiceDefinition)); in Intercept()
69 GrpcPreconditions.CheckNotNull(interceptors, nameof(interceptors)); in Intercept()
DCallInvokerExtensions.cs66 GrpcPreconditions.CheckNotNull(invoker, nameof(invoker)); in Intercept()
67 GrpcPreconditions.CheckNotNull(interceptors, nameof(interceptors)); in Intercept()
106 this.interceptor = GrpcPreconditions.CheckNotNull(interceptor, nameof(interceptor)); in MetadataInterceptor()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DClientRunners.cs51 GrpcPreconditions.CheckNotNull(profiler); in AddProfiler()
89 … GrpcPreconditions.CheckArgument(clientChannels > 0, "clientChannels needs to be at least 1."); in CreateChannels()
90 …GrpcPreconditions.CheckArgument(serverTargets.Count() > 0, "at least one serverTarget needs to be … in CreateChannels()
139 … GrpcPreconditions.CheckArgument(outstandingRpcsPerChannel > 0, "outstandingRpcsPerChannel"); in ClientRunnerImpl()
140 GrpcPreconditions.CheckNotNull(histogramParams, "histogramParams"); in ClientRunnerImpl()
311 …GrpcPreconditions.CheckArgument(clientType == ClientType.AsyncClient, "Generic client only support… in RunClientAsync()
312 …GrpcPreconditions.CheckArgument(rpcType == RpcType.Streaming, "Generic client only supports stream… in RunClientAsync()
316 GrpcPreconditions.CheckNotNull(payloadConfig.SimpleParams); in RunClientAsync()
319 …GrpcPreconditions.CheckArgument(rpcType == RpcType.Unary, "Sync client can only be used for Unary … in RunClientAsync()
338 GrpcPreconditions.CheckNotNull(payloadConfig.SimpleParams); in CreateSimpleRequest()
DStressTestClient.cs84 GrpcPreconditions.CheckArgument(options.NumChannelsPerServer > 0); in Run()
85 GrpcPreconditions.CheckArgument(options.NumStubsPerChannel > 0); in Run()
88 …GrpcPreconditions.CheckArgument(serverAddresses.Length > 0, "You need to provide at least one serv… in Run()
91 …GrpcPreconditions.CheckArgument(testCases.Count > 0, "You need to provide at least one test case"); in Run()
204 GrpcPreconditions.CheckArgument(parts.Length == 2, "Malformed test_cases option."); in ParseWeightedTestCases()
DWorkerServiceImpl.cs39 this.stopRequestHandler = GrpcPreconditions.CheckNotNull(stopRequestHandler); in WorkerServiceImpl()
44 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunServer()
68 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunClient()
DHistogram.cs54 GrpcPreconditions.CheckArgument(resolution > 0); in Histogram()
55 GrpcPreconditions.CheckArgument(maxPossible > 0); in Histogram()
119 …GrpcPreconditions.CheckArgument(mergeTo.Bucket.Count == 0 || mergeTo.Bucket.Count == buckets.Lengt… in GetSnapshotUnsafe()

123