Package tigase.server.cluster.strategy
Class CacheContenerV2
java.lang.Object
tigase.server.cluster.strategy.CacheContenerV2
- All Implemented Interfaces:
CacheContenerIfc
,tigase.sys.OnlineJidsReporter
public class CacheContenerV2
extends Object
implements tigase.sys.OnlineJidsReporter, CacheContenerIfc
- Author:
- Artur Hefczyc Created Mar 15, 2011
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionint
Returns number of all cached connections (all/total CIDs for all connected users)boolean
containsJid
(tigase.xmpp.jid.BareJID jid) boolean
containsJidLocally
(tigase.xmpp.jid.BareJID jid) boolean
containsJidLocally
(tigase.xmpp.jid.JID jid) tigase.xmpp.jid.JID[]
getConnectionIdsForJid
(tigase.xmpp.jid.BareJID jid) getConnectionRecord
(tigase.xmpp.jid.JID jid) Retrieves aConnectionRecordExt
for the particular, specificJID
getConnectionRecords
(tigase.xmpp.jid.BareJID bareJID) Method retrieves allConnectionRecordExt
records for the particularBareJID
Method allows retrieval internal structure underlying cache.List<tigase.xmpp.jid.JID>
getNodesForJid
(tigase.xmpp.jid.JID jid) Method retrieves all nodes on which particular user has it's connections.boolean
int
mapSize()
Return number of connected usersboolean
Allow obtaining information whether cache needs synching with other nodes.void
removeAllForNode
(tigase.xmpp.jid.JID node) Method removes all cached connections which were related to the given node (e.g.void
setSync
(boolean sync) Set the state of synchronisation.void
updatePresence
(tigase.xml.Element presence, ConnectionRecordExt rec) Method updates given connection in the cache with the information about presence for the given connection.void
userChangedConnId
(tigase.xmpp.jid.BareJID userId, tigase.xmpp.jid.JID oldConnectionId, tigase.xmpp.jid.JID newConnectionId) Method responsible for replacing used conn id by user connection/resource.void
Method responsible for user disconnection events.void
usersConnected
(ConnectionRecordExt... recs) Method responsible for user connection events.
-
Constructor Details
-
CacheContenerV2
public CacheContenerV2()
-
-
Method Details
-
connectionsSize
public int connectionsSize()Returns number of all cached connections (all/total CIDs for all connected users)- Returns:
- number of all cached CIDs
-
containsJid
public boolean containsJid(tigase.xmpp.jid.BareJID jid) - Specified by:
containsJid
in interfaceCacheContenerIfc
- Specified by:
containsJid
in interfacetigase.sys.OnlineJidsReporter
-
containsJidLocally
public boolean containsJidLocally(tigase.xmpp.jid.BareJID jid) - Specified by:
containsJidLocally
in interfacetigase.sys.OnlineJidsReporter
-
containsJidLocally
public boolean containsJidLocally(tigase.xmpp.jid.JID jid) - Specified by:
containsJidLocally
in interfacetigase.sys.OnlineJidsReporter
-
mapSize
public int mapSize()Return number of connected users- Returns:
- number of connected users
-
needsSync
public boolean needsSync()Allow obtaining information whether cache needs synching with other nodes.- Returns:
true
if cache is out of synch,false
otherwise.
-
setSync
public void setSync(boolean sync) Set the state of synchronisation.- Specified by:
setSync
in interfaceCacheContenerIfc
- Parameters:
sync
- boolean value denoting sync state.
-
removeAllForNode
public void removeAllForNode(tigase.xmpp.jid.JID node) Method removes all cached connections which were related to the given node (e.g. when the node was disconnected) as well as decreases count of all connections stored in cache.- Specified by:
removeAllForNode
in interfaceCacheContenerIfc
- Parameters:
node
-JID
of the node for which cached items will be removed.
-
updatePresence
Method updates given connection in the cache with the information about presence for the given connection.- Parameters:
presence
-Element
containing presence informationrec
-ConnectionRecordExt
for which presence should be updated
-
userDisconnected
Method responsible for user disconnection events. Removes given connection record from the cache and decrease counter of all connections.- Specified by:
userDisconnected
in interfaceCacheContenerIfc
- Parameters:
rec
-ConnectionRecordExt
for which presence should be updated
-
usersConnected
Method responsible for user connection events. Adds given connection record to the cache and increases counters of both all connections and number of user JIDs in cache..- Specified by:
usersConnected
in interfaceCacheContenerIfc
- Parameters:
recs
-ConnectionRecordExt
for which presence should be updated
-
userChangedConnId
public void userChangedConnId(tigase.xmpp.jid.BareJID userId, tigase.xmpp.jid.JID oldConnectionId, tigase.xmpp.jid.JID newConnectionId) Method responsible for replacing used conn id by user connection/resource. In fact it removes connection using old connection id from connection cache, updates internal value of connection id to new connection id and adds it to cache using new connection id as a key.This happens during stream resumption as connection id changes for session for which stream is resumed.
- Parameters:
userId
- - bare jid of useroldConnectionId
- - connection id which was changednewConnectionId
- - connection id which replaced old connection id
-
getConnectionIdsForJid
public tigase.xmpp.jid.JID[] getConnectionIdsForJid(tigase.xmpp.jid.BareJID jid) - Specified by:
getConnectionIdsForJid
in interfacetigase.sys.OnlineJidsReporter
-
getConnectionRecord
Retrieves aConnectionRecordExt
for the particular, specificJID
- Specified by:
getConnectionRecord
in interfaceCacheContenerIfc
- Parameters:
jid
- for whichConnectionRecordExt
should be retrieved- Returns:
ConnectionRecordExt
for the givenJID
-
getConnectionRecords
Method retrieves allConnectionRecordExt
records for the particularBareJID
- Parameters:
bareJID
- for which allConnectionRecordExt
should be retrieved- Returns:
Set
containing allConnectionRecordExt
objects for the givenJID
-
getInternalData
Method allows retrieval internal structure underlying cache.- Returns:
Object
with internal structure of underlying cache.
-
getNodesForJid
Method retrieves all nodes on which particular user has it's connections.- Parameters:
jid
- for which list of cluster nodes should be returned.- Returns:
- list of cluster nodes on which user has it's connections.
-
hasCompleteJidsInfo
public boolean hasCompleteJidsInfo()- Specified by:
hasCompleteJidsInfo
in interfacetigase.sys.OnlineJidsReporter
-