Remove extraReviewers arg from (Async)ReceiveCommits.Factory

This is never used to pass anything other than an empty multimap,
including internally at Google.

Change-Id: I9ba7fd3a1faf325d5b5b2fa324e7fee68c1ed324
This commit is contained in:
Dave Borowitz
2018-10-05 15:08:17 -07:00
parent 8fb9b490ca
commit 619a1a5852
5 changed files with 6 additions and 26 deletions

View File

@@ -14,7 +14,6 @@
package com.google.gerrit.acceptance; package com.google.gerrit.acceptance;
import com.google.common.collect.ImmutableSetMultimap;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.gerrit.acceptance.InProcessProtocol.Context; import com.google.gerrit.acceptance.InProcessProtocol.Context;
import com.google.gerrit.common.data.Capable; import com.google.gerrit.common.data.Capable;
@@ -330,8 +329,7 @@ class InProcessProtocol extends TestProtocol<Context> {
throw new RuntimeException(String.format("project %s not found", req.project)); throw new RuntimeException(String.format("project %s not found", req.project));
} }
AsyncReceiveCommits arc = AsyncReceiveCommits arc = factory.create(projectState, identifiedUser, db, null);
factory.create(projectState, identifiedUser, db, null, ImmutableSetMultimap.of());
if (arc.canUpload() != Capable.OK) { if (arc.canUpload() != Capable.OK) {
throw new ServiceNotAuthorizedException(); throw new ServiceNotAuthorizedException();
} }

View File

@@ -15,7 +15,6 @@
package com.google.gerrit.httpd; package com.google.gerrit.httpd;
import com.google.common.cache.Cache; import com.google.common.cache.Cache;
import com.google.common.collect.ImmutableSetMultimap;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.gerrit.common.data.Capable; import com.google.gerrit.common.data.Capable;
import com.google.gerrit.extensions.registration.DynamicSet; import com.google.gerrit.extensions.registration.DynamicSet;
@@ -308,8 +307,7 @@ public class GitOverHttpServlet extends GitServlet {
} }
AsyncReceiveCommits arc = AsyncReceiveCommits arc =
factory.create( factory.create(state, userProvider.get().asIdentifiedUser(), db, null);
state, userProvider.get().asIdentifiedUser(), db, null, ImmutableSetMultimap.of());
ReceivePack rp = arc.getReceivePack(); ReceivePack rp = arc.getReceivePack();
req.setAttribute(ATT_ARC, arc); req.setAttribute(ATT_ARC, arc);
return rp; return rp;

View File

