Mercurial > hg4j
view src/org/tmatesoft/hg/core/HgChangeset.java @ 338:3cfa4d908fc9
Add options to control DataAccessProvider, allow to turn off use of file memory mapping in particular to solve potential sharing violation (os file handle gets released on MappedByteByffer being GC'd, not on FileChannel.close())
author | Artem Tikhomirov <tikhomirov.artem@gmail.com> |
---|---|
date | Tue, 15 Nov 2011 04:47:03 +0100 |
parents | ee6b467c1a5f |
children | 189dc6dc1c3e |
line wrap: on
line source
/* * Copyright (c) 2011 TMate Software Ltd * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; version 2 of the License. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * For information on how to redistribute this software under * the terms of a license other than GNU General Public License * contact TMate Software at support@hg4j.com */ package org.tmatesoft.hg.core; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Map; import org.tmatesoft.hg.repo.HgChangelog.RawChangeset; import org.tmatesoft.hg.repo.HgChangelog; import org.tmatesoft.hg.repo.HgRepository; import org.tmatesoft.hg.repo.HgStatusCollector; import org.tmatesoft.hg.util.Path; /** * Record in the Mercurial changelog, describing single commit. * * Not thread-safe, don't try to read from different threads * * @author Artem Tikhomirov * @author TMate Software Ltd. */ public class HgChangeset implements Cloneable { private final HgStatusCollector statusHelper; private final Path.Source pathHelper; private HgChangelog.ParentWalker parentHelper; // private RawChangeset changeset; private Nodeid nodeid; // private List<HgFileRevision> modifiedFiles, addedFiles; private List<Path> deletedFiles; private int revNumber; private byte[] parent1, parent2; // XXX consider CommandContext with StatusCollector, PathPool etc. Commands optionally get CC through a cons or create new // and pass it around /*package-local*/HgChangeset(HgStatusCollector statusCollector, Path.Source pathFactory) { statusHelper = statusCollector; pathHelper = pathFactory; } /*package-local*/ void init(int localRevNumber, Nodeid nid, RawChangeset rawChangeset) { revNumber = localRevNumber; nodeid = nid; changeset = rawChangeset.clone(); modifiedFiles = addedFiles = null; deletedFiles = null; parent1 = parent2 = null; // keep references to parentHelper, statusHelper and pathHelper } /*package-local*/ void setParentHelper(HgChangelog.ParentWalker pw) { parentHelper = pw; if (parentHelper != null) { if (parentHelper.getRepo() != statusHelper.getRepo()) { throw new IllegalArgumentException(); } } } public int getRevision() { return revNumber; } public Nodeid getNodeid() { return nodeid; } public String getUser() { return changeset.user(); } public String getComment() { return changeset.comment(); } public String getBranch() { return changeset.branch(); } /** * @return used to be String, now {@link HgDate}, use {@link HgDate#toString()} to get same result as before */ public HgDate getDate() { return new HgDate(changeset.date().getTime(), changeset.timezone()); } public Nodeid getManifestRevision() { return changeset.manifest(); } public List<Path> getAffectedFiles() { // reports files as recorded in changelog. Note, merge revisions may have no // files listed, and thus this method would return empty list, while // #getModifiedFiles() would return list with merged file(s) (because it uses status to get 'em, not // what #files() gives). ArrayList<Path> rv = new ArrayList<Path>(changeset.files().size()); for (String name : changeset.files()) { rv.add(pathHelper.path(name)); } return rv; } public List<HgFileRevision> getModifiedFiles() { if (modifiedFiles == null) { initFileChanges(); } return modifiedFiles; } public List<HgFileRevision> getAddedFiles() { if (addedFiles == null) { initFileChanges(); } return addedFiles; } public List<Path> getRemovedFiles() { if (deletedFiles == null) { initFileChanges(); } return deletedFiles; } public boolean isMerge() { // p1 == -1 and p2 != -1 is legitimate case return !(getFirstParentRevision().isNull() || getSecondParentRevision().isNull()); } /** * @return never <code>null</code> */ public Nodeid getFirstParentRevision() { if (parentHelper != null) { return parentHelper.safeFirstParent(nodeid); } // read once for both p1 and p2 if (parent1 == null) { parent1 = new byte[20]; parent2 = new byte[20]; statusHelper.getRepo().getChangelog().parents(revNumber, new int[2], parent1, parent2); } return Nodeid.fromBinary(parent1, 0); } /** * @return never <code>null</code> */ public Nodeid getSecondParentRevision() { if (parentHelper != null) { return parentHelper.safeSecondParent(nodeid); } if (parent2 == null) { parent1 = new byte[20]; parent2 = new byte[20]; statusHelper.getRepo().getChangelog().parents(revNumber, new int[2], parent1, parent2); } return Nodeid.fromBinary(parent2, 0); } @Override public HgChangeset clone() { try { HgChangeset copy = (HgChangeset) super.clone(); // copy.changeset references this.changeset, doesn't need own copy return copy; } catch (CloneNotSupportedException ex) { throw new InternalError(ex.toString()); } } private /*synchronized*/ void initFileChanges() { ArrayList<Path> deleted = new ArrayList<Path>(); ArrayList<HgFileRevision> modified = new ArrayList<HgFileRevision>(); ArrayList<HgFileRevision> added = new ArrayList<HgFileRevision>(); HgStatusCollector.Record r = new HgStatusCollector.Record(); statusHelper.change(revNumber, r); final HgRepository repo = statusHelper.getRepo(); for (Path s : r.getModified()) { Nodeid nid = r.nodeidAfterChange(s); if (nid == null) { throw new HgBadStateException(); } modified.add(new HgFileRevision(repo, nid, s, null)); } final Map<Path, Path> copied = r.getCopied(); for (Path s : r.getAdded()) { Nodeid nid = r.nodeidAfterChange(s); if (nid == null) { throw new HgBadStateException(); } added.add(new HgFileRevision(repo, nid, s, copied.get(s))); } for (Path s : r.getRemoved()) { // with Path from getRemoved, may just copy deleted.add(s); } modified.trimToSize(); added.trimToSize(); deleted.trimToSize(); modifiedFiles = Collections.unmodifiableList(modified); addedFiles = Collections.unmodifiableList(added); deletedFiles = Collections.unmodifiableList(deleted); } }