public class CertifierReplica extends UnicastRemoteObject implements PeerInterface, ValidationService, ValidationService_thrift.Iface, PeerInterface_thrift.Iface
| 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 |
ref| Constructor and Description |
|---|
CertifierReplica(String validationReplicationConfigFile,
int serverId,
String configFile) |
clone, exportObject, exportObject, exportObject, unexportObjectgetClientHost, getLog, setLogpublic static Map<Integer,LinkedBlockingQueue<PeerInterface_thrift.Client>> peerThreadPools
public static int peerThriftPoolSize
public static int clientPort
public static int serverPort
public PrintStream ps
public CertifierReplica(String validationReplicationConfigFile, int serverId, String configFile) throws RemoteException, IOException
RemoteExceptionIOExceptionpublic long getStableTS()
public void setStableTS(long stableTS)
public long getTransactionId()
public void setTransactionId(long transactionId)
public long[] getCtsSts()
throws RemoteException
getCtsSts in interface PeerInterfaceRemoteExceptionpublic PeerResponse validate(long startTS, RWSetInfo rwSet, long transactionId) throws RemoteException
validate in interface PeerInterfaceRemoteExceptionpublic long getGTS()
throws RemoteException
getGTS in interface PeerInterfaceRemoteExceptionpublic long getSTS()
throws RemoteException
getSTS in interface PeerInterfacegetSTS in interface ValidationServiceRemoteExceptionpublic PeerResponse commit(long startTS, long commitTS, long transactionId) throws RemoteException
commit in interface PeerInterfaceRemoteExceptionpublic PeerResponse abort(long startTS, long transactionId, boolean bReleaseLock) throws RemoteException
abort in interface PeerInterfaceRemoteExceptionpublic ValidateResponse validate(long startTS, RWSetInfo rwSet, LoadInfo loadInfo) throws RemoteException
validate in interface ValidationServiceRemoteExceptionpublic long reportCompletion(long commitTS)
throws RemoteException
reportCompletion in interface PeerInterfacereportCompletion in interface ValidationServiceRemoteExceptionpublic long reportCompletion(Vector<Long> commitTSList) throws RemoteException
reportCompletion in interface PeerInterfacereportCompletion in interface ValidationServiceRemoteExceptionpublic Hashtable<String,ValidateResponse> validateBatch(Queue<ValidationRequest> requestBatch, LoadInfo myLoad) throws RemoteException
validateBatch in interface ValidationServiceRemoteExceptionpublic long getSTS_thrift()
getSTS_thrift in interface ValidationService_thrift.Ifacepublic ValidateResponse_thrift validate_thrift(long startTS, RWSetInfo_thrift rwSet) throws org.apache.thrift.TException
validate_thrift in interface ValidationService_thrift.Ifaceorg.apache.thrift.TExceptionpublic long reportCompletion_thrift(long commitTS)
reportCompletion_thrift in interface ValidationService_thrift.Ifacepublic long reportCompletionBatch_thrift(List<Long> commitTSList)
reportCompletionBatch_thrift in interface ValidationService_thrift.Ifacepublic Map<String,ValidateResponse_thrift> batchValidate_thrift(List<ValidationRequest_thrift> requests)
batchValidate_thrift in interface ValidationService_thrift.Ifacepublic long reportCompletion_peer_thrift(long commitTS)
throws org.apache.thrift.TException
reportCompletion_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TExceptionpublic long reportCompletionBatch_peer_thrift(List<Long> commitTS) throws org.apache.thrift.TException
reportCompletionBatch_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TExceptionpublic PeerResponse_thrift validate_peer_thrift(long startTS, RWSetInfo_thrift rwSet, long transactionId) throws org.apache.thrift.TException
validate_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TExceptionpublic long getSTS_peer_thrift()
throws org.apache.thrift.TException
getSTS_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TExceptionpublic List<Long> getCtsSts_peer_thrift() throws org.apache.thrift.TException
getCtsSts_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TExceptionpublic PeerResponse_thrift commit_peer_thrift(long startTS, long commitTS, long transactionId) throws org.apache.thrift.TException
commit_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TExceptionpublic PeerResponse_thrift abort_peer_thrift(long startTS, long transactionId, boolean bReleaseLock) throws org.apache.thrift.TException
abort_peer_thrift in interface PeerInterface_thrift.Ifaceorg.apache.thrift.TException