fix: correct the use of serializer in network message, issue #10585

tglman · tglman · commit 1cc1614edaae · 2025-10-19T18:42:16.000+01:00
diff --git a/client/src/main/java/com/orientechnologies/orient/client/remote/OrientDBRemote.java b/client/src/main/java/com/orientechnologies/orient/client/remote/OrientDBRemote.java
@@ -267,7 +267,7 @@ public ODocument getServerInfo(String username, String password) {
   }
 
   public ODocument getClusterStatus(String username, String password) {
-    ODistributedStatusRequest request = new ODistributedStatusRequest();
+    ODistributedStatusRequest request = new ODistributedStatusRequest("status");
     ODistributedStatusResponse response = connectAndSend(null, username, password, request);
 
     OLogManager.instance()
diff --git a/client/src/main/java/com/orientechnologies/orient/client/remote/message/ODistributedStatusRequest.java b/client/src/main/java/com/orientechnologies/orient/client/remote/message/ODistributedStatusRequest.java
@@ -23,8 +23,10 @@
 import com.orientechnologies.orient.client.remote.OBinaryRequest;
 import com.orientechnologies.orient.client.remote.OBinaryResponse;
 import com.orientechnologies.orient.client.remote.OStorageRemoteSession;
+import com.orientechnologies.orient.core.record.ORecordInternal;
 import com.orientechnologies.orient.core.record.impl.ODocument;
 import com.orientechnologies.orient.core.serialization.serializer.record.ORecordSerializer;
+import com.orientechnologies.orient.core.serialization.serializer.record.binary.ORecordSerializerNetworkV37;
 import com.orientechnologies.orient.enterprise.channel.binary.OChannelBinaryProtocol;
 import com.orientechnologies.orient.enterprise.channel.binary.OChannelDataInput;
 import com.orientechnologies.orient.enterprise.channel.binary.OChannelDataOutput;
@@ -33,16 +35,26 @@
 public class ODistributedStatusRequest implements OBinaryRequest<ODistributedStatusResponse> {
   private ODocument status;
 
-  public ODistributedStatusRequest() {}
+  public ODistributedStatusRequest() {
+    status = new ODocument();
+  }
+
+  public ODistributedStatusRequest(String operation) {
+    status = new ODocument();
+    status.setProperty("operation", operation);
+  }
 
   @Override
   public void write(OChannelDataOutput network, OStorageRemoteSession session) throws IOException {
-    network.writeBytes(new ODocument().field("operation", "status").toStream());
+    byte[] bytes = ORecordSerializerNetworkV37.INSTANCE.toStream(status);
+    network.writeBytes(bytes);
   }
 
   public void read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
       throws IOException {
-    status = new ODocument(channel.readBytes());
+    status = new ODocument();
+    ORecordInternal.setRecordSerializer(status, serializer);
+    status.fromStream(channel.readBytes());
   }
 
   public ODocument getStatus() {

Original file line number	Diff line number	Diff line change
`@@ -267,7 +267,7 @@ public ODocument getServerInfo(String username, String password) {`
`267`	`267`	`}`
`268`	`268`
`269`	`269`	`public ODocument getClusterStatus(String username, String password) {`
`270`		`- ODistributedStatusRequest request = new ODistributedStatusRequest();`
	`270`	`+ ODistributedStatusRequest request = new ODistributedStatusRequest("status");`
`271`	`271`	`ODistributedStatusResponse response = connectAndSend(null, username, password, request);`
`272`	`272`
`273`	`273`	`OLogManager.instance()`