| org.continuent.sequoia.controller.requestmanager.distributed.DistributedRequestManager org.continuent.sequoia.controller.requestmanager.distributed.RAIDb1DistributedRequestManager
RAIDb1DistributedRequestManager | public RAIDb1DistributedRequestManager(DistributedVirtualDatabase vdb, AbstractScheduler scheduler, AbstractResultCache cache, AbstractLoadBalancer loadBalancer, RecoveryLog recoveryLog, long beginTimeout, long commitTimeout, long rollbackTimeout) throws SQLException, NotCompliantMBeanException(Code) | | Creates a new RAIDb1DistributedRequestManager instance
Parameters: vdb - the virtual database this request manager belongs to Parameters: scheduler - the Request Scheduler to use Parameters: cache - a Query Cache implementation Parameters: loadBalancer - the Request Load Balancer to use Parameters: recoveryLog - the Log Recovery to use Parameters: beginTimeout - timeout in seconds for begin Parameters: commitTimeout - timeout in seconds for commit Parameters: rollbackTimeout - timeout in seconds for rollback throws: SQLException - if an error occurs throws: NotCompliantMBeanException - if the MBean is not JMX compliant |
Methods inherited from org.continuent.sequoia.controller.requestmanager.distributed.DistributedRequestManager | public void abort(long transactionId, boolean logAbort, boolean forceAbort) throws SQLException(Code)(Java Doc) public void addFailedOnAllBackends(AbstractRequest request, boolean needSchedulerNotification)(Code)(Java Doc) public long begin(String login, boolean isPersistentConnection, long persistentConnectionId) throws SQLException(Code)(Java Doc) public void blockActivity() throws SQLException(Code)(Java Doc) public ExecuteResult callableStatementExecute(StoredProcedure proc) throws SQLException(Code)(Java Doc) public ControllerResultSet callableStatementExecuteQuery(StoredProcedure proc) throws SQLException(Code)(Java Doc) public ExecuteUpdateResult callableStatementExecuteUpdate(StoredProcedure proc) throws SQLException(Code)(Java Doc) public void cleanupAllFailedQueriesFromController(long failedControllerId)(Code)(Java Doc) public void cleanupRollbackFromOtherController(long tId)(Code)(Java Doc) public void closePersistentConnection(Long connectionId)(Code)(Java Doc) public void commit(long transactionId, boolean logCommit, boolean emptyTransaction) throws SQLException(Code)(Java Doc) public void completeFailedOnAllBackends(AbstractRequest request, boolean success, boolean disableBackendOnSuccess, int updateCount)(Code)(Java Doc) public void completeTransaction(Long tid)(Code)(Java Doc) public void disableBackend(DatabaseBackend db, boolean forceDisable) throws SQLException(Code)(Java Doc) public void disableBackendsWithCheckpoint(ArrayList backendInfos, String checkpointName) throws SQLException(Code)(Java Doc) abstract public void distributedAbort(String login, long transactionId) throws SQLException(Code)(Java Doc) abstract public ExecuteResult distributedCallableStatementExecute(StoredProcedure proc) throws SQLException(Code)(Java Doc) abstract public ControllerResultSet distributedCallableStatementExecuteQuery(StoredProcedure proc) throws SQLException(Code)(Java Doc) abstract public ExecuteUpdateResult distributedCallableStatementExecuteUpdate(StoredProcedure proc) throws SQLException(Code)(Java Doc) public void distributedClosePersistentConnection(String login, long persistentConnectionId)(Code)(Java Doc) abstract public void distributedCommit(String login, long transactionId) throws SQLException(Code)(Java Doc) public void distributedFailoverForPersistentConnection(long persistentConnectionId)(Code)(Java Doc) public void distributedFailoverForTransaction(long currentTid)(Code)(Java Doc) public void distributedOpenPersistentConnection(String login, long persistentConnectionId) throws SQLException(Code)(Java Doc) abstract public void distributedReleaseSavepoint(String login, long transactionId, String name) throws SQLException(Code)(Java Doc) abstract public void distributedRollback(String login, long transactionId) throws SQLException(Code)(Java Doc) abstract public void distributedRollback(String login, long transactionId, String savepointName) throws SQLException(Code)(Java Doc) abstract public void distributedSetSavepoint(String login, long transactionId, String name) throws SQLException(Code)(Java Doc) abstract public ExecuteResult distributedStatementExecute(AbstractRequest request) throws SQLException(Code)(Java Doc) abstract public ControllerResultSet distributedStatementExecuteQuery(SelectRequest request) throws SQLException(Code)(Java Doc) abstract public ExecuteUpdateResult distributedStatementExecuteUpdate(AbstractWriteRequest request) throws SQLException(Code)(Java Doc) abstract public GeneratedKeysResult distributedStatementExecuteUpdateWithKeys(AbstractWriteRequest request) throws SQLException(Code)(Java Doc) public void enableBackend(DatabaseBackend db) throws SQLException(Code)(Java Doc) public ControllerResultSet execLocalStatementExecuteQuery(SelectRequest request) throws NoMoreBackendException, SQLException(Code)(Java Doc) public ExecuteResult execLocallyCallableStatementExecute(StoredProcedure proc) throws AllBackendsFailedException, SQLException(Code)(Java Doc) public ControllerResultSet execLocallyCallableStatementExecuteQuery(StoredProcedure proc) throws AllBackendsFailedException, SQLException(Code)(Java Doc) abstract public ControllerResultSet execRemoteStatementExecuteQuery(SelectRequest request) throws SQLException(Code)(Java Doc) public long getControllerId()(Code)(Java Doc) public Trace getLogger()(Code)(Java Doc) public long getNextConnectionId(long id)(Code)(Java Doc) public long getNextRequestId()(Code)(Java Doc) protected Serializable getRequestResultFromFailoverCache(List successfulControllers, long id) throws NoResultAvailableException(Code)(Java Doc) public VirtualDatabase getVirtualDatabase()(Code)(Java Doc) public boolean isDistributedTransaction(long currentTid)(Code)(Java Doc) public void lazyTransactionStart(AbstractRequest request) throws SQLException(Code)(Java Doc) protected void notifyControllerInconsistency(AbstractRequest request, ArrayList inconsistentControllers) throws SQLException(Code)(Java Doc) protected void notifyRequestCompletion(AbstractRequest request, boolean success, boolean disableBackendOnSuccess, ArrayList backendsToNotify) throws SQLException(Code)(Java Doc) protected void notifyRequestCompletion(AbstractRequest request, boolean success, boolean disableBackendOnSuccess, ArrayList backendsToNotify, int requestUpdateCount) throws SQLException(Code)(Java Doc) public void releaseSavepoint(long transactionId, String name) throws SQLException(Code)(Java Doc) public void resumeActivity()(Code)(Java Doc) public void rollback(long transactionId, boolean logRollback) throws SQLException(Code)(Java Doc) public void rollback(long transactionId, String savepointName) throws SQLException(Code)(Java Doc) public void scheduleExecWriteRequest(AbstractWriteRequest request) throws SQLException(Code)(Java Doc) public void setControllerId(long id)(Code)(Java Doc) public int setSavepoint(long transactionId) throws SQLException(Code)(Java Doc) public void setSavepoint(long transactionId, String name) throws SQLException(Code)(Java Doc) public void setScheduler(AbstractScheduler scheduler)(Code)(Java Doc) public ExecuteResult statementExecute(AbstractRequest request) throws SQLException(Code)(Java Doc) public ControllerResultSet statementExecuteQuery(SelectRequest request) throws SQLException(Code)(Java Doc) public ExecuteUpdateResult statementExecuteUpdate(AbstractWriteRequest request) throws SQLException(Code)(Java Doc) public GeneratedKeysResult statementExecuteUpdateWithKeys(AbstractWriteRequest request) throws SQLException(Code)(Java Doc) public boolean storeRequestResult(AbstractRequest request, Serializable result)(Code)(Java Doc) public void suspendActivity() throws SQLException(Code)(Java Doc)
|
|
|