public final class CallsPerMember extends Object implements LiveOperations
LiveOperations
and additionally collects the call IDs of operations on remote members
whose cancellation was requested.
This data-structure can be optimized to generate less litter. Instead of using an ArrayList for Long objects,
use an array for primitive longs. Also the lists don't need to be recreated every time the
LiveOperationsTracker.populate(LiveOperations)
method is called; they could be recycled. This would be easy
to do since the CallsPerMember
is used by a single thread.
Constructor and Description |
---|
CallsPerMember(Address localAddress) |
Modifier and Type | Method and Description |
---|---|
void |
add(Address address,
long callId)
Registers an invocation with this object.
|
void |
addOpToCancel(Address address,
long callId) |
Set<Address> |
addresses() |
void |
clear() |
void |
ensureMember(Address address)
Makes sure that a list of counters is created for a member.
|
com.hazelcast.spi.CallsPerMember.CategorizedCallIds |
getOrCreateCallIdsForMember(Address address) |
OperationControl |
toOpControl(Address address) |
public CallsPerMember(Address localAddress)
public void add(Address address, long callId)
LiveOperations
add
in interface LiveOperations
address
- address of the sender of the operationcallId
- call ID of the operationpublic void addOpToCancel(Address address, long callId)
public OperationControl toOpControl(Address address)
public void clear()
public void ensureMember(Address address)
address
- the address of the member.public com.hazelcast.spi.CallsPerMember.CategorizedCallIds getOrCreateCallIdsForMember(Address address)
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.