Lines Matching refs:Entry
59 * entry has a string key and a fixed number of values. Values are byte
75 * <p>Clients call {@link #edit} to create or update the values of an entry. An
76 * entry may have only one editor at one time; if a value is not available to be
79 * <li>When an entry is being <strong>created</strong> it is necessary to
82 * <li>When an entry is being <strong>edited</strong>, it is not necessary
90 * <p>Clients call {@link #get} to read a snapshot of an entry. The read will
136 * cache entry. Each line contains space-separated values: a state, a key,
138 * o DIRTY lines track that an entry is actively being created or updated.
142 * o CLEAN lines track a cache entry that has been successfully published
162 private final LinkedHashMap<String, Entry> lruEntries
163 = new LinkedHashMap<String, Entry>(0, 0.75f, true);
167 * To differentiate between old and current snapshots, each entry is given
169 * its sequence number is not equal to its entry's sequence number.
303 * @param valueCount the number of values per cache entry. Must be positive.
380 Entry entry = lruEntries.get(key);
381 if (entry == null) {
382 entry = new Entry(key);
383 lruEntries.put(key, entry);
387 entry.readable = true;
388 entry.currentEditor = null;
389 entry.setLengths(copyOfRange(parts, 2, parts.length));
391 entry.currentEditor = new Editor(entry);
405 for (Iterator<Entry> i = lruEntries.values().iterator(); i.hasNext(); ) {
406 Entry entry
407 if (entry.currentEditor == null) {
409 size += entry.lengths[t];
412 entry.currentEditor = null;
414 deleteIfExists(entry.getCleanFile(t));
415 deleteIfExists(entry.getDirtyFile(t));
442 for (Entry entry : lruEntries.values()) {
443 if (entry.currentEditor != null) {
444 writer.write(DIRTY + ' ' + entry.key + '\n');
446 writer.write(CLEAN + ' ' + entry.key + entry.getLengths() + '\n');
469 * Returns a snapshot of the entry named {@code key}, or null if it doesn't
476 Entry entry = lruEntries.get(key);
477 if (entry == null) {
481 if (!entry.readable) {
493 ins[i] = new FileInputStream(entry.getCleanFile(i));
506 return new Snapshot(key, entry.sequenceNumber, ins);
510 * Returns an editor for the entry named {@code key}, or null if another
520 Entry entry = lruEntries.get(key);
522 && (entry == null || entry.sequenceNumber != expectedSequenceNumber)) {
525 if (entry == null) {
526 entry = new Entry(key);
527 lruEntries.put(key, entry);
528 } else if (entry.currentEditor != null) {
532 Editor editor = new Editor(entry);
533 entry.currentEditor = editor;
566 Entry entry = editor.entry;
567 if (entry.currentEditor != editor) {
571 // if this edit is creating the entry for the first time, every index must have a value
572 if (success && !entry.readable) {
574 if (!entry.getDirtyFile(i).exists()) {
582 File dirty = entry.getDirtyFile(i);
585 File clean = entry.getCleanFile(i);
587 long oldLength = entry.lengths[i];
589 entry.lengths[i] = newLength;
598 entry.currentEditor = null;
599 if (entry.readable | success) {
600 entry.readable = true;
601 journalWriter.write(CLEAN + ' ' + entry.key + entry.getLengths() + '\n');
603 entry.sequenceNumber = nextSequenceNumber++;
606 lruEntries.remove(entry.key);
607 journalWriter.write(REMOVE + ' ' + entry.key + '\n');
626 * Drops the entry for {@code key} if it exists and can be removed. Entries
629 * @return true if an entry was removed.
634 Entry entry = lruEntries.get(key);
635 if (entry == null || entry.currentEditor != null) {
640 File file = entry.getCleanFile(i);
644 size -= entry.lengths[i];
645 entry.lengths[i] = 0;
688 for (Entry entry : new ArrayList<Entry>(lruEntries.values())) {
689 if (entry.currentEditor != null) {
690 entry.currentEditor.abort();
700 // Map.Entry<String, Entry> toEvict = lruEntries.eldest();
701 final Map.Entry<String, Entry> toEvict = lruEntries.entrySet().iterator().next();
728 * A snapshot of the values for an entry.
742 * Returns an editor for this snapshot's entry, or null if either the
743 * entry has changed since this snapshot was created or if another edit
772 * Edits the values for an entry.
775 private final Entry entry;
778 private Editor(Entry entry) {
779 this.entry = entry;
788 if (entry.currentEditor != this) {
791 if (!entry.readable) {
794 return new FileInputStream(entry.getCleanFile(index));
816 if (entry.currentEditor != this) {
819 return new FaultHidingOutputStream(new FileOutputStream(entry.getDirtyFile(index)));
843 remove(entry.key); // the previous entry is stale
896 private final class Entry {
899 /** Lengths of this entry's files. */
902 /** True if this entry has ever been published */
905 /** The ongoing edit or null if this entry is not being edited. */
908 /** The sequence number of the most recently committed edit to this entry. */
911 private Entry(String key) {
