| /glassfish-3.1.2/transaction/jts/src/main/java/com/sun/jts/CosTransactions/ |
| H A D | StaticResource.java | 98 * @param coord The transaction whose association is starting.
105 public abstract void startAssociation(Coordinator coord, boolean begin); argument
115 * @param coord The transaction whose association is starting.
122 public abstract void endAssociation(Coordinator coord, boolean complete); argument
|
| H A D | RegisteredStatics.java | 142 org.omg.CosTransactions.Coordinator coord = null;
145 coord = control.get_coordinator();
150 if (coord != null) {
158 resource.startAssociation(coord, begin);
167 endAssociation(coord, begin);
199 org.omg.CosTransactions.Coordinator coord = null;
202 coord = control.get_coordinator();
207 if (coord != null) {
212 resource.endAssociation(coord, complete);
241 org.omg.CosTransactions.Coordinator coord
[all...] |
| H A D | CoordinatorResourceImpl.java | 133 * @param coord The Coordinator for the transaction.
141 CoordinatorImpl coord,
153 if( coord != null )
154 coord.setTerminator(this);
255 TopCoordinator coord = (TopCoordinator)RecoveryManager.getCoordinator(globalTID);
260 if( coord != null )
261 synchronized( coord ) {
267 result = coord.prepare();
276 coord.rollback(false);
361 TopCoordinator coord
140 CoordinatorResourceImpl( GlobalTID globalTID, CoordinatorImpl coord, boolean subtran ) argument
[all...] |
| H A D | XATerminatorImpl.java | 99 // Synchronizers invoked by coord.beforeCompletion must be
125 TopCoordinator coord = (TopCoordinator)
128 if (coord == null) { // error to receive commit more than once
135 synchronized (coord) {
137 coord.beforeCompletion();
138 if (coord.getParticipantCount() == 1) {
139 coord.commitOnePhase();
143 vote = coord.prepare();
149 coord.commit();
151 coord
[all...] |
| H A D | DelegatedTimeoutManager.java | 240 CoordinatorImpl coord = DelegatedRecoveryManager.getLocalCoordinator(localTID, logPath);
241 if (coord == null) {
249 synchronized (coord) {
263 ((TopCoordinator)coord).superInfo.globalTID.toString());
266 // coord.rollback(true);
267 coord.rollback_only();
284 ((TopCoordinator)coord).superInfo.globalTID.toString());
286 Status state = ((TopCoordinator) coord).recover(isRoot);
306 ((TopCoordinator)coord).commit();
308 ((TopCoordinator) coord)
[all...] |
| H A D | TimeoutManager.java | 264 CoordinatorImpl coord = RecoveryManager.getLocalCoordinator(localTID);
265 if (coord == null) {
276 synchronized (coord) {
291 ((TopCoordinator)coord).superInfo.globalTID.toString());
294 // coord.rollback(true);
295 coord.rollback_only();
313 ((TopCoordinator)coord).superInfo.globalTID.toString());
315 Status state = ((TopCoordinator) coord).recover(isRoot);
335 ((TopCoordinator)coord).commit();
337 ((TopCoordinator) coord)
[all...] |
| H A D | RecoveryCoordinatorImpl.java | 194 CoordinatorImpl coord = RecoveryManager.getCoordinator(globalTID);
195 if (coord != null) {
197 result = coord.get_status();
213 coord.rollback_only();
260 if (coord == null) {
306 CoordinatorImpl coord = DelegatedRecoveryManager.getCoordinator(globalTID, logPath);
307 if (coord != null) {
309 result = coord.get_status();
325 coord.rollback_only();
372 if (coord
[all...] |
| H A D | DelegatedRecoveryManager.java | 92 Long localTID, CoordinatorImpl coord, int timeout, String logPath) {
101 state.coordsByGlobalTID.put(globalTID,coord);
102 state.coordsByLocalTID.put(localTID,coord);
126 CoordinatorImpl coord = null;
132 coord = (CoordinatorImpl) state.coordsByLocalTID.remove(localTID);
133 result = (coord != null);
141 if (coord != null) {
143 if (coord.is_top_level_transaction()) {
308 TopCoordinator coord = (TopCoordinator)resyncList.nextElement();
314 synchronized (coord) {
91 addCoordinator(GlobalTID globalTID, Long localTID, CoordinatorImpl coord, int timeout, String logPath) argument
[all...] |
| H A D | CurrentImpl.java | 202 Coordinator coord = controlImpl.get_coordinator();
206 Control control = coord.create_subtransaction();
386 Coordinator coord = controlImpl.get_coordinator();
390 Control control = coord.create_subtransaction();
813 Coordinator coord = CurrentTransaction.getCurrentCoordinator();
817 coord.rollback_only();
837 Coordinator coord = CurrentTransaction.getCurrentCoordinator();
841 if( coord != null )
842 result = coord.get_status();
866 Coordinator coord
[all...] |
| H A D | RecoveryManager.java | 239 * @param coord The Coordinator for the transaction.
248 Long localTID, CoordinatorImpl coord, int timeout) {
255 coordsByGlobalTID.put(globalTID,coord);
256 coordsByLocalTID.put(localTID,coord);
295 CoordinatorImpl coord = null;
301 coord = (CoordinatorImpl) coordsByLocalTID.remove(localTID);
302 result = (coord != null);
310 if (coord != null) {
312 if (coord.is_top_level_transaction()) {
313 if (inCompleteTxMap.get(coord)
247 addCoordinator(GlobalTID globalTID, Long localTID, CoordinatorImpl coord, int timeout) argument
1484 addToIncompleTx(CoordinatorImpl coord, boolean commit) argument
[all...] |
| H A D | CoordinatorSynchronizationImpl.java | 124 * @param coord The Coordinator for the transaction.
130 CoordinatorSynchronizationImpl( TopCoordinator coord ) {
134 coordinator = coord;
136 localTID = new Long(coord.getLocalTID());
|
| H A D | AdminUtil.java | 156 CoordinatorImpl coord = (CoordinatorImpl)iter.next();
157 if ( coord.get_status() ==
|
| H A D | ControlImpl.java | 107 protected CoordinatorImpl coord = null; field in class:ControlImpl
150 * @param coord The Coordinator for the transaction.
159 CoordinatorImpl coord,
167 this.coord = coord;
248 coord = null;
545 if( coordRef == null && coord != null ) {
546 coordRef = coord.object();
579 Coordinator result = (Coordinator) coord;
824 result = coord
158 ControlImpl( TerminatorImpl term, CoordinatorImpl coord, GlobalTID globalTID, Long localTID ) argument
[all...] |
| H A D | CoordinatorImpl.java | 385 synchronized static final CoordinatorImpl servant( Coordinator coord ) {
388 if( coord instanceof CoordinatorImpl )
389 result = (CoordinatorImpl)coord;
391 JCoordinator jcoord = JCoordinatorHelper.narrow(coord);
|
| H A D | SuperiorInfo.java | 241 * @param coord The Coordinator object recreated after recovery.
247 void reconstruct(CoordinatorLog log, CoordinatorImpl coord) { argument
272 RecoveryManager.addCoordinator(globalTID, localTID, coord, 0);
321 void delegated_reconstruct(CoordinatorLog log, CoordinatorImpl coord, String logPath) { argument
346 DelegatedRecoveryManager.addCoordinator(globalTID, localTID, coord, 0, logPath);
|
| H A D | TransactionFactoryImpl.java | 287 !checker.isProxy(context.current.coord)) {
344 coord._duplicate(),
366 coord._duplicate(),
381 context.parents[i].coord._release();
393 coord._duplicate(),
414 current.coord._duplicate(),
|
| H A D | CurrentTransaction.java | 894 return; // no coord, cannot mark tx for rollback
912 context.current.coord == null ||
1106 CoordinatorImpl coord = null;
1110 coord = (CoordinatorImpl) current.get_localCoordinator();
1113 coord = CoordinatorImpl.servant(coordRef);
1116 // _logger.log(Level.FINE,"Servant = "+coord);
1128 forgetParent = coord.replyAction(outInt);
1136 coord.rollback_only();
1157 coord.cleanUpEmpty(forgetParent);
1166 coord
[all...] |
| H A D | RegisteredResources.java | 113 private CoordinatorImpl coord = null; field in class:RegisteredResources
152 RegisteredResources(CoordinatorLog log, CoordinatorImpl coord) { argument
171 this.coord = coord;
183 RegisteredResources(CoordinatorImpl coord) { this.coord = coord;} argument
926 if (coord != null)
927 RecoveryManager.addToIncompleTx(coord, true);
1182 if (coord !
[all...] |
| H A D | CoordinatorTerm.java | 126 * @param coord The Coordinator for the transaction.
133 CoordinatorTerm( CoordinatorImpl coord, argument
138 coordinator = coord;
|
| H A D | SubCoordinator.java | 1949 Coordinator coord =
1951 PropagationContext pc = coord.get_txcontext();
|
| H A D | TopCoordinator.java | 3066 // Now set this coord to commited finally.
3174 // Now set this coord to commited finally.
3255 Coordinator coord =
3257 PropagationContext pc = coord.get_txcontext();
|
| /glassfish-3.1.2/transaction/jts/src/main/java/com/sun/jts/utils/RecoveryHooks/ |
| H A D | FailureInducer.java | 222 * @param coord the coordinator object (which represents the transaction.
312 Coordinator coord = Utility.getCoordinator(Utility.getControl());
313 JCoordinator jcoord = JCoordinatorHelper.narrow(coord);
|
| /glassfish-3.1.2/transaction/jts/src/main/java/com/sun/jts/pi/ |
| H A D | InterceptorImpl.java | 811 return (ctx.current.coord == null && ctx.current.term == null);
|