blitz_stable: src/org/dancres/blitz/EntryViewImpl.java annotate

author	Dan Creswell <dan.creswell@gmail.com>
date	Sat, 21 Mar 2009 11:00:06 +0000
parents
children

rev	line source
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	1 package org.dancres.blitz;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	2
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	3 import java.io.IOException;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	4
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	5 import net.jini.core.transaction.Transaction;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	6 import net.jini.core.transaction.TransactionException;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	7 import net.jini.core.transaction.UnknownTransactionException;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	8
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	9 import org.dancres.blitz.entry.*;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	10 import org.dancres.blitz.mangler.MangledEntry;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	11 import org.dancres.blitz.txn.TxnManager;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	12 import org.dancres.blitz.txn.TxnState;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	13 import org.dancres.blitz.txnlock.LockMgr;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	14 import org.dancres.blitz.txnlock.TxnLock;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	15 import org.dancres.blitz.txnlock.TxnLocks;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	16 import org.dancres.blitz.notify.EventQueue;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	17
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	18 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	19 <p>This class supports both iteration using the old JavaSpaceAdmin interface
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	20 and the new JavaSpace05 interface. The key differences amount to the
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	21 the number of templates that can be passed and whether or not locks are
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	22 held on the transaction.</p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	23
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	24 <p>For JavaSpace05, there are multiple templates and we hold locks on the
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	25 transaction.</p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	26 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	27 class EntryViewImpl implements EntryView {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	28 private TxnState theTxn;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	29
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	30 private TransactionException theException;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	31 private int theStatus = ACTIVE;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	32
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	33 private static final int ACTIVE = -1;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	34 private static final int DECEASED = -2;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	35
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	36 private UIDSet theUIDs;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	37
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	38 private NewView theDynamicView;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	39
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	40 private EntryRx theBuffer;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	41
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	42 private boolean shouldUpdate;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	43
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	44 EntryViewImpl(Transaction aTxn, MangledEntry[] aTemplates,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	45 boolean holdLocks, boolean doUpdate, long aLimit)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	46 throws TransactionException, IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	47
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	48 shouldUpdate = doUpdate;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	49
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	50 theTxn = TxnManager.get().resolve(aTxn);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	51
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	52 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	53 Basic process is to assemble a set of fully matching Entry UID's which we
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	54 then step through ascertaining whether these UID's are still valid and possibly
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	55 asserting locks transactionally.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	56
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	57 Full matching is done in each view and the matching tuples are then
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	58 logged/merged in the UIDSet
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	59
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	60 These tuple ids are then scanned through using EntryReposImpl::find to load
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	61 the entry, verify it's valid etc after which we may or may not maintain a
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	62 transaction lock (these steps are done in EntryRx).
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	63 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	64 theUIDs = new UIDSet(aLimit);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	65
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	66 theBuffer = new EntryRx(theTxn, holdLocks);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	67 theDynamicView = new NewView(this, aTemplates, theUIDs);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	68
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	69 if (shouldUpdate)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	70 EventQueue.get().insert(theDynamicView.getSearchTask());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	71
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	72 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	73 For each template do a full tree search and assemble all matches
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	74 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	75 for (int i = 0; i < aTemplates.length; i++) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	76 if (theUIDs.isFull())
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	77 break;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	78
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	79 DiskView myFixedView = new DiskView(aTemplates[i], theUIDs);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	80
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	81 EntryRepository myRepos =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	82 EntryRepositoryFactory.get().find(aTemplates[i].getType());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	83
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	84 if (myRepos != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	85 myRepos.find(aTemplates[i], myFixedView);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	86
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	87 // Try subtypes
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	88 String[] mySubtypes = myRepos.getSubtypes();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	89
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	90 for (int j = 0; j < mySubtypes.length; j++) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	91 myRepos = EntryRepositoryFactory.get().find(mySubtypes[j]);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	92
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	93 if (myRepos != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	94 myRepos.find(aTemplates[i], myFixedView);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	95 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	96 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	97 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	98 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	99 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	100
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	101 TxnState getTxn() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	102 return theTxn;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	103 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	104
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	105 void resolved() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	106 setStatus(DECEASED,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	107 new TransactionException(
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	108 "Transaction closed with view active"));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	109 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	110
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	111 private void setStatus(int aStatus, TransactionException aTE) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	112 // Make sure we only do this once
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	113 //
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	114 synchronized(this) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	115 if (theStatus == DECEASED)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	116 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	117
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	118 theStatus = aStatus;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	119 theException = aTE;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	120 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	121
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	122 if (shouldUpdate)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	123 theDynamicView.getSearchTask().taint();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	124
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	125 if (theTxn.isNull()) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	126 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	127 TxnManager.get().prepareAndCommit(theTxn);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	128 } catch (UnknownTransactionException aUTE) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	129 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	130 Don't care much...if we got here, we're defining state
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	131 and everyone else will fail at the status test above
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	132 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	133 synchronized(this) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	134 theException = aUTE;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	135 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	136 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	137 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	138 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	139
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	140 public void close() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	141 setStatus(DECEASED, null);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	142 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	143
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	144 public EntryChit next() throws TransactionException, IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	145 synchronized(this) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	146 if (theStatus == DECEASED) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	147 if (theException != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	148 throw theException;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	149 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	150 throw new TransactionException("No longer active");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	151 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	152 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	153
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	154 SpaceEntryUID myUID;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	155
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	156 while ((myUID = theUIDs.pop()) != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	157 EntryRepository myRepos =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	158 EntryRepositoryFactory.get().get(myUID.getType());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	159
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	160 myRepos.find(theBuffer, myUID.getOID(), null);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	161
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	162 MangledEntry myEntry = theBuffer.getEntry();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	163
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	164 if (myEntry != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	165 return new EntryChit(myEntry, myUID);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	166 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	167
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	168 return null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	169 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	170
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	171 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	172 Used to receive the entry requested by id from the EntryRepository
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	173 It performs the appropriate locking checks and updates the transaction
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	174 if we're holding locks
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	175 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	176 private static class EntryRx implements SearchVisitor {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	177 private MangledEntry theEntry;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	178
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	179 private TxnState theTxn;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	180 private boolean keepLock;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	181
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	182 private TransactionException theFailure;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	183
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	184 EntryRx(TxnState aTxn, boolean holdLock) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	185 theTxn = aTxn;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	186 keepLock = holdLock;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	187 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	188
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	189 public int offer(SearchOffer anOffer) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	190 OpInfo myInfo = anOffer.getInfo();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	191
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	192 // Try the lock
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	193 LockMgr myMgr = TxnLocks.getLockMgr(myInfo.getType());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	194 TxnLock myLock = myMgr.getLock(myInfo.getOID());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	195
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	196 int myResult;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	197
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	198 synchronized(myLock) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	199 myResult = myLock.acquire(theTxn, TxnLock.READ,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	200 null, null, false);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	201 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	202
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	203 if (myResult == TxnLock.SUCCESS) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	204 if (keepLock) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	205 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	206 Need to track the lock under the transaction
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	207 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	208 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	209 theTxn.add(new EntryTxnOp(TxnLock.READ, myInfo,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	210 myLock));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	211 } catch (TransactionException aTE) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	212 myLock.release(theTxn, TxnLock.READ);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	213 theFailure = aTE;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	214 return STOP;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	215 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	216 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	217 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	218 No need to track this lock, we were just testing so
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	219 we can release it now
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	220 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	221 myLock.release(theTxn, TxnLock.READ);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	222 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	223
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	224 theEntry = anOffer.getEntry();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	225 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	226
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	227 return STOP;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	228 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	229
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	230 public boolean isDeleter() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	231 return false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	232 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	233
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	234 MangledEntry getEntry() throws TransactionException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	235 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	236 If we're running under an external (non-null) transaction
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	237 we may have failed whilst attempting to lock (we would have
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	238 failed to record the lock in the transaction).
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	239 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	240 if (theFailure != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	241 throw theFailure;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	242
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	243 MangledEntry myResult = theEntry;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	244 theEntry = null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	245
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	246 return myResult;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	247 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	248 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	249 }

0

3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet.