This is an automated email from the ASF dual-hosted git repository.
av pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new d1d543697bc IGNITE-27909 Use MessageSerializer for
ServiceSingleNodeDeploymentResult (#12765)
d1d543697bc is described below
commit d1d543697bc5df279c79c8e8b90483de9242cfdb
Author: Dmitry Werner <[email protected]>
AuthorDate: Thu Feb 19 22:03:52 2026 +0500
IGNITE-27909 Use MessageSerializer for ServiceSingleNodeDeploymentResult
(#12765)
---
.../communication/GridIoMessageFactory.java | 3 +-
.../service/ServiceSingleNodeDeploymentResult.java | 61 ++--------------------
2 files changed, 5 insertions(+), 59 deletions(-)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
index 69b38116fd9..b50aad31c9d 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
@@ -164,6 +164,7 @@ import
org.apache.ignite.internal.codegen.RecoveryLastReceivedMessageSerializer;
import
org.apache.ignite.internal.codegen.SchemaOperationStatusMessageSerializer;
import org.apache.ignite.internal.codegen.ServiceDeploymentProcessIdSerializer;
import
org.apache.ignite.internal.codegen.ServiceSingleNodeDeploymentResultBatchSerializer;
+import
org.apache.ignite.internal.codegen.ServiceSingleNodeDeploymentResultSerializer;
import org.apache.ignite.internal.codegen.SessionChannelMessageSerializer;
import
org.apache.ignite.internal.codegen.SnapshotFilesFailureMessageSerializer;
import
org.apache.ignite.internal.codegen.SnapshotFilesRequestMessageSerializer;
@@ -479,7 +480,7 @@ public class GridIoMessageFactory implements
MessageFactoryProvider {
factory.register((short)163, GenerateEncryptionKeyResponse::new, new
GenerateEncryptionKeyResponseSerializer());
factory.register((short)167, ServiceDeploymentProcessId::new, new
ServiceDeploymentProcessIdSerializer());
factory.register((short)168,
ServiceSingleNodeDeploymentResultBatch::new, new
ServiceSingleNodeDeploymentResultBatchSerializer());
- factory.register((short)169, ServiceSingleNodeDeploymentResult::new);
+ factory.register((short)169, ServiceSingleNodeDeploymentResult::new,
new ServiceSingleNodeDeploymentResultSerializer());
factory.register(GridQueryKillRequest.TYPE_CODE,
GridQueryKillRequest::new, new GridQueryKillRequestSerializer());
factory.register(GridQueryKillResponse.TYPE_CODE,
GridQueryKillResponse::new, new GridQueryKillResponseSerializer());
factory.register(GridIoSecurityAwareMessage.TYPE_CODE,
GridIoSecurityAwareMessage::new, new GridIoSecurityAwareMessageSerializer());
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceSingleNodeDeploymentResult.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceSingleNodeDeploymentResult.java
index dda36cdb139..024567fa214 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceSingleNodeDeploymentResult.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceSingleNodeDeploymentResult.java
@@ -18,17 +18,13 @@
package org.apache.ignite.internal.processors.service;
import java.io.Serializable;
-import java.nio.ByteBuffer;
import java.util.Collection;
import java.util.Collections;
+import org.apache.ignite.internal.Order;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.plugin.extensions.communication.Message;
-import org.apache.ignite.plugin.extensions.communication.MessageReader;
-import org.apache.ignite.plugin.extensions.communication.MessageWriter;
import org.jetbrains.annotations.NotNull;
-import static
org.apache.ignite.plugin.extensions.communication.MessageCollectionItemType.BYTE_ARR;
-
/**
* Service single node deployment result.
* <p/>
@@ -39,9 +35,11 @@ public class ServiceSingleNodeDeploymentResult implements
Message, Serializable
private static final long serialVersionUID = 0L;
/** Count of service's instances. */
+ @Order(value = 0, method = "count")
private int cnt;
/** Serialized exceptions. */
+ @Order(1)
private Collection<byte[]> errors;
/**
@@ -85,59 +83,6 @@ public class ServiceSingleNodeDeploymentResult implements
Message, Serializable
this.errors = errors;
}
- /** {@inheritDoc} */
- @Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
- writer.setBuffer(buf);
-
- if (!writer.isHeaderWritten()) {
- if (!writer.writeHeader(directType()))
- return false;
-
- writer.onHeaderWritten();
- }
-
- switch (writer.state()) {
- case 0:
- if (!writer.writeInt(cnt))
- return false;
-
- writer.incrementState();
-
- case 1:
- if (!writer.writeCollection(errors, BYTE_ARR))
- return false;
-
- writer.incrementState();
- }
-
- return true;
- }
-
- /** {@inheritDoc} */
- @Override public boolean readFrom(ByteBuffer buf, MessageReader reader) {
- reader.setBuffer(buf);
-
- switch (reader.state()) {
- case 0:
- cnt = reader.readInt();
-
- if (!reader.isLastRead())
- return false;
-
- reader.incrementState();
-
- case 1:
- errors = reader.readCollection(BYTE_ARR);
-
- if (!reader.isLastRead())
- return false;
-
- reader.incrementState();
- }
-
- return true;
- }
-
/** {@inheritDoc} */
@Override public short directType() {
return 169;
