Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractKahaDBStore.checkpointUpdate(Transaction tx,
boolean cleanup)
Perform the checkpoint update operation.
|
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination |
MessageDatabase.getExistingStoredDestination(KahaDestination destination,
Transaction tx) |
org.apache.activemq.store.kahadb.MessageDatabase.LastAck |
MessageDatabase.getLastAck(Transaction tx,
org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
String subscriptionKey) |
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination |
TempMessageDatabase.getStoredDestination(KahaDestination destination,
Transaction tx) |
protected org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination |
MessageDatabase.getStoredDestination(KahaDestination destination,
Transaction tx) |
long |
MessageDatabase.getStoredMessageCount(Transaction tx,
org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
String subscriptionKey) |
long |
MessageDatabase.getStoredMessageSize(Transaction tx,
org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
String subscriptionKey) |
void |
KahaDBMetaData.initialize(Transaction tx)
For a newly created KahaDBMetaData instance this method is called to allow
the instance to create all of it's internal indices and other state data.
|
void |
KahaDBMetaData.load(Transaction tx)
Instructs this object to load its internal data structures from the KahaDB PageFile
and prepare itself for use.
|
protected void |
MessageDatabase.recoverIndex(Transaction tx) |
protected int |
KahaDBStore.KahaDBMessageStore.recoverRolledBackAcks(org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
Transaction tx,
int maxReturned,
MessageRecoveryListener listener) |
Modifier and Type | Method and Description |
---|---|
Value |
ListIndex.add(Transaction tx,
Key key,
Value value) |
Value |
ListNode.addFirst(Transaction tx,
Key key,
Value value) |
Value |
ListIndex.addFirst(Transaction tx,
Key key,
Value value) |
void |
Index.clear(Transaction tx)
clear the index
|
void |
BTreeIndex.clear(Transaction tx) |
void |
ListNode.clear(Transaction tx) |
void |
ListIndex.clear(Transaction tx) |
void |
BTreeNode.clear(Transaction tx) |
void |
HashIndex.clear(Transaction tx) |
boolean |
ListNode.contains(Transaction tx,
Key key) |
boolean |
BTreeNode.contains(Transaction tx,
Key key) |
boolean |
Index.containsKey(Transaction tx,
Key key) |
boolean |
BTreeIndex.containsKey(Transaction tx,
Key key) |
boolean |
ListIndex.containsKey(Transaction tx,
Key key) |
boolean |
HashIndex.containsKey(Transaction tx,
Key key) |
ListNode<Key,Value> |
ListIndex.createNode(Transaction tx) |
Value |
Index.get(Transaction tx,
Key key) |
Value |
BTreeIndex.get(Transaction tx,
Key key) |
Value |
ListNode.get(Transaction tx,
Key key) |
Value |
ListIndex.get(Transaction tx,
Key key) |
Value |
BTreeNode.get(Transaction tx,
Key key) |
Value |
HashIndex.get(Transaction tx,
Key key) |
Map.Entry<Key,Value> |
BTreeIndex.getFirst(Transaction tx) |
Map.Entry<Key,Value> |
ListNode.getFirst(Transaction tx) |
Map.Entry<Key,Value> |
ListIndex.getFirst(Transaction tx) |
Map.Entry<Key,Value> |
BTreeNode.getFirst(Transaction tx) |
BTreeNode<Key,Value> |
BTreeNode.getFirstLeafNode(Transaction tx) |
protected ListNode<Key,Value> |
ListIndex.getHead(Transaction tx) |
Map.Entry<Key,Value> |
BTreeIndex.getLast(Transaction tx) |
Map.Entry<Key,Value> |
ListNode.getLast(Transaction tx) |
Map.Entry<Key,Value> |
ListIndex.getLast(Transaction tx) |
Map.Entry<Key,Value> |
BTreeNode.getLast(Transaction tx) |
int |
BTreeIndex.getMaxLeafDepth(Transaction tx) |
int |
BTreeNode.getMaxLeafDepth(Transaction tx,
int depth) |
int |
BTreeIndex.getMinLeafDepth(Transaction tx) |
int |
BTreeNode.getMinLeafDepth(Transaction tx,
int depth) |
protected ListNode<Key,Value> |
ListIndex.getTail(Transaction tx) |
boolean |
BTreeIndex.isEmpty(Transaction tx) |
boolean |
ListNode.isEmpty(Transaction tx) |
boolean |
ListIndex.isEmpty(Transaction tx) |
boolean |
BTreeNode.isEmpty(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
Index.iterator(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
BTreeIndex.iterator(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
ListNode.iterator(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
ListIndex.iterator(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
BTreeNode.iterator(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
HashIndex.iterator(Transaction tx) |
Iterator<Map.Entry<Key,Value>> |
BTreeIndex.iterator(Transaction tx,
Key initialKey) |
Iterator<Map.Entry<Key,Value>> |
BTreeIndex.iterator(Transaction tx,
Key initialKey,
Key maxKey) |
Iterator<Map.Entry<Key,Value>> |
BTreeNode.iterator(Transaction tx,
Key startKey,
Key endKey) |
Iterator<Map.Entry<Key,Value>> |
ListNode.iterator(Transaction tx,
long pos) |
Iterator<Map.Entry<Key,Value>> |
ListIndex.iterator(Transaction tx,
long initialPosition) |
Iterator<ListNode<Key,Value>> |
ListIndex.listNodeIterator(Transaction tx) |
void |
Index.load(Transaction tx)
load indexes
|
void |
BTreeIndex.load(Transaction tx) |
void |
ListIndex.load(Transaction tx) |
void |
HashIndex.load(Transaction tx) |
protected void |
ListIndex.onLoad(ListNode<Key,Value> node,
Transaction tx) |
void |
BTreeIndex.printStructure(Transaction tx,
OutputStream out) |
void |
BTreeIndex.printStructure(Transaction tx,
PrintWriter out) |
void |
BTreeNode.printStructure(Transaction tx,
PrintWriter out,
String prefix) |
Value |
Index.put(Transaction tx,
Key key,
Value entry)
store the key, item
|
Value |
BTreeIndex.put(Transaction tx,
Key key,
Value value) |
Value |
ListNode.put(Transaction tx,
Key key,
Value value) |
Value |
ListIndex.put(Transaction tx,
Key key,
Value value)
Update the value of the item with the given key in the list if ot exists, otherwise
it appends the value to the end of the list.
|
Value |
BTreeNode.put(Transaction tx,
Key key,
Value value) |
Value |
HashIndex.put(Transaction tx,
Key key,
Value value) |
Value |
Index.remove(Transaction tx,
Key key)
remove the index key
|
Value |
BTreeIndex.remove(Transaction tx,
Key key) |
Value |
ListIndex.remove(Transaction tx,
Key key) |
Value |
BTreeNode.remove(Transaction tx,
Key key) |
Value |
HashIndex.remove(Transaction tx,
Key key) |
int |
ListNode.size(Transaction tx) |
int |
HashIndex.size(Transaction tx) |
void |
HashIndex.store(Transaction tx,
org.apache.activemq.store.kahadb.disk.index.HashBin<Key,Value> bin) |
void |
ListIndex.storeNode(Transaction tx,
ListNode<Key,Value> node,
boolean overflow) |
void |
ListNode.storeUpdate(Transaction tx) |
void |
Index.unload(Transaction tx)
unload indexes
|
void |
BTreeIndex.unload(Transaction tx) |
void |
ListIndex.unload(Transaction tx) |
void |
HashIndex.unload(Transaction tx) |
void |
BTreeIndex.visit(Transaction tx,
BTreeVisitor<Key,Value> visitor) |
void |
BTreeNode.visit(Transaction tx,
BTreeVisitor<Key,Value> visitor) |
Modifier and Type | Method and Description |
---|---|
Transaction |
PageFile.tx() |
Modifier and Type | Method and Description |
---|---|
void |
Transaction.Closure.execute(Transaction tx) |
R |
Transaction.CallableClosure.execute(Transaction tx) |
Modifier and Type | Method and Description |
---|---|
Location |
PListImpl.add(Transaction tx,
String key,
Location value) |
Location |
PListImpl.addFirst(Transaction tx,
String key,
Location value) |
void |
PListImpl.clear(Transaction tx) |
protected void |
PListImpl.onLoad(ListNode<String,Location> node,
Transaction tx) |
Modifier and Type | Method and Description |
---|---|
protected void |
JobSchedulerStoreImpl.checkpointUpdate(Transaction tx,
boolean cleanup) |
protected void |
JobSchedulerStoreImpl.decrementJournalCount(Transaction tx,
Location location)
Removes one reference for the Journal log file indicated in the given Location value.
|
protected List<org.apache.activemq.store.kahadb.scheduler.JobLocation> |
JobSchedulerImpl.getAllScheduledJobs(Transaction tx)
Walks the Scheduled Job Tree and collects the add location and last update location
for all scheduled jobs.
|
protected void |
JobSchedulerStoreImpl.incrementJournalCount(Transaction tx,
Location location)
Adds a reference for the journal log file pointed to by the given Location value.
|
void |
JobSchedulerKahaDBMetaData.initialize(Transaction tx) |
void |
JobSchedulerKahaDBMetaData.load(Transaction tx) |
void |
JobSchedulerKahaDBMetaData.loadScheduler(Transaction tx,
Map<String,JobSchedulerImpl> schedulers)
Loads all the stored JobScheduler instances into the provided map.
|
protected void |
JobSchedulerImpl.process(Transaction tx,
KahaAddScheduledJobCommand command,
Location location)
Adds a new Scheduled job to the index.
|
protected void |
JobSchedulerImpl.process(Transaction tx,
KahaRemoveScheduledJobsCommand command,
Location location)
Removes all scheduled jobs within a given time range.
|
protected void |
JobSchedulerImpl.process(Transaction tx,
KahaRescheduleJobCommand command,
Location location)
Reschedules a Job after it has be fired.
|
protected void |
JobSchedulerStoreImpl.referenceRemovedLocation(Transaction tx,
Location location,
org.apache.activemq.store.kahadb.scheduler.JobLocation removedJob)
Updates the Job removal tracking index with the location of a remove command and the
original JobLocation entry.
|
protected void |
JobSchedulerImpl.removeAll(Transaction tx)
Removes all jobs from the schedulers index.
|
protected void |
JobSchedulerImpl.removeInRange(Transaction tx,
long start,
long finish,
Location location)
Removes all scheduled jobs within the target range.
|
protected boolean |
JobSchedulerImpl.removeJobAtTime(Transaction tx,
String jobId,
long executionTime)
Removes a Job from the index using it's Id value and the time it is currently set to
be executed.
|
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.