MCPcopy Create free account
hub / github.com/grpc/grpc-java / run

Method run

core/src/main/java/io/grpc/internal/MigratingThreadDeframer.java:37–37  ·  view source on GitHub ↗
(boolean isDeframerOnTransportThread)

Source from the content-addressed store, hash-verified

35final class MigratingThreadDeframer implements ThreadOptimizedDeframer {
36 private interface Op {
37 void run(boolean isDeframerOnTransportThread);
38 }
39
40 private final MessageDeframer.Listener transportListener;

Callers 15

nextMethod · 0.95
runMethod · 0.65
runMethod · 0.65
runMethod · 0.65
runIfNotNullMethod · 0.65
shutdownBeforeTransportCreatedMethod · 0.65
resetConnectBackoffMethod · 0.65
executeMethod · 0.65
drainMethod · 0.65
maxIdleReachedMethod · 0.65
maxIdleNotReachedAndReachedMethod · 0.65
shutdownThenMaxIdleReachedMethod · 0.65

Implementers 15

RequestOpcore/src/main/java/io/grpc/internal/Mi
RequestAgainOpcore/src/main/java/io/grpc/internal/Mi
DeframeOpcore/src/main/java/io/grpc/internal/Mi
CloseWhenCompleteOpcore/src/main/java/io/grpc/internal/Mi
CloseOpcore/src/main/java/io/grpc/internal/Mi
S2AProtocolNegotiationHandlers2a/src/main/java/io/grpc/s2a/internal
CachingRlsLbClientTestrls/src/test/java/io/grpc/rls/CachingR
StaticFixedDelayRlsServerImplrls/src/test/java/io/grpc/rls/CachingR
ChildPolicyWrapperrls/src/main/java/io/grpc/rls/LbPolicy
CachingRlsLbClientrls/src/main/java/io/grpc/rls/CachingR
ScheduledTaskcore/src/testFixtures/java/io/grpc/int
ScheduleAtFixedRateTaskcore/src/testFixtures/java/io/grpc/int

Calls

no outgoing calls

Tested by 15

runMethod · 0.52
runMethod · 0.52
runMethod · 0.52
runIfNotNullMethod · 0.52
shutdownBeforeTransportCreatedMethod · 0.52
resetConnectBackoffMethod · 0.52
executeMethod · 0.52
drainMethod · 0.52
maxIdleReachedMethod · 0.52
maxIdleNotReachedAndReachedMethod · 0.52
shutdownThenMaxIdleReachedMethod · 0.52
runOnTransportThreadMethod · 0.52