From 336eb70b51fe2328d4dd21fef3c78ba11e32758d Mon Sep 17 00:00:00 2001 From: Sasa Zivkov Date: Fri, 7 Dec 2012 16:41:32 +0100 Subject: [PATCH] Rename "GitReferenceUpdated replication" to "GitReferenceUpdated gitRefUpdated" The concept of replication is not a part of the Gerrit core any more. Rename all variables of type GitReferenceUpdated which were named "replication" to "gitRefUpdated". Also rename the "MetaDataUpdate.replicate" method to "fireGitRefUpdatedEvent" as this is exactly what it does. Change-Id: I4ebe9ce05849e5f35e344195e6e5b561a079a965 Signed-off-by: Sasa Zivkov --- .../rpc/changedetail/DeleteDraftChange.java | 8 ++++---- .../changedetail/EditCommitMessageHandler.java | 8 ++++---- .../gerrit/httpd/rpc/project/DeleteBranches.java | 8 ++++---- .../com/google/gerrit/server/ChangeUtil.java | 16 ++++++++-------- .../com/google/gerrit/server/change/Revert.java | 8 ++++---- .../server/changedetail/DeleteDraftPatchSet.java | 10 +++++----- .../gerrit/server/changedetail/RebaseChange.java | 8 ++++---- .../com/google/gerrit/server/git/CherryPick.java | 8 ++++---- .../com/google/gerrit/server/git/MergeOp.java | 8 ++++---- .../google/gerrit/server/git/MetaDataUpdate.java | 10 +++++----- .../google/gerrit/server/git/ReceiveCommits.java | 16 ++++++++-------- .../gerrit/server/git/SubmitStrategyFactory.java | 8 ++++---- .../google/gerrit/server/git/SubmoduleOp.java | 8 ++++---- .../gerrit/server/git/VersionedMetaData.java | 4 ++-- .../gerrit/server/git/SubmoduleOpTest.java | 16 ++++++++-------- 15 files changed, 72 insertions(+), 72 deletions(-) diff --git a/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/DeleteDraftChange.java b/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/DeleteDraftChange.java index ecd8b549c6..63c22cea8f 100644 --- a/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/DeleteDraftChange.java +++ b/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/DeleteDraftChange.java @@ -38,7 +38,7 @@ class DeleteDraftChange extends Handler { private final ChangeControl.Factory changeControlFactory; private final ReviewDb db; private final GitRepositoryManager gitManager; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final PatchSet.Id patchSetId; @@ -46,12 +46,12 @@ class DeleteDraftChange extends Handler { DeleteDraftChange(final ReviewDb db, final ChangeControl.Factory changeControlFactory, final GitRepositoryManager gitManager, - final GitReferenceUpdated replication, + final GitReferenceUpdated gitRefUpdated, @Assisted final PatchSet.Id patchSetId) { this.changeControlFactory = changeControlFactory; this.db = db; this.gitManager = gitManager; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.patchSetId = patchSetId; } @@ -65,7 +65,7 @@ class DeleteDraftChange extends Handler { throw new NoSuchChangeException(changeId); } - ChangeUtil.deleteDraftChange(patchSetId, gitManager, replication, db); + ChangeUtil.deleteDraftChange(patchSetId, gitManager, gitRefUpdated, db); return VoidResult.INSTANCE; } } diff --git a/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/EditCommitMessageHandler.java b/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/EditCommitMessageHandler.java index c38bda72a4..f7f8da655e 100644 --- a/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/EditCommitMessageHandler.java +++ b/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/changedetail/EditCommitMessageHandler.java @@ -60,7 +60,7 @@ class EditCommitMessageHandler extends Handler { private final ChangeDetailFactory.Factory changeDetailFactory; private final CommitMessageEditedSender.Factory commitMessageEditedSenderFactory; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final PatchSet.Id patchSetId; @Nullable @@ -84,7 +84,7 @@ class EditCommitMessageHandler extends Handler { final CommitValidators.Factory commitValidatorsFactory, final GitRepositoryManager gitManager, final PatchSetInfoFactory patchSetInfoFactory, - final GitReferenceUpdated replication, + final GitReferenceUpdated gitRefUpdated, @GerritPersonIdent final PersonIdent myIdent) { this.changeControlFactory = changeControlFactory; this.db = db; @@ -99,7 +99,7 @@ class EditCommitMessageHandler extends Handler { this.gitManager = gitManager; this.patchSetInfoFactory = patchSetInfoFactory; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.myIdent = myIdent; } @@ -127,7 +127,7 @@ class EditCommitMessageHandler extends Handler { commitValidatorsFactory.create(control.getRefControl(), new NoSshInfo(), git); ChangeUtil.editCommitMessage(patchSetId, control.getRefControl(), commitValidators, currentUser, message, db, - commitMessageEditedSenderFactory, hooks, git, patchSetInfoFactory, replication, myIdent); + commitMessageEditedSenderFactory, hooks, git, patchSetInfoFactory, gitRefUpdated, myIdent); return changeDetailFactory.create(changeId).call(); } finally { diff --git a/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/project/DeleteBranches.java b/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/project/DeleteBranches.java index de3a475a2b..8f5430dd37 100644 --- a/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/project/DeleteBranches.java +++ b/gerrit-httpd/src/main/java/com/google/gerrit/httpd/rpc/project/DeleteBranches.java @@ -50,7 +50,7 @@ class DeleteBranches extends Handler> { private final ProjectControl.Factory projectControlFactory; private final GitRepositoryManager repoManager; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final IdentifiedUser identifiedUser; private final ChangeHooks hooks; private final ReviewDb db; @@ -61,7 +61,7 @@ class DeleteBranches extends Handler> { @Inject DeleteBranches(final ProjectControl.Factory projectControlFactory, final GitRepositoryManager repoManager, - final GitReferenceUpdated replication, + final GitReferenceUpdated gitRefUpdated, final IdentifiedUser identifiedUser, final ChangeHooks hooks, final ReviewDb db, @@ -69,7 +69,7 @@ class DeleteBranches extends Handler> { @Assisted Project.NameKey name, @Assisted Set toRemove) { this.projectControlFactory = projectControlFactory; this.repoManager = repoManager; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.identifiedUser = identifiedUser; this.hooks = hooks; this.db = db; @@ -121,7 +121,7 @@ class DeleteBranches extends Handler> { case FAST_FORWARD: case FORCED: deleted.add(branchKey); - replication.fire(projectName, u); + gitRefUpdated.fire(projectName, u); hooks.doRefUpdatedHook(branchKey, u, identifiedUser.getAccount()); break; diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/ChangeUtil.java b/gerrit-server/src/main/java/com/google/gerrit/server/ChangeUtil.java index 3c9e100a25..e539c3d524 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/ChangeUtil.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/ChangeUtil.java @@ -198,7 +198,7 @@ public class ChangeUtil { final RevertedSender.Factory revertedSenderFactory, final ChangeHooks hooks, Repository git, final PatchSetInfoFactory patchSetInfoFactory, - final GitReferenceUpdated replication, PersonIdent myIdent, + final GitReferenceUpdated gitRefUpdated, PersonIdent myIdent, String canonicalWebUrl) throws NoSuchChangeException, EmailException, OrmException, MissingObjectException, IncorrectObjectTypeException, IOException, InvalidChangeOperationException { @@ -279,7 +279,7 @@ public class ChangeUtil { "Failed to create ref %s in %s: %s", ps.getRefName(), change.getDest().getParentKey().get(), ru.getResult())); } - replication.fire(change.getProject(), ru); + gitRefUpdated.fire(change.getProject(), ru); db.changes().beginTransaction(change.getId()); try { @@ -321,7 +321,7 @@ public class ChangeUtil { final CommitMessageEditedSender.Factory commitMessageEditedSenderFactory, final ChangeHooks hooks, Repository git, final PatchSetInfoFactory patchSetInfoFactory, - final GitReferenceUpdated replication, PersonIdent myIdent) + final GitReferenceUpdated gitRefUpdated, PersonIdent myIdent) throws NoSuchChangeException, EmailException, OrmException, MissingObjectException, IncorrectObjectTypeException, IOException, InvalidChangeOperationException, PatchSetInfoNotAvailableException { @@ -397,7 +397,7 @@ public class ChangeUtil { "Failed to create ref %s in %s: %s", newPatchSet.getRefName(), change.getDest().getParentKey().get(), ru.getResult())); } - replication.fire(change.getProject(), ru); + gitRefUpdated.fire(change.getProject(), ru); db.changes().beginTransaction(change.getId()); try { @@ -463,7 +463,7 @@ public class ChangeUtil { public static void deleteDraftChange(final PatchSet.Id patchSetId, GitRepositoryManager gitManager, - final GitReferenceUpdated replication, final ReviewDb db) + final GitReferenceUpdated gitRefUpdated, final ReviewDb db) throws NoSuchChangeException, OrmException, IOException { final Change.Id changeId = patchSetId.getParentKey(); final Change change = db.changes().get(changeId); @@ -473,7 +473,7 @@ public class ChangeUtil { for (PatchSet ps : db.patchSets().byChange(changeId)) { // These should all be draft patch sets. - deleteOnlyDraftPatchSet(ps, change, gitManager, replication, db); + deleteOnlyDraftPatchSet(ps, change, gitManager, gitRefUpdated, db); } db.changeMessages().delete(db.changeMessages().byChange(changeId)); @@ -484,7 +484,7 @@ public class ChangeUtil { public static void deleteOnlyDraftPatchSet(final PatchSet patch, final Change change, GitRepositoryManager gitManager, - final GitReferenceUpdated replication, final ReviewDb db) + final GitReferenceUpdated gitRefUpdated, final ReviewDb db) throws NoSuchChangeException, OrmException, IOException { final PatchSet.Id patchSetId = patch.getId(); if (patch == null || !patch.isDraft()) { @@ -507,7 +507,7 @@ public class ChangeUtil { throw new IOException("Failed to delete ref " + patch.getRefName() + " in " + repo.getDirectory() + ": " + update.getResult()); } - replication.fire(change.getProject(), update); + gitRefUpdated.fire(change.getProject(), update); } finally { repo.close(); } diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/change/Revert.java b/gerrit-server/src/main/java/com/google/gerrit/server/change/Revert.java index e365a8a6cc..c268530933 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/change/Revert.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/change/Revert.java @@ -53,7 +53,7 @@ public class Revert implements RestModifyView { private final GitRepositoryManager gitManager; private final PersonIdent myIdent; private final PatchSetInfoFactory patchSetInfoFactory; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final String canonicalWebUrl; public static class Input { @@ -68,7 +68,7 @@ public class Revert implements RestModifyView { ChangeJson json, GitRepositoryManager gitManager, final PatchSetInfoFactory patchSetInfoFactory, - final GitReferenceUpdated replication, + final GitReferenceUpdated gitRefUpdated, @GerritPersonIdent final PersonIdent myIdent, @CanonicalWebUrl @Nullable final String canonicalWebUrl) { this.hooks = hooks; @@ -78,7 +78,7 @@ public class Revert implements RestModifyView { this.json = json; this.gitManager = gitManager; this.myIdent = myIdent; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.patchSetInfoFactory = patchSetInfoFactory; this.canonicalWebUrl = canonicalWebUrl; } @@ -104,7 +104,7 @@ public class Revert implements RestModifyView { commitValidators, Strings.emptyToNull(input.message), dbProvider.get(), revertedSenderFactory, hooks, git, patchSetInfoFactory, - replication, myIdent, canonicalWebUrl); + gitRefUpdated, myIdent, canonicalWebUrl); return json.format(revertedChangeId); } catch (InvalidChangeOperationException e) { diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/DeleteDraftPatchSet.java b/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/DeleteDraftPatchSet.java index e29856bdad..adec292ac2 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/DeleteDraftPatchSet.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/DeleteDraftPatchSet.java @@ -44,7 +44,7 @@ public class DeleteDraftPatchSet implements Callable { private final ChangeControl.Factory changeControlFactory; private final ReviewDb db; private final GitRepositoryManager gitManager; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final PatchSetInfoFactory patchSetInfoFactory; private final PatchSet.Id patchSetId; @@ -52,12 +52,12 @@ public class DeleteDraftPatchSet implements Callable { @Inject DeleteDraftPatchSet(ChangeControl.Factory changeControlFactory, ReviewDb db, GitRepositoryManager gitManager, - GitReferenceUpdated replication, PatchSetInfoFactory patchSetInfoFactory, + GitReferenceUpdated gitRefUpdated, PatchSetInfoFactory patchSetInfoFactory, @Assisted final PatchSet.Id patchSetId) { this.changeControlFactory = changeControlFactory; this.db = db; this.gitManager = gitManager; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.patchSetInfoFactory = patchSetInfoFactory; this.patchSetId = patchSetId; @@ -88,7 +88,7 @@ public class DeleteDraftPatchSet implements Callable { final Change change = control.getChange(); try { - ChangeUtil.deleteOnlyDraftPatchSet(patch, change, gitManager, replication, db); + ChangeUtil.deleteOnlyDraftPatchSet(patch, change, gitManager, gitRefUpdated, db); } catch (IOException e) { result.addError(new ReviewResult.Error( ReviewResult.Error.Type.GIT_ERROR, e.getMessage())); @@ -97,7 +97,7 @@ public class DeleteDraftPatchSet implements Callable { List restOfPatches = db.patchSets().byChange(changeId).toList(); if (restOfPatches.size() == 0) { try { - ChangeUtil.deleteDraftChange(patchSetId, gitManager, replication, db); + ChangeUtil.deleteDraftChange(patchSetId, gitManager, gitRefUpdated, db); result.setChangeId(null); } catch (IOException e) { result.addError(new ReviewResult.Error( diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/RebaseChange.java b/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/RebaseChange.java index 9031b47c24..98c0133f8b 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/RebaseChange.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/changedetail/RebaseChange.java @@ -68,7 +68,7 @@ public class RebaseChange { private final ReviewDb db; private final GitRepositoryManager gitManager; private final PersonIdent myIdent; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final RebasedPatchSetSender.Factory rebasedPatchSetSenderFactory; private final ChangeHookRunner hooks; private final ApprovalsUtil approvalsUtil; @@ -78,7 +78,7 @@ public class RebaseChange { final PatchSetInfoFactory patchSetInfoFactory, final ReviewDb db, @GerritPersonIdent final PersonIdent myIdent, final GitRepositoryManager gitManager, - final GitReferenceUpdated replication, + final GitReferenceUpdated gitRefUpdated, final RebasedPatchSetSender.Factory rebasedPatchSetSenderFactory, final ChangeHookRunner hooks, final ApprovalsUtil approvalsUtil) { this.changeControlFactory = changeControlFactory; @@ -86,7 +86,7 @@ public class RebaseChange { this.db = db; this.gitManager = gitManager; this.myIdent = myIdent; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.rebasedPatchSetSenderFactory = rebasedPatchSetSenderFactory; this.hooks = hooks; this.approvalsUtil = approvalsUtil; @@ -333,7 +333,7 @@ public class RebaseChange { newPatchSet.getRefName(), change.getDest().getParentKey().get(), ru.getResult())); } - replication.fire(change.getProject(), ru); + gitRefUpdated.fire(change.getProject(), ru); db.changes().beginTransaction(change.getId()); try { diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/CherryPick.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/CherryPick.java index 1581791cd8..8289ffe617 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/CherryPick.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/CherryPick.java @@ -54,19 +54,19 @@ public class CherryPick extends SubmitStrategy { private final PatchSetInfoFactory patchSetInfoFactory; private final Provider urlProvider; private final ApprovalTypes approvalTypes; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final Map newCommits; CherryPick(final SubmitStrategy.Arguments args, final PatchSetInfoFactory patchSetInfoFactory, final Provider urlProvider, final ApprovalTypes approvalTypes, - final GitReferenceUpdated replication) { + final GitReferenceUpdated gitRefUpdated) { super(args); this.patchSetInfoFactory = patchSetInfoFactory; this.urlProvider = urlProvider; this.approvalTypes = approvalTypes; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.newCommits = new HashMap(); } @@ -202,7 +202,7 @@ public class CherryPick extends SubmitStrategy { ru.getResult())); } - replication.fire(n.change.getProject(), ru); + gitRefUpdated.fire(n.change.getProject(), ru); newCommit.copyFrom(n); newCommit.statusCode = CommitMergeStatus.CLEAN_PICK; diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/MergeOp.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/MergeOp.java index 552fc072fc..dc0cf8efc4 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/MergeOp.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/MergeOp.java @@ -122,7 +122,7 @@ public class MergeOp { private final SchemaFactory schemaFactory; private final ProjectCache projectCache; private final FunctionState.Factory functionState; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final MergedSender.Factory mergedSenderFactory; private final MergeFailSender.Factory mergeFailSenderFactory; private final ApprovalTypes approvalTypes; @@ -159,7 +159,7 @@ public class MergeOp { @Inject MergeOp(final GitRepositoryManager grm, final SchemaFactory sf, final ProjectCache pc, final FunctionState.Factory fs, - final GitReferenceUpdated rq, final MergedSender.Factory msf, + final GitReferenceUpdated gru, final MergedSender.Factory msf, final MergeFailSender.Factory mfsf, final ApprovalTypes approvalTypes, final PatchSetInfoFactory psif, final IdentifiedUser.GenericFactory iuf, @@ -177,7 +177,7 @@ public class MergeOp { schemaFactory = sf; functionState = fs; projectCache = pc; - replication = rq; + gitRefUpdated = gru; mergedSenderFactory = msf; mergeFailSenderFactory = mfsf; this.approvalTypes = approvalTypes; @@ -686,7 +686,7 @@ public class MergeOp { destProject.getProject().getDescription()); } - replication.fire(destBranch.getParentKey(), branchUpdate); + gitRefUpdated.fire(destBranch.getParentKey(), branchUpdate); Account account = null; final PatchSetApproval submitter = getSubmitter(db, mergeTip.patchsetId); diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/MetaDataUpdate.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/MetaDataUpdate.java index 215f73a677..dc08a6c4e9 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/MetaDataUpdate.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/MetaDataUpdate.java @@ -88,15 +88,15 @@ public class MetaDataUpdate { @Assisted Repository db); } - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final Project.NameKey projectName; private final Repository db; private final CommitBuilder commit; @Inject - public MetaDataUpdate(GitReferenceUpdated replication, + public MetaDataUpdate(GitReferenceUpdated gitRefUpdated, @Assisted Project.NameKey projectName, @Assisted Repository db) { - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.projectName = projectName; this.db = db; this.commit = new CommitBuilder(); @@ -130,7 +130,7 @@ public class MetaDataUpdate { return commit; } - void replicate(RefUpdate ru) { - replication.fire(projectName, ru); + void fireGitRefUpdatedEvent(RefUpdate ru) { + gitRefUpdated.fire(projectName, ru); } } diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/ReceiveCommits.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/ReceiveCommits.java index 9a73c9bf82..d80fc24c85 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/ReceiveCommits.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/ReceiveCommits.java @@ -235,7 +235,7 @@ public class ReceiveCommits { private final CreateChangeSender.Factory createChangeSenderFactory; private final MergedSender.Factory mergedSenderFactory; private final ReplacePatchSetSender.Factory replacePatchSetFactory; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final PatchSetInfoFactory patchSetInfoFactory; private final ChangeHooks hooks; private final ApprovalsUtil approvalsUtil; @@ -289,7 +289,7 @@ public class ReceiveCommits { final CreateChangeSender.Factory createChangeSenderFactory, final MergedSender.Factory mergedSenderFactory, final ReplacePatchSetSender.Factory replacePatchSetFactory, - final GitReferenceUpdated replication, + final GitReferenceUpdated gitRefUpdated, final PatchSetInfoFactory patchSetInfoFactory, final ChangeHooks hooks, final ApprovalsUtil approvalsUtil, @@ -316,7 +316,7 @@ public class ReceiveCommits { this.createChangeSenderFactory = createChangeSenderFactory; this.mergedSenderFactory = mergedSenderFactory; this.replacePatchSetFactory = replacePatchSetFactory; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.patchSetInfoFactory = patchSetInfoFactory; this.hooks = hooks; this.approvalsUtil = approvalsUtil; @@ -586,10 +586,10 @@ public class ReceiveCommits { } if (!MagicBranch.isMagicBranch(c.getRefName())) { - // We only schedule direct refs updates for replication. - // Change refs are scheduled when they are created. + // We only fire gitRefUpdated for direct refs updates. + // Events for change refs are fired when they are created. // - replication.fire(project.getNameKey(), c.getRefName(), + gitRefUpdated.fire(project.getNameKey(), c.getRefName(), c.getOldId(), c.getNewId()); hooks.doRefUpdatedHook( new Branch.NameKey(project.getNameKey(), c.getRefName()), @@ -1384,7 +1384,7 @@ public class ReceiveCommits { } created = true; - replication.fire(project.getNameKey(), ps.getRefName(), + gitRefUpdated.fire(project.getNameKey(), ps.getRefName(), ObjectId.zeroId(), commit); hooks.doPatchsetCreatedHook(change, ps, db); workQueue.getDefaultQueue() @@ -1747,7 +1747,7 @@ public class ReceiveCommits { if (cmd.getResult() == NOT_ATTEMPTED) { cmd.execute(rp); } - replication.fire(project.getNameKey(), newPatchSet.getRefName(), + gitRefUpdated.fire(project.getNameKey(), newPatchSet.getRefName(), ObjectId.zeroId(), newCommit); hooks.doPatchsetCreatedHook(change, newPatchSet, db); if (mergedIntoRef != null) { diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmitStrategyFactory.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmitStrategyFactory.java index b0f52f5af8..27754af48c 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmitStrategyFactory.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmitStrategyFactory.java @@ -50,7 +50,7 @@ public class SubmitStrategyFactory { private final PatchSetInfoFactory patchSetInfoFactory; private final Provider urlProvider; private final ApprovalTypes approvalTypes; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final RebaseChange rebaseChange; @Inject @@ -59,14 +59,14 @@ public class SubmitStrategyFactory { @GerritPersonIdent final PersonIdent myIdent, final PatchSetInfoFactory patchSetInfoFactory, @CanonicalWebUrl @Nullable final Provider urlProvider, - final ApprovalTypes approvalTypes, final GitReferenceUpdated replication, + final ApprovalTypes approvalTypes, final GitReferenceUpdated gitRefUpdated, final RebaseChange rebaseChange) { this.identifiedUserFactory = identifiedUserFactory; this.myIdent = myIdent; this.patchSetInfoFactory = patchSetInfoFactory; this.urlProvider = urlProvider; this.approvalTypes = approvalTypes; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; this.rebaseChange = rebaseChange; } @@ -82,7 +82,7 @@ public class SubmitStrategyFactory { switch (submitType) { case CHERRY_PICK: return new CherryPick(args, patchSetInfoFactory, urlProvider, - approvalTypes, replication); + approvalTypes, gitRefUpdated); case FAST_FORWARD_ONLY: return new FastForwardOnly(args); case MERGE_ALWAYS: diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmoduleOp.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmoduleOp.java index a3a004035b..eeab8f33d5 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmoduleOp.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/SubmoduleOp.java @@ -85,7 +85,7 @@ public class SubmoduleOp { private final Map commits; private final PersonIdent myIdent; private final GitRepositoryManager repoManager; - private final GitReferenceUpdated replication; + private final GitReferenceUpdated gitRefUpdated; private final SchemaFactory schemaFactory; private final Set updatedSubscribers; @@ -97,7 +97,7 @@ public class SubmoduleOp { @Assisted Project destProject, @Assisted List submitted, @Assisted final Map commits, @GerritPersonIdent final PersonIdent myIdent, - GitRepositoryManager repoManager, GitReferenceUpdated replication) { + GitRepositoryManager repoManager, GitReferenceUpdated gitRefUpdated) { this.destBranch = destBranch; this.mergeTip = mergeTip; this.rw = rw; @@ -109,7 +109,7 @@ public class SubmoduleOp { this.commits = commits; this.myIdent = myIdent; this.repoManager = repoManager; - this.replication = replication; + this.gitRefUpdated = gitRefUpdated; updatedSubscribers = new HashSet(); } @@ -337,7 +337,7 @@ public class SubmoduleOp { switch (rfu.update()) { case NEW: case FAST_FORWARD: - replication.fire(subscriber.getParentKey(), rfu); + gitRefUpdated.fire(subscriber.getParentKey(), rfu); // TODO since this is performed "in the background" no mail will be // sent to inform users about the updated branch break; diff --git a/gerrit-server/src/main/java/com/google/gerrit/server/git/VersionedMetaData.java b/gerrit-server/src/main/java/com/google/gerrit/server/git/VersionedMetaData.java index 1ffe462148..7c3c0c7904 100644 --- a/gerrit-server/src/main/java/com/google/gerrit/server/git/VersionedMetaData.java +++ b/gerrit-server/src/main/java/com/google/gerrit/server/git/VersionedMetaData.java @@ -260,7 +260,7 @@ public abstract class VersionedMetaData { switch (result) { case NEW: revision = rw.parseCommit(ru.getNewObjectId()); - update.replicate(ru); + update.fireGitRefUpdatedEvent(ru); return revision; default: throw new IOException("Cannot update " + ru.getName() + " in " @@ -293,7 +293,7 @@ public abstract class VersionedMetaData { case NEW: case FAST_FORWARD: revision = rw.parseCommit(ru.getNewObjectId()); - update.replicate(ru); + update.fireGitRefUpdatedEvent(ru); return revision; default: diff --git a/gerrit-server/src/test/java/com/google/gerrit/server/git/SubmoduleOpTest.java b/gerrit-server/src/test/java/com/google/gerrit/server/git/SubmoduleOpTest.java index 104ae1b639..322ffe212f 100644 --- a/gerrit-server/src/test/java/com/google/gerrit/server/git/SubmoduleOpTest.java +++ b/gerrit-server/src/test/java/com/google/gerrit/server/git/SubmoduleOpTest.java @@ -77,7 +77,7 @@ public class SubmoduleOpTest extends LocalDiskRepositoryTestCase { private ReviewDb schema; private Provider urlProvider; private GitRepositoryManager repoManager; - private GitReferenceUpdated replication; + private GitReferenceUpdated gitRefUpdated; @SuppressWarnings("unchecked") @Override @@ -90,17 +90,17 @@ public class SubmoduleOpTest extends LocalDiskRepositoryTestCase { subscriptions = createStrictMock(SubmoduleSubscriptionAccess.class); urlProvider = createStrictMock(Provider.class); repoManager = createStrictMock(GitRepositoryManager.class); - replication = createStrictMock(GitReferenceUpdated.class); + gitRefUpdated = createStrictMock(GitReferenceUpdated.class); } private void doReplay() { replay(schemaFactory, schema, subscriptions, urlProvider, repoManager, - replication); + gitRefUpdated); } private void doVerify() { verify(schemaFactory, schema, subscriptions, urlProvider, repoManager, - replication); + gitRefUpdated); } /** @@ -645,7 +645,7 @@ public class SubmoduleOpTest extends LocalDiskRepositoryTestCase { .andReturn(targetRepository); Capture ruCapture = new Capture(); - replication.fire(eq(targetBranchNameKey.getParentKey()), + gitRefUpdated.fire(eq(targetBranchNameKey.getParentKey()), capture(ruCapture)); expect(schema.submoduleSubscriptions()).andReturn(subscriptions); @@ -665,7 +665,7 @@ public class SubmoduleOpTest extends LocalDiskRepositoryTestCase { new SubmoduleOp(sourceBranchNameKey, sourceMergeTip, new RevWalk( sourceRepository), urlProvider, schemaFactory, sourceRepository, new Project(sourceBranchNameKey.getParentKey()), submitted, - mergedCommits, myIdent, repoManager, replication); + mergedCommits, myIdent, repoManager, gitRefUpdated); submoduleOp.update(); @@ -749,7 +749,7 @@ public class SubmoduleOpTest extends LocalDiskRepositoryTestCase { .andReturn(targetRepository); Capture ruCapture = new Capture(); - replication.fire(eq(targetBranchNameKey.getParentKey()), + gitRefUpdated.fire(eq(targetBranchNameKey.getParentKey()), capture(ruCapture)); expect(schema.submoduleSubscriptions()).andReturn(subscriptions); @@ -771,7 +771,7 @@ public class SubmoduleOpTest extends LocalDiskRepositoryTestCase { new SubmoduleOp(sourceBranchNameKey, sourceMergeTip, new RevWalk( sourceRepository), urlProvider, schemaFactory, sourceRepository, new Project(sourceBranchNameKey.getParentKey()), submitted, - mergedCommits, myIdent, repoManager, replication); + mergedCommits, myIdent, repoManager, gitRefUpdated); submoduleOp.update();