You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2014/11/07 03:13:36 UTC
kafka git commit: KAFKA-1747 TestcaseEnv improperly shares state
between instances; reviewed by Neha Narkhede
Repository: kafka
Updated Branches:
refs/heads/trunk 4bb020212 -> 06e1a6552
KAFKA-1747 TestcaseEnv improperly shares state between instances; reviewed by Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/06e1a655
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/06e1a655
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/06e1a655
Branch: refs/heads/trunk
Commit: 06e1a6552e2c1de08c185359f3114eb12e61cfae
Parents: 4bb0202
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Authored: Thu Nov 6 18:13:14 2014 -0800
Committer: Neha Narkhede <ne...@gmail.com>
Committed: Thu Nov 6 18:13:28 2014 -0800
----------------------------------------------------------------------
system_test/utils/testcase_env.py | 117 ++++++++++++++++-----------------
1 file changed, 58 insertions(+), 59 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/06e1a655/system_test/utils/testcase_env.py
----------------------------------------------------------------------
diff --git a/system_test/utils/testcase_env.py b/system_test/utils/testcase_env.py
index b3c2910..1d2fb57 100644
--- a/system_test/utils/testcase_env.py
+++ b/system_test/utils/testcase_env.py
@@ -28,68 +28,67 @@ import thread
import system_test_utils
class TestcaseEnv():
+ def __init__(self, systemTestEnv, classInstance):
+ self.systemTestEnv = systemTestEnv
- # ================================
- # Generic testcase environment
- # ================================
-
- # dictionary of entity_id to ppid for Zookeeper entities
- # key: entity_id
- # val: ppid of Zookeeper associated to that entity_id
- # { 0: 12345, 1: 12389, ... }
- entityZkParentPidDict = {}
-
- # dictionary of entity_id to ppid for broker entities
- # key: entity_id
- # val: ppid of broker associated to that entity_id
- # { 0: 12345, 1: 12389, ... }
- entityBrokerParentPidDict = {}
-
- # dictionary of entity_id to ppid for mirror-maker entities
- # key: entity_id
- # val: ppid of broker associated to that entity_id
- # { 0: 12345, 1: 12389, ... }
- entityMirrorMakerParentPidDict = {}
-
- # dictionary of entity_id to ppid for console-consumer entities
- # key: entity_id
- # val: ppid of console consumer associated to that entity_id
- # { 0: 12345, 1: 12389, ... }
- entityConsoleConsumerParentPidDict = {}
-
- # dictionary of entity_id to ppid for migration tool entities
- # key: entity_id
- # val: ppid of broker associated to that entity_id
- # { 0: 12345, 1: 12389, ... }
- entityMigrationToolParentPidDict = {}
-
- # dictionary of entity_id to list of JMX ppid
- # key: entity_id
- # val: list of JMX ppid associated to that entity_id
- # { 1: [1234, 1235, 1236], 2: [2234, 2235, 2236], ... }
- entityJmxParentPidDict = {}
-
- # dictionary of hostname-topic-ppid for consumer
- # key: hostname
- # val: dict of topic-ppid
- # { host1: { test1 : 12345 }, host1: { test2 : 12389 }, ... }
- consumerHostParentPidDict = {}
-
- # dictionary of hostname-topic-ppid for producer
- # key: hostname
- # val: dict of topic-ppid
- # { host1: { test1 : 12345 }, host1: { test2 : 12389 }, ... }
- producerHostParentPidDict = {}
-
- # list of testcase configs
- testcaseConfigsList = []
-
- # dictionary to keep track of testcase arguments such as replica_factor, num_partition
- testcaseArgumentsDict = {}
+ # ================================
+ # Generic testcase environment
+ # ================================
+ # dictionary of entity_id to ppid for Zookeeper entities
+ # key: entity_id
+ # val: ppid of Zookeeper associated to that entity_id
+ # { 0: 12345, 1: 12389, ... }
+ self.entityZkParentPidDict = {}
+
+ # dictionary of entity_id to ppid for broker entities
+ # key: entity_id
+ # val: ppid of broker associated to that entity_id
+ # { 0: 12345, 1: 12389, ... }
+ self.entityBrokerParentPidDict = {}
+
+ # dictionary of entity_id to ppid for mirror-maker entities
+ # key: entity_id
+ # val: ppid of broker associated to that entity_id
+ # { 0: 12345, 1: 12389, ... }
+ self.entityMirrorMakerParentPidDict = {}
+
+ # dictionary of entity_id to ppid for console-consumer entities
+ # key: entity_id
+ # val: ppid of console consumer associated to that entity_id
+ # { 0: 12345, 1: 12389, ... }
+ self.entityConsoleConsumerParentPidDict = {}
+
+ # dictionary of entity_id to ppid for migration tool entities
+ # key: entity_id
+ # val: ppid of broker associated to that entity_id
+ # { 0: 12345, 1: 12389, ... }
+ self.entityMigrationToolParentPidDict = {}
+
+ # dictionary of entity_id to list of JMX ppid
+ # key: entity_id
+ # val: list of JMX ppid associated to that entity_id
+ # { 1: [1234, 1235, 1236], 2: [2234, 2235, 2236], ... }
+ self.entityJmxParentPidDict = {}
+
+ # dictionary of hostname-topic-ppid for consumer
+ # key: hostname
+ # val: dict of topic-ppid
+ # { host1: { test1 : 12345 }, host1: { test2 : 12389 }, ... }
+ self.consumerHostParentPidDict = {}
+
+ # dictionary of hostname-topic-ppid for producer
+ # key: hostname
+ # val: dict of topic-ppid
+ # { host1: { test1 : 12345 }, host1: { test2 : 12389 }, ... }
+ self.producerHostParentPidDict = {}
+
+ # list of testcase configs
+ self.testcaseConfigsList = []
+
+ # dictionary to keep track of testcase arguments such as replica_factor, num_partition
+ self.testcaseArgumentsDict = {}
- def __init__(self, systemTestEnv, classInstance):
- self.systemTestEnv = systemTestEnv
# gather the test case related info and add to an SystemTestEnv object
self.testcaseResultsDict = {}