06:36:16.951 [info] [ API ] <0.692.0> Node repo: {git_install_spec, "https://github.com/satori-com/mzbench.git", "02be2684655cde94d537c322bb0611e258ae9718", "node",[]} 06:36:16.951 [info] [ API ] <0.692.0> Stage 'pipeline - init': started 06:36:16.951 [info] [ API ] <0.697.0> Starting benchmark #{author => "anonymous",author_name => "anonymous", benchmark_name => "My benchmark",cloud => local, deallocate_after_bench => true,director_host => undefined, emulate_bench_crash => false, env => [{"mzb_bench_id",22}, {"mzb_script_name","generic.erl"}, {"loop_rate","1"}], exclusive => [],id => 22,initial_user => "root",log_compression => deflate, log_file => "log.txt",log_user_file => "log_user.txt", metric_update_interval_ms => 10000,metrics_compression => none, metrics_file => "metrics_~s.txt", node_install_spec => {git_install_spec,"https://github.com/satori-com/mzbench.git", "02be2684655cde94d537c322bb0611e258ae9718","node",[]}, node_interconnect_port => 4804,node_log_port => 4801, node_log_user_port => 4802,node_management_port => 4803,nodes_arg => 1, parent => 21,provision_nodes => true,purpose => "bench-22-1538634976", req_host => <<"172.16.14.236:4800">>, script => #{body => <<"#!benchDL\n\n\n#######\n# Scenario:\n# A single subscriber reading from \"prefix/clients/#\" topic filter\n# 1k publisher publishing to exclusive topic \"prefix/clients/{client_id}\"\n# Overall msg rate: 1k msg/s\n# Message size: 150 random bytes\n# Running time: 5 min\n#######\n\nmake_install(git = \"https://github.com/erlio/vmq_mzbench.git\",\n branch = \"master\")\n\npool(size = 1,\n worker_type = mqtt_worker):\n connect([t(host, \"dev.mydomain.com\"),\n t(port,1883),\n t(client,\"subscriber1\"),\n t(clean_session,false),\n t(keepalive_interval,60),\n t(proto_version,4), t(reconnect_timeout,4)\n ])\n\n wait(60 sec)\n subscribe(\"prefix/clients/#\", 0)\n">>, filename => "BEB0D97F5FBA4F421476B6ACC0F6DA868583FD.erl", name => "generic.erl"}, tags => [],vm_args => [],worker_hosts => []} 06:36:16.952 [info] [ API ] <0.692.0> Stage 'pipeline - init': finished 06:36:16.952 [info] [ API ] <0.692.0> Stage 'pipeline - checking_script': started 06:36:16.958 [info] [ API ] <0.692.0> Stage 'pipeline - checking_script': finished 06:36:16.958 [info] [ API ] <0.692.0> Stage 'pipeline - wait_exclusive': started 06:36:16.958 [info] [ API ] <0.692.0> Stage 'pipeline - wait_exclusive': finished 06:36:16.958 [info] [ API ] <0.692.0> Stage 'pipeline - allocating_hosts': started 06:36:16.958 [info] [ API ] <0.700.0> Allocating 2 hosts in local cloud... 06:36:16.966 [info] [ API ] <0.700.0> Allocated hosts: [undefined] @ ["127.0.0.1"] 06:36:16.966 [info] [ API ] <0.692.0> Stage 'pipeline - allocating_hosts': finished 06:36:16.966 [info] [ API ] <0.692.0> Stage 'pipeline - provisioning': started 06:36:16.966 [info] [ API ] <0.701.0> Provisioning 1 nodes with config: #{author => "anonymous",author_name => "anonymous", benchmark_name => "My benchmark",cloud => local, deallocate_after_bench => true,director_host => "127.0.0.1", emulate_bench_crash => false, env => [{"mzb_bench_id",22}, {"mzb_script_name","generic.erl"}, {"loop_rate","1"}], exclusive => [],id => 22,initial_user => "root",log_compression => deflate, log_file => "log.txt",log_user_file => "log_user.txt", metric_update_interval_ms => 10000,metrics_compression => none, metrics_file => "metrics_~s.txt", node_install_spec => {git_install_spec,"https://github.com/satori-com/mzbench.git", "02be2684655cde94d537c322bb0611e258ae9718","node",[]}, node_interconnect_port => 4804,node_log_port => 4801, node_log_user_port => 4802,node_management_port => 4803,nodes_arg => 1, parent => 21,provision_nodes => true,purpose => "bench-22-1538634976", req_host => <<"172.16.14.236:4800">>, script => #{body => <<"#!benchDL\n\n\n#######\n# Scenario:\n# A single subscriber reading from \"prefix/clients/#\" topic filter\n# 1k publisher publishing to exclusive topic \"prefix/clients/{client_id}\"\n# Overall msg rate: 1k msg/s\n# Message size: 150 random bytes\n# Running time: 5 min\n#######\n\nmake_install(git = \"https://github.com/erlio/vmq_mzbench.git\",\n branch = \"master\")\n\npool(size = 1,\n worker_type = mqtt_worker):\n connect([t(host, \"dev.mydomain.com\"),\n t(port,1883),\n t(client,\"subscriber1\"),\n t(clean_session,false),\n t(keepalive_interval,60),\n t(proto_version,4), t(reconnect_timeout,4)\n ])\n\n wait(60 sec)\n subscribe(\"prefix/clients/#\", 0)\n">>, filename => "BEB0D97F5FBA4F421476B6ACC0F6DA868583FD.erl", name => "generic.erl"}, tags => [],user_name => undefined,vm_args => [],worker_hosts => []} 06:36:16.966 [info] [ API ] <0.701.0> [ MKDIR ] /tmp/mz/bench-22-1538634976 06:36:16.967 [info] [ API ] <0.701.0> There's only one host, no need to make ntp check 06:36:16.967 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; ps -ef | grep beam | grep -v grep | grep -v mzbench_api && ~/.local/share/mzbench/bin/mzbench stop; true " at ["127.0.0.1"] 06:36:16.970 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; uname -sr " at ["127.0.0.1"] 06:36:16.972 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; erl -noshell -eval 'io:fwrite(\"~s\", [erlang:system_info(version)]).' -s erlang halt " at ["127.0.0.1"] 06:36:17.320 [info] [ API ] <0.701.0> Missing tarballs: [] 06:36:17.320 [info] [ API ] <0.705.0> [ COPY ] /root/.local/cache/mzbench_api/packages/node-02be2684655cde94d537c322bb0611e258ae9718-linux-4.15.0-1020-aws_erts-9.3.tgz -> /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320311.tgz 06:36:17.338 [info] [ API ] <0.705.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; mkdir -p /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320332 && cd /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320332 && tar xzf /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320311.tgz && mkdir -p ~/.local/share && rsync -aW /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320332/ ~/.local/share " at ["127.0.0.1"] 06:36:17.634 [info] [ API ] <0.705.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; rm -rf /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320311.tgz; rm -rf /tmp/bench_mzbench_api_def07b416b8b_1538_634977_320332; true " at ["127.0.0.1"] 06:36:17.663 [info] [ API ] <0.701.0> [ EXEC ] git ls-remote https://github.com/erlio/vmq_mzbench.git master (<0.701.0>) 06:36:17.764 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; uname -sr " at ["127.0.0.1"] 06:36:17.766 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; erl -noshell -eval 'io:fwrite(\"~s\", [erlang:system_info(version)]).' -s erlang halt " at ["127.0.0.1"] 06:36:18.110 [info] [ API ] <0.701.0> Missing tarballs: [] 06:36:18.110 [info] [ API ] <0.710.0> [ COPY ] /root/.local/cache/mzbench_api/packages/vmq_mzbench-0f7a688-linux-4.15.0-1020-aws_erts-9.3.tgz -> /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110276.tgz 06:36:18.117 [info] [ API ] <0.710.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; mkdir -p /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110300 && cd /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110300 && tar xzf /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110276.tgz && mkdir -p ~/.local/share/mzbench_workers && rsync -aW /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110300/ ~/.local/share/mzbench_workers " at ["127.0.0.1"] 06:36:18.188 [info] [ API ] <0.710.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; rm -rf /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110276.tgz; rm -rf /tmp/bench_mzbench_api_def07b416b8b_1538_634978_110300; true " at ["127.0.0.1"] 06:36:18.197 [info] [ API ] <0.713.0> [ COPY ] /tmp/bench_mzbench_api_def07b416b8b_1538_634978_197500 -> /tmp/mz/bench-22-1538634976/vm.args 06:36:18.198 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; cd /tmp/mz/bench-22-1538634976 && ~/.local/share/mzbench/bin/mzbench start " at ["127.0.0.1"] 06:36:24.679 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; cd /tmp/mz/bench-22-1538634976 && ~/.local/share/mzbench/bin/mzbench getpid " at ["127.0.0.1"] 06:36:25.054 [info] [ API ] <0.701.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; cd /tmp/mz/bench-22-1538634976 && ~/.local/share/mzbench/bin/mzbench rpcterms mzb_management_tcp_protocol get_port" at ["127.0.0.1"] 06:36:25.429 [info] [ API ] <0.701.0> Management port: 4803 06:36:25.430 [info] [ API ] <0.692.0> Stage 'pipeline - provisioning': finished 06:36:25.430 [info] [ API ] <0.692.0> Stage 'pipeline - connect_nodes': started 06:36:25.431 [info] [ API ] <0.692.0> Stage 'pipeline - connect_nodes': finished 06:36:25.431 [info] [ API ] <0.692.0> Stage 'pipeline - starting_collectors': started 06:36:25.433 [info] [ API ] <0.720.0> Log collector server: 'mzb_director22_0@127.0.0.1' -> "127.0.0.1":4801 06:36:25.433 [info] [ API ] <0.722.0> Log collector server: 'mzb_director22_0@127.0.0.1' -> "127.0.0.1":4802 06:36:25.433 [info] [ API ] <0.692.0> Stage 'pipeline - starting_collectors': finished 06:36:25.434 [info] [ API ] <0.692.0> Stage 'pipeline - uploading_script': started 06:36:25.434 [info] [ API ] <0.724.0> [ COPY ] /tmp/bench_mzbench_api_def07b416b8b_1538_634985_434025 -> /tmp/mz/bench-22-1538634976/BEB0D97F5FBA4F421476B6ACC0F6DA868583FD.erl 06:36:25.434 [info] [ API ] <0.692.0> Stage 'pipeline - uploading_script': finished 06:36:25.435 [info] [ API ] <0.692.0> Stage 'pipeline - uploading_includes': started 06:36:25.435 [info] [ API ] <0.692.0> Stage 'pipeline - uploading_includes': finished 06:36:25.435 [info] [ API ] <0.692.0> Stage 'pipeline - pre_hooks': started 06:36:25.436 [info] [mzb_director22_0@127.0.0.1] <0.132.0> Started tcp lager backend for info #Port<0.2512> 06:36:25.436 [info] [mzb_director22_0@127.0.0.1] <0.125.0> Started tcp lager backend for info #Port<0.2525> 06:36:25.454 [info] [mzb_director22_0@127.0.0.1] <0.249.0> Add worker paths: ["/root/.local/share/mzbench_workers/mqtt_worker/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/goldrush/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/lager/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/vmq_commons/ebin"] 06:36:25.461 [info] [mzb_director22_0@127.0.0.1] <0.249.0> signals graph: [] 06:36:25.461 [info] [mzb_director22_0@127.0.0.1] <0.249.0> signals graph sccs: [] 06:36:25.461 [info] [mzb_director22_0@127.0.0.1] <0.249.0> standalone signals: [] 06:36:25.461 [info] [ API ] <0.692.0> Stage 'pipeline - pre_hooks': finished 06:36:25.461 [info] [ API ] <0.692.0> Stage 'pipeline - starting': started 06:36:25.467 [info] [mzb_director22_0@127.0.0.1] <0.249.0> Add worker paths: ["/root/.local/share/mzbench_workers/mqtt_worker/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/goldrush/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/lager/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/vmq_commons/ebin"] 06:36:25.468 [info] [mzb_director22_0@127.0.0.1] <0.249.0> signals graph: [] 06:36:25.468 [info] [mzb_director22_0@127.0.0.1] <0.249.0> signals graph sccs: [] 06:36:25.468 [info] [mzb_director22_0@127.0.0.1] <0.249.0> standalone signals: [] 06:36:25.468 [info] [mzb_director22_0@127.0.0.1] <0.249.0> [ mzb_bench_sup ] Loading "generic" Nodes: ['mzb_director22_0@127.0.0.1'] 06:36:25.470 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] Bench name "generic", director node 'mzb_director22_0@127.0.0.1' 06:36:25.471 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] Pools: [{operation,false,pool,[[{operation,false,size,[1],[{function,size},{line,12},{column,6},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,false,worker_type,[mqtt_worker],[{function,worker_type},{line,13},{column,6},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]}],[{operation,false,connect,[[{operation,true,t,[host,"dev.mydomain.com"],[{function,t},{line,14},{column,26},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,t,[port,1883],[{function,t},{line,15},{column,17},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,t,[client,"subscriber1"],[{function,t},{line,16},{column,17},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,t,[clean_session,false],[{function,t},{line,17},{column,17},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,t,[keepalive_interval,60],[{function,t},{line,18},{column,17},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,t,[proto_version,4],[{function,t},{line,19},{column,17},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,t,[reconnect_timeout,4],[{function,t},{line,19},{column,37},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]}]],[{function,connect},{line,14},{column,17},{pools_num,1},{pool_name,"pool1"},{pool_id,1}]},{operation,true,wait,[{constant,60000,ms,[]}],[{function,wait},{line,21},...]},...]],...}], Env: [{"nodes_num",1},{"bench_script_dir","/tmp/mz/bench-22-1538634976"},{"bench_workers_dir",["~/.local/share/mzbench_workers","../workers"]},{"worker_hosts",["127.0.0.1"]},{"nodes_num",1},{"bench_script_dir","/tmp/mz/bench-22-1538634976"},{"bench_workers_dir",["~/.local/share/mzbench_workers","../workers"]},{"mzb_bench_id",22},{"mzb_script_name","generic.erl"},{"loop_rate","1"}], Asserts: [] 06:36:25.471 [info] [ API ] <0.692.0> Stage 'pipeline - starting': finished 06:36:25.471 [info] [ API ] <0.692.0> Stage 'pipeline - running': started 06:36:25.486 [info] [mzb_director22_0@127.0.0.1] <0.261.0> Add worker paths: ["/root/.local/share/mzbench_workers/mqtt_worker/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/goldrush/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/lager/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/vmq_commons/ebin"] 06:36:25.487 [info] [mzb_director22_0@127.0.0.1] <0.261.0> Reading configuration from ~/.local/share/mzbench_workers/mqtt_worker/sys.config 06:36:25.490 [info] [mzb_director22_0@127.0.0.1] <0.261.0> Starting worker on 'mzb_director22_0@127.0.0.1' no 1 06:36:25.490 [info] [mzb_director22_0@127.0.0.1] <0.252.0> Start pool monitors: [{interconnect_monitor,<0.261.0>,#Ref<0.256540803.1987051521.113725>}] 06:36:25.490 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] Started all pools 06:36:35.473 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:36:35.473 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:36:35.473 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:36:35.473 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:36:45.475 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:36:45.475 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:36:45.475 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:36:45.475 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:36:55.477 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:36:55.477 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:36:55.477 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:36:55.477 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:37:05.479 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:37:05.479 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:37:05.479 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:37:05.479 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:37:15.481 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:37:15.481 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:37:15.481 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:37:15.481 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:37:25.483 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:37:25.483 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:37:25.483 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:37:25.483 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:37:25.498 [info] [mzb_director22_0@127.0.0.1] <0.261.0> [ "pool1" ] All workers have finished 06:37:25.498 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK ASSERTIONS: 06:37:25.498 [info] [mzb_director22_0@127.0.0.1] <0.255.0> Current assertions: (empty) 06:37:25.498 [info] [mzb_director22_0@127.0.0.1] <0.255.0> [ metrics ] CHECK SIGNALS: 06:37:25.498 [info] [mzb_director22_0@127.0.0.1] <0.255.0> List of currently registered signals: 06:37:25.499 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] All pools have finished, stopping mzb_director_sup <0.199.0> 06:37:25.499 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] Succeed/Failed workers = 1/0 06:37:25.499 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] Stopped workers = 0 06:37:25.499 [info] [mzb_director22_0@127.0.0.1] <0.252.0> [ director ] Reporting benchmark results to {<0.256.0>,#Ref<0.256540803.1987051536.112574>} 06:37:25.499 [info] [mzb_director22_0@127.0.0.1] <0.284.0> [ mzb_bench_sup ] I'm at <0.284.0> 06:37:25.499 [info] [mzb_director22_0@127.0.0.1] <0.285.0> Signal server has been started 06:37:25.501 [info] [ API ] <0.728.0> Benchmark result: SUCCESS 1 workers have finished successfully 06:37:25.516 [info] [ API ] <0.728.0> Bench final metrics: [{"mqtt.publisher.qos1.puback.in.total",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.publisher.qos1.puback.waiting",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.publisher.qos2.pubrec.in.total",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.connection.current_total",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.connection.reconnects",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.message.published.total",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.message.consumed.total",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.consumer.current_total",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"mqtt.consumer.suback.errors",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"workers.pool1.started",counter,{1,[{"min",0.0},{"50",0.0},{"90",0.09998780148821844},{"95",0.09998780148821844},{"max",0.09998780148821844}]}}, {"workers.pool1.ended",counter,{1,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"workers.pool1.failed",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"errors.system",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"errors.user",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"blocked.workers",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"logs.written",counter,{45,[{"min",0.39991853659409576},{"50",0.39991957617323154},{"90",1.9997560297643688},{"95",1.9997560297643688},{"max",1.9997560297643688}]}}, {"logs.dropped.mailbox_overflow",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"logs.dropped.rate_limiter",counter,{0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"metric_merging_time",gauge,{1.307,[{"min",1.229},{"50",1.246},{"90",1.336},{"95",1.336},{"max",1.336}]}}, {"systemload.message_queue.mzb_director22_0",gauge,{0,[{"min",0},{"50",0},{"90",0},{"95",0},{"max",0}]}}, {"systemload.process_count.mzb_director22_0",gauge,{186,[{"min",186},{"50",186},{"90",186},{"95",186},{"max",186}]}}, {"systemload.interval.mzb_director22_0",gauge,{10.003002,[{"min",10.0},{"50",10.003001},{"90",10.003516},{"95",10.003516},{"max",10.003516}]}}, {"systemload.dir_time_diff.mzb_director22_0",gauge,{-1,[{"min",-1},{"50",-1},{"90",-1},{"95",-1},{"max",-1}]}}, {"systemload.time_offset.mzb_director22_0",gauge,{0,[{"min",0},{"50",0},{"90",0},{"95",0},{"max",0}]}}, {"systemload.director_ping.mzb_director22_0",gauge,{7,[{"min",6},{"50",7},{"90",15},{"95",15},{"max",15}]}}, {"systemload.la1.mzb_director22_0",gauge,{0.6796875,[{"min",0.6796875},{"50",0.80078125},{"90",1.078125},{"95",1.078125},{"max",1.078125}]}}, {"systemload.cpu.mzb_director22_0",gauge,{100.0,[{"min",100.0},{"50",100.0},{"90",100.0},{"95",100.0},{"max",100.0}]}}, {"systemload.ram.mzb_director22_0",gauge,{67.47739570807153,[{"min",67.47739570807153},{"50",67.4850095371431},{"90",67.4850095371431},{"95",67.4850095371431},{"max",67.4850095371431}]}}, {"systemload.nettx.bytes.eth0.mzb_director22_0",gauge,{0.0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"systemload.netrx.bytes.eth0.mzb_director22_0",gauge,{0.0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"systemload.nettx.pkts.eth0.mzb_director22_0",gauge,{0.0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}, {"systemload.netrx.pkts.eth0.mzb_director22_0",gauge,{0.0,[{"min",0.0},{"50",0.0},{"90",0.0},{"95",0.0},{"max",0.0}]}}] 06:37:25.517 [info] [ API ] <0.692.0> Stage 'pipeline - running': finished 06:37:25.517 [info] [ API ] <0.692.0> Stage 'pipeline - post_hooks': started 06:37:25.523 [info] [mzb_director22_0@127.0.0.1] <0.249.0> Add worker paths: ["/root/.local/share/mzbench_workers/mqtt_worker/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/goldrush/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/lager/ebin","/root/.local/share/mzbench_workers/mqtt_worker/deps/vmq_commons/ebin"] 06:37:25.524 [info] [mzb_director22_0@127.0.0.1] <0.249.0> signals graph: [] 06:37:25.524 [info] [mzb_director22_0@127.0.0.1] <0.249.0> signals graph sccs: [] 06:37:25.524 [info] [mzb_director22_0@127.0.0.1] <0.249.0> standalone signals: [] 06:37:25.524 [info] [ API ] <0.692.0> Stage 'pipeline - post_hooks': finished 06:37:25.525 [info] [ API ] <0.692.0> Bench final: complete 06:37:25.525 [info] [ API ] <0.692.0> Stage 'finalize - saving_bench_results': started 06:37:25.526 [info] [ API ] <0.692.0> Stage 'finalize - saving_bench_results': finished 06:37:25.526 [info] [ API ] <0.692.0> Stage 'finalize - sending_email_report': started 06:37:25.530 [warning] [mzb_director22_0@127.0.0.1] <0.202.0> [ watchdog ] Node 'mzb_director22_0@127.0.0.1' is going to shutdown in 20 sec because director process is down 06:37:25.553 [info] [ API ] <0.692.0> Stage 'finalize - sending_email_report': finished 06:37:25.553 [info] [ API ] <0.692.0> Stage 'finalize - stopping_collectors': started 06:37:25.553 [info] [mzb_director22_0@127.0.0.1] <0.249.0> Management tcp connection terminated: normal 06:37:25.555 [info] [ API ] <0.692.0> Stage 'finalize - stopping_collectors': finished 06:37:25.555 [info] [ API ] <0.692.0> Stage 'finalize - cleaning_nodes': started 06:37:25.555 [info] [ API ] <0.994.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; cd /tmp/mz/bench-22-1538634976; timeout 30s ~/.local/share/mzbench/bin/mzbench stop > /dev/null 2>&1; echo $? " at ["127.0.0.1"] 06:37:25.558 [info] [ API ] <0.994.0> [ REMOTE EXEC ] bash -c -l "export PATH='/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin'; rm -rf /tmp/mz/bench-22-1538634976 " at ["127.0.0.1"] 06:37:25.560 [info] [ API ] <0.692.0> Stage 'finalize - cleaning_nodes': finished 06:37:25.561 [info] [ API ] <0.692.0> Stage 'finalize - deallocating_hosts': started 06:37:25.561 [info] [ API ] <0.997.0> Deallocator has started 06:37:25.564 [info] [ API ] <0.692.0> Stage 'finalize - deallocating_hosts': finished 06:37:25.564 [info] [ API ] <0.692.0> Stage 'finalize - release_exclusive': started 06:37:25.564 [info] [ API ] <0.692.0> Stage 'finalize - release_exclusive': finished