Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

optimize: splitting MergedWarpMessage enhances the server parallel processing capability #6807

Open
wants to merge 22 commits into
base: 2.x
Choose a base branch
from

Conversation

funky-eyes
Copy link
Contributor

@funky-eyes funky-eyes commented Sep 3, 2024

  • I have registered the PR changes.

Ⅰ. Describe what this PR did

当client为2.3.0时,server将merge msg还原回单独的rpcmsg,使其通过msg类型定位到对应的线程池,放入线程池中处理
client为2.3.0时,可直接通过单个response的id定位到future进行响应client的请求,并清理mergemap,避免因为由于单个响应导致client的mergemap无限膨胀无法清理的问题
而由于2.3的client可能跟多个版本server通信,多个版本的client也可能跟2.3server通信,所以老的逻辑不进行改变向下兼容。

Ⅱ. Does this pull request fix one issue?

fixes #6775

Ⅲ. Why don't you add test cases (unit test/integration test)?

Ⅳ. Describe how to verify it

Ⅴ. Special notes for reviews

@funky-eyes funky-eyes added this to the 2.x Backlog milestone Sep 3, 2024
Copy link

codecov bot commented Sep 3, 2024

Codecov Report

Attention: Patch coverage is 0% with 60 lines in your changes missing coverage. Please review.

Please upload report for BASE (2.x@a0d0513). Learn more about missing BASE report.

Files with missing lines Patch % Lines
...pc/processor/client/ClientOnResponseProcessor.java 0.00% 23 Missing ⚠️
...ta/core/rpc/netty/AbstractNettyRemotingServer.java 0.00% 18 Missing ⚠️
...ta/core/rpc/netty/AbstractNettyRemotingClient.java 0.00% 9 Missing ⚠️
...n/java/org/apache/seata/core/protocol/Version.java 0.00% 6 Missing ⚠️
...he/seata/core/rpc/netty/TmNettyRemotingClient.java 0.00% 2 Missing ⚠️
...ache/seata/core/rpc/netty/NettyRemotingServer.java 0.00% 1 Missing ⚠️
...he/seata/core/rpc/netty/RmNettyRemotingClient.java 0.00% 1 Missing ⚠️
Additional details and impacted files

Impacted file tree graph

@@          Coverage Diff          @@
##             2.x   #6807   +/-   ##
=====================================
  Coverage       ?   0.00%           
=====================================
  Files          ?    1149           
  Lines          ?   41059           
  Branches       ?    5008           
=====================================
  Hits           ?       0           
  Misses         ?   41059           
  Partials       ?       0           
Files with missing lines Coverage Δ
...ache/seata/core/rpc/netty/NettyRemotingServer.java 0.00% <0.00%> (ø)
...he/seata/core/rpc/netty/RmNettyRemotingClient.java 0.00% <0.00%> (ø)
...he/seata/core/rpc/netty/TmNettyRemotingClient.java 0.00% <0.00%> (ø)
...n/java/org/apache/seata/core/protocol/Version.java 0.00% <0.00%> (ø)
...ta/core/rpc/netty/AbstractNettyRemotingClient.java 0.00% <0.00%> (ø)
...ta/core/rpc/netty/AbstractNettyRemotingServer.java 0.00% <0.00%> (ø)
...pc/processor/client/ClientOnResponseProcessor.java 0.00% <0.00%> (ø)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Implement an independent ChannelDuplexHandler for MergedWarpMessage
1 participant