| /glassfish-3.1.2/transaction/jts/src/main/java/com/sun/jts/CosTransactions/ |
| H A D | CoordinatorResourceImpl.java | 111 private GlobalTID globalTID = null; field in class:CoordinatorResourceImpl
132 * @param globalTID The global transaction identifier.
140 CoordinatorResourceImpl( GlobalTID globalTID, argument
148 this.globalTID = globalTID;
169 globalTID = null;
227 if( globalTID == null ) {
255 TopCoordinator coord = (TopCoordinator)RecoveryManager.getCoordinator(globalTID);
320 if( globalTID == null ) {
356 "GTID is: "+ globalTID
[all...] |
| H A D | RecoveryCoordinatorImpl.java | 109 GlobalTID globalTID = null; field in class:RecoveryCoordinatorImpl
123 * @param globalTID The global transaction identifier.
130 RecoveryCoordinatorImpl(GlobalTID globalTID, int sequence) { argument
132 this.globalTID = globalTID;
138 byte[] tidBytes = globalTID.toBytes();
160 globalTID = null;
194 CoordinatorImpl coord = RecoveryManager.getCoordinator(globalTID);
306 CoordinatorImpl coord = DelegatedRecoveryManager.getCoordinator(globalTID, logPath);
475 globalTID
[all...] |
| H A D | SuperiorInfo.java | 103 GlobalTID globalTID = null; field in class:SuperiorInfo
152 * @paran globalTID The global identifier for the transaction.
160 SuperiorInfo(Long localTID, GlobalTID globalTID, argument
164 this.globalTID = globalTID;
181 log.addData(logSection,globalTID.toBytes());
198 //$ if( globalTID != null ) globalTID.finalize();
221 globalTID = null;
259 globalTID
[all...] |
| H A D | TopCoordinator.java | 201 superInfo = new SuperiorInfo(tranState.localTID, tranState.globalTID,
206 // name = superInfo.globalTID.toString();
210 hash = superInfo.globalTID.hashCode();
242 if (!RecoveryManager.addCoordinator(tranState.globalTID,
263 * @param globalTID The global identifier for the transaction.
273 TopCoordinator(int timeOut, GlobalTID globalTID, Coordinator superior, argument
293 tranState = new TransactionState(globalTID,logRecord);
298 superInfo = new SuperiorInfo(tranState.localTID, tranState.globalTID,
303 // name = superInfo.globalTID.toString();
307 hash = superInfo.globalTID
[all...] |
| H A D | TransactionState.java | 201 GlobalTID globalTID = null; field in class:TransactionState
295 globalTID = new GlobalTID(XID_FORMAT_ID, 0,
325 * @param globalTID The global identifier for the transaction.
332 TransactionState(GlobalTID globalTID, CoordinatorLog log) { argument
336 this.globalTID = globalTID;
386 globalTID = new GlobalTID(XID_FORMAT_ID, 0,
488 globalTID = null;
692 FailureInducer.waitForFailure(this.globalTID, failurePoint);
762 // LogDBHelper.getInstance().addRecord(localTID.longValue(), globalTID
[all...] |
| H A D | SubCoordinator.java | 146 tranState.globalTID, null, null);
150 name = superInfo.globalTID.toString();
154 hash = superInfo.globalTID.hashCode();
185 RecoveryManager.addCoordinator(tranState.globalTID,
199 * @param globalTID The global identifier for the transaction.
210 SubCoordinator(GlobalTID globalTID, Coordinator superior, argument
218 tranState = new TransactionState(globalTID,null);
224 globalTID, superior, null);
228 name = superInfo.globalTID.toString();
232 hash = superInfo.globalTID
[all...] |
| H A D | DelegatedRecoveryManager.java | 91 static boolean addCoordinator(GlobalTID globalTID, argument
101 state.coordsByGlobalTID.put(globalTID,coord);
118 static boolean removeCoordinator(GlobalTID globalTID, argument
127 result = (state.coordsByGlobalTID.remove(globalTID) != null);
168 //CurrentTransaction.endAll(globalTID, aborted);
192 static CoordinatorImpl getCoordinator(GlobalTID globalTID, String logPath) { argument
196 state.coordsByGlobalTID.get(globalTID);
350 ((TopCoordinator)coord).superInfo.globalTID.toString());
382 ((TopCoordinator)coord).superInfo.globalTID.toString());
674 GlobalTID globalTID
[all...] |
| H A D | ControlImpl.java | 112 protected GlobalTID globalTID = null; field in class:ControlImpl
151 * @param globalTID The global identifier for the transaction.
160 GlobalTID globalTID,
168 this.globalTID = globalTID;
211 globalTID = new GlobalTID(cachedContext.current.otid);
253 globalTID = null;
268 return globalTID;
295 if( globalTID == null ) {
302 result = globalTID
158 ControlImpl( TerminatorImpl term, CoordinatorImpl coord, GlobalTID globalTID, Long localTID ) argument
[all...] |
| H A D | TransactionFactoryImpl.java | 218 ((TopCoordinator)coordinator).superInfo.globalTID.toString());
271 GlobalTID globalTID = new GlobalTID(context.current.otid);
273 RecoveryManager.getCoordinator(globalTID);
299 subordinate = RecoveryManager.getCoordinator(globalTID);
391 new SubCoordinator(globalTID,
412 globalTID,
433 result = (Control) new ControlImpl(null, subordinate, globalTID,
437 result = new ControlImpl(null, subordinate, globalTID,
|
| H A D | RecoveryManager.java | 237 * @param globalTID The global identifier for the transaction.
247 static boolean addCoordinator(GlobalTID globalTID, argument
255 coordsByGlobalTID.put(globalTID,coord);
280 * @param globalTID The global identifier for the transaction.
288 static boolean removeCoordinator(GlobalTID globalTID, argument
296 result = (coordsByGlobalTID.remove(globalTID) != null);
344 //CurrentTransaction.endAll(globalTID, aborted);
370 * @param globalTID The global identifier for the transaction.
376 static CoordinatorImpl getCoordinator(GlobalTID globalTID) { argument
379 coordsByGlobalTID.get(globalTID);
[all...] |
| H A D | CoordinatorTerm.java | 380 ((TopCoordinator)coordinator).superInfo.globalTID.toString());
394 ((TopCoordinator)coordinator).superInfo.globalTID.toString());
|
| H A D | DelegatedTimeoutManager.java | 263 ((TopCoordinator)coord).superInfo.globalTID.toString());
284 ((TopCoordinator)coord).superInfo.globalTID.toString());
|
| H A D | TimeoutManager.java | 291 ((TopCoordinator)coord).superInfo.globalTID.toString());
313 ((TopCoordinator)coord).superInfo.globalTID.toString());
|
| H A D | CurrentTransaction.java | 922 GlobalTID globalTID = null;
924 globalTID = new GlobalTID(current.getGlobalTID(outStatus));
932 if( globalTID != null ) {
945 if( !globalTID.isSameTID(context.current.otid) ) {
1299 * @param globalTID The global transaction identifier.
1307 synchronized static void endAll( GlobalTID globalTID, argument
1323 if( globalTID.equals(control.getGlobalTID(outStatus)) &&
1342 if( globalTID.equals(control.getGlobalTID(outStatus)) &&
|