consumer class optimization

CONTRIBUTING.md

@@ -42,7 +42,7 @@ You also need to use the formatting tool so that your code has the same coding s
 ## 7. Commit your changes
 ```bash
 git add .
-git commit -m 'some description of the changes'
+git commit -m_cv_mutex 'some description of the changes'
 ```
 You can do as many commits as you want: we will squash them into a single commit.
 

docs/html/classcpp__redis_1_1network_1_1redis__connection-members.html

@@ -76,7 +76,7 @@
 <p>This is the complete list of members for <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a>, including all inherited members.</p>
 <table class="directory">
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#a8e6980d40139877c16e995051b780d60">commit</a>(void)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a></td><td class="entry"></td></tr>
-  <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#af105573e46eadbc34a9f5907832df19f">connect</a>(const std::string &amp;host=&quot;127.0.0.1&quot;, std::size_t port=6379, const disconnection_handler_t &amp;disconnection_handler=nullptr, const reply_callback_t &amp;reply_callback=nullptr, std::uint32_t timeout_msecs=0)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a></td><td class="entry"></td></tr>
+  <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#af105573e46eadbc34a9f5907832df19f">connect</a>(const std::string &amp;host=&quot;127.0.0.1&quot;, std::size_t port=6379, const disconnection_handler_t &amp;disconnection_handler=nullptr, const reply_callback_t &amp;reply_callback=nullptr, std::uint32_t timeout_ms=0)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a></td><td class="entry"></td></tr>
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#a614a01ce8abd69b44f3d072423d2e696">disconnect</a>(bool wait_for_removal=false)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a></td><td class="entry"></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#aba1a229a3d36a5540a80776ed0cf9a44">disconnection_handler_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a></td><td class="entry"></td></tr>
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#ad3d96826e2e67fb3fed23280237d4d9c">is_connected</a>(void) const</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">cpp_redis::network::redis_connection</a></td><td class="entry"></td></tr>

docs/html/classcpp__redis_1_1network_1_1redis__connection.html

