Searched refs:localTID (Results 1 - 14 of 14) sorted by relevance

/glassfish-3.1.2/transaction/jts/src/main/java/com/sun/jts/CosTransactions/
H A DDelegatedTimeoutManager.java148 * @param localTID The local identifier for the transaction.
156 boolean setTimeout(Long localTID, int timeoutType, argument
177 timeoutInfo.localTID = localTID;
179 pendingTimeouts.put(localTID,timeoutInfo);
189 timeoutInfo.localTID = localTID;
191 indoubtTimeouts.put(localTID,timeoutInfo);
199 result = (pendingTimeouts.remove(localTID) != null);
201 result = (indoubtTimeouts.remove(localTID) !
233 timeoutCoordinator(Long localTID, int timeoutType) argument
472 timeLeft(Long localTID) argument
547 Long localTID = null; field in class:DelegatedTimeoutInfo
[all...]
H A DTimeoutManager.java165 * @param localTID The local identifier for the transaction.
173 static boolean setTimeout(Long localTID, int timeoutType, argument
196 timeoutInfo.localTID = localTID;
198 pendingTimeouts.put(localTID,timeoutInfo);
208 timeoutInfo.localTID = localTID;
210 indoubtTimeouts.put(localTID,timeoutInfo);
218 result = (pendingTimeouts.remove(localTID) != null);
220 result = (indoubtTimeouts.remove(localTID) !
257 timeoutCoordinator(Long localTID, int timeoutType) argument
501 timeLeft(Long localTID) argument
618 Long localTID = null; field in class:TimeoutInfo
[all...]
H A DCoordinatorLog.java143 Long localTID = null; field in class:CoordinatorLog
279 localTID = null;
303 localTID = null;
318 * @param localTID The local transaction identifier.
324 CoordinatorLog( Long localTID ) {
329 this.localTID = localTID;
330 if( localTID.longValue() != 0 )
331 addLog(localTID,this);
861 * @param localTID Th
881 setLocalTID( Long localTID, String logPath ) argument
1390 addLog(Long localTID, CoordinatorLog clog ) argument
1401 addLog(Long localTID, CoordinatorLog clog, String logPath ) argument
[all...]
H A DSuperiorInfo.java98 Long localTID = null; field in class:SuperiorInfo
151 * @param localTID The local identifier for the transaction.
160 SuperiorInfo(Long localTID, GlobalTID globalTID, argument
163 this.localTID = localTID;
220 localTID = null;
264 localTID = log.localTID;
272 RecoveryManager.addCoordinator(globalTID, localTID, coord, 0);
338 localTID
[all...]
H A DTransactionState.java202 Long localTID = null; field in class:TransactionState
287 localTID = new Long(getSequenceNumber());
296 generateTID(localTID.longValue()));
308 logRecord.setLocalTID(localTID);
337 localTID = new Long(getSequenceNumber());
351 logRecord.setLocalTID(localTID);
378 localTID = new Long(getSequenceNumber());
387 generateTID(localTID.longValue()));
489 localTID = null;
762 // LogDBHelper.getInstance().addRecord(localTID
871 generateTID(long localTID) argument
[all...]
H A DLogDBHelper.java148 boolean addRecord(long localTID, byte[] data) { argument
151 _logger.fine("LogDBHelper.addRecord for localTID: " + localTID);
163 prepStmt1.setString(1,Long.toString(localTID));
190 boolean deleteRecord(long localTID) { argument
191 return deleteRecord(localTID, serverName);
194 boolean deleteRecord(long localTID, String serverName0) { argument
197 _logger.fine("LogDBHelper.deleteRecord for localTID: " + localTID + " and serverName: " + serverName0);
205 prepStmt1.setString(1,Long.toString(localTID));
[all...]
H A DControlImpl.java113 protected Long localTID = null; field in class:ControlImpl
152 * @param localTID The local identifier for the transaction.
161 Long localTID ) {
169 this.localTID = localTID;
254 localTID = null;
334 if( localTID == null ) {
339 result = localTID.longValue();
751 Long localTID = null;
753 localTID
[all...]
H A DDelegatedRecoveryManager.java92 Long localTID, CoordinatorImpl coord, int timeout, String logPath) {
102 state.coordsByLocalTID.put(localTID,coord);
111 tmoutMgr.setTimeout(localTID, DelegatedTimeoutManager.ACTIVE_TIMEOUT,
119 Long localTID, boolean aborted, String logPath) {
132 coord = (CoordinatorImpl) state.coordsByLocalTID.remove(localTID);
144 CoordinatorLog.removeLog(localTID, logPath);
155 tmoutMgr.setTimeout(localTID, DelegatedTimeoutManager.CANCEL_TIMEOUT, 0);
437 * @param localTID The local identifier for the transaction.
446 static CoordinatorImpl getLocalCoordinator(Long localTID, String logPath) { argument
450 state.coordsByLocalTID.get(localTID);
91 addCoordinator(GlobalTID globalTID, Long localTID, CoordinatorImpl coord, int timeout, String logPath) argument
118 removeCoordinator(GlobalTID globalTID, Long localTID, boolean aborted, String logPath) argument
468 validLocalTID(Long localTID, String logPath) argument
[all...]
H A DRecoveryManager.java238 * @param localTID The local identifier for the transaction.
248 Long localTID, CoordinatorImpl coord, int timeout) {
256 coordsByLocalTID.put(localTID,coord);
264 TimeoutManager.setTimeout(localTID, TimeoutManager.ACTIVE_TIMEOUT,
281 * @param localTID The local identifier for the transaction.
289 Long localTID, boolean aborted) {
301 coord = (CoordinatorImpl) coordsByLocalTID.remove(localTID);
315 LogDBHelper.getInstance().deleteRecord(localTID.longValue());
317 CoordinatorLog.removeLog(localTID);
333 TimeoutManager.setTimeout(localTID, TimeoutManage
247 addCoordinator(GlobalTID globalTID, Long localTID, CoordinatorImpl coord, int timeout) argument
288 removeCoordinator(GlobalTID globalTID, Long localTID, boolean aborted) argument
707 getLocalCoordinator(Long localTID) argument
725 validLocalTID(Long localTID) argument
[all...]
H A DTopCoordinator.java201 superInfo = new SuperiorInfo(tranState.localTID, tranState.globalTID,
243 tranState.localTID,
298 superInfo = new SuperiorInfo(tranState.localTID, tranState.globalTID,
335 if (!RecoveryManager.addCoordinator(globalTID, tranState.localTID,
463 CoordinatorLog.removeLog(log.localTID);
547 CoordinatorLog.removeLog(log.localTID, logPath);
1461 superInfo.localTID,
1541 long result = superInfo.localTID.longValue();
1634 Long result = superInfo.localTID;
1854 tranState.localTID
[all...]
H A DCoordinatorSynchronizationImpl.java103 private Long localTID = null; field in class:CoordinatorSynchronizationImpl
136 localTID = new Long(coord.getLocalTID());
H A DSubCoordinator.java145 superInfo = new SuperiorInfo(tranState.localTID,
186 tranState.localTID, this, 0);
223 superInfo = new SuperiorInfo(tranState.localTID,
262 tranState.localTID,
1046 superInfo.localTID, ancestors);
1110 long result = superInfo.localTID.longValue();
1191 Long result = superInfo.localTID;
1490 superInfo.localTID, false);
1600 superInfo.localTID, false);
1779 long timeLeft = TimeoutManager.timeLeft(superInfo.localTID);
[all...]
H A DCurrentImpl.java548 Long localTID = new Long(controlImpl.getLocalTID(status));
689 Long localTID = new Long(controlImpl.getLocalTID(status));
H A DCurrentTransaction.java565 * @param localTID The local transaction identifier.
572 static int numActive( Long localTID, argument
596 if( currentLocalTID.equals(localTID) ) {

Completed in 41 milliseconds