blitz_condensed: src/org/dancres/blitz/entry/SleeveCache.java annotate

annotate src/org/dancres/blitz/entry/SleeveCache.java @ 21:8417eaebf5ab

Fix partitioning to size caches properly

author	Dan Creswell <dan.creswell@gmail.com>
date	Sat, 22 Aug 2009 23:28:55 +0100
parents	62b11f04d859
children	b7e52953b7a6

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.entry;
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 java.util.ArrayList;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	6
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	7 import java.util.logging.*;
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 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	10 import net.jini.config.ConfigurationException;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	11
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.mangler.MangledEntry;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	13
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.Logging;
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.stats.StatGenerator;
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.stats.Stat;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	17 import org.dancres.blitz.stats.SearchStat;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	18 import org.dancres.blitz.stats.StatsBoard;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	19
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	20 import org.dancres.blitz.oid.OID;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	21
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	22 import org.dancres.blitz.arc.ArcCache;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	23 import org.dancres.blitz.arc.CacheBlockDescriptor;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	24 import org.dancres.blitz.arc.RecoverySummary;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	25
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	26 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	27
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	28 import org.dancres.blitz.entry.ci.CacheIndexer;
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 import org.dancres.blitz.config.CacheSize;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	31 import org.dancres.blitz.config.Fifo;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	32 import org.dancres.blitz.config.EntryConstraints;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	33
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	34 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong;
18 62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	35 import org.dancres.blitz.config.ConfigurationFactory;
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	36
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 The organization of the space implementation can be viewed as being
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	39 similar to a memory hierarchy with EntryReposImpl/SpaceImpl being where
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	40 central processing happens. SleeveCache can be viewed as level 1 cache
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	41 whilst storage is main memory. Thus all "traffic" goes through SleeveCache
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	42 which interacts appropriately with Storage when it cannot satisfy the
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	43 demand itself. <P>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	44
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	45 Is responsible for indexing and caching of unpacked EntrySleeveImpls.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	46 Implemented using an ArcCache.<P>
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 @see org.dancres.blitz.arc.ArcCache
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 @todo One way to split caches down further in the face of concurrency
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	51 demands would be to start maintaining multiple caches scoped or hashed on
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	52 the zone id or even the uid itself.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	53 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	54 class SleeveCache implements StatGenerator {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	55 static Logger theLogger =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	56 Logging.newLogger("org.dancres.blitz.disk.SleeveCache");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	57
18 62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	58 private static int DESIRED_ENTRIES_PER_PARTITION = 0;
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	59
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	60 static {
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	61 try {
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	62 DESIRED_ENTRIES_PER_PARTITION =
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	63 ((Integer) ConfigurationFactory.getEntry("cacheEntriesPerPartition", int.class,
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	64 new Integer(128))).intValue();
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	65
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	66 theLogger.log(Level.SEVERE, "Loaded config: " +
8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	67 ((Integer) ConfigurationFactory.getEntry("cacheEntriesPerPartition", int.class,
8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	68 new Integer(32))).intValue());
18 62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	69
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	70 } catch (ConfigurationException aCE) {
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	71 theLogger.log(Level.SEVERE, "Failed to source partition setup", aCE);
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	72 }
62b11f04d859 Make cache partitioning configurable. Dan Creswell <dan.creswell@gmail.com> parents: 16 diff changeset	73 }
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	74
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	75 private final ArcCache[] theStoreCaches;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	76 private final int theNumPartitions;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	77 private final int thePartitionsMask;
0 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 private Storage theStore;
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 private CountersImpl theCounters;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	82
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	83 private EntryConstraints theConstraints;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	84
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	85 private CacheIndexer theIndexer;
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 private long theId = StatGenerator.UNSET_ID;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	88
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	89 private static class OfferTracker {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	90 private String theType;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	91 private AtomicLong theMissed = new AtomicLong();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	92 private AtomicLong theDeld = new AtomicLong();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	93
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	94 OfferTracker(String aType) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	95 theType = aType;
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 void incMissed() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	99 theMissed.incrementAndGet();
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
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	102 void incDeld() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	103 theDeld.incrementAndGet();
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
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	106 public String getTitle() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	107 return theType;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	108 }
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 public long getMisses() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	111 return theMissed.get();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	112 }
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 public long getDeld() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	115 return theDeld.get();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	116 }
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
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	119 private static final int CACHED_TRACKER = 0;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	120 private static final int DIRTY_TRACKER = 1;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	121 private static final int STORAGE_TRACKER = 2;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	122
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	123 private OfferTracker[] theTrackers = new OfferTracker[] {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	124 new OfferTracker("Cached"), new OfferTracker("Dirty"),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	125 new OfferTracker("Storage")
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	126 };
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	127
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	128 SleeveCache(Storage aStore) throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	129 theStore = aStore;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	130
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	131 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	132 theConstraints =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	133 EntryConstraints.getConstraints(theStore.getType());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	134 } catch (ConfigurationException aCE) {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	135 thePartitionsMask = 0;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	136 theNumPartitions = 0;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	137 theStoreCaches = new ArcCache[0];
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	138 theLogger.log(Level.SEVERE,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	139 "Couldn't load constraints for type " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	140 theStore.getType(), aCE);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	141 IOException myIOE =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	142 new IOException("Couldn't load constraints for type " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	143 theStore.getType());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	144 myIOE.initCause(aCE);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	145 throw myIOE;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	146 }
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	147
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	148 CacheSize myCacheSize = (CacheSize) theConstraints.get(CacheSize.class);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	149
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	150 int myNumPartitions;
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	151 int myEntriesPerCache;
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	152
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	153 if (DESIRED_ENTRIES_PER_PARTITION == -1) {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	154 myNumPartitions = 1;
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	155 myEntriesPerCache = myCacheSize.getSize();
8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	156 } else {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	157 myNumPartitions = (myCacheSize.getSize() / DESIRED_ENTRIES_PER_PARTITION);
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	158 myEntriesPerCache = DESIRED_ENTRIES_PER_PARTITION;
8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	159 }
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	160
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	161 // Find nearest power of 2 > or =
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	162 //
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	163 int myPower;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	164 for (myPower = 1; myPower < myNumPartitions; myPower = myPower << 1);
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	165 theNumPartitions = myPower;
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	166
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	167 thePartitionsMask = theNumPartitions - 1;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	168
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	169 theLogger.log(Level.INFO, aStore.getType() + " cache size = "
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	170 + myCacheSize.getSize() + " partitions = " + theNumPartitions +
8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	171 " mask = " + Integer.toHexString(thePartitionsMask) + " partition size = " + myEntriesPerCache);
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	172
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	173 theStoreCaches = new ArcCache[theNumPartitions];
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	174
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	175 for (int i = 0; i < theNumPartitions; i++) {
21 8417eaebf5ab Fix partitioning to size caches properly Dan Creswell <dan.creswell@gmail.com> parents: 18 diff changeset	176 theStoreCaches[i] = new ArcCache(aStore, myEntriesPerCache);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	177
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	178 theIndexer = CacheIndexer.getIndexer(theStore.getType());
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	179
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	180 theStoreCaches[i].add(new CacheListenerImpl(theIndexer));
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	181 }
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	182
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	183 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	184 theCounters = new CountersImpl(theStore.getType(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	185 theStore.getNumEntries());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	186 } catch (IOException anIOE) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	187 theLogger.log(Level.SEVERE,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	188 "Couldn't read instance count from storage: " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	189 theStore.getType() +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	190 " statistics will be inaccurate", anIOE);
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 theCounters = new CountersImpl(theStore.getType(), 0);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	193 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	194
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	195 StatsBoard.get().add(this);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	196 }
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 public void setId(long anId) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	199 theId = anId;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	200 }
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 public long getId() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	203 return theId;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	204 }
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 public Stat generate() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	207 String[] myTitles = new String[theTrackers.length];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	208 long[] myMisses = new long[theTrackers.length];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	209 long[] myDeld = new long[theTrackers.length];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	210
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	211 for (int i = 0; i < theTrackers.length; i++) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	212 myTitles[i] = theTrackers[i].getTitle();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	213 myMisses[i] = theTrackers[i].getMisses();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	214 myDeld[i] = theTrackers[i].getDeld();
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
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	217 return new SearchStat(theId, theStore.getType(), myTitles,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	218 myMisses, myDeld);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	219 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	220
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	221 private int getPartition(CacheBlockDescriptor aCBD) {
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	222 OID myOID = (OID) aCBD.getId();
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	223
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	224 return getPartition(myOID);
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	225 }
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	226
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	227 private int getPartition(OID anOID) {
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	228 return anOID.hashCode() & thePartitionsMask;
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	229 }
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	230
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	231 private int getPartition(EntrySleeveImpl aSleeve) {
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	232 return getPartition(aSleeve.getOID());
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	233 }
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	234
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	235 void forceSync(CacheBlockDescriptor aCBD) throws IOException {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	236 theStoreCaches[getPartition(aCBD)].forceSync(aCBD);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	237 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	238
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	239 CacheBlockDescriptor load(OID aOID) throws IOException {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	240 return theStoreCaches[getPartition(aOID)].find(aOID);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	241 }
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 CacheBlockDescriptor add(EntrySleeveImpl aSleeve) throws IOException {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	244 return theStoreCaches[getPartition(aSleeve)].insert(aSleeve);
0 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
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	247 RecoverySummary recover(EntrySleeveImpl aSleeve)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	248 throws IOException {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	249 return theStoreCaches[getPartition(aSleeve)].recover(aSleeve);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	250 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	251
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	252 boolean renew(OID aOID, long anExpiry) throws IOException {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	253 CacheBlockDescriptor myCBD = theStoreCaches[getPartition(aOID)].find(aOID);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	254
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	255 if (myCBD == null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	256 return false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	257 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	258
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	259 EntrySleeveImpl mySleeve = (EntrySleeveImpl) myCBD.getContent();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	260
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	261 if (!mySleeve.hasExpired(System.currentTimeMillis()) &&
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	262 !mySleeve.getState().test(SleeveState.DELETED)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	263
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	264 if (anExpiry == 0) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	265 // Don't reset expiry - it's useful to storage to know
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	266 // what the lease was last
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	267 mySleeve.getState().set(SleeveState.DELETED);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	268
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	269 // Update stats
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	270 theCounters.didPurge();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	271 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	272 mySleeve.setExpiry(anExpiry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	273 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	274
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	275 mySleeve.markDirty();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	276 myCBD.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	277
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	278 return true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	279 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	280
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	281 myCBD.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	282
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	283 return false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	284 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	285
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	286 boolean cancel(OID aOID) throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	287 return renew(aOID, 0);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	288 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	289
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	290 void sync() throws IOException {
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	291 for (int i = 0; i < theNumPartitions; i++) {
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	292 theStoreCaches[i].sync();
46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	293 }
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	294 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	295
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	296 Counters getCounters() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	297 return theCounters;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	298 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	299
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	300 void close() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	301 // Nothing to do here - we could destroy the counters but we put that
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	302 // in deleteAll which makes more sense as close doesn't mean deletion
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	303 // theStoreCache.dump();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	304 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	305
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	306 void write(MangledEntry anEntry, long anExpiry, WriteEscort anEscort)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	307 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	308
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	309
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	310 OID myID = theStore.getNextId();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	311 EntrySleeveImpl mySleeve = null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	312
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	313 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	314 theLogger.log(Level.FINE, "Written: " + myID + ", " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	315 anExpiry + ", " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	316 (anExpiry - System.currentTimeMillis()));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	317
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	318 mySleeve = new EntrySleeveImpl(myID, anEntry, anExpiry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	319
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	320 // Ready to write but tell the escort first
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	321 OpInfo myInfo = new WriteEntryOpInfo(mySleeve);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	322
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	323 if (!anEscort.writing(myInfo))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	324 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	325
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	326 // Now make it visible
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	327 CacheBlockDescriptor myCBD = theStoreCaches[getPartition(mySleeve)].insert(mySleeve);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	328 myCBD.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	329
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	330 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	331 theLogger.log(Level.FINE, "Unwritten: " + mySleeve.getOID());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	332 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	333
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	334 void find(MangledEntry anEntry, SearchVisitor aVisitor)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	335 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	336
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	337 if (theConstraints.get(Fifo.class) != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	338 fifoFind(anEntry, aVisitor);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	339 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	340 fastFind(anEntry, aVisitor);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	341 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	342
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	343 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	344 <p>If we're in FIFO mode, we know that each TupleLocator is sorted into
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	345 FIFO order. Thus we can merge across all locators on the fly
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	346 and obtain a fully ordered, non-duplicate set of tuple id's for
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	347 matching using a simply algorithm.</p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	348
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	349 <p>By sorting across all locators and applying global FIFO order
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	350 we can maximize use of the cache and avoid excessive disk hits if
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	351 we have sufficient of the FIFO ordering in cache. Thus we get
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	352 graceful degradation rather than consulting disk for the definitive
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	353 ordering regardless.</p>
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	354 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	355 private void fifoFind(MangledEntry anEntry, SearchVisitor aVisitor)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	356 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	357
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	358 long mySearchStart = System.currentTimeMillis();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	359
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	360 ArrayList myLocators = new ArrayList();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	361
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	362 TupleLocator myLocator = theStore.find(anEntry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	363
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	364 if (myLocator != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	365 myLocators.add(myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	366
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	367 myLocator = theStore.findCached(anEntry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	368
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	369 if (myLocator != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	370 myLocators.add(myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	371
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	372 myLocator = theIndexer.find(anEntry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	373
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	374 if (myLocator != null)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	375 myLocators.add(myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	376
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	377 if (myLocators.size() == 0)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	378 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	379
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	380 TupleLocator[] mySortedSources = new TupleLocator[myLocators.size()];
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	381
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	382 mySortedSources = (TupleLocator[]) myLocators.toArray(mySortedSources);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	383
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	384 myLocator = new SortingLocator(mySortedSources);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	385
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	386 offerAndReleaseLocator(myLocator, aVisitor, mySearchStart,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	387 theTrackers[CACHED_TRACKER]);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	388 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	389
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	390 private void fastFind(MangledEntry anEntry, SearchVisitor aVisitor)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	391 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	392
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	393 long mySearchStart = System.currentTimeMillis();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	394
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	395 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	396 Basic approach is to send the template to the CacheIndexer and
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	397 ask it to return suitable IDs which we will then pin and try.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	398 Note we should set a flag which boycotts a load from disk so that
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	399 flushed or deleted entries are not loaded more than once.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	400
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	401 If we cannot satisfy the Visitor that way, we repeat the exercise
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	402 with storage which returns OID/byte[] pairs which we can then
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	403 pin.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	404
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	405 Storage and CacheIndexer are now free to plan searches as they
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	406 see fit based on template.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	407 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	408
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	409 TupleLocator myLocator = theIndexer.find(anEntry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	410
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	411 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	412 theLogger.log(Level.FINE, "Searching[cache]: " + myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	413
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	414 if (myLocator != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	415 if (offerAndReleaseLocator(myLocator, aVisitor, mySearchStart,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	416 theTrackers[CACHED_TRACKER])) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	417 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	418 System.err.println("Cache search time: " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	419 (System.currentTimeMillis() -
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	420 mySearchStart));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	421 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	422 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	423 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	424 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	425
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	426 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	427 theLogger.log(Level.FINE, "Searching[StoreCache]: " + myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	428
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	429 myLocator = theStore.findCached(anEntry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	430
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	431 if (myLocator != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	432 if (offerAndReleaseLocator(myLocator, aVisitor, mySearchStart,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	433 theTrackers[DIRTY_TRACKER]))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	434 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	435 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	436
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	437 myLocator = theStore.find(anEntry);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	438
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	439 if (myLocator == null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	440 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	441 theLogger.log(Level.FINE, "Got no matches on disk");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	442 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	443 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	444
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	445 offerAndReleaseLocator(myLocator, aVisitor, mySearchStart,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	446 theTrackers[STORAGE_TRACKER]);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	447 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	448
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	449 LongtermOffer getOffer(OID anOID) throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	450
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	451 CacheBlockDescriptor myCBD = theStoreCaches[getPartition(anOID)].find(anOID);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	452
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	453 if (myCBD != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	454 return new LongtermOfferImpl(myCBD);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	455 } else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	456 return null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	457 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	458
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	459 boolean find(SearchVisitor aVisitor, OID aOID, MangledEntry aPreload)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	460 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	461
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	462 CacheBlockDescriptor myCBD = theStoreCaches[getPartition(aOID)].find(aOID);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	463
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	464 long myStartTime = System.currentTimeMillis();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	465
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	466 boolean offered = false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	467
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	468 if (myCBD != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	469 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	470 EntrySleeveImpl mySleeve =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	471 (EntrySleeveImpl) myCBD.getContent();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	472
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	473 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	474 If the JS specification is changed to cope with the issues
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	475 discussed in http://archives.java.sun.com/cgi-bin/wa?A2=ind0311&L=javaspaces-users&F=&S=&P=4599 and http://archives.java.sun.com/cgi-bin/wa?A2=ind0311&L=javaspaces-users&F=&S=&P=3590 then we need to do two things:
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	476
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	477 (1) Allow the SearchVisitor to see Sleeve's even if they've
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	478 expired.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	479 (2) Having "shown" it to the SearchVisitor we'd need to
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	480 query the ReapFilters and if they don't boycott, mark the
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	481 item deleted.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	482
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	483 These two steps have the effect of allowing a *ifExists to
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	484 conflict on lease-expired entries that have been locked
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	485 by a transaction and ensures we only delete such entries
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	486 when no transactions have posession of them anymore. Of
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	487 course, this is somewhat slower and less efficient as
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	488 there's never a circumstance under which we can be assured
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	489 that a SearchVisitor never sees a particular entry again.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	490
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	491 If we must implement the strategy of flunking a transaction
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	492 owing to a lock on a lease expired object, this would be
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	493 best dealt with by having TxnOp's check expiries at prepare
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	494 or commit time. However this is much less appealing as what
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	495 is basically a pessimistic transaction API becomes
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	496 optimistic in this case and only in this case.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	497
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	498 All this applies to the similar statement in offer() below.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	499 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	500 if (! mySleeve.getState().test(SleeveState.DELETED)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	501
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	502 // If it's expired, mark it deleted, subject to filters
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	503 //
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	504 if (mySleeve.hasExpired(myStartTime)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	505
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	506 if (! EntryRepositoryFactory.getReaper().filter(mySleeve)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	507 mySleeve.getState().set(SleeveState.DELETED);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	508 mySleeve.markDirty();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	509
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	510 // Update stats
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	511 theCounters.didPurge();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	512 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	513 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	514 OpInfo myInfo =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	515 new FindEntryOpInfo(theStore.getType(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	516 mySleeve.getOID(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	517 aVisitor.isDeleter());
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	518
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	519 SearchOffer myOffer;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	520
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	521 if (aPreload != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	522 myOffer = new SearchOfferImpl(aPreload, myInfo);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	523 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	524 theLogger.log(Level.FINE, "NOT using preload");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	525
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	526 myOffer = new SearchOfferImpl(mySleeve.getEntry(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	527 myInfo);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	528 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	529
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	530 aVisitor.offer(myOffer);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	531
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	532 offered = true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	533 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	534 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	535 theTrackers[CACHED_TRACKER].incDeld();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	536 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	537 } finally {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	538 myCBD.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	539 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	540 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	541 theTrackers[CACHED_TRACKER].incMissed();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	542 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	543
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	544 return offered;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	545 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	546
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	547 private boolean offerAndReleaseLocator(TupleLocator aLocator,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	548 SearchVisitor aVisitor,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	549 long aStartTime,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	550 OfferTracker aTracker)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	551 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	552
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	553 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	554 return offer(aLocator, aVisitor, aStartTime, aTracker);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	555 } finally {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	556 aLocator.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	557 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	558 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	559
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	560 /**
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	561 @return <code>true</code> means offering can stop for better or worse.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	562 <code>false</code> indicates that the search should continue if there
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	563 are other sources of offers.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	564 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	565 private boolean offer(TupleLocator aLocator, SearchVisitor aVisitor,
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	566 long aStartTime, OfferTracker aTracker)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	567 throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	568
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	569 int myVisitorResponse = SearchVisitor.TRY_AGAIN;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	570
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	571 OID myId = null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	572 EntrySleeveImpl mySleeve = null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	573 String myType = theStore.getType();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	574 boolean isDeletion = aVisitor.isDeleter();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	575
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	576 // long myStart = System.currentTimeMillis();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	577
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	578 while (aLocator.fetchNext()) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	579
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	580 myId = aLocator.getOID();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	581
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	582 CacheBlockDescriptor myCBD = theStoreCaches[getPartition(myId)].find(myId);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	583
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	584 if (myCBD != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	585 mySleeve = (EntrySleeveImpl) myCBD.getContent();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	586
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	587 if (! mySleeve.getState().test(SleeveState.DELETED)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	588
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	589 // If it's expired, mark it deleted, subject to filters
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	590 //
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	591 if (mySleeve.hasExpired(aStartTime)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	592 if (! EntryRepositoryFactory.getReaper().filter(mySleeve)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	593 mySleeve.getState().set(SleeveState.DELETED);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	594 mySleeve.markDirty();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	595
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	596 // Update stats
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	597 theCounters.didPurge();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	598 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	599 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	600
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	601 OpInfo myInfo =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	602 new FindEntryOpInfo(myType, mySleeve.getOID(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	603 isDeletion);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	604
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	605 SearchOfferImpl myOffer =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	606 new SearchOfferImpl(mySleeve.getEntry(), myInfo);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	607
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	608 myVisitorResponse =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	609 aVisitor.offer(myOffer);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	610 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	611 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	612 aTracker.incDeld();;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	613 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	614
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	615 myCBD.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	616
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	617 if ((myVisitorResponse == SearchVisitor.STOP) \|\|
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	618 (myVisitorResponse == SearchVisitor.ACCEPTED)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	619 break;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	620 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	621 } else {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	622 aTracker.incMissed();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	623 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	624 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	625
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	626 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	627 System.out.println("Time to offer: " +
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	628 (System.currentTimeMillis() -
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	629 myStart));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	630 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	631
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	632 if (myVisitorResponse != SearchVisitor.TRY_AGAIN)
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	633 return true;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	634 else
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	635 return false;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	636 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	637
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	638 void deleteAll() throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	639 theCounters.destroy();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	640
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	641 /*
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	642 Basic approach is to send the template to the CacheIndexer and
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	643 ask it to return suitable IDs which we will then pin and try.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	644 Note we should set a flag which boycotts a load from disk so that
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	645 flushed or deleted entries are not loaded more than once.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	646
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	647 If we cannot satisfy the Visitor that way, we repeat the exercise
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	648 with storage which returns OID/byte[] pairs which we can then
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	649 pin.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	650
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	651 Storage and CacheIndexer are now free to plan searches as they
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	652 see fit based on template.
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	653 */
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	654
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	655 TupleLocator myLocator = theIndexer.find(MangledEntry.NULL_TEMPLATE);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	656
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	657 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	658 theLogger.log(Level.FINE, "Searching[cache]: " + myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	659
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	660 if (myLocator != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	661 delete(myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	662 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	663
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	664 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	665 theLogger.log(Level.FINE, "Searching[StoreCache]: " + myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	666
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	667 myLocator = theStore.findCached(MangledEntry.NULL_TEMPLATE);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	668
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	669 if (myLocator != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	670 delete(myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	671 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	672
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	673 myLocator = theStore.find(MangledEntry.NULL_TEMPLATE);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	674
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	675 if (myLocator == null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	676 if (theLogger.isLoggable(Level.FINE))
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	677 theLogger.log(Level.FINE, "Got no matches on disk");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	678 return;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	679 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	680
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	681 delete(myLocator);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	682 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	683
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	684 private void delete(TupleLocator aLocator) throws IOException {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	685 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	686 while (aLocator.fetchNext()) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	687
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	688 OID myId = aLocator.getOID();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	689
16 46ac1a45718a Add support for cache partitioning to improve concurrency. Dan Creswell <dan.creswell@gmail.com> parents: 0 diff changeset	690 CacheBlockDescriptor myCBD = theStoreCaches[getPartition(myId)].find(myId);
0 3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	691
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	692 OpInfo myInfo = null;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	693
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	694 if (myCBD != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	695 EntrySleeveImpl mySleeve =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	696 (EntrySleeveImpl) myCBD.getContent();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	697
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	698 if (! mySleeve.getState().test(SleeveState.DELETED)) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	699 mySleeve.getState().set(SleeveState.DELETED);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	700 mySleeve.markDirty();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	701
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	702 myInfo =
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	703 new FindEntryOpInfo(theStore.getType(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	704 mySleeve.getOID(),
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	705 true);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	706 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	707
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	708 myCBD.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	709
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	710 if (myInfo != null) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	711 try {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	712 TxnManager.get().log(new ForcedCommit(myInfo));
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	713 } catch (TransactionException aTE) {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	714 IOException myIOE = new IOException("Eeek failed to delete Entry");
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	715 myIOE.initCause(aTE);
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	716 throw myIOE;
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	717 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	718 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	719 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	720 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	721 } finally {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	722 aLocator.release();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	723 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	724 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	725
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	726 public String toString() {
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	727 return "SC: " + theStore.getType();
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	728 }
3dc0c5604566 Initial checkin of blitz 2.0 fcs - no installer yet. Dan Creswell <dan.creswell@gmail.com> parents: diff changeset	729 }

Mercurial > hg > blitz_condensed

annotate src/org/dancres/blitz/entry/SleeveCache.java @ 21:8417eaebf5ab