Browse Source

RefDirectory: Use FileSnapshot for packed-refs

Instead of tracking the length and modification time by hand, rely
on FileSnapshot to tell RefDirectory when the $GIT_DIR/packed-refs
file has been changed or should be re-read from disk.

Change-Id: I067d268dfdca1d39c72dfa536b34e6a239117cc3
Signed-off-by: Shawn O. Pearce <spearce@spearce.org>
tags/v0.12.1
Shawn O. Pearce 13 years ago
parent
commit
c261b28f67

+ 4
- 0
org.eclipse.jgit.test/tst/org/eclipse/jgit/storage/file/RefDirectoryTest.java View File

private void writePackedRefs(String content) throws IOException { private void writePackedRefs(String content) throws IOException {
File pr = new File(diskRepo.getDirectory(), "packed-refs"); File pr = new File(diskRepo.getDirectory(), "packed-refs");
write(pr, content); write(pr, content);

final long now = System.currentTimeMillis();
final int oneHourAgo = 3600 * 1000;
pr.setLastModified(now - oneHourAgo);
} }


private void deleteLooseRef(String name) { private void deleteLooseRef(String name) {

+ 14
- 0
org.eclipse.jgit/src/org/eclipse/jgit/storage/file/FileSnapshot.java View File

*/ */
public static final FileSnapshot DIRTY = new FileSnapshot(-1, -1); public static final FileSnapshot DIRTY = new FileSnapshot(-1, -1);


/**
* A FileSnapshot that is clean if the file does not exist.
* <p>
* This instance is useful if the application wants to consider a missing
* file to be clean. {@link #isModified(File)} will return false if the file
* path does not exist.
*/
public static final FileSnapshot MISSING_FILE = new FileSnapshot(0, 0) {
@Override
public boolean isModified(File path) {
return path.exists();
}
};

/** /**
* Record a snapshot for a specific file path. * Record a snapshot for a specific file path.
* <p> * <p>

+ 9
- 11
org.eclipse.jgit/src/org/eclipse/jgit/storage/file/LockFile.java View File

/** /**
* Wait until the lock file information differs from the old file. * Wait until the lock file information differs from the old file.
* <p> * <p>
* This method tests both the length and the last modification date. If both
* are the same, this method sleeps until it can force the new lock file's
* modification date to be later than the target file.
* This method tests the last modification date. If both are the same, this
* method sleeps until it can force the new lock file's modification date to
* be later than the target file.
* *
* @throws InterruptedException * @throws InterruptedException
* the thread was interrupted before the last modified date of * the thread was interrupted before the last modified date of
* the target file. * the target file.
*/ */
public void waitForStatChange() throws InterruptedException { public void waitForStatChange() throws InterruptedException {
if (ref.length() == lck.length()) {
long otime = ref.lastModified();
long ntime = lck.lastModified();
while (otime == ntime) {
Thread.sleep(25 /* milliseconds */);
lck.setLastModified(System.currentTimeMillis());
ntime = lck.lastModified();
}
FileSnapshot o = FileSnapshot.save(ref);
FileSnapshot n = FileSnapshot.save(lck);
while (o.equals(n)) {
Thread.sleep(25 /* milliseconds */);
lck.setLastModified(System.currentTimeMillis());
n = FileSnapshot.save(lck);
} }
} }



+ 14
- 21
org.eclipse.jgit/src/org/eclipse/jgit/storage/file/RefDirectory.java View File

throw new IOException(MessageFormat.format( throw new IOException(MessageFormat.format(
JGitText.get().cannotLockFile, packedRefsFile)); JGitText.get().cannotLockFile, packedRefsFile));
try { try {
PackedRefList cur = readPackedRefs(0, 0);
PackedRefList cur = readPackedRefs();
int idx = cur.find(name); int idx = cur.find(name);
if (0 <= idx) if (0 <= idx)
commitPackedRefs(lck, cur.remove(idx), packed); commitPackedRefs(lck, cur.remove(idx), packed);
} }


private PackedRefList getPackedRefs() throws IOException { private PackedRefList getPackedRefs() throws IOException {
long size = packedRefsFile.length();
long mtime = size != 0 ? packedRefsFile.lastModified() : 0;

final PackedRefList curList = packedRefs.get(); final PackedRefList curList = packedRefs.get();
if (size == curList.lastSize && mtime == curList.lastModified)
if (!curList.snapshot.isModified(packedRefsFile))
return curList; return curList;


final PackedRefList newList = readPackedRefs(size, mtime);
final PackedRefList newList = readPackedRefs();
if (packedRefs.compareAndSet(curList, newList)) if (packedRefs.compareAndSet(curList, newList))
modCnt.incrementAndGet(); modCnt.incrementAndGet();
return newList; return newList;
} }


private PackedRefList readPackedRefs(long size, long mtime)
private PackedRefList readPackedRefs()
throws IOException { throws IOException {
final FileSnapshot snapshot = FileSnapshot.save(packedRefsFile);
final BufferedReader br; final BufferedReader br;
try { try {
br = new BufferedReader(new InputStreamReader(new FileInputStream( br = new BufferedReader(new InputStreamReader(new FileInputStream(
return PackedRefList.NO_PACKED_REFS; return PackedRefList.NO_PACKED_REFS;
} }
try { try {
return new PackedRefList(parsePackedRefs(br), size, mtime);
return new PackedRefList(parsePackedRefs(br), snapshot);
} finally { } finally {
br.close(); br.close();
} }
protected void writeFile(String name, byte[] content) protected void writeFile(String name, byte[] content)
throws IOException { throws IOException {
lck.setFSync(true); lck.setFSync(true);
lck.setNeedStatInformation(true);
lck.setNeedSnapshot(true);
try { try {
lck.write(content); lck.write(content);
} catch (IOException ioe) { } catch (IOException ioe) {
if (!lck.commit()) if (!lck.commit())
throw new ObjectWritingException(MessageFormat.format(JGitText.get().unableToWrite, name)); throw new ObjectWritingException(MessageFormat.format(JGitText.get().unableToWrite, name));


packedRefs.compareAndSet(oldPackedList, new PackedRefList(refs,
content.length, lck.getCommitLastModified()));
packedRefs.compareAndSet(oldPackedList, new PackedRefList(
refs, lck.getCommitSnapshot()));
} }
}.writePackedRefs(); }.writePackedRefs();
} }
} }


private static class PackedRefList extends RefList<Ref> { private static class PackedRefList extends RefList<Ref> {
static final PackedRefList NO_PACKED_REFS = new PackedRefList(RefList
.emptyList(), 0, 0);

/** Last length of the packed-refs file when we read it. */
final long lastSize;
static final PackedRefList NO_PACKED_REFS = new PackedRefList(
RefList.emptyList(), FileSnapshot.MISSING_FILE);


/** Last modified time of the packed-refs file when we read it. */
final long lastModified;
final FileSnapshot snapshot;


PackedRefList(RefList<Ref> src, long size, long mtime) {
PackedRefList(RefList<Ref> src, FileSnapshot s) {
super(src); super(src);
lastSize = size;
lastModified = mtime;
snapshot = s;
} }
} }



Loading…
Cancel
Save