| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 265 newPromise()); in grpcDataFrame()
274 new DefaultHttp2FrameWriter().writeData(ctx, streamId, content, 0, endStream, newPromise()); in dataFrame()
280 new DefaultHttp2FrameWriter().writePing(ctx, ack, payload, newPromise()); in pingFrame()
286 new DefaultHttp2FrameWriter().writeHeaders(ctx, streamId, headers, 0, false, newPromise()); in headersFrame()
296 new DefaultHttp2FrameWriter().writeGoAway(ctx, lastStreamId, errorCode, data, newPromise()); in goAwayFrame()
302 new DefaultHttp2FrameWriter().writeRstStream(ctx, streamId, errorCode, newPromise()); in rstStreamFrame()
308 new DefaultHttp2FrameWriter().writeSettings(ctx, settings, newPromise()); in serializeSettings()
314 new DefaultHttp2FrameWriter().writeWindowUpdate(ctx, 0, delta, newPromise()); in windowUpdate()
318 protected final ChannelPromise newPromise() { in newPromise() method in NettyHandlerTestBase
319 return channel.newPromise(); in newPromise()
|
| D | WriteQueueTest.java | 70 when(channel.newPromise()).thenReturn(promise); in setUp()
|
| D | NettyStreamTestBase.java | 94 when(channel.newPromise()).thenReturn(new DefaultChannelPromise(channel)); in setUp()
|
| D | NettyServerHandlerTest.java | 334 handler().close(ctx(), newPromise()); in closeShouldCloseChannel()
1062 /* channelUnused= */ channel().newPromise(), in newHandler()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerHandler.java | 658 resetStream(ctx, stream.id(), Http2Error.CANCEL.code(), ctx.newPromise()); in forcefulClose()
679 encoder().writeHeaders(ctx, streamId, headers, 0, false, ctx.newPromise()); in respondWithHttpError()
681 encoder().writeData(ctx, streamId, msgBuf, 0, true, ctx.newPromise()); in respondWithHttpError()
760 debugData, ctx.newPromise()); in onPingRead()
763 forcefulClose(ctx, new ForcefulCloseCommand(status), ctx.newPromise()); in onPingRead()
804 ctx, false /* isAck */, KEEPALIVE_PING, ctx.newPromise()); in ping()
825 ctx.newPromise()); in onPingTimeout()
869 ctx.newPromise()); in start()
881 encoder().writePing(ctx, false /* isAck */, GRACEFUL_SHUTDOWN_PING, ctx.newPromise()); in start()
899 ctx.newPromise()); in secondGoAwayAndClose()
[all …]
|
| D | AbstractNettyHandler.java | 169 frameWriter().writeSettings(ctx(), settings, ctx().newPromise()); in updateWindow()
185 encoder().writePing(ctx, false, BDP_MEASUREMENT_PING, ctx.newPromise()); in sendPing()
|
| D | NettyClientHandler.java | 509 close(ctx(), ctx().newPromise()); in createStream()
520 ChannelPromise tempPromise = ctx().newPromise(); in createStream()
605 promise = ctx().newPromise(); in sendPingFrame()
657 resetStream(ctx, stream.id(), Http2Error.CANCEL.code(), ctx.newPromise()); in forcefulClose()
|
| D | WriteQueue.java | 81 ChannelPromise promise = channel.newPromise(); in enqueue()
|
| D | NettyServer.java | 182 ChannelPromise channelDone = ch.newPromise(); in start()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | ProtectedPromise.java | 63 ChannelPromise newPromise() { in newPromise() method in ProtectedPromise
|
| D | TsiFrameHandler.java | 172 ctx.writeAndFlush(b, aggregatePromise.newPromise()); in flush()
|