This is an automated email from the ASF dual-hosted git repository.

heliang666s pushed a change to branch feat-tagStateRouter
in repository https://gitbox.apache.org/repos/asf/dubbo.git


    from 96f5c3c35c fix: don't bypass tag routing for broadcast without tag
     add 7d512b4967 Bump commons-io:commons-io from 2.19.0 to 2.21.0 (#15862)
     add 03bace1779 Bump org.apache.maven.plugins:maven-release-plugin from 
3.1.1 to 3.3.1 (#15854)
     add 3feacb802e Bump org.apache.commons:commons-exec from 1.5.0 to 1.6.0 
(#15867)
     add dc296d5ece fix(nacos): Add application key to consumer subscribe URL 
(#15872)
     add fdf6d39d11 Stabilize reference-related tests in dubbo-config-spring 
(#15828)
     add d9448c3a01 Stabilize RestProtocolTest.groovy in dubbo-plugin 
rest-jaxrs and rest-spring (#15849)
     add 49ecb04185 Stabilize dubbo-compatible test in 
generic/GenericServiceTest.java (#15848)
     add 47a141c12a metadata-api test unit test modification (#15879)
     add f7ff60e35f Bump org.apache.logging.log4j:log4j-core in 
/dubbo-dependencies-bom (#15885)
     add a5da18de80 Bump org.openjdk.nashorn:nashorn-core from 15.6 to 15.7 
(#15912)
     add ad31504790 Bump io.projectreactor:reactor-core from 3.7.11 to 3.8.1 
(#15911)
     add 14aef881b3 Bump org.apache.commons:commons-lang3 from 3.18.0 to 3.20.0 
(#15910)
     add a71d51a49b Bump curator_version from 4.2.0 to 5.9.0 (#15909)
     add 48ef3a061b Bump netty4_version from 4.2.2.Final to 4.2.9.Final (#15894)
     add 4b9134b8d2 Bump junit_jupiter_version from 5.12.2 to 5.14.1 (#15898)
     add bdb68ff8c8 Bump org.apache.maven.plugins:maven-plugin-plugin from 
3.15.1 to 3.15.2 (#15896)
     add 5a53901a4a Bump spring-boot-3.version from 3.5.8 to 3.5.9 (#15893)
     add 2311f40003 Bump io.micrometer:micrometer-core from 1.15.4 to 1.16.1 
(#15908)
     add 91d3f86def Bump byte-buddy_version from 1.17.6 to 1.18.3 (#15906)
     add 64488d62d5 Bump log4j2_version from 2.25.2 to 2.25.3 (#15902)
     add 5c6ae9102f Bump commons-codec:commons-codec from 1.18.0 to 1.20.0 
(#15900)
     add 5104f90c0c Bump io.opentelemetry:opentelemetry-bom from 1.54.1 to 
1.57.0 (#15905)
     add 535d786087 Bump org.xerial.snappy:snappy-java from 1.1.10.7 to 
1.1.10.8 (#15903)
     add 1e7a66c5ff Bump org.apache.maven:maven-core from 3.9.10 to 3.9.12 
(#15895)
     add 30f4eb227e Bump io.micrometer:micrometer-tracing-bom from 1.5.1 to 
1.6.1 (#15904)
     add 6b22b2ab89 Bump jetty_version from 9.4.57.v20241219 to 
9.4.58.v20250814 (#15897)
     add 8304d5fa6d Fix remaining outlier dubbo-config-spring tests (#15846)
     add a0c1dd05e7 Bump com.alibaba.nacos:nacos-client from 2.5.1 to 2.5.2 
(#15901)
     add a3a35b5f8c Bump org.apache.groovy:groovy from 4.0.27 to 4.0.29 (#15899)
     add 6a70f6b217 Call ByteBuf#release method before garbage collecting 
(#15917)
     add 1b6e2f43db Bump org.testcontainers:testcontainers from 1.21.3 to 
1.21.4 (#15955)
     add 23b5763cb5 Bump org.jacoco:jacoco-maven-plugin from 0.8.13 to 0.8.14 
(#15954)
     add 4313e01dd0 Bump org.apache.maven.plugins:maven-surefire-plugin from 
3.5.3 to 3.5.4 (#15953)
     add 3698253611 Bump org.apache.maven.plugin-tools:maven-plugin-annotations 
(#15951)
     add 25e027d03b Bump com.diffplug.spotless:spotless-maven-plugin from 
2.44.5 to 2.46.1 (#15947)
     add b5a04bbae2 Bump grpc.version from 1.77.0 to 1.78.0 (#15939)
     add cc2fa477b2 Bump org.webjars:webjars-locator-lite from 1.1.2 to 1.1.3 
(#15940)
     add fa610c4aaf Bump org.apache.maven.plugins:maven-assembly-plugin from 
3.7.1 to 3.8.0 (#15938)
     add a2cb807dff Bump io.swagger.core.v3:swagger-annotations from 2.2.34 to 
2.2.41 (#15937)
     add d2eaf653e1 Bump org.apache.maven.plugins:maven-antrun-plugin from 
3.1.0 to 3.2.0 (#15948)
     add 78079fde61 Bump 
org.springframework.security:spring-security-oauth2-authorization-server 
(#15949)
     add 00e0bacddf Bump org.webjars:swagger-ui from 5.22.0 to 5.31.0 (#15944)
     add da4f488ac5 Bump org.apache.maven.plugins:maven-jar-plugin from 3.4.2 
to 3.5.0 (#15950)
     add 1ee50f590f Bump org.apache.maven:maven-plugin-api from 3.9.10 to 
3.9.12 (#15946)
     add 0e74e5e78d Bump org.apache.commons:commons-compress from 1.27.1 to 
1.28.0 (#15945)
     add d88190a6c1 Bump io.smallrye.reactive:mutiny from 2.9.0 to 2.9.5 
(#15942)
     add 1f945d3185 Bump jakarta.xml.bind:jakarta.xml.bind-api from 4.0.2 to 
4.0.4 (#15941)
     add 872c3723f6 Import jackson 2.20.1 pom to simplify dependencies for 
bumping jackson components (#15960)
     add ac1621f9a0 Bump org.aspectj:aspectjweaver from 1.9.24 to 1.9.25.1 
(#15943)
     add 703290db37 Support Tri backpress (#15957)
     add 8700256bf2 Unify graceful shutdown interface,add Triple support 
(#15926)
     add 6a5809bd30 Bump org.apache.maven.plugins:maven-javadoc-plugin from 
3.11.2 to 3.12.0 (#15966)
     add d32427df8f Bump org.hibernate:hibernate-validator from 6.2.0.Final to 
6.2.5.Final (#15965)
     add 0bc5260e40 Bump org.codehaus.mojo:license-maven-plugin from 2.7.0 to 
2.7.1 (#15964)
     add 56924bb773 Stabilize boot-related tests in dubbo-config-spring (#15845)
     add bc09177b80 [PR] #15935 Enhance NetUtils IPv6 handling and test 
coverage (#15974)
     add 48f3a62134 Tri backpressure (#15967)
     add 405bd9f06a Enhance bug template with reproduction demo checkbox 
(#15977)
     add 5b8e1f67af Add check for empty cookie string in decodeCookies method 
(#15985)
     add dcb0db7f33 fix(cluster): During the service provider's release period, 
concurrent read routes from consumers were rejected (#15883)
     add c230a1cb07 Fix: Enhance NetUtils test coverage and boundaries (#15935) 
(#15986)
     add b6f2a0f7fb Fix: Add warning log when using unbounded queue in 
FixedThreadPool (Issue #15969) (#15984)
     add b7d52c39ac fix: AbstractMetadataReport MemoryOverflow (#15987)
     add d9121ddda3 build(deps): bump io.opentelemetry:opentelemetry-bom 
(#15994)
     add 055c75fec0 build(deps): bump spock_version from 2.3-groovy-4.0 to 
2.4-groovy-4.0 (#15993)
     add 96ce295612 build(deps): bump sentinel.version from 1.8.8 to 1.8.9 
(#15992)
     add d9fa6845b8 build(deps): bump junit_jupiter_version from 5.14.1 to 
5.14.2 (#15989)
     add 822aa6c283 build(deps-dev): bump junit_platform_version from 1.14.1 to 
1.14.2 (#15990)
     add bcc220ad4b Fix #15988: Clear SecurityContext in finally block to 
prevent thread pollution (#15997)
     add cae2fcfc0f Add unit test for PathUtils in dubbo-common (#16001)
     add 1661f1ff81 Stabilize remaining reference and schema related tests in 
dubbo-config-spring (#15844)
     add 4c0a7bdbdf Stabilize dubbo-config-spring propertyconfigurer-related 
tests (#15841)
     add 4d702bdb45 Stabilize reference-related tests in dubbo-config-spring 
(#15840)
     add 1d4e26fa13 Stabilizing context-related tests in dubbo-config-spring 
(#15835)
     add 92fcc7847d Fix several tests in dubbo-config-spring beans module 
(#15834)
     add 28685e029d Stabilize tests in the dubbo-config-spring issue module 
(#15833)
     add 5aa764c07e fix tri backpressure race condition (#16004)
     add 2daf878fc5 opt triple remote flow controller (#15983)
     add 4af95dc7c0 get moduleModel at 
ReferenceBeanManager#prepareReferenceBeans method to avoid getting null result 
(#15769)
     add ef8c0ee158 Add unit test for MethodComparator (#16006)
     add 893cd2343d Implement stream initialization in ClientStream and 
AbstractTripleClientStream (#16014)
     add aa8743623a build(deps): bump com.fasterxml.jackson:jackson-bom (#16018)
     add d5467264f0 build(deps): bump io.micrometer:micrometer-tracing-bom 
(#16020)
     add 281cfcee5f build(deps): bump io.micrometer:micrometer-core from 1.16.1 
to 1.16.2 (#16019)
     add ff1cc41a66 build(deps): bump io.micrometer:micrometer-bom from 1.16.1 
to 1.16.2 (#16016)
     add 6ffc9d6421 build(deps-dev): bump io.projectreactor:reactor-core from 
3.8.1 to 3.8.2 (#16015)
     add a92d5d08d9 build(deps): bump byte-buddy_version from 1.18.3 to 1.18.4 
(#16017)
     add 69c772b7c9 refactor: enhance backpressure handling with byte tracking  
(#16028)
     add 0f3ce734b4 Fix timestamp filtering in ZooKeeper registry causing 
pre-warmup failure (#16034)
     add 1cb1409181 Fix init stream race (#16039)
     add be40746485 Bump protobuf-java from 3.25.8 to 4.33.4 and remove guava 
dependency by rewriting CodecTest with java.nio.charset.StandardCharsets 
(#16026)
     add 2c8aa73b58 Bump protobuf-java,grpc of dubbo-security to latest version 
(#16044)
     add e6fa71b7aa build(deps): bump io.swagger.core.v3:swagger-annotations 
(#16052)
     add 49f3f67b40 build(deps): bump spring-boot-3.version from 3.5.9 to 
3.5.10 (#16050)
     add a8283f69fe build(deps): bump org.apache.groovy:groovy from 4.0.29 to 
4.0.30 (#16049)
     add 6a0491d31b Merge branch '3.3' into feat-tagStateRouter

No new revisions were added by this update.

Summary of changes:
 .github/ISSUE_TEMPLATE/1-bug.yml                   |  10 +
 dubbo-cluster/pom.xml                              |   2 +-
 .../rpc/cluster/directory/AbstractDirectory.java   |  66 +-
 .../AbstractDirectoryConcurrencyTest.java          | 276 ++++++++
 .../dubbo/common/stream/CallStreamObserver.java    | 142 ++++
 .../common/stream/ClientCallStreamObserver.java    |  99 +++
 .../common/stream/ClientResponseObserver.java      |  91 +++
 .../common/stream/ServerCallStreamObserver.java    |  85 +++
 .../threadpool/support/fixed/FixedThreadPool.java  |  12 +
 .../apache/dubbo/config/nested/TripleConfig.java   |  28 +
 .../support/fixed/FixedThreadPoolTest.java         |  11 +
 .../dubbo/common/utils/MethodComparatorTest.java   |  71 ++
 .../apache/dubbo/common/utils/NetUtilsTest.java    | 141 ++++
 .../utils/PathUtilsTest.java}                      |  25 +-
 .../apache/dubbo/generic/GenericServiceTest.java   |  12 +-
 dubbo-config/dubbo-config-api/pom.xml              |   2 +-
 dubbo-config/dubbo-config-spring/pom.xml           |   2 +-
 .../spring/reference/ReferenceBeanManager.java     |   3 +-
 .../dubbo/config/spring/JavaConfigBeanTest.java    |   4 +
 .../DubboConfigAliasPostProcessorTest.java         |  18 +
 .../annotation/MethodConfigCallbackTest.java       |   8 +-
 .../ReferenceAnnotationBeanPostProcessorTest.java  |   2 +
 .../ServiceAnnotationPostProcessorTest.java        |   2 +
 ...gDefaultPropertyValueBeanPostProcessorTest.java |  18 +
 .../MultipleServicesWithMethodConfigsTest.java     |   2 +
 .../XmlReferenceBeanConditionalTest.java           |   2 +-
 ...nfigAnnotationReferenceBeanConditionalTest.java |   8 +-
 .../JavaConfigRawReferenceBeanConditionalTest.java |   8 +-
 .../importxml/SpringBootImportDubboXmlTest.java    |   7 +-
 .../importxml2/SpringBootImportAndScanTest.java    |   4 +-
 .../context/KeepRunningOnSpringClosedTest.java     |   9 +
 .../DubboComponentScanRegistrarTest.java           |   9 +-
 .../spring/context/annotation/EnableDubboTest.java |   5 +
 .../customize/DubboSpringInitCustomizerTest.java   |   3 +
 .../extension/SpringExtensionInjectorTest.java     |   9 +-
 .../spring/annotation/AnnotationIsolationTest.java |   4 +
 .../spring/issues/issue6000/Issue6000Test.java     |   5 +
 .../spring/issues/issue6252/Issue6252Test.java     |   5 +
 .../spring/issues/issue7003/Issue7003Test.java     |   5 +
 .../issue9172/MultipleConsumerAndProviderTest.java |  18 +
 .../issues/issue9207/ConfigCenterBeanTest.java     |  17 +
 .../consumer/PropertyConfigurerTest.java           |   5 +
 .../consumer2/PropertySourcesConfigurerTest.java   |   5 +
 .../consumer3/PropertySourcesInJavaConfigTest.java |  10 +-
 .../reference/DubboConfigBeanInitializerTest.java  |   8 +-
 .../config/spring/reference/ReferenceKeyTest.java  |  11 +
 .../spring/reference/localcall/LocalCallTest.java  |   5 +
 .../LocalCallReferenceAnnotationTest.java          |   5 +
 .../LocalCallMultipleReferenceAnnotationsTest.java |  12 +-
 .../localcallmix/LocalCallReferenceMixTest.java    |   5 +
 .../registryNA/consumer/DubboXmlConsumerTest.java  |  18 +
 .../registryNA/provider/DubboXmlProviderTest.java  |  18 +
 .../config/spring/schema/GenericServiceTest.java   |   2 +
 .../schema/GenericServiceWithoutInterfaceTest.java |   2 +
 dubbo-demo/dubbo-demo-spring-boot/pom.xml          |   2 +-
 dubbo-dependencies-bom/pom.xml                     |  79 +--
 dubbo-distribution/dubbo-apache-release/pom.xml    |   2 +-
 dubbo-maven-plugin/pom.xml                         |  14 +-
 .../BaseApplicationMetadataIdentifier.java         |  19 +
 .../identifier/BaseServiceMetadataIdentifier.java  |  23 +
 .../report/identifier/MetadataIdentifier.java      |  15 +
 .../identifier/ServiceMetadataIdentifier.java      |  15 +
 .../identifier/SubscriberMetadataIdentifier.java   |  21 +
 .../metadata/AbstractServiceNameMappingTest.java   |  26 +-
 .../report/MetadataReportInstanceTest.java         |   4 +-
 .../report/identifier/MetadataIdentifierTest.java  |  15 +-
 ...est.java => ServiceMetadataIdentifierTest.java} |  30 +-
 ....java => SubscriberMetadataIdentifierTest.java} |  24 +-
 .../report/support/AbstractMetadataReportTest.java |  18 +-
 dubbo-metadata/pom.xml                             |   9 -
 .../mutiny/AbstractTripleMutinyPublisher.java      |   4 +-
 .../mutiny/AbstractTripleMutinySubscriber.java     |   2 +-
 .../dubbo/mutiny/ClientTripleMutinyPublisher.java  |   2 +-
 .../dubbo/mutiny/ServerTripleMutinyPublisher.java  |   2 +-
 .../dubbo/mutiny/ServerTripleMutinySubscriber.java |   2 +-
 .../dubbo/mutiny/calls/MutinyClientCalls.java      |   2 +-
 .../dubbo/mutiny/calls/MutinyServerCalls.java      |   2 +-
 .../mutiny/handler/ManyToManyMethodHandler.java    |   2 +-
 .../mutiny/handler/ManyToOneMethodHandler.java     |   2 +-
 .../apache/dubbo/mutiny/MutinyClientCallsTest.java |  12 +-
 .../apache/dubbo/mutiny/MutinyServerCallsTest.java |   2 +-
 .../dubbo/mutiny/TripleMutinyPublisherTest.java    |   2 +-
 .../dubbo/mutiny/TripleMutinySubscriberTest.java   |   2 +-
 .../reactive/AbstractTripleReactorPublisher.java   |  21 +-
 .../reactive/AbstractTripleReactorSubscriber.java  |   4 +-
 .../reactive/ClientTripleReactorPublisher.java     |  23 +-
 .../reactive/ServerTripleReactorPublisher.java     |   2 +-
 .../reactive/ServerTripleReactorSubscriber.java    |   2 +-
 .../dubbo/reactive/calls/ReactorClientCalls.java   |   2 +-
 .../dubbo/reactive/calls/ReactorServerCalls.java   |   2 +-
 .../reactive/handler/ManyToManyMethodHandler.java  |   2 +-
 .../reactive/handler/ManyToOneMethodHandler.java   |   2 +-
 .../dubbo/reactive/CreateObserverAdapter.java      |   8 +-
 .../tri/rest/support/jaxrs/RestProtocolTest.groovy |   3 +-
 dubbo-plugin/dubbo-rest-openapi/pom.xml            |   6 +-
 .../rest/support/spring/RestProtocolTest.groovy    |   3 +-
 dubbo-plugin/dubbo-security/pom.xml                |   2 +-
 .../ContextHolderAuthenticationResolverFilter.java |   8 +-
 ...textHolderAuthenticationResolverFilterTest.java |  68 ++
 dubbo-plugin/dubbo-spring6-security/pom.xml        |   2 +-
 .../protocol/tri/servlet/ServletStreamChannel.java |  10 +
 .../tri/websocket/WebSocketStreamChannel.java      |  10 +
 .../support/CacheableFailbackRegistry.java         | 115 ++-
 .../support/CacheableFailbackRegistryTest.java     | 162 +++++
 .../apache/dubbo/registry/nacos/NacosRegistry.java |   8 +-
 .../org/apache/dubbo/remoting/ChannelEvent.java    |  48 ++
 .../org/apache/dubbo/remoting/RemotingServer.java  |   9 +
 .../apache/dubbo/remoting/event/ReadOnlyEvent.java |  58 ++
 .../dubbo/remoting/event/WriteableEvent.java       |  58 ++
 .../exchange/support/ExchangeServerDelegate.java   |   6 +
 .../support/header/HeaderExchangeServer.java       |  22 +-
 .../dubbo/remoting/transport/AbstractServer.java   |  13 +
 .../dubbo/remoting/transport/ServerDelegate.java   |   6 +
 .../http12/AbstractServerHttpChannelObserver.java  |  20 +-
 .../dubbo/remoting/http12/HttpOutputMessage.java   |  12 +
 .../apache/dubbo/remoting/http12/HttpUtils.java    |   3 +
 .../remoting/http12/h1/Http1OutputMessage.java     |   8 +
 .../dubbo/remoting/http12/h2/H2StreamChannel.java  |  21 +
 .../remoting/http12/h2/Http2ChannelDelegate.java   |  10 +
 .../http12/h2/Http2OutputMessageFrame.java         |   8 +
 .../http12/h2/Http2ServerChannelObserver.java      | 158 ++++-
 .../remoting/http12/h2/Http2TransportListener.java |   6 +
 .../message/LengthFieldStreamingDecoder.java       |  73 +-
 .../remoting/http12/message/StreamingDecoder.java  |  29 +-
 .../http12/netty4/h1/NettyHttp1Channel.java        |   8 +-
 .../http12/netty4/h2/NettyH2StreamChannel.java     |  57 +-
 .../http12/netty4/h2/NettyHttp2FrameHandler.java   |   8 +
 .../h2/NettyHttp2ProtocolSelectorHandler.java      |  16 +-
 ...Http2ServerChannelObserverByteCountingTest.java | 260 +++++++
 .../remoting/http12/message/codec/CodecTest.java   |   6 +-
 .../http3/netty4/NettyHttp3StreamChannel.java      |  10 +
 .../transport/netty4/NettyConnectionHandler.java   |   2 +
 .../netty4/NettyPortUnificationServer.java         |  40 ++
 .../remoting/transport/netty4/NettyServer.java     |  39 ++
 .../websocket/netty4/NettyWebSocketChannel.java    |  10 +
 .../apache/dubbo/rpc/AbstractGracefulShutdown.java | 105 +++
 .../apache/dubbo/rpc/DefaultProtocolServer.java}   |  44 +-
 .../dubbo/rpc/protocol/AbstractProtocol.java       |   3 +-
 .../dubbo/rpc/protocol/AbstractProxyProtocol.java  |   6 +
 .../dubbo/rpc/AbstractGracefulShutdownTest.java    | 176 +++++
 .../dubbo/rpc/DefaultProtocolServerTest.java       | 171 +++++
 .../rpc/protocol/dubbo/DubboGracefulShutdown.java  | 101 +--
 .../dubbo/rpc/protocol/dubbo/DubboProtocol.java    |   3 +-
 .../protocol/dubbo/DubboGracefulShutdownTest.java  | 168 +++++
 .../rpc/protocol/tri/ClientStreamObserver.java     |  11 +-
 .../rpc/protocol/tri/ServerStreamObserver.java     |   9 +-
 .../protocol/tri/TriHttp2RemoteFlowController.java | 780 ---------------------
 .../rpc/protocol/tri/TripleGracefulShutdown.java   |  93 +++
 .../rpc/protocol/tri/TripleHttp2Protocol.java      |  60 +-
 .../dubbo/rpc/protocol/tri/TripleInvoker.java      |  74 +-
 .../dubbo/rpc/protocol/tri/TripleProtocol.java     |  11 +-
 .../dubbo/rpc/protocol/tri/call/ClientCall.java    |  47 +-
 .../call/ObserverToClientCallListenerAdapter.java  |  40 +-
 .../rpc/protocol/tri/call/TripleClientCall.java    |  82 ++-
 .../protocol/tri/call/UnaryClientCallListener.java |   6 +-
 ...ueCommand.java => InitOnReadyQueueCommand.java} |  44 +-
 .../dubbo/rpc/protocol/tri/frame/TriDecoder.java   |  22 +-
 .../tri/h12/AbstractServerTransportListener.java   |   4 +
 .../h12/grpc/GrpcHttp2ServerTransportListener.java |  10 +
 .../http2/GenericHttp2ServerTransportListener.java |  51 +-
 .../tri/h12/http2/Http2ServerStreamObserver.java   |   3 +-
 .../tri/h12/http2/Http2TripleClientStream.java     |  84 ++-
 .../protocol/tri/h3/Http3TripleClientStream.java   |   8 +-
 .../protocol/tri/observer/CallStreamObserver.java  |  51 --
 .../tri/observer/ClientCallToObserverAdapter.java  |  32 +-
 .../tri/stream/AbstractTripleClientStream.java     | 138 +++-
 .../rpc/protocol/tri/stream/ClientStream.java      |  12 +
 .../dubbo/rpc/protocol/tri/stream/Stream.java      |   8 +
 .../protocol/tri/transport/GracefulShutdown.java   | 116 ++-
 .../tri/transport/H2TransportListener.java         |   6 +
 .../TripleHttp2ClientResponseHandler.java          |   8 +
 .../transport/TripleHttp2LocalFlowController.java  |  70 ++
 .../transport/TripleHttp2RemoteFlowController.java |  73 ++
 .../transport/TripleServerConnectionHandler.java   |  28 +
 .../protocol/tri/TripleGracefulShutdownTest.java   | 168 +++++
 .../dubbo/rpc/protocol/tri/TripleInvokerTest.java  |   5 +-
 .../rpc/protocol/tri/call/BackpressureTest.java    | 366 ++++++++++
 .../rpc/protocol/tri/frame/RecordListener.java     |   3 +
 ...AbstractTripleClientStreamByteCountingTest.java | 265 +++++++
 .../tri/stream/TripleClientStreamTest.java         |   9 +-
 .../rpc/protocol/tri/test/MockH2StreamChannel.java |  10 +
 .../protocol/tri/test/MockHttp2OutputMessage.java  |   8 +
 dubbo-test/dubbo-test-check/pom.xml                |   4 +-
 pom.xml                                            |  23 +-
 184 files changed, 5563 insertions(+), 1255 deletions(-)
 create mode 100644 
dubbo-cluster/src/test/java/org/apache/dubbo/rpc/cluster/directory/AbstractDirectoryConcurrencyTest.java
 create mode 100644 
dubbo-common/src/main/java/org/apache/dubbo/common/stream/CallStreamObserver.java
 create mode 100644 
dubbo-common/src/main/java/org/apache/dubbo/common/stream/ClientCallStreamObserver.java
 create mode 100644 
dubbo-common/src/main/java/org/apache/dubbo/common/stream/ClientResponseObserver.java
 create mode 100644 
dubbo-common/src/main/java/org/apache/dubbo/common/stream/ServerCallStreamObserver.java
 create mode 100644 
dubbo-common/src/test/java/org/apache/dubbo/common/utils/MethodComparatorTest.java
 copy 
dubbo-common/src/test/java/org/apache/dubbo/{rpc/service/ServiceDescriptorInternalCacheTest.java
 => common/utils/PathUtilsTest.java} (58%)
 copy 
dubbo-metadata/dubbo-metadata-api/src/test/java/org/apache/dubbo/metadata/report/identifier/{KeyTypeEnumTest.java
 => ServiceMetadataIdentifierTest.java} (52%)
 copy 
dubbo-metadata/dubbo-metadata-api/src/test/java/org/apache/dubbo/metadata/report/identifier/{KeyTypeEnumTest.java
 => SubscriberMetadataIdentifierTest.java} (61%)
 create mode 100644 
dubbo-plugin/dubbo-spring-security/src/test/java/org/apache/dubbo/spring/security/filter/ContextHolderAuthenticationResolverFilterTest.java
 create mode 100644 
dubbo-registry/dubbo-registry-api/src/test/java/org/apache/dubbo/registry/support/CacheableFailbackRegistryTest.java
 create mode 100644 
dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/ChannelEvent.java
 create mode 100644 
dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/event/ReadOnlyEvent.java
 create mode 100644 
dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/event/WriteableEvent.java
 create mode 100644 
dubbo-remoting/dubbo-remoting-http12/src/test/java/org/apache/dubbo/remoting/http12/h2/Http2ServerChannelObserverByteCountingTest.java
 create mode 100644 
dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AbstractGracefulShutdown.java
 rename 
dubbo-rpc/{dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboProtocolServer.java
 => 
dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/DefaultProtocolServer.java} 
(60%)
 create mode 100644 
dubbo-rpc/dubbo-rpc-api/src/test/java/org/apache/dubbo/rpc/AbstractGracefulShutdownTest.java
 create mode 100644 
dubbo-rpc/dubbo-rpc-api/src/test/java/org/apache/dubbo/rpc/DefaultProtocolServerTest.java
 create mode 100644 
dubbo-rpc/dubbo-rpc-dubbo/src/test/java/org/apache/dubbo/rpc/protocol/dubbo/DubboGracefulShutdownTest.java
 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/TripleGracefulShutdown.java
 copy 
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/command/{CreateStreamQueueCommand.java
 => InitOnReadyQueueCommand.java} (51%)
 delete mode 100644 
dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/observer/CallStreamObserver.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/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2RemoteFlowController.java
 create mode 100644 
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/TripleGracefulShutdownTest.java
 create mode 100644 
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/call/BackpressureTest.java
 create mode 100644 
dubbo-rpc/dubbo-rpc-triple/src/test/java/org/apache/dubbo/rpc/protocol/tri/stream/AbstractTripleClientStreamByteCountingTest.java

Reply via email to