Skip to content

IGNITE-27975 Use MessageSerializer for IgniteIoTestMessage #12988

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
NSAmelchev merged 2 commits into from
Apr 7, 2026
+40 −298
Merged

IGNITE-27975 Use MessageSerializer for IgniteIoTestMessage #12988

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b5c2c76
IGNITE-27975 Use MessageSerializer for IgniteIoTestMessage
wernerdv Apr 7, 2026
b20c22a
remove IgniteCodeGeneratingFail
wernerdv Apr 7, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 0 additions & 34 deletions modules/core/src/main/java/org/apache/ignite/internal/IgniteCodeGeneratingFail.java
View file
Open in desktop

This file was deleted.

2 changes: 1 addition & 1 deletion ...src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,7 @@ public GridIoMessageFactory(Marshaller marsh, ClassLoader clsLdr) {
factory.register(-49, UpdateErrors::new, new UpdateErrorsSerializer());
factory.register(-48, GridDhtAtomicNearResponse::new, new GridDhtAtomicNearResponseSerializer());
factory.register(-45, GridChangeGlobalStateMessageResponse::new, new GridChangeGlobalStateMessageResponseSerializer());
factory.register((short)-43, IgniteIoTestMessage::new);
factory.register(-43, IgniteIoTestMessage::new, new IgniteIoTestMessageMarshallableSerializer(marsh, clsLdr));
factory.register(-36, GridDhtAtomicSingleUpdateRequest::new, new GridDhtAtomicSingleUpdateRequestSerializer());
factory.register(-27, GridDhtTxOnePhaseCommitAckRequest::new, new GridDhtTxOnePhaseCommitAckRequestSerializer());
factory.register(-25, TxLock::new, new TxLockSerializer());
Expand Down
295 changes: 37 additions & 258 deletions .../src/main/java/org/apache/ignite/internal/managers/communication/IgniteIoTestMessage.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,70 +17,81 @@

package org.apache.ignite.internal.managers.communication;

import java.nio.ByteBuffer;
import java.util.UUID;
import org.apache.ignite.internal.GridDirectTransient;
import org.apache.ignite.internal.IgniteCodeGeneratingFail;
import org.apache.ignite.IgniteCheckedException;
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.apache.ignite.marshaller.Marshaller;
import org.apache.ignite.plugin.extensions.communication.MarshallableMessage;

/**
*
*/
@IgniteCodeGeneratingFail
public class IgniteIoTestMessage implements Message {
public class IgniteIoTestMessage implements MarshallableMessage {
/** */
private static final byte FLAG_PROC_FROM_NIO = 1;

/** */
private long id;
@Order(0)
long id;

/** */
private byte flags;
@Order(1)
byte flags;

/** */
private boolean req;
@Order(2)
boolean req;

/** */
private byte[] payload;
@Order(3)
byte[] payload;

/** */
private long reqCreateTs;
@Order(4)
long reqCreateTs;

/** */
private long reqSndTs;
@Order(5)
long reqSndTs;

/** */
private long reqSndTsMillis;
@Order(6)
long reqSndTsMillis;

/** */
private long reqRcvTs;
@Order(7)
long reqRcvTs;

/** */
private long reqRcvTsMillis;
@Order(8)
long reqRcvTsMillis;

/** */
private long reqProcTs;
@Order(9)
long reqProcTs;

/** */
private long resSndTs;
@Order(10)
long resSndTs;

/** */
private long resSndTsMillis;
@Order(11)
long resSndTsMillis;

/** */
private long resRcvTs;
@Order(12)
long resRcvTs;

/** */
private long resRcvTsMillis;
@Order(13)
long resRcvTsMillis;

/** */
private long resProcTs;
@Order(14)
long resProcTs;

/** */
@GridDirectTransient
private UUID sndNodeId;

/**
Expand Down Expand Up @@ -314,247 +325,15 @@ public void senderNodeId(UUID sndNodeId) {
}

/** {@inheritDoc} */
@Override public boolean writeTo(ByteBuffer buf, MessageWriter writer) {
writer.setBuffer(buf);

@Override public void prepareMarshal(Marshaller marsh) throws IgniteCheckedException {
onBeforeWrite();

if (!writer.isHeaderWritten()) {
if (!writer.writeHeader(directType()))
return false;

writer.onHeaderWritten();
}

switch (writer.state()) {
case 0:
if (!writer.writeByte(flags))
return false;

writer.incrementState();

case 1:
if (!writer.writeLong(id))
return false;

writer.incrementState();

case 2:
if (!writer.writeByteArray(payload))
return false;

writer.incrementState();

case 3:
if (!writer.writeBoolean(req))
return false;

writer.incrementState();

case 4:
if (!writer.writeLong(reqCreateTs))
return false;

writer.incrementState();

case 5:
if (!writer.writeLong(reqProcTs))
return false;

writer.incrementState();

case 6:
if (!writer.writeLong(reqRcvTs))
return false;

writer.incrementState();

case 7:
if (!writer.writeLong(reqRcvTsMillis))
return false;

writer.incrementState();

case 8:
if (!writer.writeLong(reqSndTs))
return false;

writer.incrementState();

case 9:
if (!writer.writeLong(reqSndTsMillis))
return false;

writer.incrementState();

case 10:
if (!writer.writeLong(resProcTs))
return false;

writer.incrementState();

case 11:
if (!writer.writeLong(resRcvTs))
return false;

writer.incrementState();

case 12:
if (!writer.writeLong(resRcvTsMillis))
return false;

writer.incrementState();

case 13:
if (!writer.writeLong(resSndTs))
return false;

writer.incrementState();

case 14:
if (!writer.writeLong(resSndTsMillis))
return false;

writer.incrementState();

}

return true;
}

/** {@inheritDoc} */
@Override public boolean readFrom(ByteBuffer buf, MessageReader reader) {
reader.setBuffer(buf);

switch (reader.state()) {
case 0:
flags = reader.readByte();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 1:
id = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 2:
payload = reader.readByteArray();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 3:
req = reader.readBoolean();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 4:
reqCreateTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 5:
reqProcTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 6:
reqRcvTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 7:
reqRcvTsMillis = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 8:
reqSndTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 9:
reqSndTsMillis = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 10:
resProcTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 11:
resRcvTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 12:
resRcvTsMillis = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 13:
resSndTs = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

case 14:
resSndTsMillis = reader.readLong();

if (!reader.isLastRead())
return false;

reader.incrementState();

}

@Override public void finishUnmarshal(Marshaller marsh, ClassLoader clsLdr) throws IgniteCheckedException {
onAfterRead();

return true;
}


/** {@inheritDoc} */
@Override public String toString() {
return S.toString(IgniteIoTestMessage.class, this);
Expand Down
Loading
Loading