This is an automated email from the ASF dual-hosted git repository.
shishkovilja 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 5002499761a IGNITE-28057 Fix load test communication message
serialization (#13005)
5002499761a is described below
commit 5002499761a2338d5844c8b55e5a0f3407038b7e
Author: Aleksandr Chesnokov <[email protected]>
AuthorDate: Thu Jun 11 10:41:26 2026 +0300
IGNITE-28057 Fix load test communication message serialization (#13005)
---
.../core/src/test/config/io-manager-benchmark.xml | 6 ++++
.../communication/GridIoManagerBenchmark0.java | 3 ++
.../loadtests/communication/GridTestMessage.java | 16 ++++++----
.../LoadTestsCommunicationPluginProvider.java | 34 ++++++++++++++++++++++
4 files changed, 54 insertions(+), 5 deletions(-)
diff --git a/modules/core/src/test/config/io-manager-benchmark.xml
b/modules/core/src/test/config/io-manager-benchmark.xml
index f04aaa987ea..5f3bd89e16c 100644
--- a/modules/core/src/test/config/io-manager-benchmark.xml
+++ b/modules/core/src/test/config/io-manager-benchmark.xml
@@ -34,6 +34,12 @@
<list/>
</property>
+ <property name="pluginProviders">
+ <list>
+ <bean
class="org.apache.ignite.loadtests.communication.LoadTestsCommunicationPluginProvider"/>
+ </list>
+ </property>
+
<!-- Configure load balancing SPI in the way that do not require extra
event subscription. -->
<property name="loadBalancingSpi">
<bean
class="org.apache.ignite.spi.loadbalancing.roundrobin.RoundRobinLoadBalancingSpi">
diff --git
a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark0.java
b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark0.java
index bdf263afe52..fef6872fb09 100644
---
a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark0.java
+++
b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridIoManagerBenchmark0.java
@@ -40,6 +40,7 @@ import org.apache.ignite.internal.util.typedef.internal.SB;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
+import org.apache.ignite.spi.MessagesPluginProvider;
import org.apache.ignite.spi.communication.CommunicationSpi;
import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi;
import org.apache.ignite.testframework.GridTestUtils;
@@ -75,6 +76,8 @@ public class GridIoManagerBenchmark0 extends
GridCommonAbstractTest {
c.setCommunicationSpi(getCommunication());
+ c.setPluginProviders(new
MessagesPluginProvider(GridTestMessage.class));
+
return c;
}
diff --git
a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java
b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java
index b129cd0043f..e7ce17cc720 100644
---
a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java
+++
b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/GridTestMessage.java
@@ -21,6 +21,7 @@ import java.io.Externalizable;
import java.io.IOException;
import java.io.ObjectInput;
import java.io.ObjectOutput;
+import org.apache.ignite.internal.Order;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.lang.IgniteUuid;
import org.apache.ignite.plugin.extensions.communication.Message;
@@ -30,19 +31,24 @@ import
org.apache.ignite.plugin.extensions.communication.Message;
*/
class GridTestMessage implements Message, Externalizable {
/** */
- private IgniteUuid id;
+ @Order(0)
+ IgniteUuid id;
/** */
- private long field1;
+ @Order(1)
+ long field1;
/** */
- private long field2;
+ @Order(2)
+ long field2;
/** */
- private String str;
+ @Order(3)
+ String str;
/** */
- private byte[] bytes;
+ @Order(4)
+ byte[] bytes;
/**
* @param id Message ID.
diff --git
a/modules/core/src/test/java/org/apache/ignite/loadtests/communication/LoadTestsCommunicationPluginProvider.java
b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/LoadTestsCommunicationPluginProvider.java
new file mode 100644
index 00000000000..fd50d5ce2c1
--- /dev/null
+++
b/modules/core/src/test/java/org/apache/ignite/loadtests/communication/LoadTestsCommunicationPluginProvider.java
@@ -0,0 +1,34 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.loadtests.communication;
+
+import org.apache.ignite.plugin.PluginContext;
+import org.apache.ignite.spi.MessagesPluginProvider;
+
+/** Registers communication messages used by load tests. */
+public class LoadTestsCommunicationPluginProvider extends
MessagesPluginProvider {
+ /** */
+ public LoadTestsCommunicationPluginProvider() {
+ super(GridTestMessage.class);
+ }
+
+ /** {@inheritDoc} */
+ @Override public void start(PluginContext ctx) {
+ // No-op.
+ }
+}
