beehive.validationService

Class RMIAdapter

java.lang.Object

beehive.validationService.RMIAdapter

public class RMIAdapter
extends java.lang.Object

Created by khand055 on 5/12/17.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CTS_MANAGER
static int	STS_MANAGER

Constructor Summary

Constructors

Constructor and Description
RMIAdapter(CertifierReplica certifierReplica, java.lang.String rpc_mechanism)

Method Summary

Modifier and Type	Method and Description
PeerResponse	abort(long startTS, long transactionId, boolean bReleaseLock, int serverId)
PeerResponse	commit(long startTS, long commitTS, long transactionId, int serverId)
long[]	getCtsSts()
long	getGTS()
long	getSTS()
long	reportCompletion(long commitTS)
long	reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
PeerResponse	validate(long startTS, RWSetInfo rwSet, long transactionId, int serverId)

Methods inherited from class java.lang.Object

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

Field Detail

STS_MANAGER

public static final int STS_MANAGER

See Also:

Constant Field Values

CTS_MANAGER

public static final int CTS_MANAGER

See Also:

Constant Field Values

Constructor Detail

RMIAdapter

public RMIAdapter(CertifierReplica certifierReplica,
                  java.lang.String rpc_mechanism)

Method Detail

reportCompletion

public long reportCompletion(long commitTS)
                      throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

reportCompletion

public long reportCompletion(java.util.Vector<java.lang.Long> commitTSList)
                      throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getGTS

public long getGTS()
            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getSTS

public long getSTS()
            throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

getCtsSts

public long[] getCtsSts()
                 throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

commit

public PeerResponse commit(long startTS,
                           long commitTS,
                           long transactionId,
                           int serverId)
                    throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

abort

public PeerResponse abort(long startTS,
                          long transactionId,
                          boolean bReleaseLock,
                          int serverId)
                   throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

validate

public PeerResponse validate(long startTS,
                             RWSetInfo rwSet,
                             long transactionId,
                             int serverId)
                      throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException