MCPcopy Index your code
hub / github.com/grpc/grpc-java / scheduleFlush

Method scheduleFlush

netty/src/main/java/io/grpc/netty/WriteQueue.java:63–70  ·  view source on GitHub ↗

Schedule a flush on the channel.

()

Source from the content-addressed store, hash-verified

61 * Schedule a flush on the channel.
62 */
63 void scheduleFlush() {
64 if (scheduled.compareAndSet(false, true)) {
65 // Add the queue to the tail of the event loop so writes will be executed immediately
66 // inside the event loop. Note DO NOT do channel.write outside the event loop as
67 // it will not wake up immediately without a flush.
68 channel.eventLoop().execute(later);
69 }
70 }
71
72 /**
73 * Enqueue a write command on the channel.

Callers 7

enqueueMethod · 0.95
flushMethod · 0.95
runMethod · 0.80
bytesReadMethod · 0.80
bytesReadMethod · 0.80

Calls 2

eventLoopMethod · 0.80
executeMethod · 0.45

Tested by 3

runMethod · 0.64