tikhomirov@143: /*
tikhomirov@143:  * Copyright (c) 2011 TMate Software Ltd
tikhomirov@143:  *  
tikhomirov@143:  * This program is free software; you can redistribute it and/or modify
tikhomirov@143:  * it under the terms of the GNU General Public License as published by
tikhomirov@143:  * the Free Software Foundation; version 2 of the License.
tikhomirov@143:  *
tikhomirov@143:  * This program is distributed in the hope that it will be useful,
tikhomirov@143:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
tikhomirov@143:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
tikhomirov@143:  * GNU General Public License for more details.
tikhomirov@143:  *
tikhomirov@143:  * For information on how to redistribute this software under
tikhomirov@143:  * the terms of a license other than GNU General Public License
tikhomirov@143:  * contact TMate Software at support@hg4j.com
tikhomirov@143:  */
tikhomirov@143: package org.tmatesoft.hg.console;
tikhomirov@143: 
tikhomirov@143: import static org.tmatesoft.hg.repo.HgRepository.TIP;
tikhomirov@143: 
tikhomirov@254: import java.io.File;
tikhomirov@350: import java.io.IOException;
tikhomirov@143: import java.util.ArrayList;
tikhomirov@305: import java.util.Collection;
tikhomirov@143: import java.util.Collections;
tikhomirov@328: import java.util.HashSet;
tikhomirov@143: import java.util.List;
tikhomirov@143: import java.util.Map;
tikhomirov@143: 
tikhomirov@248: import org.junit.Assert;
tikhomirov@285: import org.tmatesoft.hg.core.HgBadStateException;
tikhomirov@354: import org.tmatesoft.hg.core.HgCallbackTargetException;
tikhomirov@295: import org.tmatesoft.hg.core.HgCatCommand;
tikhomirov@328: import org.tmatesoft.hg.core.HgChangeset;
tikhomirov@328: import org.tmatesoft.hg.core.HgChangesetTreeHandler;
tikhomirov@275: import org.tmatesoft.hg.core.HgDataStreamException;
tikhomirov@354: import org.tmatesoft.hg.core.HgException;
tikhomirov@248: import org.tmatesoft.hg.core.HgFileInformer;
tikhomirov@231: import org.tmatesoft.hg.core.HgFileRevision;
tikhomirov@295: import org.tmatesoft.hg.core.HgLogCommand;
tikhomirov@143: import org.tmatesoft.hg.core.HgManifestCommand;
tikhomirov@143: import org.tmatesoft.hg.core.Nodeid;
tikhomirov@157: import org.tmatesoft.hg.internal.ByteArrayChannel;
tikhomirov@143: import org.tmatesoft.hg.internal.DigestHelper;
tikhomirov@229: import org.tmatesoft.hg.internal.PathGlobMatcher;
tikhomirov@445: import org.tmatesoft.hg.internal.PhasesHelper;
tikhomirov@254: import org.tmatesoft.hg.internal.RelativePathRewrite;
tikhomirov@449: import org.tmatesoft.hg.internal.RevisionDescendants;
tikhomirov@295: import org.tmatesoft.hg.internal.StreamLogFacility;
tikhomirov@220: import org.tmatesoft.hg.repo.HgBranches;
tikhomirov@233: import org.tmatesoft.hg.repo.HgChangelog;
tikhomirov@295: import org.tmatesoft.hg.repo.HgChangelog.RawChangeset;
tikhomirov@143: import org.tmatesoft.hg.repo.HgDataFile;
tikhomirov@290: import org.tmatesoft.hg.repo.HgDirstate;
tikhomirov@295: import org.tmatesoft.hg.repo.HgDirstate.EntryKind;
tikhomirov@295: import org.tmatesoft.hg.repo.HgDirstate.Record;
tikhomirov@339: import org.tmatesoft.hg.repo.HgIgnore;
tikhomirov@143: import org.tmatesoft.hg.repo.HgInternals;
tikhomirov@143: import org.tmatesoft.hg.repo.HgManifest;
tikhomirov@295: import org.tmatesoft.hg.repo.HgManifest.Flags;
tikhomirov@231: import org.tmatesoft.hg.repo.HgMergeState;
tikhomirov@445: import org.tmatesoft.hg.repo.HgPhase;
tikhomirov@143: import org.tmatesoft.hg.repo.HgRepository;
tikhomirov@143: import org.tmatesoft.hg.repo.HgStatusCollector;
tikhomirov@143: import org.tmatesoft.hg.repo.HgStatusInspector;
tikhomirov@239: import org.tmatesoft.hg.repo.HgSubrepoLocation;
tikhomirov@239: import org.tmatesoft.hg.repo.HgSubrepoLocation.Kind;
tikhomirov@463: import org.tmatesoft.hg.repo.ext.MqManager;
tikhomirov@463: import org.tmatesoft.hg.repo.ext.MqManager.PatchRecord;
tikhomirov@143: import org.tmatesoft.hg.repo.HgWorkingCopyStatusCollector;
tikhomirov@254: import org.tmatesoft.hg.util.FileWalker;
tikhomirov@295: import org.tmatesoft.hg.util.LogFacility;
tikhomirov@235: import org.tmatesoft.hg.util.Pair;
tikhomirov@143: import org.tmatesoft.hg.util.Path;
tikhomirov@254: import org.tmatesoft.hg.util.PathRewrite;
tikhomirov@143: 
tikhomirov@143: /**
tikhomirov@143:  * Various debug dumps. 
tikhomirov@143:  * 
tikhomirov@143:  * @author Artem Tikhomirov
tikhomirov@143:  * @author TMate Software Ltd.
tikhomirov@143:  */
tikhomirov@295: @SuppressWarnings("unused")
tikhomirov@143: public class Main {
tikhomirov@143: 	
tikhomirov@143: 	private Options cmdLineOpts;
tikhomirov@143: 	private HgRepository hgRepo;
tikhomirov@143: 
tikhomirov@143: 	public Main(String[] args) throws Exception {
tikhomirov@299: 		cmdLineOpts = Options.parse(args, Collections.<String>emptySet());
tikhomirov@143: 		hgRepo = cmdLineOpts.findRepository();
tikhomirov@143: 		if (hgRepo.isInvalid()) {
tikhomirov@143: 			System.err.printf("Can't find repository in: %s\n", hgRepo.getLocation());
tikhomirov@143: 			return;
tikhomirov@143: 		}
tikhomirov@143: 		System.out.println("REPO:" + hgRepo.getLocation());
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@143: 	public static void main(String[] args) throws Exception {
tikhomirov@143: 		Main m = new Main(args);
tikhomirov@463: 		m.testMqManager();
tikhomirov@450: //		m.testRevisionDescendants();
tikhomirov@463: //		m.dumpPhases();
tikhomirov@463: //		m.buildFileLog();
tikhomirov@305: //		m.testConsoleLog();
tikhomirov@270: //		m.testTreeTraversal();
tikhomirov@244: //		m.testRevisionMap();
tikhomirov@242: //		m.testSubrepos();
tikhomirov@239: //		m.testReadWorkingCopy();
tikhomirov@254: //		m.testParents();
tikhomirov@243: //		m.testEffectiveFileLog();
tikhomirov@252: //		m.testCatAtCsetRevision();
tikhomirov@345: //		m.testMergeState();
tikhomirov@231: //		m.testFileStatus();
tikhomirov@341: //		m.dumpBranches();
tikhomirov@220: //		m.inflaterLengthException();
tikhomirov@157: //		m.dumpIgnored();
tikhomirov@295: //		m.dumpDirstate();
tikhomirov@157: //		m.testStatusInternals();
tikhomirov@157: //		m.catCompleteHistory();
tikhomirov@157: //		m.dumpCompleteManifestLow();
tikhomirov@445: //		m.dumpCompleteManifestHigh();
tikhomirov@157: //		m.bunchOfTests();
tikhomirov@157: 	}
tikhomirov@445: 	
tikhomirov@463: 	
tikhomirov@463: 	// TODO as junit tests in 'default'
tikhomirov@463: 	// -R ${system_property:user.home}/hg/test-mq
tikhomirov@463: 	private void testMqManager() throws Exception {
tikhomirov@463: 		MqManager mqManager = new MqManager(hgRepo);
tikhomirov@463: 		mqManager.refresh();
tikhomirov@463: 		int i = 1;
tikhomirov@463: 		System.out.println("Complete patch queue:");
tikhomirov@463: 		for (PatchRecord pr : mqManager.getAllKnownPatches()) {
tikhomirov@463: 			System.out.printf("#%-3d %s from %s\n", i++, pr.getName(), pr.getPatchLocation());
tikhomirov@463: 		}
tikhomirov@463: 		i = 1;
tikhomirov@463: 		System.out.println("Patches from the queue already applied to the repo:");
tikhomirov@463: 		for (PatchRecord pr : mqManager.getAppliedPatches()) {
tikhomirov@463: 			System.out.printf("#%-3d %s, known as cset:%s\n", i++, pr.getName(), pr.getRevision().shortNotation());
tikhomirov@463: 		}
tikhomirov@464: 		boolean allAppliedAreKnown = mqManager.getAllKnownPatches().containsAll(mqManager.getAppliedPatches());
tikhomirov@464: 		System.out.printf("[sanity] allAppliedAreKnown:%b, not yet applied:%d\n", allAppliedAreKnown, mqManager.getQueueSize());
tikhomirov@464: 		Assert.assertTrue(allAppliedAreKnown);
tikhomirov@464: 
tikhomirov@464: 		System.out.printf("Queues: %s, active:%s\n", mqManager.getQueueNames(), mqManager.getActiveQueueName());
tikhomirov@464: 		Assert.assertTrue(mqManager.getQueueNames().size() > 1);
tikhomirov@464: 		Assert.assertTrue(mqManager.getActiveQueueName().length() > 0);
tikhomirov@463: 	}
tikhomirov@463: 	
tikhomirov@463: 	
tikhomirov@449: 	// -R {junit-test-repos}/branches-1
tikhomirov@449: 	private void testRevisionDescendants() throws Exception {
tikhomirov@449: 		int[] roots = new int[] {0, 1, 2, 3, 4, 5};
tikhomirov@449: 		RevisionDescendants[] result = new RevisionDescendants[roots.length];
tikhomirov@449: 		for (int i = 0; i < roots.length; i++) {
tikhomirov@449: 			result[i] = new RevisionDescendants(hgRepo, roots[i]);
tikhomirov@449: 			result[i].build();
tikhomirov@449: 		}
tikhomirov@449: 		for (int i = 0; i < roots.length; i++) {
tikhomirov@449: 			System.out.printf("For root %d descendats are:", roots[i]);
tikhomirov@449: 			for (int j = roots[i], x = hgRepo.getChangelog().getLastRevision(); j <= x; j++) {
tikhomirov@449: 				if (result[i].isDescendant(j)) {
tikhomirov@449: 					System.out.printf("%3d ", j);
tikhomirov@449: 				}
tikhomirov@449: 			}
tikhomirov@449: 			System.out.printf(", isEmpty:%b\n", !result[i].hasDescendants());
tikhomirov@449: 		}
tikhomirov@449: 	}
tikhomirov@449: 	
tikhomirov@449: 	// -R ${system_property:user.home}/hg/test-phases/
tikhomirov@445: 	// TODO as junit test
tikhomirov@445: 	private void dumpPhases() throws Exception {
tikhomirov@449: 		HgPhase[] result1 = new HgPhase[hgRepo.getChangelog().getRevisionCount()];
tikhomirov@449: 		HgPhase[] result2 = new HgPhase[hgRepo.getChangelog().getRevisionCount()];
tikhomirov@449: 		final long start1 = System.nanoTime();
tikhomirov@445: 		HgChangelog.ParentWalker pw = hgRepo.getChangelog().new ParentWalker();
tikhomirov@445: 		pw.init();
tikhomirov@449: 		final long start1bis = System.nanoTime();
tikhomirov@445: 		PhasesHelper ph = new PhasesHelper(hgRepo, pw);
tikhomirov@445: 		for (int i = 0, l = hgRepo.getChangelog().getLastRevision(); i <= l; i++) {
tikhomirov@449: 			result1[i] = ph.getPhase(i, null);
tikhomirov@445: 		}
tikhomirov@449: 		final long start2 = System.nanoTime();
tikhomirov@445: 		ph = new PhasesHelper(hgRepo);
tikhomirov@445: 		for (int i = 0, l = hgRepo.getChangelog().getLastRevision(); i <= l; i++) {
tikhomirov@449: 			result2[i] = ph.getPhase(i, null);
tikhomirov@449: 		}
tikhomirov@449: 		final long end = System.nanoTime();
tikhomirov@449: 		System.out.printf("With ParentWalker(simulates log command for whole repo): %d ms (pw init: %,d ns)\n", (start2 - start1)/1000, start1bis - start1);
tikhomirov@449: 		printPhases(result1);
tikhomirov@449: 		System.out.printf("Without ParentWalker (simulates log command for single file): %d ms\n", (end - start2)/1000);
tikhomirov@449: 		printPhases(result2);
tikhomirov@449: 	}
tikhomirov@449: 	
tikhomirov@449: 	private static void printPhases(HgPhase[] phase) {
tikhomirov@449: 		for (int i = 0; i < phase.length; i++) {
tikhomirov@449: 			System.out.printf("rev:%3d, phase:%s\n", i, phase[i]);
tikhomirov@445: 		}
tikhomirov@445: 	}
tikhomirov@305: 
tikhomirov@328: 	private void buildFileLog() throws Exception {
tikhomirov@450: 		final long start = System.nanoTime();
tikhomirov@328: 		HgLogCommand cmd = new HgLogCommand(hgRepo);
tikhomirov@328: 		cmd.file("file1", false);
tikhomirov@328: 		cmd.execute(new HgChangesetTreeHandler() {
tikhomirov@354: 			public void next(HgChangesetTreeHandler.TreeElement entry) {
tikhomirov@366: 				try {
tikhomirov@366: 					StringBuilder sb = new StringBuilder();
tikhomirov@366: 					HashSet<Nodeid> test = new HashSet<Nodeid>(entry.childRevisions());
tikhomirov@366: 					for (HgChangeset cc : entry.children()) {
tikhomirov@366: 						sb.append(cc.getRevision());
tikhomirov@366: 						sb.append(':');
tikhomirov@366: 						sb.append(cc.getNodeid().shortNotation());
tikhomirov@366: 						sb.append(", ");
tikhomirov@366: 					}
tikhomirov@366: 					final Pair<Nodeid, Nodeid> parents = entry.parentRevisions();
tikhomirov@366: 					final boolean isJoin = !parents.first().isNull() && !parents.second().isNull();
tikhomirov@366: 					final boolean isFork = entry.children().size() > 1;
tikhomirov@366: 					final HgChangeset cset = entry.changeset();
tikhomirov@450: 					System.out.printf("%d:%s - %s (%s)\n", cset.getRevision(), cset.getNodeid().shortNotation(), cset.getComment(), cset.getPhase());
tikhomirov@366: 					if (!isJoin && !isFork && !entry.children().isEmpty()) {
tikhomirov@366: 						System.out.printf("\t=> %s\n", sb);
tikhomirov@366: 					}
tikhomirov@366: 					if (isJoin) {
tikhomirov@366: 						HgChangeset p1 = entry.parents().first();
tikhomirov@366: 						HgChangeset p2 = entry.parents().second();
tikhomirov@366: 						System.out.printf("\tjoin <= (%d:%s, %d:%s)", p1.getRevision(), p1.getNodeid().shortNotation(), p2.getRevision(), p2.getNodeid().shortNotation());
tikhomirov@366: 						if (isFork) {
tikhomirov@366: 							System.out.print(", ");
tikhomirov@366: 						}
tikhomirov@366: 					}
tikhomirov@328: 					if (isFork) {
tikhomirov@366: 						if (!isJoin) {
tikhomirov@366: 							System.out.print('\t');
tikhomirov@366: 						}
tikhomirov@366: 						System.out.printf("fork => [%s]", sb);
tikhomirov@328: 					}
tikhomirov@366: 					if (isJoin || isFork) {
tikhomirov@366: 						System.out.println();
tikhomirov@328: 					}
tikhomirov@366: 				} catch (HgException ex) {
tikhomirov@366: 					ex.printStackTrace();
tikhomirov@317: 				}
tikhomirov@305: 			}
tikhomirov@328: 		});
tikhomirov@450: 		final long end = System.nanoTime();
tikhomirov@450: 		System.out.printf("buildFileLog: %,d ms\n", (end-start)/1000);
tikhomirov@305: 	}
tikhomirov@305: 
tikhomirov@366: 	private void buildFileLogOld() throws Exception {
tikhomirov@305: 		final HgDataFile fn = hgRepo.getFileNode("file1");
tikhomirov@305: 		final int[] fileChangesetRevisions = new int[fn.getRevisionCount()];
tikhomirov@305: 		fn.history(new HgChangelog.Inspector() {
tikhomirov@305: 			private int fileLocalRevisions = 0;
tikhomirov@305: 			private int[] parentRevisions = new int[2];
tikhomirov@305: 			
tikhomirov@305: 			public void next(int revisionNumber, Nodeid nodeid, RawChangeset cset) {
tikhomirov@366: 				try {
tikhomirov@366: 					fileChangesetRevisions[fileLocalRevisions] = revisionNumber;
tikhomirov@366: 					fn.parents(fileLocalRevisions, parentRevisions, null, null);
tikhomirov@366: 					boolean join = parentRevisions[0] != -1 && parentRevisions[1] != -1;
tikhomirov@366: 					if (join) {
tikhomirov@366: 						System.out.print("join[");
tikhomirov@366: 					}
tikhomirov@366: 					if (parentRevisions[0] != -1) {
tikhomirov@366: 						System.out.printf("%2d->%2d, ", fileChangesetRevisions[parentRevisions[0]], revisionNumber);
tikhomirov@366: 					}
tikhomirov@366: 					if (parentRevisions[1] != -1) {
tikhomirov@366: 						System.out.printf("%2d->%2d, ", fileChangesetRevisions[parentRevisions[1]], revisionNumber);
tikhomirov@366: 					}
tikhomirov@366: 					if (join) {
tikhomirov@366: 						System.out.print("]");
tikhomirov@366: 					}
tikhomirov@366: 					fileLocalRevisions++;
tikhomirov@366: 				} catch (HgException ex) {
tikhomirov@366: 					ex.printStackTrace();
tikhomirov@305: 				}
tikhomirov@305: 			}
tikhomirov@305: 		});
tikhomirov@305: 		System.out.println();
tikhomirov@305: 	}
tikhomirov@243: 	
tikhomirov@295: 	private void testConsoleLog() {
tikhomirov@295: 		LogFacility fc = new StreamLogFacility(true, true, true, System.out);
tikhomirov@295: 		System.out.printf("isDebug: %s, isInfo:%s\n", fc.isDebug(), fc.isInfo());
tikhomirov@295: 		fc.debug(getClass(), "%d", 1);
tikhomirov@295: 		fc.info(getClass(), "%d\n", 2);
tikhomirov@295: 		fc.warn(getClass(), "%d\n", 3);
tikhomirov@295: 		fc.error(getClass(), "%d", 4);
tikhomirov@295: 		Exception ex = new Exception();
tikhomirov@295: 		fc.debug(getClass(), ex, "message");
tikhomirov@295: 		fc.info(getClass(), ex, null);
tikhomirov@295: 		fc.warn(getClass(), ex, null);
tikhomirov@295: 		fc.error(getClass(), ex, "message");
tikhomirov@295: 	}
tikhomirov@295: 	
tikhomirov@254: 	private void testTreeTraversal() throws Exception {
tikhomirov@254: 		File repoRoot = hgRepo.getWorkingDir();
tikhomirov@254: 		Path.Source pathSrc = new Path.SimpleSource(new PathRewrite.Composite(new RelativePathRewrite(repoRoot), hgRepo.getToRepoPathHelper()));
tikhomirov@254: 		FileWalker w =  new FileWalker(repoRoot, pathSrc);
tikhomirov@254: 		int count = 0;
tikhomirov@254: 		final long start = System.currentTimeMillis();
tikhomirov@254: 		while (w.hasNext()) {
tikhomirov@254: 			count++;
tikhomirov@254: 			w.next();
tikhomirov@254: 		}
tikhomirov@254: 		System.out.printf("Traversal of %d files took %d ms", count, System.currentTimeMillis() - start);
tikhomirov@254: 	}
tikhomirov@254: 	
tikhomirov@243: 	/*
tikhomirov@243: 	 * cpython repo with 70715 revisions.
tikhomirov@243: 	 	3 revisions - 80 ms vs 250 ms (250ms init)
tikhomirov@243: 		4 revisions - 110 ms vs 265 ms (265 ms init)
tikhomirov@243: 		5 revisions - 94 vs 266.
tikhomirov@367: 		complete iteration in changelog.getRevisionIndex(tipNodeid) takes 47 ms
tikhomirov@243: 		compared to complete iteration inside RevisionMap.init() of 171 ms.
tikhomirov@243: 		The only difference is latter instantiates Nodeids, while former compares binary content as is.
tikhomirov@243: 		Hence, with 20-30 ms per regular getLocalRevision, it pays off to use RevisionMap with at least 15-20
tikhomirov@243: 		queries 
tikhomirov@243: 	 */
tikhomirov@243: 	private void testRevisionMap() throws Exception {
tikhomirov@243: 		HgChangelog changelog = hgRepo.getChangelog();
tikhomirov@243: 		HgChangelog.RevisionMap rmap = changelog.new RevisionMap().init(); // warm-up, ensure complete file read
tikhomirov@243: 		int tip = changelog.getLastRevision();
tikhomirov@243: 		// take 5 arbitrary revisions at 0, 1/4, 2/4, 3/4 and 4/4 
tikhomirov@243: 		final Nodeid[] revs = new Nodeid[5];
tikhomirov@243: 		revs[4] = changelog.getRevision(0);
tikhomirov@243: 		revs[3] = changelog.getRevision(tip / 4);
tikhomirov@243: 		revs[2] = changelog.getRevision(tip / 2);
tikhomirov@243: 		revs[1] = changelog.getRevision(tip / 4 + tip / 2);
tikhomirov@243: 		revs[0] = changelog.getRevision(tip);
tikhomirov@243: 		long start = System.currentTimeMillis();
tikhomirov@243: 		for (int i = 0; i < revs.length; i++) {
tikhomirov@367: 			final int localRev = changelog.getRevisionIndex(revs[i]);
tikhomirov@243: 			System.out.printf("%d:%s\n", localRev, revs[i]);
tikhomirov@243: 		}
tikhomirov@243: 		System.out.println(System.currentTimeMillis() - start);
tikhomirov@243: 		System.out.println();
tikhomirov@243: 		//
tikhomirov@243: 		start = System.currentTimeMillis();
tikhomirov@243: 		rmap = changelog.new RevisionMap().init();
tikhomirov@243: 		long s2 = System.currentTimeMillis();
tikhomirov@243: 		for (int i = 0; i < revs.length; i++) {
tikhomirov@367: 			final int localRev = rmap.revisionIndex(revs[i]);
tikhomirov@243: 			System.out.printf("%d:%s\n", localRev, revs[i]);
tikhomirov@243: 		}
tikhomirov@243: 		System.out.println(System.currentTimeMillis() - start);
tikhomirov@243: 		System.out.printf("\t from that, init took %d ms\n", s2 - start);
tikhomirov@243: 		
tikhomirov@243: 	}
tikhomirov@239: 
tikhomirov@239: 	private void testSubrepos() throws Exception {
tikhomirov@239: 		for (HgSubrepoLocation l : hgRepo.getSubrepositories()) {
tikhomirov@239: 			System.out.println(l.getLocation());
tikhomirov@239: 			System.out.println(l.getSource());
tikhomirov@239: 			System.out.println(l.getType());
tikhomirov@239: 			System.out.println(l.isCommitted() ? l.getRevision() : "not yet committed");
tikhomirov@239: 			if (l.getType() == Kind.Hg) {
tikhomirov@239: 				HgRepository r = l.getRepo();
tikhomirov@239: 				System.out.printf("%s has %d revisions\n", l.getLocation(), r.getChangelog().getLastRevision() + 1);
tikhomirov@239: 				if (r.getChangelog().getLastRevision() >= 0) {
tikhomirov@239: 					final RawChangeset c = r.getChangelog().range(TIP, TIP).get(0);
tikhomirov@239: 					System.out.printf("TIP: %s %s %s\n", c.user(), c.dateString(), c.comment());
tikhomirov@239: 				}
tikhomirov@239: 			}
tikhomirov@239: 		}
tikhomirov@239: 	}
tikhomirov@239: 
tikhomirov@237: 	private void testReadWorkingCopy() throws Exception {
tikhomirov@237: 		for (String fname : cmdLineOpts.getList("")) {
tikhomirov@237: 			HgDataFile fn = hgRepo.getFileNode(fname);
tikhomirov@237: 			ByteArrayChannel sink = new ByteArrayChannel();
tikhomirov@237: 			fn.workingCopy(sink);
tikhomirov@237: 			System.out.printf("%s: read %d bytes of working copy", fname, sink.toArray().length);
tikhomirov@237: 		}
tikhomirov@237: 	}
tikhomirov@237: 	
tikhomirov@235: 	private void testParents() throws Exception {
tikhomirov@235: 		// hg parents cmd
tikhomirov@235: 		final Pair<Nodeid, Nodeid> wcParents = hgRepo.getWorkingCopyParents();
tikhomirov@235: 		ChangesetDumpHandler dump = new ChangesetDumpHandler(hgRepo);
tikhomirov@235: 		HgLogCommand cmd = new HgLogCommand(hgRepo);
tikhomirov@235: 		if (wcParents.hasFirst()) {
tikhomirov@253: 			cmd.changeset(wcParents.first()).execute(dump);
tikhomirov@235: 		}
tikhomirov@235: 		if (wcParents.hasSecond()) {
tikhomirov@253: 			cmd.changeset(wcParents.second()).execute(dump);
tikhomirov@235: 		}
tikhomirov@252: 		System.out.println("Branch:" + hgRepo.getWorkingCopyBranchName());
tikhomirov@235: 	}
tikhomirov@235: 	
tikhomirov@242: 	/*
tikhomirov@242: 	 *  -R \temp\hg\hg4j-50 src/org/tmatesoft/hg/internal/RevlogStream.java
tikhomirov@242: 	 *  
tikhomirov@242: 	 *  -R \temp\hg\cpython Lib/doctest.py, range 15907..68588, total 251 revision
tikhomirov@242: 	 *  no improvement (collect linkRev, hgchangelog.range([]))							10890 ms
tikhomirov@242: 	 *  improved history logic in HgDataFile (minimize reads of close revisions): 
tikhomirov@242: 	 *  		with no sort (defect for tool-created repos)					took	10500 ms
tikhomirov@242: 	 *  		with sort (to order revisions from linkRev before use)					  610 ms
tikhomirov@242: 	 *  			HgChangelog.range() - 92 calls
tikhomirov@242: 	 *  RevlogStream with separate iterate(int[] sortedRevisions,...)
tikhomirov@242: 	 *  		RevlogStream.ReaderN1.range(): 185										  380 ms 
tikhomirov@242: 	 */
tikhomirov@366: 	private void testEffectiveFileLog() throws Exception {
tikhomirov@233: 		for (String fname : cmdLineOpts.getList("")) {
tikhomirov@233: 			System.out.println(fname);
tikhomirov@242: 			final long start = System.currentTimeMillis();
tikhomirov@233: 			HgDataFile fn = hgRepo.getFileNode(fname);
tikhomirov@233: 			if (fn.exists()) {
tikhomirov@233: 				fn.history(new HgChangelog.Inspector() {
tikhomirov@233: 					public void next(int revisionNumber, Nodeid nodeid, RawChangeset cset) {
tikhomirov@233: 						System.out.printf("%d:%s\n", revisionNumber, nodeid);
tikhomirov@233: 					}
tikhomirov@233: 				});
tikhomirov@233: 			}
tikhomirov@242: 			System.out.printf("Done: %d\n", System.currentTimeMillis() - start);
tikhomirov@233: 		}
tikhomirov@233: 	}
tikhomirov@233: 	
tikhomirov@232: 	// TODO as test in TestCat
tikhomirov@232: 	private void testCatAtCsetRevision() throws Exception {
tikhomirov@232: 		HgCatCommand cmd = new HgCatCommand(hgRepo);
tikhomirov@248: 		final Path file = Path.create("src/org/tmatesoft/hg/internal/RevlogStream.java");
tikhomirov@248: 		cmd.file(file);
tikhomirov@248: 		final Nodeid cset = Nodeid.fromAscii("08db726a0fb7914ac9d27ba26dc8bbf6385a0554");
tikhomirov@248: 		cmd.changeset(cset);
tikhomirov@232: 		final ByteArrayChannel sink = new ByteArrayChannel();
tikhomirov@232: 		cmd.execute(sink);
tikhomirov@232: 		System.out.println(sink.toArray().length);
tikhomirov@248: 		HgFileInformer i = new HgFileInformer(hgRepo);
tikhomirov@362: 		boolean result = i.changeset(cset).checkExists(file);
tikhomirov@248: 		Assert.assertFalse(result);
tikhomirov@248: 		Assert.assertFalse(i.exists());
tikhomirov@362: 		result = i.followRenames(true).checkExists(file);
tikhomirov@248: 		Assert.assertTrue(result);
tikhomirov@248: 		Assert.assertTrue(i.exists());
tikhomirov@248: 		HgCatCommand cmd2 = new HgCatCommand(hgRepo).revision(i.getFileRevision());
tikhomirov@248: 		final ByteArrayChannel sink2 = new ByteArrayChannel();
tikhomirov@248: 		cmd2.execute(sink2);
tikhomirov@248: 		System.out.println(sink2.toArray().length);
tikhomirov@248: 		Assert.assertEquals(sink.toArray().length, sink2.toArray().length);
tikhomirov@232: 	}
tikhomirov@232: 	
tikhomirov@231: 	private void testMergeState() throws Exception {
tikhomirov@231: 		final HgMergeState mergeState = hgRepo.getMergeState();
tikhomirov@231: 		mergeState.refresh();
tikhomirov@270: 		System.out.printf("isMerging: %s, isStale: %s.\n", mergeState.isMerging(), mergeState.isStale());
tikhomirov@270: 		System.out.printf("P1:%s\nP2:%s\nState parent:%s\n",mergeState.getFirstParent().shortNotation(), mergeState.getSecondParent().shortNotation(), mergeState.getStateParent().shortNotation());
tikhomirov@231: 		for (HgMergeState.Entry e : mergeState.getConflicts()) {
tikhomirov@231: 			System.out.println(e.getState() + " " + e.getActualFile());
tikhomirov@231: 			System.out.println("p1:       " + formatFileRevision(e.getFirstParent()));
tikhomirov@231: 			System.out.println("p2:       " + formatFileRevision(e.getSecondParent()));
tikhomirov@231: 			System.out.println("ancestor: " + formatFileRevision(e.getCommonAncestor()));
tikhomirov@231: 			System.out.println();
tikhomirov@231: 		}
tikhomirov@231: 	}
tikhomirov@231: 	
tikhomirov@231: 	private static String formatFileRevision(HgFileRevision r) throws Exception {
tikhomirov@231: 		final ByteArrayChannel sink = new ByteArrayChannel();
tikhomirov@231: 		r.putContentTo(sink);
tikhomirov@231: 		return String.format("%s %s (%d bytes)", r.getPath(), r.getRevision(), sink.toArray().length);
tikhomirov@231: 	}
tikhomirov@231: 	
tikhomirov@362: 	private void testFileStatus() throws HgException, IOException {
tikhomirov@226: //		final Path path = Path.create("src/org/tmatesoft/hg/util/");
tikhomirov@229: //		final Path path = Path.create("src/org/tmatesoft/hg/internal/Experimental.java");
tikhomirov@231: //		final Path path = Path.create("missing-dir/");
tikhomirov@229: //		HgWorkingCopyStatusCollector wcsc = HgWorkingCopyStatusCollector.create(hgRepo, path);
tikhomirov@233: 		HgWorkingCopyStatusCollector wcsc = HgWorkingCopyStatusCollector.create(hgRepo, new PathGlobMatcher("mi**"));
tikhomirov@226: 		wcsc.walk(TIP, new StatusDump());
tikhomirov@226: 	}
tikhomirov@226: 	
tikhomirov@236: 	/*
tikhomirov@236: 	 * Straightforward approach to collect branches, no use of branchheads.cache
tikhomirov@236: 	 * First, single run - 18 563
tikhomirov@236: 	 * 10 runs (after 1 warm up) of HgBranches.collect took 167391 ms, ~17 seconds per run.
tikhomirov@236: 	 */
tikhomirov@366: 	private void dumpBranches() throws Exception {
tikhomirov@236: 		final long start0 = System.currentTimeMillis();
tikhomirov@220: 		HgBranches b = hgRepo.getBranches();
tikhomirov@236: 		System.out.println("1:" + (System.currentTimeMillis() - start0));
tikhomirov@220: 		for (HgBranches.BranchInfo bi : b.getAllBranches()) {
tikhomirov@220: 			System.out.print(bi.getName());
tikhomirov@236: //			System.out.print(" ");
tikhomirov@236: //			System.out.print(bi.getStart());
tikhomirov@220: 			System.out.print(" ");
tikhomirov@308: 			System.out.print(bi.getHeads());
tikhomirov@308: 			if (bi.isClosed()) {
tikhomirov@308: 				System.out.print(" x ");
tikhomirov@308: 			}
tikhomirov@308: 			System.out.println();
tikhomirov@220: 		}
tikhomirov@308: //		b.writeCache();
tikhomirov@236: //		final long start = System.currentTimeMillis();
tikhomirov@236: //		for (int i = 0; i < 10; i++) {
tikhomirov@236: //			b.collect(ProgressSupport.Factory.get(null));
tikhomirov@236: //		}
tikhomirov@236: //		System.out.println("10:" + (System.currentTimeMillis() - start));
tikhomirov@220: 	}
tikhomirov@220: 	
tikhomirov@157: 	private void inflaterLengthException() throws Exception {
tikhomirov@157: 		HgDataFile f1 = hgRepo.getFileNode("src/com/tmate/hgkit/console/Bundle.java");
tikhomirov@157: 		HgDataFile f2 = hgRepo.getFileNode("test-repos.jar");
tikhomirov@157: 		System.out.println(f1.isCopy());
tikhomirov@157: 		System.out.println(f2.isCopy());
tikhomirov@157: 		ByteArrayChannel bac = new ByteArrayChannel();
tikhomirov@158: 		f1.content(1, bac); // 0: 1151, 1: 1139
tikhomirov@158: 		System.out.println(bac.toArray().length);
tikhomirov@158: 		f2.content(0, bac = new ByteArrayChannel()); // 0: 14269
tikhomirov@157: 		System.out.println(bac.toArray().length);
tikhomirov@143: 	}
tikhomirov@143: 	
tikhomirov@143: 	private void dumpIgnored() {
tikhomirov@143: 		String[] toCheck = new String[] {"design.txt", "src/com/tmate/hgkit/ll/Changelog.java", "src/Extras.java", "bin/com/tmate/hgkit/ll/Changelog.class"};
tikhomirov@339: 		HgIgnore ignore = hgRepo.getIgnore();
tikhomirov@143: 		for (int i = 0; i < toCheck.length; i++) {
tikhomirov@339: 			System.out.println("Ignored " + toCheck[i] + ": " + ignore.isIgnored(Path.create(toCheck[i])));
tikhomirov@143: 		}
tikhomirov@143: 	}
tikhomirov@348: 
tikhomirov@348: 	static class DirstateDump implements HgDirstate.Inspector {
tikhomirov@348: 		private final char[] x = new char[] {'n', 'a', 'r', 'm' };
tikhomirov@348: 
tikhomirov@348: 		public boolean next(EntryKind kind, Record entry) {
tikhomirov@348: 			System.out.printf("%c %3o%6d %30tc\t\t%s", x[kind.ordinal()], entry.mode(), entry.size(), (long) entry.modificationTime() * 1000, entry.name());
tikhomirov@348: 			if (entry.copySource() != null) {
tikhomirov@348: 				System.out.printf(" --> %s", entry.copySource());
tikhomirov@348: 			}
tikhomirov@348: 			System.out.println();
tikhomirov@348: 			return true;
tikhomirov@348: 		}
tikhomirov@348: 	}
tikhomirov@143: 	
tikhomirov@348: 	private void dumpDirstate() throws Exception {
tikhomirov@348: 		new HgInternals(hgRepo).getDirstate().walk(new DirstateDump());
tikhomirov@290: 		HgWorkingCopyStatusCollector wcc = HgWorkingCopyStatusCollector.create(hgRepo, new Path.Matcher.Any());
tikhomirov@290: 		wcc.getDirstate().walk(new HgDirstate.Inspector() {
tikhomirov@290: 			
tikhomirov@290: 			public boolean next(EntryKind kind, Record entry) {
tikhomirov@290: 				System.out.printf("%s %s\n", kind, entry.name());
tikhomirov@290: 				return true;
tikhomirov@290: 			}
tikhomirov@290: 		});
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@143: 	
tikhomirov@157: 	private void catCompleteHistory() throws Exception {
tikhomirov@143: 		DigestHelper dh = new DigestHelper();
tikhomirov@143: 		for (String fname : cmdLineOpts.getList("")) {
tikhomirov@143: 			System.out.println(fname);
tikhomirov@143: 			HgDataFile fn = hgRepo.getFileNode(fname);
tikhomirov@143: 			if (fn.exists()) {
tikhomirov@143: 				int total = fn.getRevisionCount();
tikhomirov@143: 				System.out.printf("Total revisions: %d\n", total);
tikhomirov@143: 				for (int i = 0; i < total; i++) {
tikhomirov@157: 					ByteArrayChannel sink = new ByteArrayChannel();
tikhomirov@157: 					fn.content(i, sink);
tikhomirov@143: 					System.out.println("==========>");
tikhomirov@157: 					byte[] content = sink.toArray();
tikhomirov@143: 					System.out.println(new String(content));
tikhomirov@143: 					int[] parentRevisions = new int[2];
tikhomirov@143: 					byte[] parent1 = new byte[20];
tikhomirov@143: 					byte[] parent2 = new byte[20];
tikhomirov@143: 					fn.parents(i, parentRevisions, parent1, parent2);
tikhomirov@143: 					System.out.println(dh.sha1(parent1, parent2, content).asHexString());
tikhomirov@143: 				}
tikhomirov@143: 			} else {
tikhomirov@143: 				System.out.println(">>>Not found!");
tikhomirov@143: 			}
tikhomirov@143: 		}
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@366: 	private void dumpCompleteManifestLow() throws Exception {
tikhomirov@143: 		hgRepo.getManifest().walk(0, TIP, new ManifestDump());
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@285: 	public static final class ManifestDump implements HgManifest.Inspector2 {
tikhomirov@222: 		public boolean begin(int manifestRevision, Nodeid nid, int changelogRevision) {
tikhomirov@222: 			System.out.printf("%d : %s\n", manifestRevision, nid);
tikhomirov@143: 			return true;
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public boolean next(Nodeid nid, String fname, String flags) {
tikhomirov@285: 			throw new HgBadStateException(HgManifest.Inspector2.class.getName());
tikhomirov@285: 		}
tikhomirov@285: 		public boolean next(Nodeid nid, Path fname, Flags flags) {
tikhomirov@143: 			System.out.println(nid + "\t" + fname + "\t\t" + flags);
tikhomirov@143: 			return true;
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public boolean end(int revision) {
tikhomirov@143: 			System.out.println();
tikhomirov@143: 			return true;
tikhomirov@143: 		}
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@366: 	private void dumpCompleteManifestHigh() throws Exception {
tikhomirov@143: 		new HgManifestCommand(hgRepo).dirs(true).execute(new HgManifestCommand.Handler() {
tikhomirov@143: 			
tikhomirov@143: 			public void begin(Nodeid manifestRevision) {
tikhomirov@143: 				System.out.println(">> " + manifestRevision);
tikhomirov@143: 			}
tikhomirov@143: 			public void dir(Path p) {
tikhomirov@143: 				System.out.println(p);
tikhomirov@143: 			}
tikhomirov@249: 			public void file(HgFileRevision fileRevision) {
tikhomirov@354: 				try {
tikhomirov@354: 					System.out.print(fileRevision.getRevision());;
tikhomirov@354: 					System.out.print("   ");
tikhomirov@354: 					System.out.printf("%s %s", fileRevision.getParents().first().shortNotation(), fileRevision.getParents().second().shortNotation());
tikhomirov@354: 					System.out.print("   ");
tikhomirov@354: 					System.out.println(fileRevision.getPath());
tikhomirov@354: 				} catch (HgException ex) {
tikhomirov@354: 					throw new HgCallbackTargetException.Wrap(ex);
tikhomirov@354: 				}
tikhomirov@143: 			}
tikhomirov@143: 			
tikhomirov@143: 			public void end(Nodeid manifestRevision) {
tikhomirov@143: 				System.out.println();
tikhomirov@143: 			}
tikhomirov@143: 		}); 
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@143: 	private void bunchOfTests() throws Exception {
tikhomirov@143: 		final StatusDump dump = new StatusDump();
tikhomirov@143: 		dump.showIgnored = false;
tikhomirov@143: 		dump.showClean = false;
tikhomirov@143: 		HgStatusCollector sc = new HgStatusCollector(hgRepo);
tikhomirov@143: 		final int r1 = 0, r2 = 3;
tikhomirov@143: 		System.out.printf("Status for changes between revision %d and %d:\n", r1, r2);
tikhomirov@143: 		sc.walk(r1, r2, dump);
tikhomirov@143: 		// 
tikhomirov@143: 		System.out.println("\n\nSame, but sorted in the way hg status does:");
tikhomirov@143: 		HgStatusCollector.Record r = sc.status(r1, r2);
tikhomirov@143: 		sortAndPrint('M', r.getModified(), null);
tikhomirov@143: 		sortAndPrint('A', r.getAdded(), null);
tikhomirov@143: 		sortAndPrint('R', r.getRemoved(), null);
tikhomirov@143: 		//
tikhomirov@143: 		System.out.println("\n\nTry hg status --change <rev>:");
tikhomirov@143: 		sc.change(0, dump);
tikhomirov@143: 		System.out.println("\nStatus against working dir:");
tikhomirov@143: 		HgWorkingCopyStatusCollector wcc = new HgWorkingCopyStatusCollector(hgRepo);
tikhomirov@143: 		wcc.walk(TIP, dump);
tikhomirov@143: 		System.out.println();
tikhomirov@143: 		System.out.printf("Manifest of the revision %d:\n", r2);
tikhomirov@143: 		hgRepo.getManifest().walk(r2, r2, new ManifestDump());
tikhomirov@143: 		System.out.println();
tikhomirov@143: 		System.out.printf("\nStatus of working dir against %d:\n", r2);
tikhomirov@143: 		r = wcc.status(r2);
tikhomirov@143: 		sortAndPrint('M', r.getModified(), null);
tikhomirov@143: 		sortAndPrint('A', r.getAdded(), r.getCopied());
tikhomirov@143: 		sortAndPrint('R', r.getRemoved(), null);
tikhomirov@143: 		sortAndPrint('?', r.getUnknown(), null);
tikhomirov@143: 		sortAndPrint('I', r.getIgnored(), null);
tikhomirov@143: 		sortAndPrint('C', r.getClean(), null);
tikhomirov@143: 		sortAndPrint('!', r.getMissing(), null);
tikhomirov@143: 	}
tikhomirov@143: 	
tikhomirov@143: 	private void sortAndPrint(char prefix, List<Path> ul, Map<Path, Path> copies) {
tikhomirov@143: 		ArrayList<Path> sortList = new ArrayList<Path>(ul);
tikhomirov@143: 		Collections.sort(sortList);
tikhomirov@143: 		for (Path s : sortList)  {
tikhomirov@143: 			System.out.print(prefix);
tikhomirov@143: 			System.out.print(' ');
tikhomirov@143: 			System.out.println(s);
tikhomirov@143: 			if (copies != null && copies.containsKey(s)) {
tikhomirov@143: 				System.out.println("  " + copies.get(s));
tikhomirov@143: 			}
tikhomirov@143: 		}
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@143: 
tikhomirov@354: 	private void testStatusInternals() throws HgException {
tikhomirov@143: 		HgDataFile n = hgRepo.getFileNode(Path.create("design.txt"));
tikhomirov@143: 		for (String s : new String[] {"011dfd44417c72bd9e54cf89b82828f661b700ed", "e5529faa06d53e06a816e56d218115b42782f1ba", "c18e7111f1fc89a80a00f6a39d51288289a382fc"}) {
tikhomirov@143: 			// expected: 359, 2123, 3079
tikhomirov@143: 			byte[] b = s.getBytes();
tikhomirov@143: 			final Nodeid nid = Nodeid.fromAscii(b, 0, b.length);
tikhomirov@143: 			System.out.println(s + " : " + n.length(nid));
tikhomirov@143: 		}
tikhomirov@143: 	}
tikhomirov@143: 
tikhomirov@197: 	static void force_gc() {
tikhomirov@197: 		Runtime.getRuntime().runFinalization();
tikhomirov@197: 		Runtime.getRuntime().gc();
tikhomirov@197: 		Thread.yield();
tikhomirov@197: 		Runtime.getRuntime().runFinalization();
tikhomirov@197: 		Runtime.getRuntime().gc();
tikhomirov@197: 		Thread.yield();
tikhomirov@197: 	}
tikhomirov@197: 
tikhomirov@143: 	private static class StatusDump implements HgStatusInspector {
tikhomirov@143: 		public boolean hideStatusPrefix = false; // hg status -n option
tikhomirov@143: 		public boolean showCopied = true; // -C
tikhomirov@143: 		public boolean showIgnored = true; // -i
tikhomirov@143: 		public boolean showClean = true; // -c
tikhomirov@143: 
tikhomirov@143: 		public void modified(Path fname) {
tikhomirov@143: 			print('M', fname);
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void added(Path fname) {
tikhomirov@143: 			print('A', fname);
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void copied(Path fnameOrigin, Path fnameAdded) {
tikhomirov@143: 			added(fnameAdded);
tikhomirov@143: 			if (showCopied) {
tikhomirov@143: 				print(' ', fnameOrigin);
tikhomirov@143: 			}
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void removed(Path fname) {
tikhomirov@143: 			print('R', fname);
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void clean(Path fname) {
tikhomirov@143: 			if (showClean) {
tikhomirov@143: 				print('C', fname);
tikhomirov@143: 			}
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void missing(Path fname) {
tikhomirov@143: 			print('!', fname);
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void unknown(Path fname) {
tikhomirov@143: 			print('?', fname);
tikhomirov@143: 		}
tikhomirov@143: 
tikhomirov@143: 		public void ignored(Path fname) {
tikhomirov@143: 			if (showIgnored) {
tikhomirov@143: 				print('I', fname);
tikhomirov@143: 			}
tikhomirov@143: 		}
tikhomirov@143: 		
tikhomirov@360: 		public void invalid(Path fname, Exception ex) {
tikhomirov@360: 			System.out.printf("FAILURE: %s\n", fname);
tikhomirov@360: 			ex.printStackTrace(System.out);
tikhomirov@360: 		}
tikhomirov@360: 		
tikhomirov@143: 		private void print(char status, Path fname) {
tikhomirov@143: 			if (!hideStatusPrefix) {
tikhomirov@143: 				System.out.print(status);
tikhomirov@143: 				System.out.print(' ');
tikhomirov@143: 			}
tikhomirov@143: 			System.out.println(fname);
tikhomirov@143: 		}
tikhomirov@143: 	}
tikhomirov@143: }