Functions — github.com/grpc/grpc-java

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

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

⨍ Functions 22,628◇ Types & classes 3,835

↓ 3 callersMethodstartLrsRpc

()

xds/src/main/java/io/grpc/xds/client/LoadReportClient.java:162

↓ 3 callersMethodstartRecvMessage

Requests a message to be received.

xds/src/main/java/io/grpc/xds/client/XdsTransportFactory.java:57

↓ 3 callersMethodstartRpc

()

services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:349

↓ 3 callersMethodstartRpc

()

xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:401

↓ 3 callersMethodstartRpcStream

()

xds/src/main/java/io/grpc/xds/client/ControlPlaneClient.java:277

↓ 3 callersMethodstdevFactor

()

xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:424

↓ 3 callersMethodstopDelivery

Sets a flag to interrupt delivery of any currently queued messages. This may be invoked outside of the deframing thread, and must be followed by a cal

core/src/main/java/io/grpc/internal/MessageDeframer.java:204

↓ 3 callersMethodstopEchos

(List<Future<?>> echos)

examples/src/main/java/io/grpc/examples/cancellation/CancellationServer.java:142

↓ 3 callersMethodstopIfNecessary

When the transport is in goAway state, we should stop it once all active streams finish.

cronet/src/main/java/io/grpc/cronet/CronetClientTransport.java:257

↓ 3 callersMethodstopLoadReportingInSyncContext

()

xds/src/test/java/io/grpc/xds/LoadReportClientTest.java:627

↓ 3 callersMethodstreamClosed

(Status status)

grpclb/src/main/java/io/grpc/grpclb/GrpclbClientLoadRecorder.java:146

↓ 3 callersMethodstreamClosed

Stream is closed. This will be called exactly once.

api/src/main/java/io/grpc/StreamTracer.java:31

↓ 3 callersMethodstreamCoreMetrics

