com.hazelcast.spi.hotrestart.impl

Class RestartItem

java.lang.Object

com.hazelcast.spi.hotrestart.impl.RestartItem

Direct Known Subclasses:

RestartItem.WithSetOfKeyHandle

public class RestartItem
extends Object

Item in the concurret queues during restarting. Reused along the complete pipeline:

1. HotRestarter thread creates it and submits to a partition thread;
2. partition thread attaches a key handle to it and submits to the Rebuilder thread;
3. Rebuilder uses it to update the GC metadata and submits back to the partition thread, unless it determines that it corresponds to a record that is known to be garbage;
4. partition thread inserts the value blob into the appropriate RamStore.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RestartItem.WithSetOfKeyHandle Used both for the "remove null keys" item and for the "submitter gone" item.

Field Summary

Fields

Modifier and Type	Field and Description
long	chunkSeq
static RestartItem	END
int	filePos
byte[]	key
KeyHandle	keyHandle
long	prefix
RamStore	ramStore
long	recordSeq
int	size
byte[]	value

Method Summary

Modifier and Type	Method and Description
static RestartItem	clearedItem(ChunkFileRecord rec) Constructs an item that corresponds to a cleared record (interred by a prefix tombstone).
boolean	isClearedItem()
boolean	isSpecialItem() Says whether this is a special item, either: describing a cleared record (interred by a prefix tombstone), requesting to remove null-keys from the RamStore, or the "submitter gone" item, which the submitter thread sends as the very last item.

Methods inherited from class java.lang.Object

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

Field Detail

END

public static final RestartItem END

chunkSeq

public final long chunkSeq

recordSeq

public final long recordSeq

prefix

public final long prefix

filePos

public final int filePos

size

public final int size

key

public final byte[] key

value

public final byte[] value

ramStore

public RamStore ramStore

keyHandle

public KeyHandle keyHandle

Method Detail

isSpecialItem

public final boolean isSpecialItem()

Says whether this is a special item, either:

• describing a cleared record (interred by a prefix tombstone),
• requesting to remove null-keys from the RamStore,
• or the "submitter gone" item, which the submitter thread sends as the very last item.

isClearedItem

public final boolean isClearedItem()

Returns:

whether this item corresponds to a cleared record (interred by a prefix tombstone)

clearedItem

public static RestartItem clearedItem(ChunkFileRecord rec)

Constructs an item that corresponds to a cleared record (interred by a prefix tombstone).

Parameters:

rec - the object representing the cleared record in a chunk file