YvCeung commented on code in PR #8102:
URL: https://github.com/apache/incubator-seata/pull/8102#discussion_r3248906486
##########
core/src/main/java/org/apache/seata/core/rpc/netty/ChannelManager.java:
##########
@@ -361,6 +366,113 @@ private static Channel
getChannelFromSameClientMap(Map<Integer, RpcContext> clie
* @return Corresponding channel, NULL if not found.
*/
public static Channel getChannel(String resourceId, String clientId,
boolean tryOtherApp) {
+ return getChannel(resourceId, clientId, tryOtherApp, null, null);
+ }
+
+ /**
+ * Gets channel with transaction context for server-side load balancing.
+ *
+ * Only AT and TCC branch types support server-side load balancing.
+ * XA is excluded because its second-phase operations are bound to the
local database connection
+ * of the original RM. SAGA is excluded because its state machine
execution context is held
+ * in memory with no distributed lock protection. For XA/SAGA and
unconfigured AT/TCC,
+ * the original priority-based channel selection logic is used.
+ *
+ * @param resourceId Resource ID
+ * @param clientId Client ID - ApplicationId:IP:Port
+ * @param tryOtherApp try other app
+ * @param xid global transaction xid, used for load balancing
affinity
+ * @param branchType branch type, determines whether and which LB
algorithm to use
+ * @return Corresponding channel, NULL if not found.
Review Comment:
removed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
