This is an automated email from the ASF dual-hosted git repository.
liujun pushed a change to branch 3.0.6-release
in repository https://gitbox.apache.org/repos/asf/dubbo.git.
from 316d171 netty4_extend (#9725)
add 5216214 merge redundant if branches (#9657)
add 5d044c7 Fix the issue that providerUrl could not be registered in the
application-level registry when simplified is set to true (#9671)
add eed418a Fixe the issue that the default protocol configured by the
consumer does not take effect in the application-level mode (#9683)
add 08dea81 Fix the problem that NPE may appear in
ReferenceBeanSupport#convertToString method (#9693)
add 5c9287f Revert "Fixe the issue that the default protocol configured
by the consumer does not take effect in the application-level mode (#9683)"
(#9727)
add 8686d8d prepare for the next release 3.0.7-SNAPSHOT
add e4c036d ignore raw content in MetadataInfo (#9726)
add 71c7e24 Merge remote-tracking branch 'origin/3.0' into 3.0
add 1add77e [3.0-Triple] A reactor for better abstraction and futher stub
api (#9708)
add 8f9d0ee [3.0-compiler] proto3 support optional (#9688)
add 1a52091 [3.0] Remove attribute pass when Injvm invoke (#9734)
add 0dba4f9 Update README.md
add b7b4993 Add test case for RouterChain (#9732)
new 6e763a4 Merge branch '3.0.6-release' into 3.0
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
README.md | 2 +-
compiler/pom.xml | 26 +-
.../org/apache/dubbo/gen/AbstractGenerator.java | 61 ++-
.../apache/dubbo/gen/dubbo/Dubbo3Generator.java | 5 +
.../rpc/cluster/router/RouterSnapshotSwitcher.java | 2 +-
.../condition/config/ListenableStateRouter.java | 2 +-
...{ServiceRouter.java => ServiceStateRouter.java} | 4 +-
.../config/ServiceStateRouterFactory.java | 2 +-
.../cluster/router/mesh/route/MeshRuleRouter.java | 3 +-
.../apache/dubbo/rpc/cluster/RouterChainTest.java | 201 +++++++-
.../apache/dubbo/common/stream/StreamObserver.java | 2 +
.../org/apache/dubbo/config/ApplicationConfig.java | 22 +-
.../apache/dubbo/config/ReferenceConfigBase.java | 8 +-
.../apache/dubbo/rpc/model/MethodDescriptor.java | 213 +++------
.../apache/dubbo/rpc/model/ServiceDescriptor.java | 16 +-
.../dubbo/rpc/model/StreamMethodDescriptor.java | 88 ++++
.../dubbo/descriptor/MethodDescriptorTest.java | 35 +-
.../config/spring/util/DubboAnnotationUtils.java | 3 +-
dubbo-dependencies-bom/pom.xml | 2 +-
.../dubbo-dependencies-zookeeper-curator5/pom.xml | 2 +-
.../dubbo-dependencies-zookeeper/pom.xml | 2 +-
.../apache/dubbo/metadata/MappingCacheManager.java | 2 +-
.../org/apache/dubbo/metadata/MetadataInfo.java | 4 +-
.../listener/ServiceInstancesChangedListener.java | 15 +-
.../registry/integration/RegistryProtocol.java | 3 +-
.../protocol/injvm/DefaultParamDeepCopyUtil.java | 2 +-
.../dubbo/rpc/protocol/injvm/InjvmInvoker.java | 4 +-
dubbo-rpc/dubbo-rpc-triple/pom.xml | 2 +-
.../rpc/protocol/tri/AbstractClientStream.java | 487 -------------------
.../rpc/protocol/tri/AbstractServerStream.java | 439 -----------------
.../dubbo/rpc/protocol/tri/AbstractStream.java | 520 ---------------------
.../rpc/protocol/tri/CancelableStreamObserver.java | 29 +-
.../dubbo/rpc/protocol/tri/ClassLoadUtil.java | 1 +
.../tri/ClientOutboundTransportObserver.java | 82 ----
.../dubbo/rpc/protocol/tri/ClientStream.java | 122 -----
.../rpc/protocol/tri/ClientStreamObserver.java | 16 +-
.../dubbo/rpc/protocol/tri}/DefaultFuture2.java | 143 +++---
.../dubbo/rpc/protocol/tri/DefaultMetadata.java | 66 ---
.../dubbo/rpc/protocol/tri/GrpcDataDecoder.java | 114 -----
.../dubbo/rpc/protocol/tri/Http2HeaderMeta.java | 57 ---
.../rpc/protocol/tri/InboundTransportObserver.java | 60 ---
.../protocol/tri/OutboundTransportObserver.java | 101 ----
.../dubbo/rpc/protocol/tri/PathResolver.java | 1 +
.../tri/{Metadata.java => RequestMetadata.java} | 44 +-
.../tri/{GrpcStatus.java => RpcStatus.java} | 158 ++++---
.../tri/ServerOutboundTransportObserver.java | 88 ----
.../dubbo/rpc/protocol/tri/ServerStream.java | 210 ---------
.../rpc/protocol/tri/ServerStreamObserver.java | 13 +-
.../rpc/protocol/tri/SingleProtobufUtils.java | 1 +
.../org/apache/dubbo/rpc/protocol/tri/Stream.java | 69 ---
.../dubbo/rpc/protocol/tri/TransportState.java | 71 ---
.../protocol/tri/TripleClientRequestHandler.java | 68 ---
.../dubbo/rpc/protocol/tri/TripleConstant.java | 35 +-
.../dubbo/rpc/protocol/tri/TripleHeaderEnum.java | 1 +
.../tri/TripleHttp2FrameServerHandler.java | 297 ------------
.../rpc/protocol/tri/TripleHttp2Protocol.java | 40 +-
.../dubbo/rpc/protocol/tri/TripleInvoker.java | 137 +++---
.../dubbo/rpc/protocol/tri/TriplePathResolver.java | 1 +
.../dubbo/rpc/protocol/tri/TripleProtocol.java | 37 +-
.../protocol/tri/TripleServerInboundHandler.java | 32 --
.../dubbo/rpc/protocol/tri/UnaryClientStream.java | 103 ----
.../dubbo/rpc/protocol/tri/UnaryServerStream.java | 112 -----
.../tri/call/AbstractServerCallListener.java | 70 +++
.../tri/call/BiStreamServerCallListener.java | 58 +++
.../dubbo/rpc/protocol/tri/call/ClientCall.java | 260 +++++++++++
.../rpc/protocol/tri/call/ClientCallUtil.java | 137 ++++++
.../call/ObserverToClientCallListenerAdapter.java | 56 +++
.../dubbo/rpc/protocol/tri/call/ServerCall.java | 455 ++++++++++++++++++
.../rpc/protocol/tri/call/ServerCallUtil.java | 95 ++++
.../tri/call/ServerStreamServerCallListener.java | 55 +++
.../rpc/protocol/tri/call/UnaryCallListener.java | 57 +++
.../protocol/tri/call/UnaryServerCallListener.java | 62 +++
.../tri/call/WrapRequestServerCallListener.java | 51 ++
.../tri/call/WrapResponseCallListener.java | 62 +++
.../protocol/tri/command/CancelQueueCommand.java | 14 +-
.../rpc/protocol/tri/command/DataQueueCommand.java | 56 +--
...ueueCommand.java => EndStreamQueueCommand.java} | 9 +-
.../protocol/tri/command/FlushQueueCommand.java | 2 +-
.../protocol/tri/command/HeaderQueueCommand.java | 27 +-
.../rpc/protocol/tri/command/QueuedCommand.java | 61 +--
.../protocol/tri/command/TextDataQueueCommand.java | 2 +-
.../protocol/tri/{ => compressor}/Compressor.java | 28 +-
.../DeCompressor.java} | 45 +-
.../{GzipCompressor.java => compressor/Gzip.java} | 12 +-
.../Identity.java} | 10 +-
.../MessageEncoding.java} | 17 +-
.../dubbo/rpc/protocol/tri/frame/Deframer.java | 33 +-
.../dubbo/rpc/protocol/tri/frame/TriDecoder.java | 167 +++++++
.../protocol/tri/observer/CallStreamObserver.java} | 44 +-
.../tri/observer/ClientCallToObserverAdapter.java | 80 ++++
.../tri/observer/ServerCallToObserverAdapter.java | 118 +++++
.../tri/observer/WrapperRequestObserver.java | 82 ++++
.../tri/observer/WrapperResponseObserver.java | 66 +++
.../dubbo/rpc/protocol/tri/pack/GenericPack.java | 67 +++
.../dubbo/rpc/protocol/tri/pack/GenericUnpack.java | 47 ++
.../FlushQueueCommand.java => pack/Pack.java} | 13 +-
.../{IdentityCompressor.java => pack/PbPack.java} | 28 +-
.../dubbo/rpc/protocol/tri/pack/PbUnpack.java} | 37 +-
.../rpc/protocol/tri/pack/WrapRequestUnpack.java | 47 ++
.../WrapResponseUnpack.java} | 29 +-
.../AbstractStream.java} | 33 +-
.../rpc/protocol/tri/stream/ClientStream.java | 342 ++++++++++++++
.../ClientStreamListener.java} | 35 +-
.../rpc/protocol/tri/stream/ServerStream.java | 349 ++++++++++++++
.../protocol/tri/stream/ServerStreamListener.java} | 26 +-
.../tri/{PathResolver.java => stream/Stream.java} | 25 +-
.../StreamListener.java} | 11 +-
.../dubbo/rpc/protocol/tri/stream/StreamUtils.java | 164 +++++++
.../tri/transport/AbstractH2TransportListener.java | 81 ++++
.../tri/{ => transport}/GracefulShutdown.java | 3 +-
.../H2TransportListener.java} | 46 +-
.../tri/{ => transport}/TripleClientHandler.java | 3 +-
.../TripleCommandOutBoundHandler.java | 6 +-
.../TripleHttp2ClientResponseHandler.java | 62 +--
.../transport/TripleHttp2FrameServerHandler.java | 115 +++++
.../TripleServerConnectionHandler.java | 5 +-
.../tri/{ => transport}/TripleTailHandler.java | 2 +-
.../protocol/tri/{ => transport}/WriteQueue.java | 9 +-
.../src/main/proto/triple_wrapper.proto | 24 +-
.../org.apache.dubbo.rpc.protocol.tri.Compressor | 1 -
...he.dubbo.rpc.protocol.tri.compressor.Compressor | 1 +
....dubbo.rpc.protocol.tri.compressor.DeCompressor | 1 +
.../dubbo/rpc/protocol/tri/AbstractStreamTest.java | 119 -----
.../dubbo/rpc/protocol/tri/ClientStreamTest.java | 368 ---------------
.../rpc/protocol/tri/GrpcDataDecoderTest.java | 102 ----
.../{GrpcStatusTest.java => RpcStatusTest.java} | 17 +-
.../dubbo/rpc/protocol/tri/ServerStreamTest.java | 293 ------------
.../rpc/protocol/tri/SingleProtobufUtilsTest.java | 4 +-
.../dubbo/rpc/protocol/tri/TransportStateTest.java | 122 -----
.../dubbo/rpc/protocol/tri/TripleProtocolTest.java | 12 +-
.../rpc/protocol/tri/UnaryClientStreamTest.java | 69 ---
.../rpc/protocol/tri/call/ClientCallTest.java | 52 +++
.../GzipTest.java} | 20 +-
.../rpc/protocol/tri/compressor/IdentityTest.java} | 40 +-
.../RecordListener.java} | 23 +-
.../rpc/protocol/tri/frame/TriDecoderTest.java | 54 +++
.../rpc/protocol/tri/stream/ClientStreamTest.java | 112 +++++
.../tri/stream/MockClientStreamListener.java} | 31 +-
.../rpc/protocol/tri/support/IGreeterImpl.java | 23 +-
.../transport/AbstractH2TransportListenerTest.java | 65 +++
.../TripleHttp2ClientResponseHandlerTest.java | 40 +-
.../tri/{ => transport}/WriteQueueTest.java | 27 +-
...gBeanDefinitionConflictApplicationListener.java | 6 +-
pom.xml | 2 +-
144 files changed, 4688 insertions(+), 5304 deletions(-)
rename
dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/config/{ServiceRouter.java
=> ServiceStateRouter.java} (91%)
create mode 100644
dubbo-common/src/main/java/org/apache/dubbo/rpc/model/StreamMethodDescriptor.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/AbstractClientStream.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/AbstractServerStream.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/AbstractStream.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ClientOutboundTransportObserver.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ClientStream.java
rename
{dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support
=>
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri}/DefaultFuture2.java
(59%)
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/DefaultMetadata.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/GrpcDataDecoder.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/Http2HeaderMeta.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/InboundTransportObserver.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/OutboundTransportObserver.java
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{Metadata.java
=> RequestMetadata.java} (52%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{GrpcStatus.java
=> RpcStatus.java} (61%)
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ServerOutboundTransportObserver.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/ServerStream.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/Stream.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TransportState.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleClientRequestHandler.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleHttp2FrameServerHandler.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/TripleServerInboundHandler.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/UnaryClientStream.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/UnaryServerStream.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/AbstractServerCallListener.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/BiStreamServerCallListener.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ClientCall.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ClientCallUtil.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ObserverToClientCallListenerAdapter.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ServerCall.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ServerCallUtil.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ServerStreamServerCallListener.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/UnaryCallListener.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/UnaryServerCallListener.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/WrapRequestServerCallListener.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/WrapResponseCallListener.java
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/command/{FlushQueueCommand.java
=> EndStreamQueueCommand.java} (79%)
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
compressor}/Compressor.java (76%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{Compressor.java
=> compressor/DeCompressor.java} (50%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{GzipCompressor.java
=> compressor/Gzip.java} (89%)
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{IdentityCompressor.java
=> compressor/Identity.java} (80%)
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{command/FlushQueueCommand.java
=> compressor/MessageEncoding.java} (70%)
copy
dubbo-common/src/main/java/org/apache/dubbo/common/stream/StreamObserver.java
=>
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/frame/Deframer.java
(52%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/frame/TriDecoder.java
copy
dubbo-rpc/dubbo-rpc-triple/src/{test/java/org/apache/dubbo/rpc/protocol/tri/support/MockAbstractStreamImpl.java
=>
main/java/org/apache/dubbo/rpc/protocol/tri/observer/CallStreamObserver.java}
(51%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/observer/ClientCallToObserverAdapter.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/observer/ServerCallToObserverAdapter.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/observer/WrapperRequestObserver.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/observer/WrapperResponseObserver.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/pack/GenericPack.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/pack/GenericUnpack.java
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{command/FlushQueueCommand.java
=> pack/Pack.java} (70%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{IdentityCompressor.java
=> pack/PbPack.java} (63%)
rename
dubbo-rpc/dubbo-rpc-triple/src/{test/java/org/apache/dubbo/rpc/protocol/tri/support/MockAbstractStreamImpl.java
=> main/java/org/apache/dubbo/rpc/protocol/tri/pack/PbUnpack.java} (50%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/pack/WrapRequestUnpack.java
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ClassLoadUtil.java
=> pack/WrapResponseUnpack.java} (51%)
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{TripleClientHandler.java
=> stream/AbstractStream.java} (53%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/ClientStream.java
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{TripleClientInboundHandler.java
=> stream/ClientStreamListener.java} (55%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/ServerStream.java
copy
dubbo-rpc/dubbo-rpc-triple/src/{test/java/org/apache/dubbo/rpc/protocol/tri/UnaryServerStreamTest.java
=>
main/java/org/apache/dubbo/rpc/protocol/tri/stream/ServerStreamListener.java}
(65%)
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{PathResolver.java
=> stream/Stream.java} (57%)
copy
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{command/FlushQueueCommand.java
=> stream/StreamListener.java} (70%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/StreamUtils.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/AbstractH2TransportListener.java
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/GracefulShutdown.java (98%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{TransportObserver.java
=> transport/H2TransportListener.java} (54%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/TripleClientHandler.java (96%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/TripleCommandOutBoundHandler.java (86%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/TripleHttp2ClientResponseHandler.java (51%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2FrameServerHandler.java
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/TripleServerConnectionHandler.java (96%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/TripleTailHandler.java (96%)
rename
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/WriteQueue.java (92%)
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.rpc.protocol.tri.Compressor
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.rpc.protocol.tri.compressor.Compressor
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/main/resources/META-INF/dubbo/internal/org.apache.dubbo.rpc.protocol.tri.compressor.DeCompressor
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/AbstractStreamTest.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/ClientStreamTest.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/GrpcDataDecoderTest.java
rename
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/{GrpcStatusTest.java
=> RpcStatusTest.java} (71%)
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/ServerStreamTest.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TransportStateTest.java
delete mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/UnaryClientStreamTest.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/call/ClientCallTest.java
rename
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/{CompressorTest.java
=> compressor/GzipTest.java} (72%)
rename
dubbo-rpc/dubbo-rpc-triple/src/{main/java/org/apache/dubbo/rpc/protocol/tri/Metadata.java
=> test/java/org/apache/dubbo/rpc/protocol/tri/compressor/IdentityTest.java}
(53%)
rename
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/{UnaryServerStreamTest.java
=> frame/RecordListener.java} (70%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/frame/TriDecoderTest.java
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/stream/ClientStreamTest.java
rename
dubbo-rpc/dubbo-rpc-triple/src/{main/java/org/apache/dubbo/rpc/protocol/tri/ServerUnaryInboundTransportObserver.java
=>
test/java/org/apache/dubbo/rpc/protocol/tri/stream/MockClientStreamListener.java}
(58%)
create mode 100644
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/transport/AbstractH2TransportListenerTest.java
rename
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/TripleHttp2ClientResponseHandlerTest.java (61%)
rename
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/{ =>
transport}/WriteQueueTest.java (86%)
