Searched refs:writeGoAway (Results 1 – 4 of 4) sorted by relevance
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 336 verifyWrite().writeGoAway(eq(ctx()), eq(0), eq(Http2Error.NO_ERROR.code()), in closeShouldCloseChannel()
614 verifyWrite().writeGoAway(eq(ctx()), eq(0), eq(Http2Error.ENHANCE_YOUR_CALM.code()), in keepAliveEnforcer_enforcesPings()
637 verifyWrite(never()).writeGoAway(eq(ctx()), eq(STREAM_ID), in keepAliveEnforcer_sendingDataResetsCounters()
650 verifyWrite().writeGoAway(eq(ctx()), eq(0), in keepAliveEnforcer_initialIdle()
665 verifyWrite(never()).writeGoAway(eq(ctx()), eq(STREAM_ID), in keepAliveEnforcer_noticesActive()
680 verifyWrite().writeGoAway(eq(ctx()), eq(STREAM_ID), in keepAliveEnforcer_noticesInactive()
693 verifyWrite(never()).writeGoAway( in noGoAwaySentBeforeMaxConnectionIdleReached()
708 verifyWrite().writeGoAway( in maxConnectionIdle_goAwaySent_pingAck()
714 verifyWrite(never()).writeGoAway( in maxConnectionIdle_goAwaySent_pingAck()
719 verifyWrite(never()).writeGoAway( in maxConnectionIdle_goAwaySent_pingAck()
[all …]
|
| D | NettyHandlerTestBase.java | 296 new DefaultHttp2FrameWriter().writeGoAway(ctx, lastStreamId, errorCode, data, newPromise()); in goAwayFrame()
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | write.go | 85 type writeGoAway struct { struct
90 func (p *writeGoAway) writeFrame(ctx writeContext) error { argument
96 func (*writeGoAway) staysWithinBuffer(max int) bool { return false } // flushes argument
|
| D | server.go | 1193 write: &writeGoAway{
|