Mercurial > jhg
annotate src/org/tmatesoft/hg/repo/Revlog.java @ 339:863356c2847e
Issue 16: respect glob patterns in HgIgnore for sub-directories
| author | Artem Tikhomirov <tikhomirov.artem@gmail.com> | 
|---|---|
| date | Wed, 16 Nov 2011 22:42:21 +0100 | 
| parents | a674b8590362 | 
| children | 8da7ade36c57 | 
| 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 /* | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 2 * Copyright (c) 2010-2011 TMate Software Ltd | 
| 
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 | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 19 import static org.tmatesoft.hg.repo.HgRepository.BAD_REVISION; | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 20 import static org.tmatesoft.hg.repo.HgRepository.TIP; | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 21 | 
| 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 | 22 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 | 23 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 | 24 import java.util.ArrayList; | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 25 import java.util.Arrays; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 26 import java.util.Collection; | 
| 171 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 27 import java.util.HashSet; | 
| 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 28 import java.util.LinkedList; | 
| 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 29 import java.util.List; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 30 | 
| 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 | 31 import org.tmatesoft.hg.core.HgBadStateException; | 
| 
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 | 32 import org.tmatesoft.hg.core.HgException; | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 33 import org.tmatesoft.hg.core.Nodeid; | 
| 307 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 34 import org.tmatesoft.hg.internal.ArrayHelper; | 
| 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 | 35 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 | 36 import org.tmatesoft.hg.internal.Experimental; | 
| 77 
c677e1593919
Moved RevlogStream implementation into .internal
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
74diff
changeset | 37 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 | 38 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 | 39 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 | 40 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 | 41 import org.tmatesoft.hg.util.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 | 42 import org.tmatesoft.hg.util.ProgressSupport; | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 43 | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 44 | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 45 /** | 
| 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 | 46 * 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 | 47 * | 
| 
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 | 48 * 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 | 49 * 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 | 50 * 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 | 51 * | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 52 * @author Artem Tikhomirov | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 53 * @author TMate Software Ltd. | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 54 */ | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 55 abstract class Revlog { | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 56 | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 57 private final HgRepository repo; | 
| 21 
e929cecae4e1
Refactor to move revlog content to base class
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
3diff
changeset | 58 protected final RevlogStream content; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 59 | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 60 protected Revlog(HgRepository hgRepo, RevlogStream contentStream) { | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 61 if (hgRepo == null) { | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 62 throw new IllegalArgumentException(); | 
| 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 63 } | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 64 if (contentStream == null) { | 
| 74 
6f1b88693d48
Complete refactoring to org.tmatesoft
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
56diff
changeset | 65 throw new IllegalArgumentException(); | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 66 } | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 67 repo = hgRepo; | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 68 content = contentStream; | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 69 } | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 70 | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 71 // invalid Revlog | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 72 protected Revlog(HgRepository hgRepo) { | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 73 repo = hgRepo; | 
| 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 74 content = null; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 75 } | 
| 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 76 | 
| 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 77 public final HgRepository getRepo() { | 
| 115 
c0cc2535462c
Introduced channels to pipeline (and easily filter) data streams
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
102diff
changeset | 78 return repo; | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 79 } | 
| 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 80 | 
| 135 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 81 public final int getRevisionCount() { | 
| 21 
e929cecae4e1
Refactor to move revlog content to base class
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
3diff
changeset | 82 return content.revisionCount(); | 
| 
e929cecae4e1
Refactor to move revlog content to base class
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
3diff
changeset | 83 } | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 84 | 
| 135 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 85 public final int getLastRevision() { | 
| 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 86 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 | 87 } | 
| 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 88 | 
| 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 89 public final Nodeid getRevision(int revision) { | 
| 328 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 90 // XXX cache nodeids? Rather, if context.getCache(this).getRevisionMap(create == false) != null, use it | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 91 return Nodeid.fromBinary(content.nodeid(revision), 0); | 
| 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 92 } | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 93 | 
| 328 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 94 /** | 
| 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 95 * FIXME need to be careful about (1) ordering of the revisions in the return list; (2) modifications (sorting) of the argument array | 
| 
a674b8590362
Move file tree history to upper API level
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
327diff
changeset | 96 */ | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 97 public final List<Nodeid> getRevisions(int... revisions) { | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 98 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 | 99 Arrays.sort(revisions); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 100 getRevisionsInternal(rv, revisions); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 101 return rv; | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 102 } | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 103 | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 104 /*package-local*/ void getRevisionsInternal(final List<Nodeid> retVal, int[] sortedRevs) { | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 105 // 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 | 106 // 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 | 107 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 | 108 | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 109 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 | 110 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 | 111 } | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 112 }); | 
| 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 113 } | 
| 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 | 114 | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 115 /** | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 116 * Get local revision number (index) of the specified revision. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 117 * | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 118 * For occasional queries, this method works with decent performance, despite its O(n/2) approach. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 119 * Alternatively, if you need to perform multiple queries (e.g. at least 15-20), {@link RevisionMap} may come handy. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 120 * | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 121 * @param nid revision to look up | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 122 * @return revision index, or {@link HgRepository#BAD_REVISION} if specified revision not found. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 123 */ | 
| 135 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 124 public final int getLocalRevision(Nodeid nid) { | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 125 int revision = content.findLocalRevisionNumber(nid); | 
| 80 
4222b04f34ee
Follow history of a file
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
77diff
changeset | 126 if (revision == BAD_REVISION) { | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 127 throw new IllegalArgumentException(String.format("%s doesn't represent a revision of %s", nid.toString(), this /*XXX HgDataFile.getPath might be more suitable here*/)); | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 128 } | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 129 return revision; | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 130 } | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 131 | 
| 39 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 132 // Till now, i follow approach that NULL nodeid is never part of revlog | 
| 135 
3959bffb14e9
explicit op name instead math op to get last rev number
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
115diff
changeset | 133 public final boolean isKnown(Nodeid nodeid) { | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 134 final int rn = content.findLocalRevisionNumber(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 | 135 if (BAD_REVISION == rn) { | 
| 39 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 136 return false; | 
| 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 137 } | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 138 if (rn < 0 || rn >= content.revisionCount()) { | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 139 // Sanity check | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 140 throw new IllegalStateException(); | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 141 } | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 142 return true; | 
| 39 
4e9b66b07a28
Check changelog group starts with proper (known) base
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
37diff
changeset | 143 } | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 144 | 
| 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 | 145 /** | 
| 
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 | 146 * Access to revision data as is (decompressed, but otherwise unprocessed, i.e. not parsed for e.g. changeset or manifest entries) | 
| 
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 | 147 * @param nodeid | 
| 
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 | 148 */ | 
| 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 | 149 protected void rawContent(Nodeid nodeid, ByteChannel sink) throws HgException, IOException, 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 | 150 rawContent(getLocalRevision(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 | 151 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 152 | 
| 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 | 153 /** | 
| 
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 | 154 * @param revision - repo-local index of this file change (not a changelog revision number!) | 
| 
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 | 155 */ | 
| 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 | 156 protected void rawContent(int revision, ByteChannel sink) throws HgException, IOException, 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 | 157 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 | 158 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 | 159 } | 
| 
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 | 160 ContentPipe insp = new ContentPipe(sink, 0); | 
| 
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 | 161 insp.checkCancelled(); | 
| 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 | 162 content.iterate(revision, revision, true, insp); | 
| 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 | 163 insp.checkFailed(); | 
| 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 | 164 } | 
| 
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 | 165 | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 166 /** | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 167 * XXX perhaps, return value Nodeid[2] and boolean needNodeids is better (and higher level) API for this query? | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 168 * | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 169 * @param revision - revision to query parents, or {@link HgRepository#TIP} | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 170 * @param parentRevisions - int[2] to get local revision numbers of parents (e.g. {6, -1}) | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 171 * @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 | 172 * @param parent2 - byte[20] or null, if second parent's nodeid is not needed | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 173 * @return | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 174 */ | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 175 public void parents(int revision, int[] parentRevisions, byte[] parent1, byte[] parent2) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 176 if (revision != TIP && !(revision >= 0 && revision < content.revisionCount())) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 177 throw new IllegalArgumentException(String.valueOf(revision)); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 178 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 179 if (parentRevisions == null || parentRevisions.length < 2) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 180 throw new IllegalArgumentException(String.valueOf(parentRevisions)); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 181 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 182 if (parent1 != null && parent1.length < 20) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 183 throw new IllegalArgumentException(parent1.toString()); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 184 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 185 if (parent2 != null && parent2.length < 20) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 186 throw new IllegalArgumentException(parent2.toString()); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 187 } | 
| 77 
c677e1593919
Moved RevlogStream implementation into .internal
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
74diff
changeset | 188 class ParentCollector implements RevlogStream.Inspector { | 
| 56 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 189 public int p1 = -1; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 190 public int p2 = -1; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 191 public byte[] nodeid; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 192 | 
| 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 | 193 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 | 194 p1 = parent1Revision; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 195 p2 = parent2Revision; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 196 this.nodeid = new byte[20]; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 197 // 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 | 198 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 | 199 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 200 }; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 201 ParentCollector pc = new ParentCollector(); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 202 content.iterate(revision, revision, false, pc); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 203 parentRevisions[0] = pc.p1; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 204 parentRevisions[1] = pc.p2; | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 205 if (parent1 != null) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 206 if (parentRevisions[0] == -1) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 207 Arrays.fill(parent1, 0, 20, (byte) 0); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 208 } else { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 209 content.iterate(parentRevisions[0], parentRevisions[0], false, pc); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 210 System.arraycopy(pc.nodeid, 0, parent1, 0, 20); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 211 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 212 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 213 if (parent2 != null) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 214 if (parentRevisions[1] == -1) { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 215 Arrays.fill(parent2, 0, 20, (byte) 0); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 216 } else { | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 217 content.iterate(parentRevisions[1], parentRevisions[1], false, pc); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 218 System.arraycopy(pc.nodeid, 0, parent2, 0, 20); | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 219 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 220 } | 
| 
576d6e8a09f6
Analog of 'hg status --change' command
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
49diff
changeset | 221 } | 
| 317 
09628675bcee
Rework file history build approach to match rest of the API
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
308diff
changeset | 222 | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 223 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 224 public void walk(int start, int end, final Revlog.Inspector inspector) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 225 int lastRev = getLastRevision(); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 226 if (start == TIP) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 227 start = lastRev; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 228 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 229 if (end == TIP) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 230 end = lastRev; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 231 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 232 final RevisionInspector revisionInsp = getAdapter(inspector, RevisionInspector.class); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 233 final ParentInspector parentInsp = getAdapter(inspector, ParentInspector.class); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 234 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 | 235 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 236 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 | 237 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 238 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 | 239 Nodeid nid = Nodeid.fromBinary(nodeid, 0); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 240 if (revisionInsp != null) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 241 revisionInsp.next(revisionNumber, nid, linkRevision); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 242 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 243 if (parentInsp != null) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 244 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 | 245 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 | 246 allRevisions[revisionNumber] = nid; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 247 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 | 248 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 249 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 250 }); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 251 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 252 private static <T> T getAdapter(Object o, Class<T> adapterClass) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 253 if (adapterClass.isInstance(o)) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 254 return adapterClass.cast(o); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 255 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 256 if (o instanceof Adaptable) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 257 return ((Adaptable) o).getAdapter(adapterClass); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 258 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 259 return null; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 260 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 261 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 262 /** | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 263 * MARKER | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 264 */ | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 265 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 266 public interface Inspector { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 267 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 268 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 269 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 270 public interface RevisionInspector extends Inspector { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 271 void next(int localRevision, Nodeid revision, int linkedRevision); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 272 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 273 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 274 @Experimental | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 275 public interface ParentInspector extends Inspector { | 
| 327 
3f09b8c19142
Tests for Revlog.Inspectors
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
324diff
changeset | 276 // XXX document whether parentX is -1 or a constant (BAD_REVISION? or dedicated?) | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 277 void next(int localRevision, Nodeid revision, int parent1, int parent2, Nodeid nidParent1, Nodeid nidParent2); | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 278 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 279 | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 280 /* | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 281 * XXX think over if it's better to do either: | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 282 * pw = getChangelog().new ParentWalker(); pw.init() and pass pw instance around as needed | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 283 * or | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 284 * add Revlog#getParentWalker(), static class, make cons() and #init package-local, and keep SoftReference to allow walker reuse. | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 285 * | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 286 * and yes, walker is not a proper name | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 287 */ | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 288 public final class ParentWalker implements ParentInspector { | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 289 | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 290 | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 291 private Nodeid[] sequential; // natural repository order, childrenOf rely on ordering | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 292 private Nodeid[] sorted; // for binary search | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 293 private int[] sorted2natural; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 294 private Nodeid[] firstParent; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 295 private Nodeid[] secondParent; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 296 | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 297 // Nodeid instances shall be shared between all arrays | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 298 | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 299 public ParentWalker() { | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 300 } | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 301 | 
| 192 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 302 public HgRepository getRepo() { | 
| 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 303 return Revlog.this.getRepo(); | 
| 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 304 } | 
| 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 305 | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 306 public void next(int revisionNumber, Nodeid revision, int parent1Revision, int parent2Revision, Nodeid nidParent1, Nodeid nidParent2) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 307 if (parent1Revision >= revisionNumber || parent2Revision >= revisionNumber) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 308 throw new IllegalStateException(); // sanity, revisions are sequential | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 309 } | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 310 int ix = revisionNumber; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 311 sequential[ix] = sorted[ix] = revision; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 312 if (parent1Revision != -1) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 313 firstParent[ix] = sequential[parent1Revision]; | 
| 
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 if (parent2Revision != -1) { // revlog of DataAccess.java has p2 set when p1 is -1 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 316 secondParent[ix] = sequential[parent2Revision]; | 
| 
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 | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 320 public void init() { | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 321 final int revisionCount = Revlog.this.getRevisionCount(); | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 322 firstParent = new Nodeid[revisionCount]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 323 // although branches/merges are less frequent, and most of secondParent would be -1/null, some sort of | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 324 // SparseOrderedList might be handy, provided its inner structures do not overweight simplicity of an array | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 325 // FIXME IntMap is right candidate? | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 326 secondParent = new Nodeid[revisionCount]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 327 // | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 328 sequential = new Nodeid[revisionCount]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 329 sorted = new Nodeid[revisionCount]; | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 330 Revlog.this.walk(0, TIP, this); | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 331 Arrays.sort(sorted); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 332 sorted2natural = new int[revisionCount]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 333 for (int i = 0; i < revisionCount; i++) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 334 Nodeid n = sequential[i]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 335 int x = Arrays.binarySearch(sorted, n); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 336 assertSortedIndex(x); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 337 sorted2natural[x] = i; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 338 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 339 } | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 340 | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 341 private void assertSortedIndex(int x) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 342 if (x < 0) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 343 throw new HgBadStateException(); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 344 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 345 } | 
| 31 
346b66add79d
Basic lookup for incoming changes
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
29diff
changeset | 346 | 
| 
346b66add79d
Basic lookup for incoming changes
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
29diff
changeset | 347 // FIXME need to decide whether Nodeid(00 * 20) is always known or not | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 348 // right now Nodeid.NULL is not recognized as known if passed to this method, | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 349 // caller is supposed to make explicit check | 
| 31 
346b66add79d
Basic lookup for incoming changes
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
29diff
changeset | 350 public boolean knownNode(Nodeid nid) { | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 351 return Arrays.binarySearch(sorted, nid) >= 0; | 
| 31 
346b66add79d
Basic lookup for incoming changes
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
29diff
changeset | 352 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 353 | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 354 /** | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 355 * null if none. only known nodes (as per #knownNode) are accepted as arguments | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 356 */ | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 357 public Nodeid firstParent(Nodeid nid) { | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 358 int x = Arrays.binarySearch(sorted, nid); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 359 assertSortedIndex(x); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 360 int i = sorted2natural[x]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 361 return firstParent[i]; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 362 } | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 363 | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 364 // never null, Nodeid.NULL if none known | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 365 public Nodeid safeFirstParent(Nodeid nid) { | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 366 Nodeid rv = firstParent(nid); | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 367 return rv == null ? Nodeid.NULL : rv; | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 368 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 369 | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 370 public Nodeid secondParent(Nodeid nid) { | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 371 int x = Arrays.binarySearch(sorted, nid); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 372 assertSortedIndex(x); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 373 int i = sorted2natural[x]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 374 return secondParent[i]; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 375 } | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 376 | 
| 49 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 377 public Nodeid safeSecondParent(Nodeid nid) { | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 378 Nodeid rv = secondParent(nid); | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 379 return rv == null ? Nodeid.NULL : rv; | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 380 } | 
| 
26e3eeaa3962
branch and user filtering for log operation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
39diff
changeset | 381 | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 382 public boolean appendParentsOf(Nodeid nid, Collection<Nodeid> c) { | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 383 int x = Arrays.binarySearch(sorted, nid); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 384 assertSortedIndex(x); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 385 int i = sorted2natural[x]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 386 Nodeid p1 = firstParent[i]; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 387 boolean modified = false; | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 388 if (p1 != null) { | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 389 modified = c.add(p1); | 
| 191 
b777502a06f5
Do not assume second parent can be set only when first one is set, again
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
183diff
changeset | 390 } | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 391 Nodeid p2 = secondParent[i]; | 
| 191 
b777502a06f5
Do not assume second parent can be set only when first one is set, again
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
183diff
changeset | 392 if (p2 != null) { | 
| 
b777502a06f5
Do not assume second parent can be set only when first one is set, again
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
183diff
changeset | 393 modified = c.add(p2) || modified; | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 394 } | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 395 return modified; | 
| 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 396 } | 
| 171 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 397 | 
| 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 398 // XXX alternative (and perhaps more reliable) approach would be to make a copy of allNodes and remove | 
| 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 399 // nodes, their parents and so on. | 
| 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 400 | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 401 // @return ordered collection of all children rooted at supplied nodes. Nodes shall not be descendants of each other! | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 402 // Nodeids shall belong to this revlog | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 403 public List<Nodeid> childrenOf(List<Nodeid> roots) { | 
| 171 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 404 HashSet<Nodeid> parents = new HashSet<Nodeid>(); | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 405 LinkedList<Nodeid> result = new LinkedList<Nodeid>(); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 406 int earliestRevision = Integer.MAX_VALUE; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 407 assert sequential.length == firstParent.length && firstParent.length == secondParent.length; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 408 // first, find earliest index of roots in question, as there's no sense | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 409 // to check children among nodes prior to branch's root node | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 410 for (Nodeid r : roots) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 411 int x = Arrays.binarySearch(sorted, r); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 412 assertSortedIndex(x); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 413 int i = sorted2natural[x]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 414 if (i < earliestRevision) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 415 earliestRevision = i; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 416 } | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 417 parents.add(sequential[i]); // add canonical instance in hope equals() is bit faster when can do a == | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 418 } | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 419 for (int i = earliestRevision + 1; i < sequential.length; i++) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 420 if (parents.contains(firstParent[i]) || parents.contains(secondParent[i])) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 421 parents.add(sequential[i]); // to find next child | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 422 result.add(sequential[i]); | 
| 171 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 423 } | 
| 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 424 } | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 425 return result; | 
| 171 
2c3e96674e2a
Towards outgoing changes - initial detection logic, get connected with remote repo stub
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
157diff
changeset | 426 } | 
| 192 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 427 | 
| 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 428 /** | 
| 308 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 429 * @return revisions that have supplied revision as their immediate parent | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 430 */ | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 431 public List<Nodeid> directChildren(Nodeid nid) { | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 432 LinkedList<Nodeid> result = new LinkedList<Nodeid>(); | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 433 int x = Arrays.binarySearch(sorted, nid); | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 434 assertSortedIndex(x); | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 435 nid = sorted[x]; // canonical instance | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 436 int start = sorted2natural[x]; | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 437 for (int i = start + 1; i < sequential.length; i++) { | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 438 if (nid == firstParent[i] || nid == secondParent[i]) { | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 439 result.add(sequential[i]); | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 440 } | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 441 } | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 442 return result; | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 443 } | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 444 | 
| 
3f40262153a4
Recognize closed branches
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
307diff
changeset | 445 /** | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 446 * @param nid possibly parent node, shall be {@link #knownNode(Nodeid) known} in this revlog. | 
| 192 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 447 * @return <code>true</code> if there's any node in this revlog that has specified node as one of its parents. | 
| 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 448 */ | 
| 200 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 449 public boolean hasChildren(Nodeid nid) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 450 int x = Arrays.binarySearch(sorted, nid); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 451 assertSortedIndex(x); | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 452 int i = sorted2natural[x]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 453 assert firstParent.length == secondParent.length; // just in case later I implement sparse array for secondParent | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 454 assert firstParent.length == sequential.length; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 455 // to use == instead of equals, take the same Nodeid instance we used to fill all the arrays. | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 456 final Nodeid canonicalNode = sequential[i]; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 457 i++; // no need to check node itself. child nodes may appear in sequential only after revision in question | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 458 for (; i < sequential.length; i++) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 459 // FIXME likely, not very effective. | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 460 // May want to optimize it with another (Tree|Hash)Set, created on demand on first use, | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 461 // however, need to be careful with memory usage | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 462 if (firstParent[i] == canonicalNode || secondParent[i] == canonicalNode) { | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 463 return true; | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 464 } | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 465 } | 
| 
114c9fe7b643
Performance optimization: reduce memory ParentWalker hogs
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
197diff
changeset | 466 return false; | 
| 192 
e5407b5a586a
Incoming and Outgoing commands are alive
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
191diff
changeset | 467 } | 
| 29 
6cce719bbb62
Collector for nodes and their parents
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
24diff
changeset | 468 } | 
| 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 | 469 | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 470 /** | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 471 * Effective int to Nodeid and vice versa translation. It's advised to use this class instead of | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 472 * multiple {@link Revlog#getLocalRevision(Nodeid)} calls. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 473 * | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 474 * getLocalRevision(Nodeid) with straightforward lookup approach performs O(n/2) | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 475 * #localRevision() is log(n), plus initialization is O(n) | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 476 */ | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 477 public final class RevisionMap implements RevisionInspector { | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 478 /* | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 479 * in fact, initialization is much slower as it instantiates Nodeids, while #getLocalRevision | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 480 * compares directly against byte buffer. Measuring cpython with 70k+ gives 3 times difference (47 vs 171) | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 481 * for complete changelog iteration. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 482 */ | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 483 | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 484 /* | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 485 * XXX 3 * (x * 4) bytes. Can I do better? | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 486 * It seems, yes. Don't need to keep sorted, always can emulate it with indirect access to sequential through sorted2natural. | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 487 * i.e. instead sorted[mid].compareTo(toFind), do sequential[sorted2natural[mid]].compareTo(toFind) | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 488 */ | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 489 private Nodeid[] sequential; // natural repository order, childrenOf rely on ordering | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 490 private Nodeid[] sorted; // for binary search | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 491 private int[] sorted2natural; | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 492 | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 493 public RevisionMap() { | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 494 } | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 495 | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 496 public HgRepository getRepo() { | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 497 return Revlog.this.getRepo(); | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 498 } | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 499 | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 500 public void next(int localRevision, Nodeid revision, int linkedRevision) { | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 501 sequential[localRevision] = sorted[localRevision] = revision; | 
| 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 502 } | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 503 | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 504 /** | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 505 * @return <code>this</code> for convenience. | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 506 */ | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 507 public RevisionMap init(/*XXX Pool<Nodeid> to reuse nodeids, if possible. */) { | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 508 // XXX HgRepository.register((RepoChangeListener) this); // listen to changes in repo, re-init if needed? | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 509 final int revisionCount = Revlog.this.getRevisionCount(); | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 510 sequential = new Nodeid[revisionCount]; | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 511 sorted = new Nodeid[revisionCount]; | 
| 324 
283b294d1079
Explore alternatives to access file-changelog combined history
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
317diff
changeset | 512 Revlog.this.walk(0, TIP, this); | 
| 307 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 513 // next is alternative to Arrays.sort(sorted), and build sorted2natural looking up each element of sequential in sorted. | 
| 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 514 // the way sorted2natural was build is O(n*log n). | 
| 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 515 final ArrayHelper ah = new ArrayHelper(); | 
| 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 516 ah.sort(sorted); | 
| 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 517 // note, values in ArrayHelper#getReversed are 1-based indexes, not 0-based | 
| 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 518 sorted2natural = ah.getReverse(); | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 519 return this; | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 520 } | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 521 | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 522 public Nodeid revision(int localRevision) { | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 523 return sequential[localRevision]; | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 524 } | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 525 public int localRevision(Nodeid revision) { | 
| 274 
9fb50c04f03c
Use Nodeid.isNull check instead of NULL.equals
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
243diff
changeset | 526 if (revision == null || revision.isNull()) { | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 527 return BAD_REVISION; | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 528 } | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 529 int x = Arrays.binarySearch(sorted, revision); | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 530 if (x < 0) { | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 531 return BAD_REVISION; | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 532 } | 
| 307 
2f2ab5c27f41
Collect sort reverse indexes along with array sorting
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
277diff
changeset | 533 return sorted2natural[x]-1; | 
| 243 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 534 } | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 535 } | 
| 
0e01f9182e16
External cache Nodeid<->int added, Revlog.RevisionMap
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
218diff
changeset | 536 | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 537 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 | 538 private Exception failure; | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 539 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 | 540 | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 541 protected void setCancelSupport(CancelSupport cs) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 542 assert cancelSupport == null; // no reason to set it twice | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 543 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 | 544 } | 
| 
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 | 545 | 
| 
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 | 546 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 | 547 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 | 548 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 | 549 } | 
| 
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 | 550 | 
| 
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 | 551 public void checkFailed() throws HgException, IOException, 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 | 552 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 | 553 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 | 554 } | 
| 
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 | 555 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 | 556 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 | 557 } | 
| 
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 | 558 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 | 559 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 | 560 } | 
| 
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 | 561 if (failure instanceof HgException) { | 
| 
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 | 562 throw (HgException) 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 | 563 } | 
| 
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 | 564 throw new HgBadStateException(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 | 565 } | 
| 277 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 566 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 567 public void checkCancelled() throws CancelledException { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 568 if (cancelSupport != null) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 569 cancelSupport.checkCancelled(); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 570 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 571 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 572 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 573 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 574 protected static class ContentPipe extends ErrorHandlingInspector implements RevlogStream.Inspector, CancelSupport { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 575 private final ByteChannel sink; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 576 private final int offset; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 577 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 578 /** | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 579 * @param _sink - cannot be <code>null</code> | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 580 * @param seekOffset - when positive, orders to pipe bytes to the sink starting from specified offset, not from the first byte available in DataAccess | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 581 */ | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 582 public ContentPipe(ByteChannel _sink, int seekOffset) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 583 assert _sink != null; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 584 sink = _sink; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 585 setCancelSupport(CancelSupport.Factory.get(_sink)); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 586 offset = seekOffset; | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 587 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 588 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 589 protected void prepare(int revisionNumber, DataAccess da) throws HgException, IOException { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 590 if (offset > 0) { // save few useless reset/rewind operations | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 591 da.seek(offset); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 592 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 593 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 594 | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 595 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 | 596 try { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 597 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 | 598 final ProgressSupport progressSupport = ProgressSupport.Factory.get(sink); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 599 ByteBuffer buf = ByteBuffer.allocate(512); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 600 progressSupport.start(da.length()); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 601 while (!da.isEmpty()) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 602 checkCancelled(); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 603 da.readBytes(buf); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 604 buf.flip(); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 605 // XXX I may not rely on returned number of bytes but track change in buf position instead. | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 606 int consumed = sink.write(buf); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 607 // FIXME in fact, bad sink implementation (that consumes no bytes) would result in endless loop. Need to account for this | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 608 buf.compact(); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 609 progressSupport.worked(consumed); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 610 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 611 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 | 612 } catch (IOException ex) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 613 recordFailure(ex); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 614 } catch (CancelledException ex) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 615 recordFailure(ex); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 616 } catch (HgException ex) { | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 617 recordFailure(ex); | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 618 } | 
| 
74e7493a042a
Favor delegation over generalization
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
274diff
changeset | 619 } | 
| 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 | 620 } | 
| 2 
08db726a0fb7
Shaping out low-level Hg structures
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 621 } | 
