beehive.validationService

Class CertifierReplica

java.lang.Object

java.rmi.server.RemoteObject

java.rmi.server.RemoteServer

java.rmi.server.UnicastRemoteObject

beehive.validationService.CertifierReplica

All Implemented Interfaces:

PeerInterface_thrift.Iface, ValidationService_thrift.Iface, PeerInterface, ValidationService, Serializable, Remote

public class CertifierReplica
extends UnicastRemoteObject
implements PeerInterface, ValidationService, ValidationService_thrift.Iface, PeerInterface_thrift.Iface

Created by khand055 on 3/23/17.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	clientPort
static Map<Integer,LinkedBlockingQueue<PeerInterface_thrift.Client>>	peerThreadPools
static int	peerThriftPoolSize
PrintStream	ps
static int	serverPort

Fields inherited from class java.rmi.server.RemoteObject

ref

Constructor Summary

Constructors

Constructor and Description
CertifierReplica(String validationReplicationConfigFile, int serverId, String configFile)

Method Summary

Modifier and Type	Method and Description
PeerResponse_thrift	abort_peer_thrift(long startTS, long transactionId, boolean bReleaseLock)
PeerResponse	abort(long startTS, long transactionId, boolean bReleaseLock)
Map<String,ValidateResponse_thrift>	batchValidate_thrift(List<ValidationRequest_thrift> requests)
PeerResponse_thrift	commit_peer_thrift(long startTS, long commitTS, long transactionId)
PeerResponse	commit(long startTS, long commitTS, long transactionId)
List<Long>	getCtsSts_peer_thrift()
long[]	getCtsSts()
long	getGTS()
long	getStableTS()
long	getSTS_peer_thrift()
long	getSTS_thrift()
long	getSTS()
long	getTransactionId()
static void	main(String[] args)
long	reportCompletion_peer_thrift(long commitTS)
long	reportCompletion_thrift(long commitTS)
long	reportCompletion(long commitTS)
long	reportCompletion(Vector<Long> commitTSList)
long	reportCompletionBatch_peer_thrift(List<Long> commitTS)
long	reportCompletionBatch_thrift(List<Long> commitTSList)
void	setStableTS(long stableTS)
void	setTransactionId(long transactionId)
PeerResponse_thrift	validate_peer_thrift(long startTS, RWSetInfo_thrift rwSet, long transactionId)
ValidateResponse_thrift	validate_thrift(long startTS, RWSetInfo_thrift rwSet)
ValidateResponse	validate(long startTS, RWSetInfo rwSet, LoadInfo loadInfo)
PeerResponse	validate(long startTS, RWSetInfo rwSet, long transactionId)
Hashtable<String,ValidateResponse>	validateBatch(Queue<ValidationRequest> requestBatch, LoadInfo myLoad)

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

peerThreadPools

public static Map<Integer,LinkedBlockingQueue<PeerInterface_thrift.Client>> peerThreadPools

peerThriftPoolSize

public static int peerThriftPoolSize

clientPort

public static int clientPort

serverPort

public static int serverPort

ps

public PrintStream ps

Constructor Detail

CertifierReplica

public CertifierReplica(String validationReplicationConfigFile,
                        int serverId,
                        String configFile)
                 throws RemoteException,
                        IOException

Throws:

RemoteException

IOException

Method Detail

getStableTS

public long getStableTS()

setStableTS

public void setStableTS(long stableTS)

getTransactionId

public long getTransactionId()

setTransactionId

public void setTransactionId(long transactionId)

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

getCtsSts

public long[] getCtsSts()
                 throws RemoteException

Specified by:

getCtsSts in interface PeerInterface

Throws:

RemoteException

validate

public PeerResponse validate(long startTS,
                             RWSetInfo rwSet,
                             long transactionId)
                      throws RemoteException

Specified by:

validate in interface PeerInterface

Throws:

RemoteException

getGTS

public long getGTS()
            throws RemoteException

Specified by:

getGTS in interface PeerInterface

Throws:

RemoteException

getSTS