(com.github.xds.service.orca.v3.OrcaLoadReportRequest request, io.grpc.stub.StreamObserver<com.github.

xds/src/generated/thirdparty/grpc/com/github/xds/service/orca/v3/OpenRcaServiceGrpc.java:131

↓ 3 callersMethodstreamReadyToStart

(OkHttpClientStream clientStream, String authority)

okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java:522

↓ 3 callersMethodstreamingCall

<pre> Repeated sequence of one request followed by one response. Should be called streaming ping-pong The server returns the client payload as-is on e

benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/BenchmarkServiceGrpc.java:251

↓ 3 callersMethodstripAttrs

(EquivalentAddressGroup eag)

xds/src/main/java/io/grpc/xds/RingHashLoadBalancer.java:350

↓ 3 callersMethodstripNonApplicationHeaders

Strips all non-pseudo headers reserved by gRPC, to avoid duplicates and misinterpretation.

okhttp/src/main/java/io/grpc/okhttp/Headers.java:149

↓ 3 callersMethodsubZone

()

xds/src/main/java/io/grpc/xds/client/Locality.java:30

↓ 3 callersMethodsubtestCallsAndShutdown

(boolean shutdownNow, boolean shutdownNowAfterShutdown)

core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:833

↓ 3 callersMethodsubtestGrpclbFallbackConnectionLost

( boolean balancerBroken, boolean allSubchannelsBroken)

grpclb/src/test/java/io/grpc/grpclb/GrpclbLoadBalancerTest.java:1521

↓ 3 callersMethodsubtest_tlsHandler

(Attributes eagAttributes)

alts/src/test/java/io/grpc/alts/internal/GoogleDefaultProtocolNegotiatorTest.java:129

↓ 3 callersMethodsuccessRate

()

util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:577

↓ 3 callersMethodsuffix

()

xds/src/main/java/io/grpc/xds/internal/Matchers.java:217

↓ 3 callersMethodswap

()

util/src/main/java/io/grpc/util/GracefulSwitchLoadBalancer.java:161

↓ 3 callersMethodtearDown

()

core/src/main/java/io/grpc/internal/ClientCallImpl.java:372

↓ 3 callersMethodtearDown

()

xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:285

↓ 3 callersMethodtestAuthority

(InternalServer server)

inprocess/src/test/java/io/grpc/inprocess/InProcessTransportTest.java:90

↓ 3 callersMethodtestValidUri

(String uri)

grpclb/src/test/java/io/grpc/grpclb/SecretGrpclbNameResolverProviderTest.java:133

↓ 3 callersMethodthreshold

()

xds/src/main/java/io/grpc/xds/EnvoyServerProtoData.java:449

↓ 3 callersMethodtoChannelRef

(InternalWithLogId obj)

services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:93

↓ 3 callersMethodtoChunkQueue

Breaks down the request and creates a queue of response chunks for the given request.

interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:440

↓ 3 callersMethodtoJavaLogLevel

(ChannelLogLevel level)

core/src/main/java/io/grpc/internal/ChannelLoggerImpl.java:97

↓ 3 callersMethodtoJavaLogLevel

(XdsLogLevel level)

xds/src/main/java/io/grpc/xds/client/XdsLogger.java:79

↓ 3 callersMethodtoSeverity

(Event.Severity severity)

services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:399

↓ 3 callersMethodtoSocketOptionLinger

(int lingerSeconds)

services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:249

↓ 3 callersMethodtoState

(ConnectivityState state)

services/src/main/java/io/grpc/protobuf/services/ChannelzProtoUtil.java:415

↓ 3 callersMethodtoStream

Serializes a metadata value to an {@link InputStream}. @param value to serialize @return serialized version of value

api/src/main/java/io/grpc/Metadata.java:628

↓ 3 callersMethodtoString

()

s2a/src/main/java/io/grpc/s2a/internal/channel/S2AHandshakerServiceChannel.java:100

↓ 3 callersMethodtoString

()

rls/src/main/java/io/grpc/rls/LbPolicyConfiguration.java:95

↓ 3 callersMethodtoString

()

core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1987

↓ 3 callersMethodtoString

()

services/src/test/java/io/grpc/protobuf/services/ChannelzTestHelper.java:82

↓ 3 callersMethodtoString

()

api/src/test/java/io/grpc/CallOptionsTest.java:297

↓ 3 callersMethodtoString

()

api/src/main/java/io/grpc/InternalLogId.java:88

↓ 3 callersMethodtoString

(Settings settings)

okhttp/src/main/java/io/grpc/okhttp/OkHttpFrameLogger.java:47

↓ 3 callersMethodtoString

()

util/src/main/java/io/grpc/util/ForwardingSubchannel.java:88

↓ 3 callersMethodtoString

()

xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:600

↓ 3 callersMethodtransact

(int code, ParcelHolder data)

binder/src/main/java/io/grpc/binder/internal/OneWayBinderProxy.java:111

↓ 3 callersMethodtransportState

()

core/src/main/java/io/grpc/internal/AbstractServerStream.java:85

↓ 3 callersMethodtryNextPriority

()

xds/src/main/java/io/grpc/xds/PriorityLoadBalancer.java:158

↓ 3 callersMethodtrySuccess

(Void unused)

alts/src/main/java/io/grpc/alts/internal/ProtectedPromise.java:125

↓ 3 callersMethodunaryPayloadLength

()

interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:1338

↓ 3 callersMethodunavailableException

(String msg)

netty/src/main/java/io/grpc/netty/ProtocolNegotiators.java:956

↓ 3 callersMethoduncompressedIndex

(int hash, int bitsConsumed)

api/src/context/java/io/grpc/PersistentHashArrayMappedTrie.java:284

↓ 3 callersMethodunpackedClassName

()

xds/src/main/java/io/grpc/xds/client/XdsResourceType.java:66

↓ 3 callersMethodupdateAddresses

Replaces the existing addresses used with this {@code Subchannel}. If the new and old addresses overlap, the Subchannel can continue using an existing

api/src/main/java/io/grpc/LoadBalancer.java:1482

↓ 3 callersMethodupdateAddresses

(List<EquivalentAddressGroup> addrs)

xds/src/test/java/io/grpc/xds/ClusterImplLoadBalancerTest.java:1295

↓ 3 callersMethodupdateBalancingState

( final ConnectivityState newState, final SubchannelPicker newPicker)

core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1355

↓ 3 callersMethodupdateBalancingState

(ConnectivityState state, SubchannelPicker picker)

core/src/main/java/io/grpc/internal/PickFirstLoadBalancer.java:153

↓ 3 callersMethodupdateBalancingState

(ConnectivityState newState, LoadBalancer.SubchannelPicker newPicker)

examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:102

↓ 3 callersMethodupdateBalancingState

(ConnectivityState state, SubchannelPicker picker)

util/src/main/java/io/grpc/util/RoundRobinLoadBalancer.java:80

↓ 3 callersMethodupdateBalancingState

(ConnectivityState newState, SubchannelPicker newPicker)

xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:219

↓ 3 callersMethodupdateBalancingState

(ConnectivityState state, SubchannelPicker picker)

xds/src/main/java/io/grpc/xds/LeastRequestLoadBalancer.java:132

↓ 3 callersMethodupdateBalancingState

(ConnectivityState state, SubchannelPicker picker)

xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:283

↓ 3 callersMethodupdateBalancingStateIsGraceful

(ConnectivityState swapsOnState)

util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:378

↓ 3 callersMethodupdateBalancingStateSafely

( final Helper helper, final ConnectivityState state, final SubchannelPicker picker)

core/src/test/java/io/grpc/internal/ManagedChannelImplIdlenessTest.java:637

↓ 3 callersMethodupdateGroups

Update to new groups, resetting the current index.

core/src/main/java/io/grpc/internal/InternalSubchannel.java:849

↓ 3 callersMethodupdateResolutionResult

(XdsConfig xdsConfig)

xds/src/main/java/io/grpc/xds/XdsNameResolver.java:313

↓ 3 callersMethodupdateSslContext

Updates SslContext via the passed callback.

xds/src/main/java/io/grpc/xds/internal/security/SslContextProviderSupplier.java:57

↓ 3 callersMethodupdateSslContextWhenReady

()

xds/src/main/java/io/grpc/xds/internal/security/certprovider/CertProviderSslContextProvider.java:170

↓ 3 callersMethoduseFallbackBackends

Populate backend servers to be used from the fallback backends.

grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:375

↓ 3 callersMethodusePlaintext

Does nothing.

inprocess/src/main/java/io/grpc/inprocess/InProcessChannelBuilder.java:150

↓ 3 callersMethodvalidateGeneration

If the ancestry chain length is unreasonably long, then print an error to the log and record the stack trace.

api/src/context/java/io/grpc/Context.java:1108

↓ 3 callersMethodvalueAsBytes

(int i)

api/src/main/java/io/grpc/Metadata.java:178

↓ 3 callersMethodverifyDoubleHistogramRecord

(String name, int times, double value)

xds/src/test/java/io/grpc/xds/WeightedRoundRobinLoadBalancerTest.java:1611

↓ 3 callersMethodverifyNoSubscribers

(ControlPlaneRule rule)

xds/src/test/java/io/grpc/xds/XdsClientFallbackTest.java:366

↓ 3 callersMethodverifyRetryAfterNanos

(InOrder inOrder, OpenRcaServiceImp orcaServiceImp, long nanos)

xds/src/test/java/io/grpc/xds/orca/OrcaOobUtilTest.java:751

↓ 3 callersMethodverifyServerNotStart

(List<SocketAddress> addr, EventLoopGroup ev, Class<?> expectedException, String expectedMessage)

netty/src/test/java/io/grpc/netty/NettyServerTest.java:592

↓ 3 callersMethodverifySignature

( byte[] dataToSign, byte[] signature, String signatureAlgorithm)

s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2APrivateKeyMethodTest.java:67

↓ 3 callersMethodverifySize

()

core/src/main/java/io/grpc/internal/MessageDeframer.java:526

↓ 3 callersMethodverifyWriteFutureFailure

(Http2Exception h2Error)

netty/src/test/java/io/grpc/netty/NettyServerStreamTest.java:208

↓ 3 callersMethodwaitAndDrainWithTimeout

Waits for up to specified nanoseconds until there is a Runnable, then executes it and all queued Runnables after it. <p>his should always be called i

stub/src/main/java/io/grpc/stub/ClientCalls.java:901

↓ 3 callersMethodwaitUntilActiveHandler

Internal version of {@link WaitUntilActiveHandler}.

netty/src/main/java/io/grpc/netty/InternalProtocolNegotiators.java:162

↓ 3 callersMethodwithAnnotation

Returns a copy of {@code callOptions} with {@code annotation} included as one of the Cronet annotation objects. When an RPC is made using a {@link Cal

cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:161

↓ 3 callersMethodwithAttributes

(Attributes attributes)

netty/src/main/java/io/grpc/netty/ProtocolNegotiationEvent.java:57

↓ 3 callersMethodwithOnReadyThreshold

Specifies how many bytes must be queued before the call is considered not ready to send more messages. @param numBytes The number of bytes that must

api/src/main/java/io/grpc/CallOptions.java:224

↓ 3 callersMethodwithReadyAndDrained

Only {@code onWritePossible()} can set readyAndDrained to true, and only {@code runOrBuffer()} can set it to false.

servlet/src/main/java/io/grpc/servlet/AsyncServletOutputStreamWriter.java:291

↓ 3 callersMethodwithSecurity

( ProtocolNegotiationEvent event, @Nullable Security security)

netty/src/main/java/io/grpc/netty/InternalProtocolNegotiationEvent.java:40

↓ 3 callersMethodworkerEventLoopGroupPool

( ObjectPool<? extends EventLoopGroup> workerEventLoopGroupPool)

netty/src/main/java/io/grpc/netty/NettyServerBuilder.java:340

↓ 3 callersMethodwrap

(NameResolver retriedNameResolver, Args args)

core/src/main/java/io/grpc/internal/RetryingNameResolver.java:31

↓ 3 callersMethodwrite

(MessageLite message)

services/src/main/java/io/grpc/protobuf/services/TempFileSink.java:50

↓ 3 callersMethodwriteMetadata

Write a Metadata instance to a Parcel. @param parcel The {@link Parcel} to write to. @param metadata The {@link Metadata} to write.

binder/src/main/java/io/grpc/binder/internal/MetadataHelper.java:66

↓ 3 callersMethodwritePayload

Writes out a payload message. @param message contains the message to be written out. It will be completely consumed.

core/src/main/java/io/grpc/internal/Framer.java:29

↓ 3 callersMethodwriteSlice

(ByteBuf in, int len)

alts/src/main/java/io/grpc/alts/internal/AltsTsiFrameProtector.java:402

↓ 3 callersMethodwriteStreams

Writes as much data for all the streams as possible given the current flow control windows. <p>Must be called with holding transport lock.

okhttp/src/main/java/io/grpc/okhttp/OutboundFlowController.java:155

↓ 3 callersMethodwriteToOutputStream

(InputStream message, OutputStream outputStream)

core/src/main/java/io/grpc/internal/MessageFramer.java:273

↓ 3 callersMethodwriteToParcel

Write the {@link Parcelable} this stream wraps to the given {@link Parcel}. <p>This will retain any android-specific data (e.g. file descriptors) whi

binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:171

↓ 3 callersMethodwriteTrailers

Sends trailers to the remote end point. This call implies end of stream. @param trailers metadata to be sent to the end point @param headersSent {@co

core/src/main/java/io/grpc/internal/AbstractServerStream.java:62

↓ 3 callersMethodwriteUnknownLength

(MessageFramer framer, byte[] bytes)

core/src/test/java/io/grpc/internal/MessageFramerTest.java:366

↓ 3 callersMethodzone

()

xds/src/main/java/io/grpc/xds/client/Locality.java:28

↓ 2 callersMethodaccept

(T t)

alts/src/main/java/io/grpc/alts/internal/TsiFrameProtector.java:58

← previous next →4,101–4,200 of 22,628, ranked by callers