# HG changeset patch # User Dmitry Neverov # Date 1412166091 -7200 # Node ID b06ea5c379cc6ba9ba733ec81f3e2f93aff24e77 # Parent 894b7e0c9dd61c2972423bad08d31685812a056e more progress for 'hg pull' commands diff -r 894b7e0c9dd6 -r b06ea5c379cc mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/MercurialCollectChangesPolicy.java --- a/mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/MercurialCollectChangesPolicy.java Tue Sep 30 18:45:16 2014 +0200 +++ b/mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/MercurialCollectChangesPolicy.java Wed Oct 01 14:21:31 2014 +0200 @@ -110,7 +110,7 @@ if (toRevision.equals(fromRevision) || fromRevision == null) continue; - Collection fromRevisions = ctx.getFromRevisionsForBranch(hgRoot, fromRevision, toRevision); + Collection fromRevisions = ctx.getFromRevisionsForBranch(hgRoot, fromRevision, toRevision, ctx.getProgressConsumer()); List branchChanges = collectChanges(ctx, root, fromRevisions, toRevision, rules); for (ModificationData change : branchChanges) { if (!ctx.isReportedModification(change)) { @@ -193,9 +193,7 @@ @Nullable String currentVersion, @NotNull CheckoutRules checkoutRules) throws VcsException { HgVcsRoot hgRoot = myHgVcsRootFactory.createHgRoot(root); - SyncSettings settings = new SyncSettings(VcsCallable.NO_OP); - settings.setProgressConsumer(ctx.getProgressConsumer()); - ctx.syncRepository(hgRoot); + ctx.syncRepository(hgRoot, ctx.getProgressConsumer()); List result = new ArrayList(); List csets = getChangesets(ctx, hgRoot, fromVersion, currentVersion); //When commit has no changes in subrepo configuration we can reuse diff -r 894b7e0c9dd6 -r b06ea5c379cc mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/OperationContext.java --- a/mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/OperationContext.java Tue Sep 30 18:45:16 2014 +0200 +++ b/mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/OperationContext.java Wed Oct 01 14:21:31 2014 +0200 @@ -81,11 +81,13 @@ myUninterestingRevisions = new HashSet(fromVersions); } - public void syncRepository(@NotNull final HgVcsRoot root) throws VcsException { + public void syncRepository(@NotNull HgVcsRoot root, @Nullable ProgressParser.ProgressConsumer progressConsumer) throws VcsException { File dir = myVcs.getWorkingDir(root); if (mySyncedDirs.contains(dir)) return; - myVcs.syncRepository(root); + SyncSettings settings = new SyncSettings(VcsCallable.NO_OP); + settings.setProgressConsumer(progressConsumer); + myVcs.syncRepository(root, settings); mySyncedDirs.add(dir); } @@ -210,8 +212,9 @@ @NotNull public Collection getFromRevisionsForBranch(@NotNull HgVcsRoot root, @NotNull String fromRevision, - @NotNull String toRevision) throws VcsException { - syncRepository(root); + @NotNull String toRevision, + @Nullable ProgressParser.ProgressConsumer progressConsumer) throws VcsException { + syncRepository(root, progressConsumer); ServerHgRepo repo = createRepo(root, myVcs.getWorkingDir(root)); if (!repo.supportRevsets())