From 6c68d989e0490b8003e17b93d7ad69bd19d4577e Mon Sep 17 00:00:00 2001
From: Marko Culinovic <marko.culinovic@memgraph.io>
Date: Mon, 26 Feb 2018 12:58:52 +0100
Subject: [PATCH] Add rpc_num_workers to cluster config in json
Summary:
Memgraph has flag --rpc-num-workers, so support for this
was added to script.
Reviewers: buda, mtomic
Reviewed By: buda
Subscribers: pullbot
Differential Revision: https://phabricator.memgraph.io/D1243
---
tools/manage_distributed_card_fraud | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git a/tools/manage_distributed_card_fraud b/tools/manage_distributed_card_fraud
index 0a01a548b..69c6746f8 100755
--- a/tools/manage_distributed_card_fraud
+++ b/tools/manage_distributed_card_fraud
@@ -18,6 +18,8 @@ Script provides helper actions for strata card fraud demo:
4) Stop memgraph cluster
5) Clean memgraph directories
6) Clean durability directories
+ 7) Collect memgraph logs
+ 8) Start and stop tcpdump
Cluster config should be provided in separate json file.
@@ -34,6 +36,7 @@ Example json config:
"address" : "10.1.13.5",
"port" : 10000,
"num_workers" : 4,
+ "rpc_num_workers" : 4,
"ssh_port" : 60022
},
{
@@ -42,6 +45,7 @@ Example json config:
"address" : "10.1.13.6",
"port" : 10001,
"num_workers" : 2,
+ "rpc_num_workers" : 2,
"ssh_port" : 60022
},
{
@@ -50,6 +54,7 @@ Example json config:
"address" : "10.1.13.7",
"port" : 10002,
"num_workers" : 2,
+ "rpc_num_workers" : 2,
"ssh_port" : 60022
}
],
@@ -91,13 +96,16 @@ def parse_args():
class Machine(namedtuple('Machine', ['host', 'type', 'address',
- 'port', 'num_workers', 'ssh_port'])):
+ 'port', 'num_workers',
+ 'rpc_num_workers', 'ssh_port'])):
__slots__ = () # prevent creation of instance dictionaries
def __init__(self, **kwargs):
assert isinstance(self.port, int), "port must be an integer"
assert isinstance(self.num_workers, int), "num_workers must be \
an integer"
+ assert isinstance(self.rpc_num_workers, int), "rpc_num_workers must be \
+ an integer"
assert isinstance(self.ssh_port, int), "ssh_port must be an integer"
@@ -290,6 +298,7 @@ class RemoteRunner:
self._config.durability_remote_dir),
"--db-recover-on-startup=true",
"--num-workers", str(machine.num_workers),
+ "--rpc-num-workers", str(machine.rpc_num_workers),
"--log-file",
os.path.join(self._config.logs_remote_dir,
"log_worker_0"),
@@ -320,6 +329,7 @@ class RemoteRunner:
self._config.durability_remote_dir),
"--db-recover-on-startup=true",
"--num-workers", str(machine.num_workers),
+ "--rpc-num-workers", str(machine.rpc_num_workers),
"--statsd-address", str(self._config.statsd_address),
"--statsd-port", str(self._config.statsd_port),
"--log-file",
@@ -352,6 +362,7 @@ class RemoteRunner:
self._config.durability_remote_dir),
"--db-recover-on-startup=true",
"--num-workers", str(machine.num_workers),
+ "--rpc-num-workers", str(machine.rpc_num_workers),
"--statsd-address", str(self._config.statsd_address),
"--statsd-port", str(self._config.statsd_port),
"--log-file",