Merge branch 'tcp_rcvwnd' of github.com:AndreasAakesson/IncludeOS into tcp_rcvwnd

Author: AndreasAakesson

api/net/tcp/read_buffer.hpp

@@ -84,6 +84,14 @@ class Read_buffer {
   buffer_t buffer()
   { return buf; }
 
+  /**
+   * @brief  Check if internal buffer has unhandled data
+   *
+   * @return True if the internal buffer is unique with data and doesnt contain hole
+  */
+  bool has_unhandled_data()
+  { return (buf.unique() && (size() > 0) && (missing() == 0)); }
+
   /**
    * @brief      Exposes the internal buffer (read only)
    *

lib/microLB/micro_lb/balancer.cpp

@@ -202,13 +202,14 @@ namespace microLB
         assert(outgoing->is_connected());
         LBOUT("Assigning client to node %d (%s)\n",
               algo_iterator, outgoing->to_string().c_str());
-        auto& session = this->create_session(
-              std::move(conn), std::move(outgoing));
-        // flush readq to session.outgoing
+        // flush readq to outgoing before creating session
         for (auto buffer : readq) {
           LBOUT("*** Flushing %lu bytes\n", buffer->size());
-          session.outgoing->write(buffer);
+          outgoing->write(buffer);
         }
+        auto& session = this->create_session(
+              std::move(conn), std::move(outgoing));
+
         return nullptr;
       }
     }

src/net/tcp/read_request.cpp

@@ -202,8 +202,9 @@ namespace tcp {
     // if noone is using the buffer right now, (stupid yes)
     // AND it contains data without any holes,
     // return it to the user
-    if(buf->buffer().unique() and buf->size() > 0 and buf->missing() == 0)
+    if (buf->has_unhandled_data())
     {
+
       callback(buf->buffer());
     }
     // reset the first buffer