Skip to content

Commit

Permalink
Revert "Add optional start callback to GerritStatusPush"
Browse files Browse the repository at this point in the history
This reverts commit 660f61e, which was
merged accidentally from gh-480
  • Loading branch information
djmitche committed Sep 7, 2012
1 parent f11fa88 commit 20e005a
Showing 1 changed file with 10 additions and 20 deletions.
30 changes: 10 additions & 20 deletions master/buildbot/status/status_gerrit.py
Expand Up @@ -37,18 +37,15 @@ def defaultReviewCB(builderName, build, result, status, arg):
class GerritStatusPush(StatusReceiverMultiService):
"""Event streamer to a gerrit ssh server."""

def __init__(self, server, username, reviewCB=defaultReviewCB, startCB=None,
port=29418, reviewArg=None, **kwargs):
def __init__(self, server, username, reviewCB=defaultReviewCB, port=29418, reviewArg=None,
**kwargs):
"""
@param server: Gerrit SSH server's address to use for push event notifications.
@param username: Gerrit SSH server's username.
@param reviewCB: Callback that is called each time a build is finished, and that is used
to define the message and review approvals depending on the build result.
@param startCB: Callback that is called each time a build is started.
Used to define the message sent to Gerrit.
@param port: Gerrit SSH server's port.
@param reviewArg: Optional argument passed to the review callback.
@param startArg: Optional argument passed to the start callback.
@param reviewArg: Optional argument that is passed to the callback.
"""
StatusReceiverMultiService.__init__(self)
# Parameters.
Expand All @@ -57,8 +54,6 @@ def __init__(self, server, username, reviewCB=defaultReviewCB, startCB=None,
self.gerrit_port = port
self.reviewCB = reviewCB
self.reviewArg = reviewArg
self.startCB = startCB
self.startArg = startArg

class LocalPP(ProcessProtocol):
def __init__(self, status):
Expand All @@ -85,26 +80,18 @@ def startService(self):
def builderAdded(self, name, builder):
return self # subscribe to this builder

def buildStarted(self, builderName, build):
if self.startCB is not None:
message = self.startCB(builderName, build, self.startArg)
self.sendCodeReviews(build, message)

def buildFinished(self, builderName, build, result):
"""Do the SSH gerrit verify command to the server."""
message, verified, reviewed = self.reviewCB(builderName, build, result, self.reviewArg)
self.sendCodeReviews(build, message, verified, reviewed)

def sendCodeReviews(self, build, message, verified=0, reviewed=0):
if message is None:
return

# Gerrit + Repo
downloads = build.getProperty("repo_downloads")
downloaded = build.getProperty("repo_downloaded")
if downloads is not None and downloaded is not None:
if downloads is not None and downloaded is not None:
downloaded = downloaded.split(" ")
if downloads and 2 * len(downloads) == len(downloaded):
message, verified, reviewed = self.reviewCB(builderName, build, result, self.status, self.reviewArg)
if message is None:
return
for i in range(0, len(downloads)):
try:
project, change1 = downloads[i].split(" ")
Expand All @@ -123,6 +110,9 @@ def sendCodeReviews(self, build, message, verified=0, reviewed=0):
project = build.getProperty("project")
revision = build.getProperty("got_revision")
if project is not None and revision is not None:
message, verified, reviewed = self.reviewCB(builderName, build, result, self.status, self.reviewArg)
if message is None:
return
self.sendCodeReview(project, revision, message, verified, reviewed)
return

Expand Down

0 comments on commit 20e005a

Please sign in to comment.