MCPcopy Create free account

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

⨍ Functions 22,628◇ Types & classes 3,835
↓ 1 callersMethodhttp2ProcessingFailed
Called to process a failure in HTTP/2 processing.
netty/src/main/java/io/grpc/netty/NettyServerStream.java:223
↓ 1 callersMethodhttp2ProcessingFailed
(Status status, boolean stopDelivery, Metadata trailers)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:290
↓ 1 callersMethodhttp2Stream
Gets the underlying Netty {@link Http2Stream} for this stream.
netty/src/main/java/io/grpc/netty/NettyClientStream.java:283
↓ 1 callersMethodhttpMaxStreamDurationNano
()
xds/src/main/java/io/grpc/xds/HttpConnectionManager.java:33
↓ 1 callersMethodhttpStatusToGrpcCode
(int httpStatusCode)
core/src/main/java/io/grpc/internal/GrpcUtil.java:305
↓ 1 callersMethodhttpUrl
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/Request.java:35
↓ 1 callersMethodidleTimeout
(long value, TimeUnit unit)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:486
↓ 1 callersMethodidleTimeout
Set the duration without ongoing RPCs before going to idle mode. <p>In idle mode the channel shuts down all connections, the NameResolver and the Loa
api/src/main/java/io/grpc/ManagedChannelBuilder.java:322
↓ 1 callersMethodignoreClose
Decorates the given {@link ReadableBuffer} to ignore calls to {@link ReadableBuffer#close}. @param buffer the buffer to be decorated. @return a wrapp
core/src/main/java/io/grpc/internal/ReadableBuffers.java:119
↓ 1 callersMethodinboundDataReceived
Called in the transport thread to process the content of an inbound DATA frame from the client. @param frame the inbound HTTP/2 DATA frame. If this b
core/src/main/java/io/grpc/internal/AbstractServerStream.java:275
↓ 1 callersMethodinboundDataReceived
( Buffer frame, int dataLength, int paddingLength, boolean endOfStream)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1193
↓ 1 callersMethodinboundDataShouldForwardToStreamListener
()
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:267
↓ 1 callersMethodinboundMessage
See {@link StreamTracer#inboundMessage(int)}. <p>Called from {@link io.grpc.internal.MessageDeframer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:200
↓ 1 callersMethodinboundMessageRead
See {@link StreamTracer#inboundMessageRead}. <p>Called from {@link io.grpc.internal.MessageDeframer}.
core/src/main/java/io/grpc/internal/StatsTraceContext.java:222
↓ 1 callersMethodinboundMessageShouldCallListener
()
netty/src/test/java/io/grpc/netty/NettyClientStreamTest.java:291
↓ 1 callersMethodinboundRstReceived
Must be holding 'lock' when calling.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1169
↓ 1 callersMethodinboundWindowAvailable
Must be holding 'lock' when calling.
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerTransport.java:1163
↓ 1 callersMethodincrementAndGetNextStreamId
()
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1040
↓ 1 callersMethodincrementDataSincePing
(int increase)
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:243
↓ 1 callersMethodincrementInCounterForTesting
(int n)
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:156
↓ 1 callersMethodincrementNumWrites
()
okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:198
↓ 1 callersMethodincrementOutCounterForTesting
(int n)
alts/src/main/java/io/grpc/alts/internal/AltsChannelCrypter.java:163
↓ 1 callersMethodincrementReceiveState
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiHandshaker.java:138
↓ 1 callersMethodincrementSendState
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiHandshaker.java:134
↓ 1 callersMethodindexOfKey
(K key)
api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:165
↓ 1 callersMethodinet6AddressToAscii
(byte[] address)
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/proxy/HttpUrl.java:359
↓ 1 callersMethodinflate
(byte[] b, int off, int len)
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:413
↓ 1 callersMethodinit
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:291
↓ 1 callersMethodinit
(SubchannelStateListener listener)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:294
↓ 1 callersMethodinitJndi
Returns whether the JNDI DNS resolver is available. This is accomplished by looking up a particular class. It is believed to be the default (only?)
core/src/main/java/io/grpc/internal/JndiResourceResolverFactory.java:59
↓ 1 callersMethodinitLastMetricsCollectionTime
()
interop-testing/src/main/java/io/grpc/testing/integration/StressTestClient.java:517
↓ 1 callersMethodinitTransportTracer
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:409
↓ 1 callersMethodinitWriteQueue
()
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:370
↓ 1 callersMethodinitialConnectionSpec
()
okhttp/src/main/java/io/grpc/okhttp/OkHttpChannelBuilder.java:211
↓ 1 callersMethodinitialize
()
core/src/main/java/io/grpc/internal/ApplicationThreadDeframer.java:149
↓ 1 callersMethodinitializeInflater
()
core/src/main/java/io/grpc/internal/GzipInflatingBuffer.java:396
↓ 1 callersMethodinitializeTestKeyData
()
alts/src/test/java/io/grpc/alts/internal/MockAltsHandshakerResp.java:48
↓ 1 callersMethodinitiateEchos
(List<String> valuesToSend)
examples/src/main/java/io/grpc/examples/multiplex/SharingClient.java:94
↓ 1 callersMethodinstallAuthInterceptor
Install a security policy on an about-to-be created server. @param serverBuilder The ServerBuilder being used to create the server.
binder/src/main/java/io/grpc/binder/internal/BinderTransportSecurity.java:59
↓ 1 callersMethodinstallConscryptIfAvailable
Add Conscrypt to the list of security providers, if it is available. If it appears to be available but fails to load, this method will throw an except
testing/src/main/java/io/grpc/internal/testing/TestUtils.java:148
↓ 1 callersMethodinterceptForward
Create a new {@code ServerServiceDefinition} whose {@link ServerCallHandler}s will call {@code interceptors} before calling the pre-existing {@code Se
api/src/main/java/io/grpc/ServerInterceptors.java:43
↓ 1 callersMethodinterceptWithTarget
(InterceptorFactory factory)
core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java:405
↓ 1 callersMethodinterceptWithTarget
( ManagedChannelBuilder<T> builder, InternalInterceptorFactory factory)
api/src/main/java/io/grpc/InternalManagedChannelBuilder.java:26
↓ 1 callersMethodinternalStart
()
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:196
↓ 1 callersMethodinvalidateAll
Invalidates cache entries for all keys. This operation will trigger {@link EvictionListener} with {@link EvictionType#EXPLICIT}.
rls/src/main/java/io/grpc/rls/LruCache.java:55
↓ 1 callersMethodinvalidateAll
()
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:183
↓ 1 callersMethodinvoke
Invokes the method on {@code target} with {@code args}. Throws an error if the method is not supported. See also {@link #invokeWithoutCheckedException
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OptionalMethod.java:111
↓ 1 callersMethodinvokeIteratorCallable
( String callableClassName, ClassLoader cl)
api/src/test/java/io/grpc/ServiceProvidersTestUtil.java:73
↓ 1 callersMethodipAddressesMatch
(String ldsAddress)
xds/src/main/java/io/grpc/xds/XdsServerWrapper.java:499
↓ 1 callersMethodisAbeforeB
(@Nullable Deadline a, @Nullable Deadline b)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:87
↓ 1 callersMethodisApplicationHeader
(String key)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:362
↓ 1 callersMethodisAscii
Returns true if {@code input} is an ASCII string. @param input the string to check.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/OkHostnameVerifier.java:268
↓ 1 callersMethodisAtLeastAndroid41
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java:272
↓ 1 callersMethodisAtLeastAndroid5
()
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/Platform.java:260
↓ 1 callersMethodisAvailable
Returns true if the environment supports LongAdder. In other words, we are running in >= JDK8.
core/src/main/java/io/grpc/internal/ReflectionLongAdderCounter.java:96
↓ 1 callersMethodisAvailable
(ManagedChannelProvider provider)
api/src/main/java/io/grpc/InternalManagedChannelProvider.java:28
↓ 1 callersMethodisAvailable
()
netty/src/main/java/io/grpc/netty/UdsNettyChannelProvider.java:33
↓ 1 callersMethodisCancelled
Returns {@code true} when the call is cancelled and the server is encouraged to abort processing to save resources, since the client will not be proce
api/src/main/java/io/grpc/ServerCall.java:187
↓ 1 callersMethodisCancelled
()
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:194
↓ 1 callersMethodisChannelCached
()
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactoryTest.java:255
↓ 1 callersMethodisClosed
()
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:161
↓ 1 callersMethodisClosed
Return {@code true} if {@code #awaitClose} would return immediately with a status.
core/src/testFixtures/java/io/grpc/internal/ClientStreamListenerBase.java:49
↓ 1 callersMethodisClosedOrScheduledToClose
Returns true if this deframer has already been closed or scheduled to close.
core/src/main/java/io/grpc/internal/MessageDeframer.java:245
↓ 1 callersMethodisCompletedConnectivityAttempt
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:877
↓ 1 callersMethodisDirectPathCluster
(String clusterName)
alts/src/main/java/io/grpc/alts/internal/AltsProtocolNegotiator.java:317
↓ 1 callersMethodisDone
()
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:564
↓ 1 callersMethodisEnabled
(Runnable r)
core/src/main/java/io/grpc/internal/Rescheduler.java:108
↓ 1 callersMethodisEnabledXdsDualStack
()
xds/src/main/java/io/grpc/xds/XdsEndpointResource.java:111
↓ 1 callersMethodisFakeWriterClosed
()
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:176
↓ 1 callersMethodisGet
()
netty/src/main/java/io/grpc/netty/CreateStreamCommand.java:54
↓ 1 callersMethodisHalfClosed
()
core/src/testFixtures/java/io/grpc/internal/ServerStreamListenerBase.java:57
↓ 1 callersMethodisHedging
Whether the stream is hedging. @since 1.74.0
api/src/main/java/io/grpc/ClientStreamTracer.java:176
↓ 1 callersMethodisHttp11ProxyAvailable
()
xds/src/main/java/io/grpc/xds/XdsClusterResource.java:622
↓ 1 callersMethodisInBackoffPeriod
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:827
↓ 1 callersMethodisInPanicMode
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:780
↓ 1 callersMethodisInProgress
()
alts/src/test/java/io/grpc/alts/internal/FakeTsiHandshaker.java:202
↓ 1 callersMethodisIndexValid
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:853
↓ 1 callersMethodisNameLongEnough
(HelloRequest req)
examples/src/main/java/io/grpc/examples/healthservice/HealthServiceServer.java:136
↓ 1 callersMethodisOldEnoughToBeEvicted
(long now)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:669
↓ 1 callersMethodisPassComplete
()
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java:606
↓ 1 callersMethodisPersisted
Returns true if this setting was persisted.
okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/Settings.java:227
↓ 1 callersMethodisPingAllowed
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:278
↓ 1 callersMethodisPinging
()
netty/src/main/java/io/grpc/netty/AbstractNettyHandler.java:228
↓ 1 callersMethodisReady
()
core/src/main/java/io/grpc/internal/RetriableStream.java:634
↓ 1 callersMethodisReady
()
core/src/main/java/io/grpc/internal/AbstractStream.java:296
↓ 1 callersMethodisReady
()
binder/src/main/java/io/grpc/binder/internal/Outbound.java:197
↓ 1 callersMethodisReady
Returns whether this transport is able to send rpc transactions. Intentionally unsynchronized since this will be called while Outbound is held.
binder/src/main/java/io/grpc/binder/internal/BinderTransport.java:244
↓ 1 callersMethodisReady
()
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:176
↓ 1 callersMethodisReady
()
xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java:235
↓ 1 callersMethodisRegularTlsAndClientSide
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertProviderSslContextProvider.java:202
↓ 1 callersMethodisRegularTlsAndServerSide
()
xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertProviderSslContextProvider.java:206
↓ 1 callersMethodisRetryable
()
auth/src/test/java/io/grpc/auth/GoogleAuthLibraryCallCredentialsTest.java:497
↓ 1 callersMethodisRunningOnGcp
()
alts/src/main/java/io/grpc/alts/InternalCheckGcpEnvironment.java:74
↓ 1 callersMethodisServiceGlob
Returns true if the input string is a glob of the form: {@code <package-service>/ }.
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:781
↓ 1 callersMethodisShutdown
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:790
↓ 1 callersMethodisSpecCompliantAscii
Returns {@code true} if {@code subject} contains only bytes that are spec-compliant ASCII characters and space.
core/src/main/java/io/grpc/internal/TransportFrameUtil.java:170
↓ 1 callersMethodisSpecificExecutorRequired
()
api/src/main/java/io/grpc/InternalMayRequireSpecificExecutor.java:21
↓ 1 callersMethodisStaled
(long now)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:769
↓ 1 callersMethodisTerminated
()
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:800
↓ 1 callersMethodisTraceEnabled
()
core/src/main/java/io/grpc/internal/ChannelTracer.java:109
← previousnext →6,701–6,800 of 22,628, ranked by callers