Narrowed down the problem. (#144)

hbina · web-flow · commit 28647e830b7d · 2020-10-26T11:17:53.000+02:00
The application will no longer abort but instead perform the benchmark
without entering the endless loop.

Signed-off-by: Hanif Bin Ariffin &lt;hanif.ariffin.4326@gmail.com&gt;
diff --git a/shard_connection.cpp b/shard_connection.cpp
@@ -438,7 +438,7 @@ void shard_connection::process_response(void)
     }
 
     if (m_config->reconnect_interval > 0 && responses_handled) {
-        if ((m_conns_manager->get_reqs_processed() % m_config->reconnect_interval) == 0) {
+        if ((m_config->requests != m_conns_manager->get_reqs_processed()) && ((m_conns_manager->get_reqs_processed() % m_config->reconnect_interval) == 0)) {
             assert(m_pipeline->size() == 0);
             benchmark_debug_log("reconnecting, m_reqs_processed = %u\n", m_conns_manager->get_reqs_processed());
 

Original file line number	Diff line number	Diff line change
`@@ -438,7 +438,7 @@ void shard_connection::process_response(void)`
`438`	`438`	`}`
`439`	`439`
`440`	`440`	`if (m_config->reconnect_interval > 0 && responses_handled) {`
`441`		`- if ((m_conns_manager->get_reqs_processed() % m_config->reconnect_interval) == 0) {`
	`441`	`+ if ((m_config->requests != m_conns_manager->get_reqs_processed()) && ((m_conns_manager->get_reqs_processed() % m_config->reconnect_interval) == 0)) {`
`442`	`442`	`assert(m_pipeline->size() == 0);`
`443`	`443`	`benchmark_debug_log("reconnecting, m_reqs_processed = %u\n", m_conns_manager->get_reqs_processed());`
`444`	`444`