From commits-return-9173-apmail-kafka-commits-archive=kafka.apache.org@kafka.apache.org Tue Mar 13 13:15:49 2018 Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 0A32010727 for ; Tue, 13 Mar 2018 13:15:49 +0000 (UTC) Received: (qmail 87553 invoked by uid 500); 13 Mar 2018 13:15:48 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 87506 invoked by uid 500); 13 Mar 2018 13:15:48 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 87492 invoked by uid 99); 13 Mar 2018 13:15:48 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 13 Mar 2018 13:15:48 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 007458099A; Tue, 13 Mar 2018 13:15:47 +0000 (UTC) Date: Tue, 13 Mar 2018 13:15:47 +0000 To: "commits@kafka.apache.org" Subject: [kafka] branch trunk updated: MINOR: add DEFAULT_PORT for Trogdor Agent and Coordinator (#4674) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <152094694750.28060.5374196245592665594@gitbox.apache.org> From: rsivaram@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: kafka X-Git-Refname: refs/heads/trunk X-Git-Reftype: branch X-Git-Oldrev: 0c00aa0983f963dae18232ca539cc0731f228c70 X-Git-Newrev: ec9e8110e3967c3ef38ed475a0cb40fc951a2aef X-Git-Rev: ec9e8110e3967c3ef38ed475a0cb40fc951a2aef X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. rsivaram pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new ec9e811 MINOR: add DEFAULT_PORT for Trogdor Agent and Coordinator (#4674) ec9e811 is described below commit ec9e8110e3967c3ef38ed475a0cb40fc951a2aef Author: Colin Patrick McCabe AuthorDate: Tue Mar 13 06:15:44 2018 -0700 MINOR: add DEFAULT_PORT for Trogdor Agent and Coordinator (#4674) Add a DEFAULT_PORT constant for the Trogdor Agent and Coordinator. Reviewers: Rajini Sivaram --- tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java | 2 ++ tools/src/main/java/org/apache/kafka/trogdor/common/Node.java | 7 +++++-- .../java/org/apache/kafka/trogdor/coordinator/Coordinator.java | 2 ++ 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java b/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java index 43334a1..b0fea87 100644 --- a/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java +++ b/tools/src/main/java/org/apache/kafka/trogdor/agent/Agent.java @@ -44,6 +44,8 @@ import static net.sourceforge.argparse4j.impl.Arguments.store; public final class Agent { private static final Logger log = LoggerFactory.getLogger(Agent.class); + public static final int DEFAULT_PORT = 8888; + /** * The time at which this server was started. */ diff --git a/tools/src/main/java/org/apache/kafka/trogdor/common/Node.java b/tools/src/main/java/org/apache/kafka/trogdor/common/Node.java index 24c8488..b0c63d8 100644 --- a/tools/src/main/java/org/apache/kafka/trogdor/common/Node.java +++ b/tools/src/main/java/org/apache/kafka/trogdor/common/Node.java @@ -17,6 +17,9 @@ package org.apache.kafka.trogdor.common; +import org.apache.kafka.trogdor.agent.Agent; +import org.apache.kafka.trogdor.coordinator.Coordinator; + import java.util.Set; /** @@ -34,11 +37,11 @@ public interface Node { } public static int getTrogdorAgentPort(Node node) { - return getIntConfig(node, Platform.Config.TROGDOR_AGENT_PORT, 0); + return getIntConfig(node, Platform.Config.TROGDOR_AGENT_PORT, Agent.DEFAULT_PORT); } public static int getTrogdorCoordinatorPort(Node node) { - return getIntConfig(node, Platform.Config.TROGDOR_COORDINATOR_PORT, 0); + return getIntConfig(node, Platform.Config.TROGDOR_COORDINATOR_PORT, Coordinator.DEFAULT_PORT); } } diff --git a/tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java b/tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java index b2dc474..545e3a3 100644 --- a/tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java +++ b/tools/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java @@ -45,6 +45,8 @@ import static net.sourceforge.argparse4j.impl.Arguments.store; public final class Coordinator { private static final Logger log = LoggerFactory.getLogger(Coordinator.class); + public static final int DEFAULT_PORT = 8889; + /** * The start time of the Coordinator in milliseconds. */ -- To stop receiving notification emails like this one, please contact rsivaram@apache.org.