This is an automated email from the ASF dual-hosted git repository.
zrlw pushed a change to branch 3.3
in repository https://gitbox.apache.org/repos/asf/dubbo.git
from ac1621f9a0 Bump org.aspectj:aspectjweaver from 1.9.24 to 1.9.25.1
(#15943)
add 703290db37 Support Tri backpress (#15957)
No new revisions were added by this update.
Summary of changes:
.../apache/dubbo/config/nested/TripleConfig.java | 28 +
.../apache/dubbo/mutiny/MutinyClientCallsTest.java | 10 +
.../protocol/tri/servlet/ServletStreamChannel.java | 10 +
.../tri/websocket/WebSocketStreamChannel.java | 10 +
.../dubbo/remoting/http12/h2/H2StreamChannel.java | 21 +
.../remoting/http12/h2/Http2ChannelDelegate.java | 10 +
.../http12/h2/Http2ServerChannelObserver.java | 28 +
.../remoting/http12/h2/Http2TransportListener.java | 6 +
.../message/LengthFieldStreamingDecoder.java | 15 +-
.../remoting/http12/message/StreamingDecoder.java | 29 +-
.../http12/netty4/h2/NettyH2StreamChannel.java | 57 +-
.../http12/netty4/h2/NettyHttp2FrameHandler.java | 8 +
.../h2/NettyHttp2ProtocolSelectorHandler.java | 16 +-
.../http3/netty4/NettyHttp3StreamChannel.java | 10 +
.../websocket/netty4/NettyWebSocketChannel.java | 10 +
.../rpc/protocol/tri/ClientStreamObserver.java | 2 +
.../protocol/tri/TriHttp2RemoteFlowController.java | 780 ---------------------
.../rpc/protocol/tri/TripleHttp2Protocol.java | 57 +-
.../dubbo/rpc/protocol/tri/TripleInvoker.java | 6 +
.../dubbo/rpc/protocol/tri/call/ClientCall.java | 41 +-
.../call/ObserverToClientCallListenerAdapter.java | 40 +-
.../rpc/protocol/tri/call/TripleClientCall.java | 60 +-
.../protocol/tri/call/UnaryClientCallListener.java | 6 +-
.../dubbo/rpc/protocol/tri/frame/TriDecoder.java | 22 +-
.../tri/h12/AbstractServerTransportListener.java | 4 +
.../h12/grpc/GrpcHttp2ServerTransportListener.java | 10 +
.../http2/GenericHttp2ServerTransportListener.java | 54 +-
.../tri/h12/http2/Http2TripleClientStream.java | 82 +++
.../protocol/tri/h3/Http3TripleClientStream.java | 6 +
.../protocol/tri/observer/CallStreamObserver.java | 60 ++
.../tri/observer/ClientCallToObserverAdapter.java | 28 +-
.../tri/stream/AbstractTripleClientStream.java | 50 ++
.../rpc/protocol/tri/stream/ClientStream.java | 7 +
.../dubbo/rpc/protocol/tri/stream/Stream.java | 8 +
.../tri/transport/H2TransportListener.java | 6 +
.../TripleHttp2ClientResponseHandler.java | 8 +
.../transport/TripleHttp2LocalFlowController.java | 65 ++
.../rpc/protocol/tri/call/BackpressureTest.java | 367 ++++++++++
.../rpc/protocol/tri/frame/RecordListener.java | 3 +
.../rpc/protocol/tri/test/MockH2StreamChannel.java | 10 +
40 files changed, 1220 insertions(+), 830 deletions(-)
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TriHttp2RemoteFlowController.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2LocalFlowController.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/call/BackpressureTest.java