@@ -14,13 +14,11 @@
package com.google.gerrit.server.git.receive; package com.google.gerrit.server.git.receive;
import com.google.common.collect.SetMultimap;
import com.google.common.flogger.FluentLogger; import com.google.common.flogger.FluentLogger;
import com.google.gerrit.common.Nullable; import com.google.gerrit.common.Nullable;
import com.google.gerrit.common.data.Capable; import com.google.gerrit.common.data.Capable;
import com.google.gerrit.extensions.restapi.AuthException; import com.google.gerrit.extensions.restapi.AuthException;
import com.google.gerrit.extensions.restapi.ResourceConflictException; import com.google.gerrit.extensions.restapi.ResourceConflictException;
import com.google.gerrit.reviewdb.client.Account;
import com.google.gerrit.reviewdb.client.Project; import com.google.gerrit.reviewdb.client.Project;
import com.google.gerrit.server.IdentifiedUser; import com.google.gerrit.server.IdentifiedUser;
import com.google.gerrit.server.config.ConfigUtil; import com.google.gerrit.server.config.ConfigUtil;
@@ -30,7 +28,6 @@ import com.google.gerrit.server.git.DefaultAdvertiseRefsHook;
import com.google.gerrit.server.git.MultiProgressMonitor; import com.google.gerrit.server.git.MultiProgressMonitor;
import com.google.gerrit.server.git.ProjectRunnable; import com.google.gerrit.server.git.ProjectRunnable;
import com.google.gerrit.server.git.TransferConfig; import com.google.gerrit.server.git.TransferConfig;
import com.google.gerrit.server.notedb.ReviewerStateInternal;
import com.google.gerrit.server.permissions.PermissionBackend; import com.google.gerrit.server.permissions.PermissionBackend;
import com.google.gerrit.server.permissions.PermissionBackend.RefFilterOptions; import com.google.gerrit.server.permissions.PermissionBackend.RefFilterOptions;
import com.google.gerrit.server.permissions.PermissionBackendException; import com.google.gerrit.server.permissions.PermissionBackendException;
@@ -82,8 +79,7 @@ public class AsyncReceiveCommits implements PreReceiveHook {
ProjectState projectState, ProjectState projectState,
IdentifiedUser user, IdentifiedUser user,
Repository repository, Repository repository,
@Nullable MessageSender messageSender, @Nullable MessageSender messageSender);
SetMultimap<ReviewerStateInternal, Account.Id> extraReviewers);
} }
public static class Module extends PrivateModule { public static class Module extends PrivateModule {
@@ -196,8 +192,7 @@ public class AsyncReceiveCommits implements PreReceiveHook {
@Assisted ProjectState projectState, @Assisted ProjectState projectState,
@Assisted IdentifiedUser user, @Assisted IdentifiedUser user,
@Assisted Repository repo, @Assisted Repository repo,
@Assisted @Nullable MessageSender messageSender, @Assisted @Nullable MessageSender messageSender)
@Assisted SetMultimap<ReviewerStateInternal, Account.Id> extraReviewers)
throws PermissionBackendException { throws PermissionBackendException {
this.executor = executor; this.executor = executor;
this.scopePropagator = scopePropagator; this.scopePropagator = scopePropagator;
@@ -242,9 +237,7 @@ public class AsyncReceiveCommits implements PreReceiveHook {
advHooks.add(new HackPushNegotiateHook()); advHooks.add(new HackPushNegotiateHook());
receivePack.setAdvertiseRefsHook(AdvertiseRefsHookChain.newChain(advHooks)); receivePack.setAdvertiseRefsHook(AdvertiseRefsHookChain.newChain(advHooks));
receiveCommits = receiveCommits = factory.create(projectState, user, receivePack, allRefsWatcher, messageSender);
factory.create(
projectState, user, receivePack, allRefsWatcher, extraReviewers, messageSender);
receiveCommits.init(); receiveCommits.init();
} }

View File

@@ -47,14 +47,12 @@ import com.google.common.base.Throwables;
import com.google.common.collect.BiMap; import com.google.common.collect.BiMap;
import com.google.common.collect.HashBiMap; import com.google.common.collect.HashBiMap;
import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableSetMultimap;
import com.google.common.collect.Iterables; import com.google.common.collect.Iterables;
import com.google.common.collect.LinkedListMultimap; import com.google.common.collect.LinkedListMultimap;
import com.google.common.collect.ListMultimap; import com.google.common.collect.ListMultimap;
import com.google.common.collect.Lists; import com.google.common.collect.Lists;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
import com.google.common.collect.MultimapBuilder; import com.google.common.collect.MultimapBuilder;
import com.google.common.collect.SetMultimap;
import com.google.common.collect.Sets; import com.google.common.collect.Sets;
import com.google.common.collect.SortedSetMultimap; import com.google.common.collect.SortedSetMultimap;
import com.google.common.flogger.FluentLogger; import com.google.common.flogger.FluentLogger;
@@ -119,7 +117,6 @@ import com.google.gerrit.server.logging.TraceContext;
import com.google.gerrit.server.mail.MailUtil.MailRecipients; import com.google.gerrit.server.mail.MailUtil.MailRecipients;
import com.google.gerrit.server.notedb.ChangeNotes; import com.google.gerrit.server.notedb.ChangeNotes;
import com.google.gerrit.server.notedb.NotesMigration; import com.google.gerrit.server.notedb.NotesMigration;
import com.google.gerrit.server.notedb.ReviewerStateInternal;
import com.google.gerrit.server.patch.PatchSetInfoFactory; import com.google.gerrit.server.patch.PatchSetInfoFactory;
import com.google.gerrit.server.permissions.ChangePermission; import com.google.gerrit.server.permissions.ChangePermission;
import com.google.gerrit.server.permissions.GlobalPermission; import com.google.gerrit.server.permissions.GlobalPermission;
@@ -231,7 +228,6 @@ class ReceiveCommits {
IdentifiedUser user, IdentifiedUser user,
ReceivePack receivePack, ReceivePack receivePack,
AllRefsWatcher allRefsWatcher, AllRefsWatcher allRefsWatcher,
SetMultimap<ReviewerStateInternal, Account.Id> extraReviewers,
MessageSender messageSender); MessageSender messageSender);
} }
@@ -322,7 +318,6 @@ class ReceiveCommits {
// Assisted injected fields. // Assisted injected fields.
private final AllRefsWatcher allRefsWatcher; private final AllRefsWatcher allRefsWatcher;
private final ImmutableSetMultimap<ReviewerStateInternal, Account.Id> extraReviewers;
private final ProjectState projectState; private final ProjectState projectState;
private final IdentifiedUser user; private final IdentifiedUser user;
private final ReceivePack receivePack; private final ReceivePack receivePack;
@@ -398,7 +393,6 @@ class ReceiveCommits {
@Assisted IdentifiedUser user, @Assisted IdentifiedUser user,
@Assisted ReceivePack rp, @Assisted ReceivePack rp,
@Assisted AllRefsWatcher allRefsWatcher, @Assisted AllRefsWatcher allRefsWatcher,
@Assisted SetMultimap<ReviewerStateInternal, Account.Id> extraReviewers,
@Nullable @Assisted MessageSender messageSender) @Nullable @Assisted MessageSender messageSender)
throws IOException { throws IOException {
// Injected fields. // Injected fields.
@@ -438,7 +432,6 @@ class ReceiveCommits {
// Assisted injected fields. // Assisted injected fields.
this.allRefsWatcher = allRefsWatcher; this.allRefsWatcher = allRefsWatcher;
this.extraReviewers = ImmutableSetMultimap.copyOf(extraReviewers);
this.projectState = projectState; this.projectState = projectState;
this.user = user; this.user = user;
this.receivePack = rp; this.receivePack = rp;
@@ -1582,8 +1575,6 @@ class ReceiveCommits {
private void parseMagicBranch(ReceiveCommand cmd) throws PermissionBackendException { private void parseMagicBranch(ReceiveCommand cmd) throws PermissionBackendException {
logger.atFine().log("Found magic branch %s", cmd.getRefName()); logger.atFine().log("Found magic branch %s", cmd.getRefName());
MagicBranchInput magicBranch = new MagicBranchInput(user, cmd, labelTypes, notesMigration); MagicBranchInput magicBranch = new MagicBranchInput(user, cmd, labelTypes, notesMigration);
magicBranch.reviewer.addAll(extraReviewers.get(ReviewerStateInternal.REVIEWER));
magicBranch.cc.addAll(extraReviewers.get(ReviewerStateInternal.CC));
String ref; String ref;
magicBranch.cmdLineParser = optionParserFactory.create(magicBranch); magicBranch.cmdLineParser = optionParserFactory.create(magicBranch);

View File

@@ -88,7 +88,7 @@ final class Receive extends AbstractGitCommand {
throw new Failure(1, "fatal: unable to check permissions " + e); throw new Failure(1, "fatal: unable to check permissions " + e);
} }
AsyncReceiveCommits arc = factory.create(projectState, currentUser, repo, null, reviewers); AsyncReceiveCommits arc = factory.create(projectState, currentUser, repo, null);
try { try {
Capable r = arc.canUpload(); Capable r = arc.canUpload();