@@ -106,7 +106,7 @@
 <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">redis_connection</a> &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#a54a4c28ad1b9e9f3bac2854fddf4e30d">operator=</a> (const <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html">redis_connection</a> &amp;)=delete</td></tr>
 <tr class="memdesc:a54a4c28ad1b9e9f3bac2854fddf4e30d"><td class="mdescLeft">&#160;</td><td class="mdescRight">assignment operator <br /></td></tr>
 <tr class="separator:a54a4c28ad1b9e9f3bac2854fddf4e30d"><td class="memSeparator" colspan="2">&#160;</td></tr>
-<tr class="memitem:af105573e46eadbc34a9f5907832df19f"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#af105573e46eadbc34a9f5907832df19f">connect</a> (const std::string &amp;host=&quot;127.0.0.1&quot;, std::size_t port=6379, const <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#aba1a229a3d36a5540a80776ed0cf9a44">disconnection_handler_t</a> &amp;disconnection_handler=nullptr, const <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#a40f4b55a3103b7436e34211893377245">reply_callback_t</a> &amp;reply_callback=nullptr, std::uint32_t timeout_msecs=0)</td></tr>
+<tr class="memitem:af105573e46eadbc34a9f5907832df19f"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#af105573e46eadbc34a9f5907832df19f">connect</a> (const std::string &amp;host=&quot;127.0.0.1&quot;, std::size_t port=6379, const <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#aba1a229a3d36a5540a80776ed0cf9a44">disconnection_handler_t</a> &amp;disconnection_handler=nullptr, const <a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#a40f4b55a3103b7436e34211893377245">reply_callback_t</a> &amp;reply_callback=nullptr, std::uint32_t timeout_ms=0)</td></tr>
 <tr class="separator:af105573e46eadbc34a9f5907832df19f"><td class="memSeparator" colspan="2">&#160;</td></tr>
 <tr class="memitem:a614a01ce8abd69b44f3d072423d2e696"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1redis__connection.html#a614a01ce8abd69b44f3d072423d2e696">disconnect</a> (bool wait_for_removal=false)</td></tr>
 <tr class="separator:a614a01ce8abd69b44f3d072423d2e696"><td class="memSeparator" colspan="2">&#160;</td></tr>
@@ -239,7 +239,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#af105573e46eadbc34a9f5907
           <td class="paramkey"></td>
           <td></td>
           <td class="paramtype">std::uint32_t&#160;</td>
-          <td class="paramname"><em>timeout_msecs</em> = <code>0</code>&#160;</td>
+          <td class="paramname"><em>timeout_ms</em> = <code>0</code>&#160;</td>
         </tr>
         <tr>
           <td></td>
@@ -255,7 +255,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#af105573e46eadbc34a9f5907
     <tr><td class="paramname">port</td><td>port to be connected to </td></tr>
     <tr><td class="paramname">disconnection_handler</td><td>handler to be called in case of disconnection </td></tr>
     <tr><td class="paramname">reply_callback</td><td>handler to be called once a reply is ready </td></tr>
-    <tr><td class="paramname">timeout_msecs</td><td>max time to connect (in ms) </td></tr>
+    <tr><td class="paramname">timeout_ms</td><td>max time to connect (in ms) </td></tr>
   </table>
   </dd>
 </dl>

docs/html/classcpp__redis_1_1network_1_1tcp__client-members.html

@@ -79,7 +79,7 @@
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#ae8bf79e8e1f1d7e359ed1c7cdc4026fc">async_read_callback_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"></td></tr>
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a6d15785b71776cd85426c9634cb446f0">async_write</a>(write_request &amp;request)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html">cpp_redis::network::tcp_client</a></td><td class="entry"><span class="mlabel">virtual</span></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a1dc52ccc70cf377c4fbb495a16adc658">async_write_callback_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"></td></tr>
-  <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a5808c0569980d83479f755ac55a12dfb">connect</a>(const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_msecs)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html">cpp_redis::network::tcp_client</a></td><td class="entry"><span class="mlabel">virtual</span></td></tr>
+  <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a5808c0569980d83479f755ac55a12dfb">connect</a>(const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_ms)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html">cpp_redis::network::tcp_client</a></td><td class="entry"><span class="mlabel">virtual</span></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a88f49c4e32d59855a62296fb74136a44">disconnect</a>(bool wait_for_removal=false)</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html">cpp_redis::network::tcp_client</a></td><td class="entry"><span class="mlabel">virtual</span></td></tr>
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a9a7d5942205db8be03da581a848b8ec0">disconnection_handler_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a0a636ca6bd59425bf22416a1c7694f65">is_connected</a>(void) const</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html">cpp_redis::network::tcp_client</a></td><td class="entry"><span class="mlabel">virtual</span></td></tr>

docs/html/classcpp__redis_1_1network_1_1tcp__client.html

@@ -97,7 +97,7 @@
 &#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#af859036bbc7e5ec9149c1410a1a66f09">~tcp_client</a> (void)=default</td></tr>
 <tr class="memdesc:af859036bbc7e5ec9149c1410a1a66f09"><td class="mdescLeft">&#160;</td><td class="mdescRight">dtor <br /></td></tr>
 <tr class="separator:af859036bbc7e5ec9149c1410a1a66f09"><td class="memSeparator" colspan="2">&#160;</td></tr>
-<tr class="memitem:a5808c0569980d83479f755ac55a12dfb"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a5808c0569980d83479f755ac55a12dfb">connect</a> (const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_msecs)</td></tr>
+<tr class="memitem:a5808c0569980d83479f755ac55a12dfb"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a5808c0569980d83479f755ac55a12dfb">connect</a> (const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_ms)</td></tr>
 <tr class="separator:a5808c0569980d83479f755ac55a12dfb"><td class="memSeparator" colspan="2">&#160;</td></tr>
 <tr class="memitem:a88f49c4e32d59855a62296fb74136a44"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client.html#a88f49c4e32d59855a62296fb74136a44">disconnect</a> (bool wait_for_removal=false)</td></tr>
 <tr class="separator:a88f49c4e32d59855a62296fb74136a44"><td class="memSeparator" colspan="2">&#160;</td></tr>
@@ -229,7 +229,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#a5808c0569980d83479f755ac
           <td class="paramkey"></td>
           <td></td>
           <td class="paramtype">std::uint32_t&#160;</td>
-          <td class="paramname"><em>timeout_msecs</em>&#160;</td>
+          <td class="paramname"><em>timeout_ms</em>&#160;</td>
         </tr>
         <tr>
           <td></td>
@@ -248,7 +248,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#a5808c0569980d83479f755ac
   <table class="params">
     <tr><td class="paramname">addr</td><td>host to be connected to </td></tr>
     <tr><td class="paramname">port</td><td>port to be connected to </td></tr>
-    <tr><td class="paramname">timeout_msecs</td><td>max time to connect in ms </td></tr>
+    <tr><td class="paramname">timeout_ms</td><td>max time to connect in ms </td></tr>
   </table>
   </dd>
 </dl>

docs/html/classcpp__redis_1_1network_1_1tcp__client__iface-members.html

@@ -79,7 +79,7 @@
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#ae8bf79e8e1f1d7e359ed1c7cdc4026fc">async_read_callback_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"></td></tr>
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a9cd01e8a68479456d15d6435ffad9b92">async_write</a>(write_request &amp;request)=0</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"><span class="mlabel">pure virtual</span></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a1dc52ccc70cf377c4fbb495a16adc658">async_write_callback_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"></td></tr>
-  <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a81ee982136e85b7c3401393341bc594c">connect</a>(const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_msecs=0)=0</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"><span class="mlabel">pure virtual</span></td></tr>
+  <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a81ee982136e85b7c3401393341bc594c">connect</a>(const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_ms=0)=0</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"><span class="mlabel">pure virtual</span></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a024073fb3436d8fa99de8cad63418f6c">disconnect</a>(bool wait_for_removal=false)=0</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"><span class="mlabel">pure virtual</span></td></tr>
   <tr class="even"><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a9a7d5942205db8be03da581a848b8ec0">disconnection_handler_t</a> typedef</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"></td></tr>
   <tr><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a41ad0b43e3ab172828a3d2ce55d23893">is_connected</a>(void) const =0</td><td class="entry"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html">cpp_redis::network::tcp_client_iface</a></td><td class="entry"><span class="mlabel">pure virtual</span></td></tr>

docs/html/classcpp__redis_1_1network_1_1tcp__client__iface.html

@@ -119,7 +119,7 @@
 virtual&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a7381e8921118a13b5994101864906122">~tcp_client_iface</a> (void)=default</td></tr>
 <tr class="memdesc:a7381e8921118a13b5994101864906122"><td class="mdescLeft">&#160;</td><td class="mdescRight">dtor <br /></td></tr>
 <tr class="separator:a7381e8921118a13b5994101864906122"><td class="memSeparator" colspan="2">&#160;</td></tr>
-<tr class="memitem:a81ee982136e85b7c3401393341bc594c"><td class="memItemLeft" align="right" valign="top">virtual void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a81ee982136e85b7c3401393341bc594c">connect</a> (const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_msecs=0)=0</td></tr>
+<tr class="memitem:a81ee982136e85b7c3401393341bc594c"><td class="memItemLeft" align="right" valign="top">virtual void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a81ee982136e85b7c3401393341bc594c">connect</a> (const std::string &amp;addr, std::uint32_t port, std::uint32_t timeout_ms=0)=0</td></tr>
 <tr class="separator:a81ee982136e85b7c3401393341bc594c"><td class="memSeparator" colspan="2">&#160;</td></tr>
 <tr class="memitem:a024073fb3436d8fa99de8cad63418f6c"><td class="memItemLeft" align="right" valign="top">virtual void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classcpp__redis_1_1network_1_1tcp__client__iface.html#a024073fb3436d8fa99de8cad63418f6c">disconnect</a> (bool wait_for_removal=false)=0</td></tr>
 <tr class="separator:a024073fb3436d8fa99de8cad63418f6c"><td class="memSeparator" colspan="2">&#160;</td></tr>
@@ -276,7 +276,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#a81ee982136e85b7c34013933
           <td class="paramkey"></td>
           <td></td>
           <td class="paramtype">std::uint32_t&#160;</td>
-          <td class="paramname"><em>timeout_msecs</em> = <code>0</code>&#160;</td>
+          <td class="paramname"><em>timeout_ms</em> = <code>0</code>&#160;</td>
         </tr>
         <tr>
           <td></td>
@@ -295,7 +295,7 @@ <h2 class="memtitle"><span class="permalink"><a href="#a81ee982136e85b7c34013933
   <table class="params">
     <tr><td class="paramname">addr</td><td>host to be connected to </td></tr>
     <tr><td class="paramname">port</td><td>port to be connected to </td></tr>
-    <tr><td class="paramname">timeout_msecs</td><td>max time to connect in ms </td></tr>
+    <tr><td class="paramname">timeout_ms</td><td>max time to connect in ms </td></tr>
   </table>
   </dd>
 </dl>