sergey-chugunov-1985 commented on code in PR #12724:
URL: https://github.com/apache/ignite/pull/12724#discussion_r2827952999
##########
modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryJoinRequestMessage.java:
##########
@@ -78,6 +116,37 @@ public void responded(boolean responded) {
setFlag(RESPONDED_FLAG_POS, responded);
}
+ /**
+ * @param marsh Marshaller.
+ */
+ public void prepareMarshal(Marshaller marsh) {
+ if (node != null && nodeBytes == null) {
+ try {
+ nodeBytes = U.marshal(marsh, node);
+ }
+ catch (IgniteCheckedException e) {
+ throw new IgniteException("Failed to marshal node", e);
+ }
+ }
+ }
+
+ /**
+ * @param marsh Marshaller.
+ * @param clsLdr Class loader.
+ */
+ public void finishUnmarshal(Marshaller marsh, ClassLoader clsLdr) {
+ if (nodeBytes != null && node == null) {
+ try {
+ node = U.unmarshal(marsh, nodeBytes, clsLdr);
+
+ nodeBytes = null;
+ }
+ catch (IgniteCheckedException e) {
+ throw new IgniteException("Failed to unmarshal node", e);
Review Comment:
```suggestion
throw new IgniteException("Failed to unmarshal
TcpDiscoveryNode object", e);
```
##########
modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryJoinRequestMessage.java:
##########
@@ -78,6 +116,37 @@ public void responded(boolean responded) {
setFlag(RESPONDED_FLAG_POS, responded);
}
+ /**
+ * @param marsh Marshaller.
+ */
+ public void prepareMarshal(Marshaller marsh) {
+ if (node != null && nodeBytes == null) {
+ try {
+ nodeBytes = U.marshal(marsh, node);
+ }
+ catch (IgniteCheckedException e) {
+ throw new IgniteException("Failed to marshal node", e);
Review Comment:
```suggestion
throw new IgniteException("Failed to marshal
TcpDiscoveryNode object", e);
```
--
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]
