Mercurial > jhg
annotate src/org/tmatesoft/hg/repo/Revlog.java @ 437:32184ddcf46d
Better argument names
| author | Artem Tikhomirov <tikhomirov.artem@gmail.com> | 
|---|---|
| date | Tue, 17 Apr 2012 22:29:50 +0200 | 
| parents | be697c3e951e | 
| children | 909306e412e2 | 
| rev | line source | 
|---|---|
| 22 
603806cd2dc6
Status of local working dir against non-tip base revision
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
21diff
changeset | 1 /* | 
| 388 
b015f3918120
Work on FIXME: correct HgDataFile#workingCopy with tests; BasicSessionContext with property override; platform-specific options to internals
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
385diff
changeset | 2 * Copyright (c) 2010-2012 TMate Software Ltd | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 3 * | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 4 * This program is free software; you can redistribute it and/or modify | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 5 * it under the terms of the GNU General Public License as published by | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 6 * the Free Software Foundation; version 2 of the License. | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 7 * | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 8 * This program is distributed in the hope that it will be useful, | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 9 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 11 * GNU General Public License for more details. | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 12 * | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 13 * For information on how to redistribute this software under | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 14 * the terms of a license other than GNU General Public License | 
| 102 
a3a2e5deb320
Updated contact address to support@hg4j.com
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
88diff
changeset | 15 * contact TMate Software at support@hg4j.com | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 16 */ | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 17 package org.tmatesoft.hg.repo; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 18 | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 19 import static org.tmatesoft.hg.repo.HgRepository.*; | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 20 | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 21 import java.io.IOException; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 22 import java.nio.ByteBuffer; | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 23 import java.util.ArrayList; | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 24 import java.util.Arrays; | 
| 171 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 25 import java.util.List; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 26 | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 27 import org.tmatesoft.hg.core.Nodeid; | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 28 import org.tmatesoft.hg.internal.DataAccess; | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 29 import org.tmatesoft.hg.internal.Experimental; | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 30 import org.tmatesoft.hg.internal.Preview; | 
| 77 
c677e1593919
Moved RevlogStream implementation into .internal
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
74diff
changeset | 31 import org.tmatesoft.hg.internal.RevlogStream; | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 32 import org.tmatesoft.hg.util.Adaptable; | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 33 import org.tmatesoft.hg.util.ByteChannel; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 34 import org.tmatesoft.hg.util.CancelSupport; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 35 import org.tmatesoft.hg.util.CancelledException; | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 36 import org.tmatesoft.hg.util.LogFacility; | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 37 import org.tmatesoft.hg.util.ProgressSupport; | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 38 | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 39 | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 40 /** | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 41 * Base class for all Mercurial entities that are serialized in a so called revlog format (changelog, manifest, data files). | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 42 * | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 43 * Implementation note: | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 44 * Hides actual actual revlog stream implementation and its access methods (i.e. RevlogStream.Inspector), iow shall not expose anything internal | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 45 * in public methods. | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 46 * | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 47 * @author Artem Tikhomirov | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 48 * @author TMate Software Ltd. | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 49 */ | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 50 abstract class Revlog { | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 51 | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 52 private final HgRepository repo; | 
| 21 
e929cecae4e1
Refactor to move revlog content to base class
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
3diff
changeset | 53 protected final RevlogStream content; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 54 | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 55 protected Revlog(HgRepository hgRepo, RevlogStream contentStream) { | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 56 if (hgRepo == null) { | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 57 throw new IllegalArgumentException(); | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 58 } | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 59 if (contentStream == null) { | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 60 throw new IllegalArgumentException(); | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 61 } | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 62 repo = hgRepo; | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 63 content = contentStream; | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 64 } | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 65 | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 66 // invalid Revlog | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 67 protected Revlog(HgRepository hgRepo) { | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 68 repo = hgRepo; | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 69 content = null; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 70 } | 
| 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 71 | 
| 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 72 public final HgRepository getRepo() { | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 73 return repo; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 74 } | 
| 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 75 | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 76 /** | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 77 * @return total number of revisions kept in this revlog | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 78 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 79 */ | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 80 public final int getRevisionCount() throws HgRuntimeException { | 
| 21 
e929cecae4e1
Refactor to move revlog content to base class
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
3diff
changeset | 81 return content.revisionCount(); | 
| 
e929cecae4e1
Refactor to move revlog content to base class
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
3diff
changeset | 82 } | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 83 | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 84 /** | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 85 * @return index of last known revision, a.k.a. {@link HgRepository#TIP} | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 86 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 87 */ | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 88 public final int getLastRevision() throws HgRuntimeException { | 
| 135 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 89 return content.revisionCount() - 1; | 
| 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 90 } | 
| 354 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 91 | 
| 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 92 /** | 
| 388 
b015f3918120
Work on FIXME: correct HgDataFile#workingCopy with tests; BasicSessionContext with property override; platform-specific options to internals
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
385diff
changeset | 93 * Map revision index to unique revision identifier (nodeid). | 
| 354 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 94 * | 
| 437 
32184ddcf46d
Better argument names
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
433diff
changeset | 95 * @param revisionIndex index of the entry in this revlog, may be {@link HgRepository#TIP} | 
| 354 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 96 * @return revision nodeid of the entry | 
| 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 97 * | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 98 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 354 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 99 */ | 
| 437 
32184ddcf46d
Better argument names
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
433diff
changeset | 100 public final Nodeid getRevision(int revisionIndex) throws HgRuntimeException { | 
| 328 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 101 // XXX cache nodeids? Rather, if context.getCache(this).getRevisionMap(create == false) != null, use it | 
| 437 
32184ddcf46d
Better argument names
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
433diff
changeset | 102 return Nodeid.fromBinary(content.nodeid(revisionIndex), 0); | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 103 } | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 104 | 
| 328 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 105 /** | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 106 * Effective alternative to map few revision indexes to corresponding nodeids at once. | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 107 * <p>Note, there are few aspects to be careful about when using this method<ul> | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 108 * <li>ordering of the revisions in the return list is unspecified, it's likely won't match that of the method argument | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 109 * <li>supplied array get modified (sorted)</ul> | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 110 * @return list of mapped revisions in no particular order | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 111 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 328 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 112 */ | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 113 public final List<Nodeid> getRevisions(int... revisions) throws HgRuntimeException { | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 114 ArrayList<Nodeid> rv = new ArrayList<Nodeid>(revisions.length); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 115 Arrays.sort(revisions); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 116 getRevisionsInternal(rv, revisions); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 117 return rv; | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 118 } | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 119 | 
| 366 
189dc6dc1c3e
Use exceptions to expose errors reading mercurial data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
356diff
changeset | 120 /*package-local*/ void getRevisionsInternal(final List<Nodeid> retVal, int[] sortedRevs) throws HgInvalidRevisionException, HgInvalidControlFileException { | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 121 // once I have getRevisionMap and may find out whether it is avalable from cache, | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 122 // may use it, perhaps only for small number of revisions | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 123 content.iterate(sortedRevs, false, new RevlogStream.Inspector() { | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 124 | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 125 public void next(int revisionNumber, int actualLen, int baseRevision, int linkRevision, int parent1Revision, int parent2Revision, byte[] nodeid, DataAccess data) { | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 126 retVal.add(Nodeid.fromBinary(nodeid, 0)); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 127 } | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 128 }); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 129 } | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 130 | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 131 /** | 
| 368 
8107b95f4280
Update Javadoc with 'revision index'
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
367diff
changeset | 132 * Get local index of the specified revision. | 
| 347 
8da7ade36c57
Add specific IAE subclass to handle wrong (e.g. outdated after rollback) revisions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
328diff
changeset | 133 * If unsure, use {@link #isKnown(Nodeid)} to find out whether nodeid belongs to this revlog. | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 134 * | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 135 * For occasional queries, this method works with decent performance, despite its O(n/2) approach. | 
| 433 
be697c3e951e
Revlog.RevisionMap helper class got promoted as TLC, renamed to HgRevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
432diff
changeset | 136 * Alternatively, if you need to perform multiple queries (e.g. at least 15-20), {@link HgRevisionMap} may come handy. | 
| 347 
8da7ade36c57
Add specific IAE subclass to handle wrong (e.g. outdated after rollback) revisions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
328diff
changeset | 137 * | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 138 * @param nid revision to look up | 
| 347 
8da7ade36c57
Add specific IAE subclass to handle wrong (e.g. outdated after rollback) revisions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
328diff
changeset | 139 * @return revision local index in this revlog | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 140 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 141 */ | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 142 public final int getRevisionIndex(Nodeid nid) throws HgRuntimeException { | 
| 367 
2fadf8695f8a
Use 'revision index' instead of the vague 'local revision number' concept in the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
366diff
changeset | 143 int revision = content.findRevisionIndex(nid); | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 144 if (revision == BAD_REVISION) { | 
| 393 
728708de3597
Resolve FIXMEs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
388diff
changeset | 145 // using toString() to identify revlog. HgDataFile.toString includes path, HgManifest and HgChangelog instances | 
| 
728708de3597
Resolve FIXMEs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
388diff
changeset | 146 // are fine with default (class name) | 
| 
728708de3597
Resolve FIXMEs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
388diff
changeset | 147 // Perhaps, more tailored description method would be suitable here | 
| 
728708de3597
Resolve FIXMEs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
388diff
changeset | 148 throw new HgInvalidRevisionException(String.format("Can't find revision %s in %s", nid.shortNotation(), this), nid, null); | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 149 } | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 150 return revision; | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 151 } | 
| 367 
2fadf8695f8a
Use 'revision index' instead of the vague 'local revision number' concept in the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
366diff
changeset | 152 | 
| 
2fadf8695f8a
Use 'revision index' instead of the vague 'local revision number' concept in the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
366diff
changeset | 153 /** | 
| 354 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 154 * Note, {@link Nodeid#NULL} nodeid is not reported as known in any revlog. | 
| 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 155 * | 
| 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 156 * @param nodeid | 
| 419 
7f136a3fa671
Clean javadoc to fix obvious warnings
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
418diff
changeset | 157 * @return <code>true</code> if revision is part of this revlog | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 158 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 354 
5f9073eabf06
Propagate errors with exceptions up to a end client
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
347diff
changeset | 159 */ | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 160 public final boolean isKnown(Nodeid nodeid) throws HgRuntimeException { | 
| 367 
2fadf8695f8a
Use 'revision index' instead of the vague 'local revision number' concept in the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
366diff
changeset | 161 final int rn = content.findRevisionIndex(nodeid); | 
| 218 
047b1dec7a04
Issue 7: Correctly handle manifest and changelog with different number of (or non-matching) revisions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
200diff
changeset | 162 if (BAD_REVISION == rn) { | 
| 39 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 163 return false; | 
| 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 164 } | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 165 if (rn < 0 || rn >= content.revisionCount()) { | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 166 // Sanity check | 
| 423 
9c9c442b5f2e
Major refactoring of exception handling. Low-level API uses RuntimeExceptions, while checked are left for higher level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
419diff
changeset | 167 throw new HgInvalidStateException(String.format("Revision index %d found for nodeid %s is not from the range [0..%d]", rn, nodeid.shortNotation(), content.revisionCount()-1)); | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 168 } | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 169 return true; | 
| 39 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 170 } | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 171 | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 172 /** | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 173 * Access to revision data as is, equivalent to <code>rawContent(getRevisionIndex(nodeid), sink)</code> | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 174 * | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 175 * @param nodeid revision to retrieve | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 176 * @param sink data destination | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 177 * | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 178 * @throws HgInvalidRevisionException if supplied argument doesn't represent revision index in this revlog | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 179 * @throws HgInvalidControlFileException if access to revlog index/data entry failed | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 180 * @throws CancelledException if content retrieval operation was cancelled | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 181 * | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 182 * @see #rawContent(int, ByteChannel) | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 183 */ | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 184 protected void rawContent(Nodeid nodeid, ByteChannel sink) throws HgInvalidControlFileException, CancelledException, HgInvalidRevisionException { | 
| 367 
2fadf8695f8a
Use 'revision index' instead of the vague 'local revision number' concept in the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
366diff
changeset | 185 rawContent(getRevisionIndex(nodeid), sink); | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 186 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 187 | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 188 /** | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 189 * Access to revision data as is (decompressed, but otherwise unprocessed, i.e. not parsed for e.g. changeset or manifest entries). | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 190 * | 
| 416 
d30083c80d52
Better names - non-confusing and aligned with the rest of API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
405diff
changeset | 191 * @param revisionIndex index of this revlog change (not a changelog revision index), non-negative. From predefined constants, only {@link HgRepository#TIP} makes sense. | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 192 * @param sink data destination | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 193 * | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 194 * @throws HgInvalidRevisionException if supplied argument doesn't represent revision index in this revlog | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 195 * @throws HgInvalidControlFileException if access to revlog index/data entry failed | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 196 * @throws CancelledException if content retrieval operation was cancelled | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 197 */ | 
| 416 
d30083c80d52
Better names - non-confusing and aligned with the rest of API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
405diff
changeset | 198 protected void rawContent(int revisionIndex, ByteChannel sink) throws HgInvalidControlFileException, CancelledException, HgInvalidRevisionException { | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 199 if (sink == null) { | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 200 throw new IllegalArgumentException(); | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 201 } | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 202 try { | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 203 ContentPipe insp = new ContentPipe(sink, 0, repo.getContext().getLog()); | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 204 insp.checkCancelled(); | 
| 416 
d30083c80d52
Better names - non-confusing and aligned with the rest of API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
405diff
changeset | 205 content.iterate(revisionIndex, revisionIndex, true, insp); | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 206 insp.checkFailed(); | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 207 } catch (IOException ex) { | 
| 416 
d30083c80d52
Better names - non-confusing and aligned with the rest of API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
405diff
changeset | 208 HgInvalidControlFileException e = new HgInvalidControlFileException(String.format("Access to revision %d content failed", revisionIndex), ex, null); | 
| 
d30083c80d52
Better names - non-confusing and aligned with the rest of API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
405diff
changeset | 209 e.setRevisionIndex(revisionIndex); | 
| 418 
528b6780a8bd
A bit of FIXME cleanup (mostly degraded to TODO post 1.0), comments and javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
416diff
changeset | 210 // TODO post 1.0 e.setFileName(content.getIndexFile() or this.getHumanFriendlyPath()) - shall decide whether | 
| 
528b6780a8bd
A bit of FIXME cleanup (mostly degraded to TODO post 1.0), comments and javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
416diff
changeset | 211 // protected abstract getHFPath() with impl in HgDataFile, HgManifest and HgChangelog or path is data of either Revlog or RevlogStream | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 212 // Do the same (add file name) below | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 213 throw e; | 
| 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 214 } catch (HgInvalidControlFileException ex) { | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 215 throw ex.isRevisionIndexSet() ? ex : ex.setRevisionIndex(revisionIndex); | 
| 394 
f52ca9530774
Resolve FIXMEs: more consistent exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
393diff
changeset | 216 } | 
| 37 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 217 } | 
| 
e45e75e22523
Parse changesets from bundle's changelog group. Refactor Revlog to provide access to revision's raw content
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
31diff
changeset | 218 | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 219 /** | 
| 405 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 220 * Fills supplied arguments with information about revision parents. | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 221 * | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 222 * @param revision - revision to query parents, or {@link HgRepository#TIP} | 
| 405 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 223 * @param parentRevisions - int[2] to get local revision numbers of parents (e.g. {6, -1}), {@link HgRepository#NO_REVISION} indicates parent not set | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 224 * @param parent1 - byte[20] or null, if parent's nodeid is not needed | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 225 * @param parent2 - byte[20] or null, if second parent's nodeid is not needed | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 226 * @throws IllegalArgumentException if passed arrays can't fit requested data | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 227 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 228 */ | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 229 public void parents(int revision, int[] parentRevisions, byte[] parent1, byte[] parent2) throws HgRuntimeException, IllegalArgumentException { | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 230 if (revision != TIP && !(revision >= 0 && revision < content.revisionCount())) { | 
| 347 
8da7ade36c57
Add specific IAE subclass to handle wrong (e.g. outdated after rollback) revisions
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
328diff
changeset | 231 throw new HgInvalidRevisionException(revision); | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 232 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 233 if (parentRevisions == null || parentRevisions.length < 2) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 234 throw new IllegalArgumentException(String.valueOf(parentRevisions)); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 235 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 236 if (parent1 != null && parent1.length < 20) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 237 throw new IllegalArgumentException(parent1.toString()); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 238 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 239 if (parent2 != null && parent2.length < 20) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 240 throw new IllegalArgumentException(parent2.toString()); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 241 } | 
| 77 
c677e1593919
Moved RevlogStream implementation into .internal
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
74diff
changeset | 242 class ParentCollector implements RevlogStream.Inspector { | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 243 public int p1 = -1; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 244 public int p2 = -1; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 245 public byte[] nodeid; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 246 | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 247 public void next(int revisionNumber, int actualLen, int baseRevision, int linkRevision, int parent1Revision, int parent2Revision, byte[] nodeid, DataAccess da) { | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 248 p1 = parent1Revision; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 249 p2 = parent2Revision; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 250 this.nodeid = new byte[20]; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 251 // nodeid arg now comes in 32 byte from (as in file format description), however upper 12 bytes are zeros. | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 252 System.arraycopy(nodeid, nodeid.length > 20 ? nodeid.length - 20 : 0, this.nodeid, 0, 20); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 253 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 254 }; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 255 ParentCollector pc = new ParentCollector(); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 256 content.iterate(revision, revision, false, pc); | 
| 405 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 257 // although next code looks odd (NO_REVISION *is* -1), it's safer to be explicit | 
| 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 258 parentRevisions[0] = pc.p1 == -1 ? NO_REVISION : pc.p1; | 
| 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 259 parentRevisions[1] = pc.p2 == -1 ? NO_REVISION : pc.p2; | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 260 if (parent1 != null) { | 
| 405 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 261 if (parentRevisions[0] == NO_REVISION) { | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 262 Arrays.fill(parent1, 0, 20, (byte) 0); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 263 } else { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 264 content.iterate(parentRevisions[0], parentRevisions[0], false, pc); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 265 System.arraycopy(pc.nodeid, 0, parent1, 0, 20); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 266 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 267 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 268 if (parent2 != null) { | 
| 405 
866fc3b597a0
Add an explicit constant instead of -1 to indicate 'no revision' case
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
403diff
changeset | 269 if (parentRevisions[1] == NO_REVISION) { | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 270 Arrays.fill(parent2, 0, 20, (byte) 0); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 271 } else { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 272 content.iterate(parentRevisions[1], parentRevisions[1], false, pc); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 273 System.arraycopy(pc.nodeid, 0, parent2, 0, 20); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 274 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 275 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 276 } | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 277 | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 278 /** | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 279 * EXPERIMENTAL CODE, DO NOT USE | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 280 * | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 281 * Alternative revlog iteration | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 282 * | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 283 * @param start | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 284 * @param end | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 285 * @param inspector | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 286 * @throws HgRuntimeException subclass thereof to indicate issues with the library. <em>Runtime exception</em> | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 287 */ | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 288 @Experimental | 
| 431 
12f668401613
FIXMEs: awkward API refactored, what need to be internal got hidden; public aspects got captured in slim interfaces
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
425diff
changeset | 289 public void indexWalk(int start, int end, final Revlog.Inspector inspector) throws HgRuntimeException { | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 290 int lastRev = getLastRevision(); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 291 if (start == TIP) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 292 start = lastRev; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 293 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 294 if (end == TIP) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 295 end = lastRev; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 296 } | 
| 356 
91d75e1bac9f
Consistent approach to deal with adaptable objects. Give adaptable precedence over instanceof to allow conditional response when classes do implement desired interface
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
355diff
changeset | 297 final RevisionInspector revisionInsp = Adaptable.Factory.getAdapter(inspector, RevisionInspector.class, null); | 
| 
91d75e1bac9f
Consistent approach to deal with adaptable objects. Give adaptable precedence over instanceof to allow conditional response when classes do implement desired interface
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
355diff
changeset | 298 final ParentInspector parentInsp = Adaptable.Factory.getAdapter(inspector, ParentInspector.class, null); | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 299 final Nodeid[] allRevisions = parentInsp == null ? null : new Nodeid[end - start + 1]; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 300 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 301 content.iterate(start, end, false, new RevlogStream.Inspector() { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 302 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 303 public void next(int revisionNumber, int actualLen, int baseRevision, int linkRevision, int parent1Revision, int parent2Revision, byte[] nodeid, DataAccess data) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 304 Nodeid nid = Nodeid.fromBinary(nodeid, 0); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 305 if (revisionInsp != null) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 306 revisionInsp.next(revisionNumber, nid, linkRevision); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 307 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 308 if (parentInsp != null) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 309 Nodeid p1 = parent1Revision == -1 ? Nodeid.NULL : allRevisions[parent1Revision]; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 310 Nodeid p2 = parent2Revision == -1 ? Nodeid.NULL : allRevisions[parent2Revision]; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 311 allRevisions[revisionNumber] = nid; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 312 parentInsp.next(revisionNumber, nid, parent1Revision, parent2Revision, p1, p2); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 313 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 314 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 315 }); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 316 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 317 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 318 /** | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 319 * MARKER | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 320 */ | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 321 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 322 public interface Inspector { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 323 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 324 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 325 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 326 public interface RevisionInspector extends Inspector { | 
| 368 
8107b95f4280
Update Javadoc with 'revision index'
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
367diff
changeset | 327 void next(int revisionIndex, Nodeid revision, int linkedRevisionIndex); | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 328 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 329 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 330 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 331 public interface ParentInspector extends Inspector { | 
| 327 
3f09b8c19142
Tests for Revlog.Inspectors
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
324diff
changeset | 332 // XXX document whether parentX is -1 or a constant (BAD_REVISION? or dedicated?) | 
| 367 
2fadf8695f8a
Use 'revision index' instead of the vague 'local revision number' concept in the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
366diff
changeset | 333 void next(int revisionIndex, Nodeid revision, int parent1, int parent2, Nodeid nidParent1, Nodeid nidParent2); | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 334 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 335 | 
| 432 
1fc0da631200
Revlog.ParentWalker helper class got promoted as TLC, renamed to HgParentChildMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
431diff
changeset | 336 protected HgParentChildMap<? extends Revlog> getParentWalker() { | 
| 
1fc0da631200
Revlog.ParentWalker helper class got promoted as TLC, renamed to HgParentChildMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
431diff
changeset | 337 HgParentChildMap<Revlog> pw = new HgParentChildMap<Revlog>(this); | 
| 
1fc0da631200
Revlog.ParentWalker helper class got promoted as TLC, renamed to HgParentChildMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
431diff
changeset | 338 pw.init(); | 
| 
1fc0da631200
Revlog.ParentWalker helper class got promoted as TLC, renamed to HgParentChildMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
431diff
changeset | 339 return pw; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 340 } | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 341 | 
| 433 
be697c3e951e
Revlog.RevisionMap helper class got promoted as TLC, renamed to HgRevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
432diff
changeset | 342 /* | 
| 
be697c3e951e
Revlog.RevisionMap helper class got promoted as TLC, renamed to HgRevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
432diff
changeset | 343 * class with cancel and few other exceptions support. TODO consider general superclass to share with e.g. HgManifestCommand.Mediator | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 344 */ | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 345 protected abstract static class ErrorHandlingInspector implements RevlogStream.Inspector, CancelSupport { | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 346 private Exception failure; | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 347 private CancelSupport cancelSupport; | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 348 | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 349 protected void setCancelSupport(CancelSupport cs) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 350 assert cancelSupport == null; // no reason to set it twice | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 351 cancelSupport = cs; | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 352 } | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 353 | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 354 protected void recordFailure(Exception ex) { | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 355 assert failure == null; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 356 failure = ex; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 357 } | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 358 | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 359 public void checkFailed() throws HgRuntimeException, IOException, CancelledException { | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 360 if (failure == null) { | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 361 return; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 362 } | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 363 if (failure instanceof IOException) { | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 364 throw (IOException) failure; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 365 } | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 366 if (failure instanceof CancelledException) { | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 367 throw (CancelledException) failure; | 
| 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 368 } | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 369 if (failure instanceof HgRuntimeException) { | 
| 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 370 throw (HgRuntimeException) failure; | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 371 } | 
| 423 
9c9c442b5f2e
Major refactoring of exception handling. Low-level API uses RuntimeExceptions, while checked are left for higher level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
419diff
changeset | 372 throw new HgInvalidStateException(failure.toString()); | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 373 } | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 374 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 375 public void checkCancelled() throws CancelledException { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 376 if (cancelSupport != null) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 377 cancelSupport.checkCancelled(); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 378 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 379 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 380 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 381 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 382 protected static class ContentPipe extends ErrorHandlingInspector implements RevlogStream.Inspector, CancelSupport { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 383 private final ByteChannel sink; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 384 private final int offset; | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 385 private final LogFacility logFacility; | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 386 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 387 /** | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 388 * @param _sink - cannot be <code>null</code> | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 389 * @param seekOffset - when positive, orders to pipe bytes to the sink starting from specified offset, not from the first byte available in DataAccess | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 390 * @param log optional facility to put warnings/debug messages into, may be null. | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 391 */ | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 392 public ContentPipe(ByteChannel _sink, int seekOffset, LogFacility log) { | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 393 assert _sink != null; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 394 sink = _sink; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 395 setCancelSupport(CancelSupport.Factory.get(_sink)); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 396 offset = seekOffset; | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 397 logFacility = log; | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 398 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 399 | 
| 425 
48f993aa2f41
FIXMEs: exceptions, javadoc
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
424diff
changeset | 400 protected void prepare(int revisionNumber, DataAccess da) throws IOException { | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 401 if (offset > 0) { // save few useless reset/rewind operations | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 402 da.seek(offset); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 403 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 404 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 405 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 406 public void next(int revisionNumber, int actualLen, int baseRevision, int linkRevision, int parent1Revision, int parent2Revision, byte[] nodeid, DataAccess da) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 407 try { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 408 prepare(revisionNumber, da); // XXX perhaps, prepare shall return DA (sliced, if needed) | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 409 final ProgressSupport progressSupport = ProgressSupport.Factory.get(sink); | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 410 ByteBuffer buf = ByteBuffer.allocate(actualLen > 8192 ? 8192 : actualLen); | 
| 356 
91d75e1bac9f
Consistent approach to deal with adaptable objects. Give adaptable precedence over instanceof to allow conditional response when classes do implement desired interface
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
355diff
changeset | 411 Preview p = Adaptable.Factory.getAdapter(sink, Preview.class, null); | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 412 if (p != null) { | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 413 progressSupport.start(2 * da.length()); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 414 while (!da.isEmpty()) { | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 415 checkCancelled(); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 416 da.readBytes(buf); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 417 p.preview(buf); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 418 buf.clear(); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 419 } | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 420 da.reset(); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 421 prepare(revisionNumber, da); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 422 progressSupport.worked(da.length()); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 423 buf.clear(); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 424 } else { | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 425 progressSupport.start(da.length()); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 426 } | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 427 while (!da.isEmpty()) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 428 checkCancelled(); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 429 da.readBytes(buf); | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 430 buf.flip(); // post: position == 0 | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 431 // XXX I may not rely on returned number of bytes but track change in buf position instead. | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 432 | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 433 int consumed = sink.write(buf); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 434 if ((consumed == 0 || consumed != buf.position()) && logFacility != null) { | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 435 logFacility.warn(getClass(), "Bad data sink when reading revision %d. Reported %d bytes consumed, byt actually read %d", revisionNumber, consumed, buf.position()); | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 436 } | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 437 if (buf.position() == 0) { | 
| 423 
9c9c442b5f2e
Major refactoring of exception handling. Low-level API uses RuntimeExceptions, while checked are left for higher level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
419diff
changeset | 438 throw new HgInvalidStateException("Bad sink implementation (consumes no bytes) results in endless loop"); | 
| 355 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 439 } | 
| 
f2c11fe7f3e9
Newline filter shall respect whole stream when deciding whether to process line terminators, hence added stream preview functionality
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
354diff
changeset | 440 buf.compact(); // ensure (a) there's space for new (b) data starts at 0 | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 441 progressSupport.worked(consumed); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 442 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 443 progressSupport.done(); // XXX shall specify whether #done() is invoked always or only if completed successfully. | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 444 } catch (IOException ex) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 445 recordFailure(ex); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 446 } catch (CancelledException ex) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 447 recordFailure(ex); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 448 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 449 } | 
| 157 
d5268ca7715b
Merged branch wrap-data-access into default for resource-friendly data access. Updated API to promote that friendliness to clients (channels, not byte[]). More exceptions
 Artem Tikhomirov <tikhomirov.artem@gmail.com>diff
changeset | 450 } | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 451 } | 