public long getSTS()
            throws RemoteException

Specified by:

getSTS in interface PeerInterface

Specified by:

getSTS in interface ValidationService

Throws:

RemoteException

commit

public PeerResponse commit(long startTS,
                           long commitTS,
                           long transactionId)
                    throws RemoteException

Specified by:

commit in interface PeerInterface

Throws:

RemoteException

abort

public PeerResponse abort(long startTS,
                          long transactionId,
                          boolean bReleaseLock)
                   throws RemoteException

Specified by:

abort in interface PeerInterface

Throws:

RemoteException

validate

public ValidateResponse validate(long startTS,
                                 RWSetInfo rwSet,
                                 LoadInfo loadInfo)
                          throws RemoteException

Specified by:

validate in interface ValidationService

Throws:

RemoteException

reportCompletion

public long reportCompletion(long commitTS)
                      throws RemoteException

Specified by:

reportCompletion in interface PeerInterface

Specified by:

reportCompletion in interface ValidationService

Throws:

RemoteException

reportCompletion

public long reportCompletion(Vector<Long> commitTSList)
                      throws RemoteException

Specified by:

reportCompletion in interface PeerInterface

Specified by:

reportCompletion in interface ValidationService

Throws:

RemoteException

validateBatch

public Hashtable<String,ValidateResponse> validateBatch(Queue<ValidationRequest> requestBatch,
                                                        LoadInfo myLoad)
                                                 throws RemoteException

Specified by:

validateBatch in interface ValidationService

Throws:

RemoteException

getSTS_thrift

public long getSTS_thrift()

Specified by:

getSTS_thrift in interface ValidationService_thrift.Iface

validate_thrift

public ValidateResponse_thrift validate_thrift(long startTS,
                                               RWSetInfo_thrift rwSet)
                                        throws org.apache.thrift.TException

Specified by:

validate_thrift in interface ValidationService_thrift.Iface

Throws:

org.apache.thrift.TException

reportCompletion_thrift

public long reportCompletion_thrift(long commitTS)

Specified by:

reportCompletion_thrift in interface ValidationService_thrift.Iface

reportCompletionBatch_thrift

public long reportCompletionBatch_thrift(List<Long> commitTSList)

Specified by:

reportCompletionBatch_thrift in interface ValidationService_thrift.Iface

batchValidate_thrift

public Map<String,ValidateResponse_thrift> batchValidate_thrift(List<ValidationRequest_thrift> requests)

Specified by:

batchValidate_thrift in interface ValidationService_thrift.Iface

reportCompletion_peer_thrift

public long reportCompletion_peer_thrift(long commitTS)
                                  throws org.apache.thrift.TException

Specified by:

reportCompletion_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException

reportCompletionBatch_peer_thrift

public long reportCompletionBatch_peer_thrift(List<Long> commitTS)
                                       throws org.apache.thrift.TException

Specified by:

reportCompletionBatch_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException

validate_peer_thrift

public PeerResponse_thrift validate_peer_thrift(long startTS,
                                                RWSetInfo_thrift rwSet,
                                                long transactionId)
                                         throws org.apache.thrift.TException

Specified by:

validate_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException

getSTS_peer_thrift

public long getSTS_peer_thrift()
                        throws org.apache.thrift.TException

Specified by:

getSTS_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException

getCtsSts_peer_thrift

public List<Long> getCtsSts_peer_thrift()
                                 throws org.apache.thrift.TException

Specified by:

getCtsSts_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException

commit_peer_thrift

public PeerResponse_thrift commit_peer_thrift(long startTS,
                                              long commitTS,
                                              long transactionId)
                                       throws org.apache.thrift.TException

Specified by:

commit_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException

abort_peer_thrift

public PeerResponse_thrift abort_peer_thrift(long startTS,
                                             long transactionId,
                                             boolean bReleaseLock)
                                      throws org.apache.thrift.TException

Specified by:

abort_peer_thrift in interface PeerInterface_thrift.Iface

Throws:

org.apache.thrift.TException