From fbbebdf86b811cdc5fe9bf171358205720f93d8b Mon Sep 17 00:00:00 2001
From: Ilya Shakhat <ishakhat@mirantis.com>
Date: Thu, 17 Mar 2016 18:27:12 +0300
Subject: [PATCH] Throughput is sum of all processes

---
 performa/scenarios/mq/omsimulator.rst | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/performa/scenarios/mq/omsimulator.rst b/performa/scenarios/mq/omsimulator.rst
index de551d1..74a01ef 100644
--- a/performa/scenarios/mq/omsimulator.rst
+++ b/performa/scenarios/mq/omsimulator.rst
@@ -60,9 +60,9 @@ depending on number of concurrent threads.
     pipeline:
     - { $match: { task: omsimulator, mode: call }}
     - { $group: { _id: { threads: { $multiply: [ "$threads", "$host_count" ] } },
-                  msg_sent_per_sec: { $avg: { $divide: ["$client.count", "$client.duration"] }},
-                  msg_received_per_sec: { $avg: { $divide: ["$server.count", "$server.duration"] }},
-                  msg_round_trip_per_sec: { $avg: { $divide: ["$round_trip.count", "$round_trip.duration"] }},
+                  msg_sent_per_sec: { $sum: { $divide: ["$client.count", "$client.duration"] }},
+                  msg_received_per_sec: { $sum: { $divide: ["$server.count", "$server.duration"] }},
+                  msg_round_trip_per_sec: { $sum: { $divide: ["$round_trip.count", "$round_trip.duration"] }},
                   latency: { $avg: "$round_trip.latency" },
                   rabbit_total: { $avg: "$rabbit_total" }
                 }}
@@ -129,8 +129,8 @@ depending on number of concurrent threads.
     pipeline:
     - { $match: { task: omsimulator, mode: cast }}
     - { $group: { _id: { threads: { $multiply: [ "$threads", "$host_count" ] } },
-                  msg_sent_per_sec: { $avg: { $divide: ["$client.count", "$client.duration"] }},
-                  msg_received_per_sec: { $avg: { $divide: ["$server.count", "$server.duration"] }},
+                  msg_sent_per_sec: { $sum: { $divide: ["$client.count", "$client.duration"] }},
+                  msg_received_per_sec: { $sum: { $divide: ["$server.count", "$server.duration"] }},
                   latency: { $avg: "$server.latency" },
                   rabbit_total: { $avg: "$rabbit_total" }
                 }}
@@ -196,8 +196,8 @@ depending on number of concurrent threads.
     pipeline:
     - { $match: { task: omsimulator, mode: notify }}
     - { $group: { _id: { threads: { $multiply: [ "$threads", "$host_count" ] } },
-                  msg_sent_per_sec: { $avg: { $divide: ["$client.count", "$client.duration"] }},
-                  msg_received_per_sec: { $avg: { $divide: ["$server.count", "$server.duration"] }},
+                  msg_sent_per_sec: { $sum: { $divide: ["$client.count", "$client.duration"] }},
+                  msg_received_per_sec: { $sum: { $divide: ["$server.count", "$server.duration"] }},
                   latency: { $avg: "$server.latency" },
                   rabbit_total: { $avg: "$rabbit_total" }
                 }}