Now refs can be renamed. The intent is that should be safe. Only the named
refs and associated logs are updated. Any symbolic refs referring to the renames
branches are unaffected, except HEAD, which is updated if the branch it refers
to is being renamed.
In order to perform operations like rename from a to a/b and vice verse, we
perform the rename similar to the way C git does it, i.e. one ref update at
a time using the same temporary intermediate names as the C version does.
Signed-off-by: Robin Rosenberg <robin.rosenberg@xxxxxxxxxx>
---
.../org/spearce/jgit/test/resources/packed-refs | 1 +
.../tst/org/spearce/jgit/lib/RefUpdateTest.java | 347 +++++++++++++++++++-
.../org/spearce/jgit/transport/TransportTest.java | 2 +-
.../src/org/spearce/jgit/lib/RefDatabase.java | 31 ++
.../src/org/spearce/jgit/lib/RefLogWriter.java | 33 ++-
.../src/org/spearce/jgit/lib/RefRename.java | 163 +++++++++
.../src/org/spearce/jgit/lib/RefUpdate.java | 59 +++-
.../src/org/spearce/jgit/lib/Repository.java | 16 +
8 files changed, 625 insertions(+), 27 deletions(-)
create mode 100644 org.spearce.jgit/src/org/spearce/jgit/lib/RefRename.java
diff --git a/org.spearce.jgit.test/tst-rsrc/org/spearce/jgit/test/resources/packed-refs b/org.spearce.jgit.test/tst-rsrc/org/spearce/jgit/test/resources/packed-refs
index 38a70ec..a6a14f2 100644
--- a/org.spearce.jgit.test/tst-rsrc/org/spearce/jgit/test/resources/packed-refs
+++ b/org.spearce.jgit.test/tst-rsrc/org/spearce/jgit/test/resources/packed-refs
@@ -6,6 +6,7 @@ f73b95671f326616d66b2afb3bdfcdbbce110b44 refs/heads/d
d0114ab8ac326bab30e3a657a0397578c5a1af88 refs/heads/e
47d3697c3747e8184e0dc479ccbd01e359023577 refs/heads/f
175d5b80bd9768884d8fced02e9bd33488174396 refs/heads/g
+175d5b80bd9768884d8fced02e9bd33488174396 refs/heads/prefix/a
49322bb17d3acc9146f98c97d078513228bbf3c0 refs/heads/master
d86a2aada2f5e7ccf6f11880bfb9ab404e8a8864 refs/heads/pa
6db9c2ebf75590eef973081736730a9ea169a0c4 refs/tags/A
diff --git a/org.spearce.jgit.test/tst/org/spearce/jgit/lib/RefUpdateTest.java b/org.spearce.jgit.test/tst/org/spearce/jgit/lib/RefUpdateTest.java
index 84653c8..c505b79 100644
--- a/org.spearce.jgit.test/tst/org/spearce/jgit/lib/RefUpdateTest.java
+++ b/org.spearce.jgit.test/tst/org/spearce/jgit/lib/RefUpdateTest.java
@@ -39,6 +39,7 @@
import java.io.File;
import java.io.IOException;
+import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
@@ -83,9 +84,75 @@ public void testNoCacheObjectIdSubclass() throws IOException {
assertEquals(newid.copy(), r.getObjectId());
}
+ public void testNewNamespaceConflictWithLoosePrefixNameExists()
+ throws IOException {
+ final String newRef = "refs/heads/z";
+ final RefUpdate ru = updateRef(newRef);
+ final RevCommit newid = new RevCommit(ru.getNewObjectId()) {
+ // empty
+ };
+ ru.setNewObjectId(newid);
+ Result update = ru.update();
+ assertEquals(Result.NEW, update);
+ // end setup
+ final String newRef2 = "refs/heads/z/a";
+ final RefUpdate ru2 = updateRef(newRef2);
+ final RevCommit newid2 = new RevCommit(ru2.getNewObjectId()) {
+ // empty
+ };
+ ru.setNewObjectId(newid2);
+ Result update2 = ru2.update();
+ assertEquals(Result.LOCK_FAILURE, update2);
+ }
+
+ public void testNewNamespaceConflictWithPackedPrefixNameExists()
+ throws IOException {
+ final String newRef = "refs/heads/master/x";
+ final RefUpdate ru = updateRef(newRef);
+ final RevCommit newid = new RevCommit(ru.getNewObjectId()) {
+ // empty
+ };
+ ru.setNewObjectId(newid);
+ Result update = ru.update();
+ assertEquals(Result.LOCK_FAILURE, update);
+ }
+
+ public void testNewNamespaceConflictWithLoosePrefixOfExisting()
+ throws IOException {
+ final String newRef = "refs/heads/z/a";
+ final RefUpdate ru = updateRef(newRef);
+ final RevCommit newid = new RevCommit(ru.getNewObjectId()) {
+ // empty
+ };
+ ru.setNewObjectId(newid);
+ Result update = ru.update();
+ assertEquals(Result.NEW, update);
+ // end setup
+ final String newRef2 = "refs/heads/z";
+ final RefUpdate ru2 = updateRef(newRef2);
+ final RevCommit newid2 = new RevCommit(ru2.getNewObjectId()) {
+ // empty
+ };
+ ru.setNewObjectId(newid2);
+ Result update2 = ru2.update();
+ assertEquals(Result.LOCK_FAILURE, update2);
+ }
+
+ public void testNewNamespaceConflictWithPackedPrefixOfExisting()
+ throws IOException {
+ final String newRef = "refs/heads/prefix";
+ final RefUpdate ru = updateRef(newRef);
+ final RevCommit newid = new RevCommit(ru.getNewObjectId()) {
+ // empty
+ };
+ ru.setNewObjectId(newid);
+ Result update = ru.update();
+ assertEquals(Result.LOCK_FAILURE, update);
+ }
+
/**
* Delete a ref that is pointed to by HEAD
- *
+ *
* @throws IOException
*/
public void testDeleteHEADreferencedRef() throws IOException {
@@ -118,7 +185,7 @@ public void testDeleteHead() throws IOException {
/**
* Delete a loose ref and make sure the directory in refs is deleted too,
* and the reflog dir too
- *
+ *
* @throws IOException
*/
public void testDeleteLooseAndItsDirectory() throws IOException {
@@ -172,7 +239,7 @@ public void testRefKeySameAsOrigName() {
/**
* Try modify a ref forward, fast forward
- *
+ *
* @throws IOException
*/
public void testUpdateRefForward() throws IOException {
@@ -197,7 +264,7 @@ public void testUpdateRefForward() throws IOException {
/**
* Delete a ref that exists both as packed and loose. Make sure the ref
* cannot be resolved after delete.
- *
+ *
* @throws IOException
*/
public void testDeleteLoosePacked() throws IOException {
@@ -218,7 +285,7 @@ public void testDeleteLoosePacked() throws IOException {
/**
* Try modify a ref to same
- *
+ *
* @throws IOException
*/
public void testUpdateRefNoChange() throws IOException {
@@ -232,7 +299,7 @@ public void testUpdateRefNoChange() throws IOException {
/**
* Try modify a ref, but get wrong expected old value
- *
+ *
* @throws IOException
*/
public void testUpdateRefLockFailureWrongOldValue() throws IOException {
@@ -247,7 +314,7 @@ public void testUpdateRefLockFailureWrongOldValue() throws IOException {
/**
* Try modify a ref that is locked
- *
+ *
* @throws IOException
*/
public void testUpdateRefLockFailureLocked() throws IOException {
@@ -255,18 +322,20 @@ public void testUpdateRefLockFailureLocked() throws IOException {
ObjectId pid = db.resolve("refs/heads/master^");
RefUpdate updateRef = db.updateRef("refs/heads/master");
updateRef.setNewObjectId(pid);
- LockFile lockFile1 = new LockFile(new File(db.getDirectory(),"refs/heads/master"));
+ LockFile lockFile1 = new LockFile(new File(db.getDirectory(),
+ "refs/heads/master"));
assertTrue(lockFile1.lock()); // precondition to test
Result update = updateRef.update();
assertEquals(Result.LOCK_FAILURE, update);
assertEquals(opid, db.resolve("refs/heads/master"));
- LockFile lockFile2 = new LockFile(new File(db.getDirectory(),"refs/heads/master"));
+ LockFile lockFile2 = new LockFile(new File(db.getDirectory(),
+ "refs/heads/master"));
assertFalse(lockFile2.lock()); // was locked, still is
}
/**
* Try to delete a ref. Delete requires force.
- *
+ *
* @throws IOException
*/
public void testDeleteLoosePackedRejected() throws IOException {
@@ -279,4 +348,262 @@ public void testDeleteLoosePackedRejected() throws IOException {
assertEquals(oldpid, db.resolve("refs/heads/c"));
}
+ public void testRenameBranchNoPreviousLog() throws IOException {
+ assertFalse("precondition, no log on old branchg", new File(db
+ .getDirectory(), "logs/refs/heads/b").exists());
+ ObjectId rb = db.resolve("refs/heads/b");
+ ObjectId oldHead = db.resolve(Constants.HEAD);
+ assertFalse(rb.equals(oldHead)); // assumption for this test
+ RefRename renameRef = db.renameRef("refs/heads/b",
+ "refs/heads/new/name");
+ Result result = renameRef.rename();
+ assertEquals(Result.RENAMED, result);
+ assertEquals(rb, db.resolve("refs/heads/new/name"));
+ assertNull(db.resolve("refs/heads/b"));
+ assertEquals(1, db.getReflogReader("new/name").getReverseEntries().size());
+ assertEquals("Branch: renamed b to new/name", db.getReflogReader("new/name")
+ .getLastEntry().getComment());
+ assertFalse(new File(db.getDirectory(), "logs/refs/heads/b").exists());
+ assertEquals(oldHead, db.resolve(Constants.HEAD)); // unchanged
+ }
+
+ public void testRenameBranchHasPreviousLog() throws IOException {
+ ObjectId rb = db.resolve("refs/heads/b");
+ ObjectId oldHead = db.resolve(Constants.HEAD);
+ assertFalse("precondition for this test, branch b != HEAD", rb
+ .equals(oldHead));
+ RefLogWriter.writeReflog(db, rb, rb, "Just a message", "refs/heads/b");
+ assertTrue("no log on old branch", new File(db.getDirectory(),
+ "logs/refs/heads/b").exists());
+ RefRename renameRef = db.renameRef("refs/heads/b",
+ "refs/heads/new/name");
+ Result result = renameRef.rename();
+ assertEquals(Result.RENAMED, result);
+ assertEquals(rb, db.resolve("refs/heads/new/name"));
+ assertNull(db.resolve("refs/heads/b"));
+ assertEquals(2, db.getReflogReader("new/name").getReverseEntries().size());
+ assertEquals("Branch: renamed b to new/name", db.getReflogReader("new/name")
+ .getLastEntry().getComment());
+ assertEquals("Just a message", db.getReflogReader("new/name")
+ .getReverseEntries().get(1).getComment());
+ assertFalse(new File(db.getDirectory(), "logs/refs/heads/b").exists());
+ assertEquals(oldHead, db.resolve(Constants.HEAD)); // unchanged
+ }
+
+ public void testRenameCurrentBranch() throws IOException {
+ ObjectId rb = db.resolve("refs/heads/b");
+ db.writeSymref(Constants.HEAD, "refs/heads/b");
+ ObjectId oldHead = db.resolve(Constants.HEAD);
+ assertTrue("internal test condition, b == HEAD", rb.equals(oldHead));
+ RefLogWriter.writeReflog(db, rb, rb, "Just a message", "refs/heads/b");
+ assertTrue("no log on old branch", new File(db.getDirectory(),
+ "logs/refs/heads/b").exists());
+ RefRename renameRef = db.renameRef("refs/heads/b",
+ "refs/heads/new/name");
+ Result result = renameRef.rename();
+ assertEquals(Result.RENAMED, result);
+ assertEquals(rb, db.resolve("refs/heads/new/name"));
+ assertNull(db.resolve("refs/heads/b"));
+ assertEquals("Branch: renamed b to new/name", db.getReflogReader(
+ "new/name").getLastEntry().getComment());
+ assertFalse(new File(db.getDirectory(), "logs/refs/heads/b").exists());
+ assertEquals(rb, db.resolve(Constants.HEAD));
+ assertEquals(2, db.getReflogReader("new/name").getReverseEntries().size());
+ assertEquals("Branch: renamed b to new/name", db.getReflogReader("new/name").getReverseEntries().get(0).getComment());
+ assertEquals("Just a message", db.getReflogReader("new/name").getReverseEntries().get(1).getComment());
+ }
+
+ public void testRenameBranchAlsoInPack() throws IOException {
+ ObjectId rb = db.resolve("refs/heads/b");
+ ObjectId rb2 = db.resolve("refs/heads/b~1");
+ assertEquals(Ref.Storage.PACKED, db.getRef("refs/heads/b").getStorage());
+ RefUpdate updateRef = db.updateRef("refs/heads/b");
+ updateRef.setNewObjectId(rb2);
+ updateRef.setForceUpdate(true);
+ Result update = updateRef.update();
+ assertEquals("internal check new ref is loose", Result.FORCED, update);
+ assertEquals(Ref.Storage.LOOSE_PACKED, db.getRef("refs/heads/b")
+ .getStorage());
+ RefLogWriter.writeReflog(db, rb, rb, "Just a message", "refs/heads/b");
+ assertTrue("no log on old branch", new File(db.getDirectory(),
+ "logs/refs/heads/b").exists());
+ RefRename renameRef = db.renameRef("refs/heads/b",
+ "refs/heads/new/name");
+ Result result = renameRef.rename();
+ assertEquals(Result.RENAMED, result);
+ assertEquals(rb2, db.resolve("refs/heads/new/name"));
+ assertNull(db.resolve("refs/heads/b"));
+ assertEquals("Branch: renamed b to new/name", db.getReflogReader(
+ "new/name").getLastEntry().getComment());
+ assertFalse(new File(db.getDirectory(), "logs/refs/heads/b").exists());
+
+ // Create new Repository instance, to reread caches and make sure our
+ // assumptions are persistent.
+ Repository ndb = new Repository(db.getDirectory());
+ assertEquals(rb2, ndb.resolve("refs/heads/new/name"));
+ assertNull(ndb.resolve("refs/heads/b"));
+ }
+
+ public void tryRenameWhenLocked(String toLock, String fromName,
+ String toName, String headPointsTo) throws IOException {
+ // setup
+ db.writeSymref(Constants.HEAD, headPointsTo);
+ ObjectId oldfromId = db.resolve(fromName);
+ ObjectId oldHeadId = db.resolve(Constants.HEAD);
+ RefLogWriter.writeReflog(db, oldfromId, oldfromId, "Just a message",
+ fromName);
+ List<org.spearce.jgit.lib.ReflogReader.Entry> oldFromLog = db
+ .getReflogReader(fromName).getReverseEntries();
+ List<org.spearce.jgit.lib.ReflogReader.Entry> oldHeadLog = oldHeadId != null ? db
+ .getReflogReader(Constants.HEAD).getReverseEntries() : null;
+
+ assertTrue("internal check, we have a log", new File(db.getDirectory(),
+ "logs/" + fromName).exists());
+
+ // "someone" has branch X locked
+ assertTrue(new LockFile(new File(db.getDirectory(), toLock)).lock());
+
+ // Now this is our test
+ RefRename renameRef = db.renameRef(fromName, toName);
+ Result result = renameRef.rename();
+ assertEquals(Result.LOCK_FAILURE, result);
+
+ // Check that the involved refs are the same despite the failure
+ assertExists(false, toName);
+ if (!toLock.equals(toName))
+ assertExists(false, toName + ".lock");
+ assertExists(true, toLock + ".lock");
+ if (!toLock.equals(fromName))
+ assertExists(false, "logs/" + fromName + ".lock");
+ assertExists(false, "logs/" + toName + ".lock");
+ assertEquals(oldHeadId, db.resolve(Constants.HEAD));
+ assertEquals(oldfromId, db.resolve(fromName));
+ assertNull(db.resolve(toName));
+ assertEquals(oldFromLog.toString(), db.getReflogReader(fromName)
+ .getReverseEntries().toString());
+ if (oldHeadId != null)
+ assertEquals(oldHeadLog, db.getReflogReader(Constants.HEAD)
+ .getReverseEntries());
+ }
+
+ private void assertExists(boolean positive, String toName) {
+ assertEquals(toName + (positive ? " " : " does not ") + "exist",
+ positive, new File(db.getDirectory(), toName).exists());
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisFromLockHEAD()
+ throws IOException {
+ tryRenameWhenLocked("HEAD", "refs/heads/b", "refs/heads/new/name",
+ "refs/heads/b");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisFromLockFrom()
+ throws IOException {
+ tryRenameWhenLocked("refs/heads/b", "refs/heads/b",
+ "refs/heads/new/name", "refs/heads/b");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisFromLockTo()
+ throws IOException {
+ tryRenameWhenLocked("refs/heads/new/name", "refs/heads/b",
+ "refs/heads/new/name", "refs/heads/b");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisToLockFrom()
+ throws IOException {
+ tryRenameWhenLocked("refs/heads/b", "refs/heads/b",
+ "refs/heads/new/name", "refs/heads/new/name");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisToLockTo()
+ throws IOException {
+ tryRenameWhenLocked("refs/heads/new/name", "refs/heads/b",
+ "refs/heads/new/name", "refs/heads/new/name");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisToLockTmp()
+ throws IOException {
+ tryRenameWhenLocked("RENAMED-REF.." + Thread.currentThread().getId(),
+ "refs/heads/b", "refs/heads/new/name", "refs/heads/new/name");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisOtherLockFrom()
+ throws IOException {
+ tryRenameWhenLocked("refs/heads/b", "refs/heads/b",
+ "refs/heads/new/name", "refs/heads/a");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisOtherLockTo()
+ throws IOException {
+ tryRenameWhenLocked("refs/heads/new/name", "refs/heads/b",
+ "refs/heads/new/name", "refs/heads/a");
+ }
+
+ public void testRenameBranchCannotLockAFileHEADisOtherLockTmp()
+ throws IOException {
+ tryRenameWhenLocked("RENAMED-REF.." + Thread.currentThread().getId(),
+ "refs/heads/b", "refs/heads/new/name", "refs/heads/a");
+ }
+
+ public void testRenameRefNameColission1avoided() throws IOException {
+ // setup
+ ObjectId rb = db.resolve("refs/heads/b");
+ db.writeSymref(Constants.HEAD, "refs/heads/a");
+ RefUpdate updateRef = db.updateRef("refs/heads/a");
+ updateRef.setNewObjectId(rb);
+ updateRef.setRefLogMessage("Setup", false);
+ assertEquals(Result.FAST_FORWARD, updateRef.update());
+ ObjectId oldHead = db.resolve(Constants.HEAD);
+ assertTrue(rb.equals(oldHead)); // assumption for this test
+ RefLogWriter.writeReflog(db, rb, rb, "Just a message", "refs/heads/a");
+ assertTrue("internal check, we have a log", new File(db.getDirectory(),
+ "logs/refs/heads/a").exists());
+
+ // Now this is our test
+ RefRename renameRef = db.renameRef("refs/heads/a", "refs/heads/a/b");
+ Result result = renameRef.rename();
+ assertEquals(Result.RENAMED, result);
+ assertNull(db.resolve("refs/heads/a"));
+ assertEquals(rb, db.resolve("refs/heads/a/b"));
+ assertEquals(3, db.getReflogReader("a/b").getReverseEntries().size());
+ assertEquals("Branch: renamed a to a/b", db.getReflogReader("a/b")
+ .getReverseEntries().get(0).getComment());
+ assertEquals("Just a message", db.getReflogReader("a/b")
+ .getReverseEntries().get(1).getComment());
+ assertEquals("Setup", db.getReflogReader("a/b").getReverseEntries()
+ .get(2).getComment());
+ }
+
+ public void testRenameRefNameColission2avoided() throws IOException {
+ // setup
+ ObjectId rb = db.resolve("refs/heads/b");
+ db.writeSymref(Constants.HEAD, "refs/heads/prefix/a");
+ RefUpdate updateRef = db.updateRef("refs/heads/prefix/a");
+ updateRef.setNewObjectId(rb);
+ updateRef.setRefLogMessage("Setup", false);
+ updateRef.setForceUpdate(true);
+ assertEquals(Result.FORCED, updateRef.update());
+ ObjectId oldHead = db.resolve(Constants.HEAD);
+ assertTrue(rb.equals(oldHead)); // assumption for this test
+ RefLogWriter.writeReflog(db, rb, rb, "Just a message",
+ "refs/heads/prefix/a");
+ assertTrue("internal check, we have a log", new File(db.getDirectory(),
+ "logs/refs/heads/prefix/a").exists());
+
+ // Now this is our test
+ RefRename renameRef = db.renameRef("refs/heads/prefix/a",
+ "refs/heads/prefix");
+ Result result = renameRef.rename();
+ assertEquals(Result.RENAMED, result);
+
+ assertNull(db.resolve("refs/heads/prefix/a"));
+ assertEquals(rb, db.resolve("refs/heads/prefix"));
+ assertEquals(3, db.getReflogReader("prefix").getReverseEntries().size());
+ assertEquals("Branch: renamed prefix/a to prefix", db.getReflogReader(
+ "prefix").getReverseEntries().get(0).getComment());
+ assertEquals("Just a message", db.getReflogReader("prefix")
+ .getReverseEntries().get(1).getComment());
+ assertEquals("Setup", db.getReflogReader("prefix").getReverseEntries()
+ .get(2).getComment());
+ }
}
diff --git a/org.spearce.jgit.test/tst/org/spearce/jgit/transport/TransportTest.java b/org.spearce.jgit.test/tst/org/spearce/jgit/transport/TransportTest.java
index c6e3335..fcf3f5c 100644
--- a/org.spearce.jgit.test/tst/org/spearce/jgit/transport/TransportTest.java
+++ b/org.spearce.jgit.test/tst/org/spearce/jgit/transport/TransportTest.java
@@ -123,7 +123,7 @@ public void testFindRemoteRefUpdatesWildcardNoTracking() throws IOException {
.findRemoteRefUpdatesFor(Collections.nCopies(1, new RefSpec(
"+refs/heads/*:refs/heads/test/*")));
- assertEquals(9, result.size());
+ assertEquals(10, result.size());
boolean foundA = false;
boolean foundB = false;
for (final RemoteRefUpdate rru : result) {
diff --git a/org.spearce.jgit/src/org/spearce/jgit/lib/RefDatabase.java b/org.spearce.jgit/src/org/spearce/jgit/lib/RefDatabase.java
index 869d012..6d4f374 100644
--- a/org.spearce.jgit/src/org/spearce/jgit/lib/RefDatabase.java
+++ b/org.spearce.jgit/src/org/spearce/jgit/lib/RefDatabase.java
@@ -146,6 +146,23 @@ synchronized (this) {
}
/**
+ * An set of update operations for renaming a ref
+ *
+ * @param fromRef Old ref name
+ * @param toRef New ref name
+ * @return a RefUpdate operation to rename a ref
+ * @throws IOException
+ */
+ RefRename newRename(String fromRef, String toRef) throws IOException {
+ refreshPackedRefs();
+ Ref f = readRefBasic(fromRef, 0);
+ Ref t = new Ref(Ref.Storage.NEW, toRef, null);
+ RefUpdate refUpdateFrom = new RefUpdate(this, f, fileForRef(f.getName()));
+ RefUpdate refUpdateTo = new RefUpdate(this, t, fileForRef(t.getName()));
+ return new RefRename(refUpdateTo, refUpdateFrom);
+ }
+
+ /**
* Writes a symref (e.g. HEAD) to disk
*
* @param name
@@ -158,11 +175,25 @@ void link(final String name, final String target) throws IOException {
final byte[] content = Constants.encode("ref: " + target + "\n");
lockAndWriteFile(fileForRef(name), content);
synchronized (this) {
+ looseSymRefs.remove(name);
setModified();
}
db.fireRefsMaybeChanged();
}
+ void uncacheSymRef(String name) {
+ synchronized(this) {
+ looseSymRefs.remove(name);
+ setModified();
+ }
+ }
+
+ void uncacheRef(String name) {
+ looseRefs.remove(name);
+ looseRefsMTime.remove(name);
+ packedRefs.remove(name);
+ }
+
private void setModified() {
lastRefModification = refModificationCounter++;
}
diff --git a/org.spearce.jgit/src/org/spearce/jgit/lib/RefLogWriter.java b/org.spearce.jgit/src/org/spearce/jgit/lib/RefLogWriter.java
index a077051..0864209 100644
--- a/org.spearce.jgit/src/org/spearce/jgit/lib/RefLogWriter.java
+++ b/org.spearce.jgit/src/org/spearce/jgit/lib/RefLogWriter.java
@@ -44,7 +44,7 @@
import java.io.IOException;
/**
- * Utility class to add reflog entries
+ * Utility class to work with reflog files
*
* @author Dave Watson
*/
@@ -58,6 +58,37 @@ static void append(final RefUpdate u, final String msg) throws IOException {
appendOneRecord(oldId, newId, ident, msg, db, u.getName());
}
+ static void append(RefRename refRename, String msg) throws IOException {
+ final ObjectId id = refRename.getObjectId();
+ final Repository db = refRename.getRepository();
+ final PersonIdent ident = refRename.getRefLogIdent();
+ appendOneRecord(id, id, ident, msg, db, refRename.getToName());
+ }
+
+ static void renameTo(final Repository db, final RefUpdate from,
+ final RefUpdate to) throws IOException {
+ final File logdir = new File(db.getDirectory(), Constants.LOGS);
+ final File reflogFrom = new File(logdir, from.getName());
+ if (!reflogFrom.exists())
+ return;
+ final File reflogTo = new File(logdir, to.getName());
+ final File reflogToDir = reflogTo.getParentFile();
+ File tmp = new File(logdir, "tmp-renamed-log.." + Thread.currentThread().getId());
+ if (!reflogFrom.renameTo(tmp)) {
+ throw new IOException("Cannot rename " + reflogFrom + " to (" + tmp
+ + ")" + reflogTo);
+ }
+ RefUpdate.deleteEmptyDir(reflogFrom, RefUpdate.count(from.getName(),
+ '/'));
+ if (!reflogToDir.exists() && !reflogToDir.mkdirs()) {
+ throw new IOException("Cannot create directory " + reflogToDir);
+ }
+ if (!tmp.renameTo(reflogTo)) {
+ throw new IOException("Cannot rename (" + tmp + ")" + reflogFrom
+ + " to " + reflogTo);
+ }
+ }
+
private static void appendOneRecord(final ObjectId oldId,
final ObjectId newId, PersonIdent ident, final String msg,
final Repository db, final String refName) throws IOException {
diff --git a/org.spearce.jgit/src/org/spearce/jgit/lib/RefRename.java b/org.spearce.jgit/src/org/spearce/jgit/lib/RefRename.java
new file mode 100644
index 0000000..c89459b
--- /dev/null
+++ b/org.spearce.jgit/src/org/spearce/jgit/lib/RefRename.java
@@ -0,0 +1,163 @@
+/*
+ * Copyright (C) 2009, Robin Rosenberg
+ *
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or
+ * without modification, are permitted provided that the following
+ * conditions are met:
+ *
+ * - Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *
+ * - Redistributions in binary form must reproduce the above
+ * copyright notice, this list of conditions and the following
+ * disclaimer in the documentation and/or other materials provided
+ * with the distribution.
+ *
+ * - Neither the name of the Git Development Community nor the
+ * names of its contributors may be used to endorse or promote
+ * products derived from this software without specific prior
+ * written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
+ * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
+ * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
+ * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
+ * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
+ * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+ * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
+ * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
+ * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+package org.spearce.jgit.lib;
+
+import java.io.IOException;
+
+import org.spearce.jgit.lib.RefUpdate.Result;
+
+/**
+ * A RefUpdate combination for renaming a ref
+ */
+public class RefRename {
+ private RefUpdate newToUpdate;
+
+ private RefUpdate oldFromDelete;
+
+ private Result renameResult = Result.NOT_ATTEMPTED;
+
+ RefRename(final RefUpdate toUpdate, final RefUpdate fromUpdate) {
+ newToUpdate = toUpdate;
+ oldFromDelete = fromUpdate;
+ }
+
+ /**
+ * @return result of rename operation
+ */
+ public Result getResult() {
+ return renameResult;
+ }
+
+ /**
+ * @return the result of the new ref update
+ * @throws IOException
+ */
+ public Result rename() throws IOException {
+ Ref oldRef = oldFromDelete.db.readRef(Constants.HEAD);
+ boolean renameHEADtoo = oldRef != null
+ && oldRef.getName().equals(oldFromDelete.getName());
+ Repository db = oldFromDelete.getRepository();
+ try {
+ RefLogWriter.renameTo(db, oldFromDelete,
+ newToUpdate);
+ newToUpdate.setRefLogMessage(null, false);
+ String tmpRefName = "RENAMED-REF.." + Thread.currentThread().getId();
+ RefUpdate tmpUpdateRef = db.updateRef(tmpRefName);
+ if (renameHEADtoo) {
+ try {
+ oldFromDelete.db.link(Constants.HEAD, tmpRefName);
+ } catch (IOException e) {
+ RefLogWriter.renameTo(db,
+ newToUpdate, oldFromDelete);
+ return renameResult = Result.LOCK_FAILURE;
+ }
+ }
+ tmpUpdateRef.setNewObjectId(oldFromDelete.getOldObjectId());
+ tmpUpdateRef.setForceUpdate(true);
+ Result update = tmpUpdateRef.update();
+ if (update != Result.FORCED && update != Result.NEW && update != Result.NO_CHANGE) {
+ RefLogWriter.renameTo(db,
+ newToUpdate, oldFromDelete);
+ if (renameHEADtoo) {
+ oldFromDelete.db.link(Constants.HEAD, oldFromDelete.getName());
+ }
+ return renameResult = update;
+ }
+
+ oldFromDelete.setExpectedOldObjectId(oldFromDelete.getOldObjectId());
+ oldFromDelete.setForceUpdate(true);
+ Result delete = oldFromDelete.delete();
+ if (delete != Result.FORCED) {
+ if (db.getRef(
+ oldFromDelete.getName()) != null) {
+ RefLogWriter.renameTo(db,
+ newToUpdate, oldFromDelete);
+ if (renameHEADtoo) {
+ oldFromDelete.db.link(Constants.HEAD, oldFromDelete
+ .getName());
+ }
+ }
+ return renameResult = delete;
+ }
+
+ newToUpdate.setNewObjectId(tmpUpdateRef.getNewObjectId());
+ Result updateResult = newToUpdate.update();
+ if (updateResult != Result.NEW) {
+ RefLogWriter.renameTo(db, newToUpdate, oldFromDelete);
+ if (renameHEADtoo) {
+ oldFromDelete.db.link(Constants.HEAD, oldFromDelete.getName());
+ }
+ oldFromDelete.setExpectedOldObjectId(null);
+ oldFromDelete.setNewObjectId(oldFromDelete.getOldObjectId());
+ oldFromDelete.setForceUpdate(true);
+ oldFromDelete.setRefLogMessage(null, false);
+ Result undelete = oldFromDelete.update();
+ if (undelete != Result.NEW && undelete != Result.LOCK_FAILURE)
+ return renameResult = Result.IO_FAILURE;
+ return renameResult = Result.LOCK_FAILURE;
+ }
+
+ if (renameHEADtoo) {
+ oldFromDelete.db.link(Constants.HEAD, newToUpdate.getName());
+ } else {
+ db.fireRefsMaybeChanged();
+ }
+ RefLogWriter.append(this, "Branch: renamed "
+ + db.shortenRefName(oldFromDelete.getName()) + " to "
+ + db.shortenRefName(newToUpdate.getName()));
+ return renameResult = Result.RENAMED;
+ } catch (RuntimeException e) {
+ throw e;
+ }
+ }
+
+ ObjectId getObjectId() {
+ return oldFromDelete.getOldObjectId();
+ }
+
+ Repository getRepository() {
+ return oldFromDelete.getRepository();
+ }
+
+ PersonIdent getRefLogIdent() {
+ return newToUpdate.getRefLogIdent();
+ }
+
+ String getToName() {
+ return newToUpdate.getName();
+ }
+}
\ No newline at end of file
diff --git a/org.spearce.jgit/src/org/spearce/jgit/lib/RefUpdate.java b/org.spearce.jgit/src/org/spearce/jgit/lib/RefUpdate.java
index 8044c6e..f8ecc3c 100644
--- a/org.spearce.jgit/src/org/spearce/jgit/lib/RefUpdate.java
+++ b/org.spearce.jgit/src/org/spearce/jgit/lib/RefUpdate.java
@@ -125,14 +125,20 @@
* This kind of error doesn't include {@link #LOCK_FAILURE}, which is a
* different case.
*/
- IO_FAILURE
+ IO_FAILURE,
+
+ /**
+ * The ref was renamed from another name
+ * <p>
+ */
+ RENAMED
}
/** Repository the ref is stored in. */
- private final RefDatabase db;
+ final RefDatabase db;
/** Location of the loose file holding the value of this ref. */
- private final File looseFile;
+ final File looseFile;
/** New value the caller wants this ref to have. */
private ObjectId newValue;
@@ -156,7 +162,7 @@
private ObjectId expValue;
/** Result of the update operation. */
- private Result result = Result.NOT_ATTEMPTED;
+ Result result = Result.NOT_ATTEMPTED;
private final Ref ref;
@@ -434,6 +440,15 @@ private Result updateImpl(final RevWalk walk, final Store store)
RevObject newObj;
RevObject oldObj;
+ int lastSlash = getName().lastIndexOf('/');
+ if (lastSlash > 0)
+ if (db.getRepository().getRef(getName().substring(0, lastSlash)) != null)
+ return Result.LOCK_FAILURE;
+ String rName = getName() + "/";
+ for (Ref r : db.getAllRefs().values()) {
+ if (r.getName().startsWith(rName))
+ return Result.LOCK_FAILURE;
+ }
lock = new LockFile(looseFile);
if (!lock.lock())
return Result.LOCK_FAILURE;
@@ -527,7 +542,7 @@ abstract Result store(final LockFile lock, final Result status)
throws IOException;
}
- private class UpdateStore extends Store {
+ class UpdateStore extends Store {
@Override
Result store(final LockFile lock, final Result status)
@@ -536,7 +551,7 @@ Result store(final LockFile lock, final Result status)
}
}
- private class DeleteStore extends Store {
+ class DeleteStore extends Store {
@Override
Result store(LockFile lock, Result status) throws IOException {
@@ -557,28 +572,42 @@ Result store(LockFile lock, Result status) throws IOException {
lock.unlock();
if (storage.isLoose())
deleteFileAndEmptyDir(looseFile, levels);
+ db.uncacheRef(ref.getName());
return status;
}
private void deleteFileAndEmptyDir(final File file, final int depth)
throws IOException {
- if (file.exists()) {
+ if (file.isFile()) {
if (!file.delete())
throw new IOException("File cannot be deleted: " + file);
- deleteEmptyDir(file.getParentFile(), depth);
+ File dir = file.getParentFile();
+ for (int i = 0; i < depth; ++i) {
+ if (!dir.delete())
+ break; // ignore problem here
+ dir = dir.getParentFile();
+ }
}
}
+ }
- private void deleteEmptyDir(File dir, int depth) {
- for (; depth > 0 && dir != null; depth--) {
- if (!dir.delete())
- break;
- dir = dir.getParentFile();
- }
+ UpdateStore newUpdateStore() {
+ return new UpdateStore();
+ }
+
+ DeleteStore newDeleteStore() {
+ return new DeleteStore();
+ }
+
+ static void deleteEmptyDir(File dir, int depth) {
+ for (; depth > 0 && dir != null; depth--) {
+ if (dir.exists() && !dir.delete())
+ break;
+ dir = dir.getParentFile();
}
}
- private static int count(final String s, final char c) {
+ static int count(final String s, final char c) {
int count = 0;
for (int p = s.indexOf(c); p >= 0; p = s.indexOf(c, p + 1)) {
count++;
diff --git a/org.spearce.jgit/src/org/spearce/jgit/lib/Repository.java b/org.spearce.jgit/src/org/spearce/jgit/lib/Repository.java
index 971215c..9b97fdc 100644
--- a/org.spearce.jgit/src/org/spearce/jgit/lib/Repository.java
+++ b/org.spearce.jgit/src/org/spearce/jgit/lib/Repository.java
@@ -468,6 +468,22 @@ public RefUpdate updateRef(final String ref) throws IOException {
}
/**
+ * Create a command to rename a ref in this repository
+ *
+ * @param fromRef
+ * name of ref to rename from
+ * @param toRef
+ * name of ref to rename to
+ * @return an update command that knows how to rename a branch to another.
+ * @throws IOException
+ * the rename could not be performed.
+ *
+ */
+ public RefRename renameRef(final String fromRef, final String toRef) throws IOException {
+ return refs.newRename(fromRef, toRef);
+ }
+
+ /**
* Parse a git revision string and return an object id.
*
* Currently supported is combinations of these.
--
1.6.3.2.199.g7340d
--
To unsubscribe from this list: send the line "unsubscribe git" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html