Package com.gigaspaces.internal.server.space.broadcast_table

Class BroadcastTableHandler

java.lang.Object

com.gigaspaces.internal.server.space.broadcast_table.BroadcastTableHandler

public class BroadcastTableHandler
extends Object

Since:

15.8.0

Author:

alon shoham

Constructor Summary

Constructors

Constructor	Description
BroadcastTableHandler(SpaceImpl space)

Method Summary

Modifier and Type	Method	Description
void	clearEntries(ITemplatePacket template, int modifiers)
int	clearEntries(ITemplatePacket template, int modifiers, int maxEntries)	Returns the number of entries cleared from backup partitions.
boolean	pullEntries(String typeName, Integer targetPartitionId)
void	pushEntries(IEntryPacket[] entryPackets, long lease, long[] leases, long timeout, int modifiers)
void	pushEntry(IEntryPacket entryPacket, long lease, boolean isUpdate, long timeout, int modifiers)

Methods inherited from class java.lang.Object

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

Constructor Details

BroadcastTableHandler

public BroadcastTableHandler(SpaceImpl space)
                      throws RemoteException

Throws:

RemoteException

Method Details

pushEntry

public void pushEntry(IEntryPacket entryPacket,
 long lease,
 boolean isUpdate,
 long timeout,
 int modifiers)

pushEntries

public void pushEntries(IEntryPacket[] entryPackets,
 long lease,
 long[] leases,
 long timeout,
 int modifiers)

pullEntries

public boolean pullEntries(String typeName,
 Integer targetPartitionId)

clearEntries

public void clearEntries(ITemplatePacket template,
 int modifiers)

clearEntries

public int clearEntries(ITemplatePacket template,
 int modifiers,
 int maxEntries)

Returns the number of entries cleared from backup partitions.

Returns:

The maximum number of entries cleared on any single backup partition (partition 0 is a no-op and reports 0), 0 if the broadcast task failed (and was logged), or -1 if any backup was an older version that ignored maxEntries and performed an unbounded clear. In the latter case, a follow-up unbounded broadcast has already been sent so all backups end up consistent (zero entries of this type).