Mercurial > hg4j
comparison src/org/tmatesoft/hg/repo/HgManifest.java @ 232:b7347daa50e3
Allow to cat a file with changeset revision
| author | Artem Tikhomirov <tikhomirov.artem@gmail.com> |
|---|---|
| date | Thu, 02 Jun 2011 05:13:39 +0200 |
| parents | 373e07cd3991 |
| children | a620f0663a37 |
comparison
equal
deleted
inserted
replaced
| 231:1792b37650f2 | 232:b7347daa50e3 |
|---|---|
| 16 */ | 16 */ |
| 17 package org.tmatesoft.hg.repo; | 17 package org.tmatesoft.hg.repo; |
| 18 | 18 |
| 19 import static org.tmatesoft.hg.repo.HgRepository.TIP; | 19 import static org.tmatesoft.hg.repo.HgRepository.TIP; |
| 20 | 20 |
| 21 import java.io.ByteArrayOutputStream; | |
| 21 import java.io.IOException; | 22 import java.io.IOException; |
| 22 import java.util.ArrayList; | 23 import java.util.ArrayList; |
| 23 import java.util.Arrays; | 24 import java.util.Arrays; |
| 24 | 25 |
| 25 import org.tmatesoft.hg.core.HgBadStateException; | 26 import org.tmatesoft.hg.core.HgBadStateException; |
| 26 import org.tmatesoft.hg.core.Nodeid; | 27 import org.tmatesoft.hg.core.Nodeid; |
| 27 import org.tmatesoft.hg.internal.DataAccess; | 28 import org.tmatesoft.hg.internal.DataAccess; |
| 29 import org.tmatesoft.hg.internal.Experimental; | |
| 28 import org.tmatesoft.hg.internal.Lifecycle; | 30 import org.tmatesoft.hg.internal.Lifecycle; |
| 29 import org.tmatesoft.hg.internal.Pool; | 31 import org.tmatesoft.hg.internal.Pool; |
| 30 import org.tmatesoft.hg.internal.RevlogStream; | 32 import org.tmatesoft.hg.internal.RevlogStream; |
| 33 import org.tmatesoft.hg.util.Path; | |
| 31 | 34 |
| 32 | 35 |
| 33 /** | 36 /** |
| 34 * | 37 * |
| 35 * @author Artem Tikhomirov | 38 * @author Artem Tikhomirov |
| 55 int start0 = fromChangelog(start); | 58 int start0 = fromChangelog(start); |
| 56 int end0 = fromChangelog(end); | 59 int end0 = fromChangelog(end); |
| 57 content.iterate(start0, end0, true, new ManifestParser(inspector)); | 60 content.iterate(start0, end0, true, new ManifestParser(inspector)); |
| 58 } | 61 } |
| 59 | 62 |
| 63 // manifest revision number that corresponds to the given changeset | |
| 60 /*package-local*/ int fromChangelog(int revisionNumber) { | 64 /*package-local*/ int fromChangelog(int revisionNumber) { |
| 61 if (HgInternals.wrongLocalRevision(revisionNumber)) { | 65 if (HgInternals.wrongLocalRevision(revisionNumber)) { |
| 62 throw new IllegalArgumentException(String.valueOf(revisionNumber)); | 66 throw new IllegalArgumentException(String.valueOf(revisionNumber)); |
| 63 } | 67 } |
| 64 if (revisionMap == null) { | 68 if (revisionMap == null) { |
| 66 content.iterate(0, TIP, false, revisionMap); | 70 content.iterate(0, TIP, false, revisionMap); |
| 67 } | 71 } |
| 68 return revisionMap.at(revisionNumber); | 72 return revisionMap.at(revisionNumber); |
| 69 } | 73 } |
| 70 | 74 |
| 75 /** | |
| 76 * Extracts file revision as it was known at the time of given changeset. | |
| 77 * | |
| 78 * @param revisionNumber local changeset index | |
| 79 * @param file path to file in question | |
| 80 * @return file revision or <code>null</code> if manifest at specified revision doesn't list such file | |
| 81 */ | |
| 82 @Experimental(reason="Perhaps, HgDataFile shall own this method") | |
| 83 public Nodeid getFileRevision(int revisionNumber, final Path file) { | |
| 84 int rev = fromChangelog(revisionNumber); | |
| 85 final Nodeid[] rv = new Nodeid[] { null }; | |
| 86 content.iterate(rev, rev, true, new RevlogStream.Inspector() { | |
| 87 | |
| 88 public void next(int revisionNumber, int actualLen, int baseRevision, int linkRevision, int parent1Revision, int parent2Revision, byte[] nodeid, DataAccess data) { | |
| 89 ByteArrayOutputStream bos = new ByteArrayOutputStream(); | |
| 90 try { | |
| 91 byte b; | |
| 92 while (!data.isEmpty() && (b = data.readByte()) != '\n') { | |
| 93 if (b != 0) { | |
| 94 bos.write(b); | |
| 95 } else { | |
| 96 String fname = new String(bos.toByteArray()); | |
| 97 bos.reset(); | |
| 98 if (file.toString().equals(fname)) { | |
| 99 byte[] nid = new byte[40]; | |
| 100 data.readBytes(nid, 0, 40); | |
| 101 rv[0] = Nodeid.fromAscii(nid, 0, 40); | |
| 102 break; | |
| 103 } | |
| 104 // else skip to the end of line | |
| 105 while (!data.isEmpty() && (b = data.readByte()) != '\n') | |
| 106 ; | |
| 107 } | |
| 108 } | |
| 109 } catch (IOException ex) { | |
| 110 throw new HgBadStateException(ex); | |
| 111 } | |
| 112 } | |
| 113 }); | |
| 114 return rv[0]; | |
| 115 } | |
| 116 | |
| 71 public interface Inspector { | 117 public interface Inspector { |
| 72 boolean begin(int mainfestRevision, Nodeid nid, int changelogRevision); | 118 boolean begin(int mainfestRevision, Nodeid nid, int changelogRevision); |
| 73 boolean next(Nodeid nid, String fname, String flags); | 119 boolean next(Nodeid nid, String fname, String flags); |
| 74 boolean end(int manifestRevision); | 120 boolean end(int manifestRevision); |
| 75 } | 121 } |
