Class TcpMigrationDataSender

java.lang.Object

com.loomcache.server.cluster.TcpMigrationDataSender

All Implemented Interfaces:

PartitionMigrationPipeline.MigrationDataSender

public final class TcpMigrationDataSender
extends Object
implements PartitionMigrationPipeline.MigrationDataSender

PartitionMigrationPipeline.MigrationDataSender that ships partition data to a target node over TCP with per-chunk ACK + retry (Session 10 ESC-12).

Protocol:

1. PARTITION_MIGRATE_START(slotId, sourceNodeId) — single frame.
2. For each chunk c ∈ [0, totalChunks):
   • Source registers an ACK waiter for (target, slotId, c).
   • Source sends PARTITION_MIGRATE_DATA with value = [chunkSeq 4B][totalChunks 4B][serialized batch].
   • Source waits up to ACK_TIMEOUT for a PARTITION_MIGRATE_DATA_ACK(slotId, chunkSeq) from target. On timeout it retries up to MAX_ATTEMPTS times, then aborts the whole slot migration.
3. PARTITION_MIGRATE_COMPLETE(slotId, sourceNodeId) — single frame.

Target-side applies chunks idempotently via PartitionMigrationManager.onMigrateData(int, String, int, int, byte[]), dedupes re-delivered chunks by the applied-chunk high-water mark, and re-ACKs duplicates so the source can unstick if an earlier ACK was dropped.

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	ACK_TIMEOUT	Default ACK timeout for a single chunk.
static final int	DEFAULT_CHUNK_ENTRIES	Default per-chunk batch size (entry count).
static final int	MAX_ATTEMPTS	Default max attempts per chunk before aborting.

Constructor Summary

Constructors

Constructor	Description
TcpMigrationDataSender(TcpServer tcpServer, PartitionMigrationManager migrationManager, String sourceNodeId)
TcpMigrationDataSender(TcpServer tcpServer, PartitionMigrationManager migrationManager, String sourceNodeId, int chunkEntries, Duration ackTimeout, int maxAttempts)

Method Summary

Modifier and Type	Method	Description
boolean	sendPartitionData(String targetNode, int partitionId, Map<String, Map<String, PartitionMigrationPipeline.MigratedEntry>> mapEntries)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_CHUNK_ENTRIES

public static final int DEFAULT_CHUNK_ENTRIES

Default per-chunk batch size (entry count).

See Also:

• Constant Field Values

ACK_TIMEOUT

public static final Duration ACK_TIMEOUT

Default ACK timeout for a single chunk.

MAX_ATTEMPTS

public static final int MAX_ATTEMPTS

Default max attempts per chunk before aborting.

See Also:

• Constant Field Values

Constructor Details

TcpMigrationDataSender

public TcpMigrationDataSender(TcpServer tcpServer,
 PartitionMigrationManager migrationManager,
 String sourceNodeId)

TcpMigrationDataSender

public TcpMigrationDataSender(TcpServer tcpServer,
 PartitionMigrationManager migrationManager,
 String sourceNodeId,
 int chunkEntries,
 Duration ackTimeout,
 int maxAttempts)

Method Details

sendPartitionData

public boolean sendPartitionData(String targetNode,
 int partitionId,
 Map<String, Map<String, PartitionMigrationPipeline.MigratedEntry>> mapEntries)

Specified by:

sendPartitionData in interface PartitionMigrationPipeline.MigrationDataSender