Package org.infinispan.persistence.sifs

Class TemporaryTable

java.lang.Object

org.infinispan.persistence.sifs.TemporaryTable

public class TemporaryTable
extends Object

Table holding the entry positions in log before these are persisted to the index.

Author:

Radim Vansa <rvansa@redhat.com>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TemporaryTable.LockedEntry

Constructor Summary

Constructors

Constructor	Description
TemporaryTable(int numSegments)

Method Summary

Modifier and Type	Method	Description
void	addSegments(IntSet segments)
void	clear()
org.infinispan.persistence.sifs.EntryPosition	get(int segment, Object key)
IntSet	getOwnedSegments()
int	getSegmentMax()
void	removeAndUnlock(TemporaryTable.LockedEntry lockedEntry, int segment, Object key)
void	removeConditionally(int segment, Object key, int file, int offset)
void	removeSegments(IntSet segments)
TemporaryTable.LockedEntry	replaceOrLock(int segment, Object key, int file, int offset, int prevFile, int prevOffset)
boolean	set(int segment, Object key, int file, int offset)
void	updateAndUnlock(TemporaryTable.LockedEntry lockedEntry, int file, int offset)

Constructor Detail

TemporaryTable

public TemporaryTable(int numSegments)

Method Detail

getSegmentMax

public int getSegmentMax()

addSegments

public void addSegments(IntSet segments)

removeSegments

public void removeSegments(IntSet segments)

set

public boolean set(int segment,
                   Object key,
                   int file,
                   int offset)

replaceOrLock

public TemporaryTable.LockedEntry replaceOrLock(int segment,
                                                Object key,
                                                int file,
                                                int offset,
                                                int prevFile,
                                                int prevOffset)

updateAndUnlock

public void updateAndUnlock(TemporaryTable.LockedEntry lockedEntry,
                            int file,
                            int offset)

removeAndUnlock

public void removeAndUnlock(TemporaryTable.LockedEntry lockedEntry,
                            int segment,
                            Object key)

get

public org.infinispan.persistence.sifs.EntryPosition get(int segment,
                                                         Object key)

clear

public void clear()

removeConditionally

public void removeConditionally(int segment,
                                Object key,
                                int file,
                                int offset)

getOwnedSegments

public IntSet getOwnedSegments()