anton-vinogradov commented on code in PR #13095:
URL: https://github.com/apache/ignite/pull/13095#discussion_r3599159121
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java:
##########
@@ -1197,11 +1201,19 @@ public void sendOrderedMessage(ClusterNode node, Object
topic, GridCacheMessage
msg.lastAffinityChangedTopologyVersion(cctx.exchange().lastAffinityChangedTopologyVersion(msg.topologyVersion()));
+ if (node.isLocal()) {
+ cctx.gridIO().sendOrderedMessage(node, topic, msg, plc, timeout,
false);
+
+ return;
+ }
+
+ GridIoMessage ioMsg = cctx.gridIO().prepare(topic, msg, plc, true,
timeout, false);
Review Comment:
Done via the encapsulation above: with `sendWithRetry` owning prepare-once +
retry inside the transport, callers neither see the flag nor the wrap —
`prepare` is private now. The flag itself got generalized along the way
(`marshalled`, set and asserted at every marshal point, asserted again at
transmit), so a future re-marshal on any path trips an assertion without a
per-message base class.
--
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]
