com.viaoa.sync.remote

Class RemoteSessionImpl

java.lang.Object

com.viaoa.sync.remote.RemoteSessionImpl

All Implemented Interfaces:

RemoteSessionInterface

public abstract class RemoteSessionImpl
extends Object
implements RemoteSessionInterface

Server side client session.

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentHashMap<OAObject,OAObject>	hashLock
protected Map<Integer,Boolean>	hmGuid List of guids that are on the client.
protected ConcurrentHashMap<Integer,OAObject>	hmObjectsWithoutHubs
protected int	sessionId

Constructor Summary

Constructors

Constructor and Description
RemoteSessionImpl(int sessionId, Map<Integer,Boolean> hmGuid)

Method Summary

Modifier and Type	Method and Description
void	clearCaches()
void	clearLocks()
OAObject	createNewObject(Class clazz)
abstract boolean	isLocked(Class objectClass, OAObjectKey objectKey)
abstract boolean	isLockedByAnotherClient(Class objectClass, OAObjectKey objectKey)
boolean	isLockedByThisClient(Class objectClass, OAObjectKey objectKey)
void	objectCreated(int guid) Add to guid to cache, to know what objects are on client.
void	objectsFinalized(int[] guids) Called by client side OAObject.finalize, to remove the guids from hmGuid/Cache.
String	ping(String msg)
void	ping2(String msg)
void	saveCache(OACascade cascade, int iCascadeRule)
abstract void	sendException(String msg, Throwable ex)
boolean	setLock(Class objectClass, OAObjectKey objectKey, boolean bLock)
void	setLock(OAObject obj, boolean bLock)
void	update(ClientInfo ci)
void	updateObjectsWithoutHubs(Class c, OAObjectKey ok, boolean bIsInHub) Used to manage OAObject on client to make sure that they are not GCd on Server.

Methods inherited from class java.lang.Object

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

Field Detail

sessionId

protected final int sessionId

hmGuid

protected final Map<Integer,Boolean> hmGuid

List of guids that are on the client. This is used for filtering sync messages that are sent to clients. This is added: 1: whenever objects are serialized to the client. 2: when an object is created on client and objectCreated is called.

hashLock

protected final ConcurrentHashMap<OAObject,OAObject> hashLock

hmObjectsWithoutHubs

protected final ConcurrentHashMap<Integer,OAObject> hmObjectsWithoutHubs

Constructor Detail

RemoteSessionImpl

public RemoteSessionImpl(int sessionId,
                         Map<Integer,Boolean> hmGuid)

Method Detail

objectCreated

public void objectCreated(int guid)

Add to guid to cache, to know what objects are on client.

Specified by:

objectCreated in interface RemoteSessionInterface

objectsFinalized

public void objectsFinalized(int[] guids)

Called by client side OAObject.finalize, to remove the guids from hmGuid/Cache.

Specified by:

objectsFinalized in interface RemoteSessionInterface

updateObjectsWithoutHubs

public void updateObjectsWithoutHubs(Class c,
                                     OAObjectKey ok,
                                     boolean bIsInHub)

Used to manage OAObject on client to make sure that they are not GCd on Server.

Specified by:

updateObjectsWithoutHubs in interface RemoteSessionInterface

saveCache

public void saveCache(OACascade cascade,
                      int iCascadeRule)

clearCaches

public void clearCaches()

setLock

public boolean setLock(Class objectClass,
                       OAObjectKey objectKey,
                       boolean bLock)

Specified by:

setLock in interface RemoteSessionInterface

setLock

public void setLock(OAObject obj,
                    boolean bLock)

clearLocks

public void clearLocks()

createNewObject

public OAObject createNewObject(Class clazz)

isLockedByThisClient

public boolean isLockedByThisClient(Class objectClass,
                                    OAObjectKey objectKey)

Specified by:

isLockedByThisClient in interface RemoteSessionInterface

ping

public String ping(String msg)

Specified by:

ping in interface RemoteSessionInterface

ping2

public void ping2(String msg)

Specified by:

ping2 in interface RemoteSessionInterface

isLocked

public abstract boolean isLocked(Class objectClass,
                                 OAObjectKey objectKey)

Specified by:

isLocked in interface RemoteSessionInterface

isLockedByAnotherClient

public abstract boolean isLockedByAnotherClient(Class objectClass,
                                                OAObjectKey objectKey)

Specified by:

isLockedByAnotherClient in interface RemoteSessionInterface

sendException

public abstract void sendException(String msg,
                                   Throwable ex)

Specified by:

sendException in interface RemoteSessionInterface

update

public void update(ClientInfo ci)

Specified by:

update in interface RemoteSessionInterface