Shuffle maybeMakeSpaceAvailable() to ConnStateData::In

maybeMakeSpaceAvailable() is an operation only for the buffer from
ConnStateData::In.

diff --git a/src/client_side.cc b/src/client_side.cc
index 95c809c331f5910ef051fb6124ccb948a93dc55b..54f11b455149306a4f36bc215bf1d823f6d86fab 100644 (file)
--- a/src/client_side.cc
+++ b/src/client_side.cc
@@ -248,7 +248,7 @@ ConnStateData::readSomeData()
 
     debugs(33, 4, HERE << clientConnection << ": reading request...");
 
-    if (!maybeMakeSpaceAvailable())
+    if (!in.maybeMakeSpaceAvailable())
         return;
 
     typedef CommCbMemFunT<ConnStateData, CommIoCbParams> Dialer;
@@ -2375,19 +2375,19 @@ parseHttpRequest(ConnStateData *csd, HttpParser *hp, HttpRequestMethod * method_
 }
 
 bool
-ConnStateData::maybeMakeSpaceAvailable()
+ConnStateData::In::maybeMakeSpaceAvailable()
 {
-    if (in.buf.spaceSize() < 2) {
-        const SBuf::size_type haveCapacity = in.buf.length() + in.buf.spaceSize();
+    if (buf.spaceSize() < 2) {
+        const SBuf::size_type haveCapacity = buf.length() + buf.spaceSize();
         if (haveCapacity >= Config.maxRequestBufferSize) {
             debugs(33, 4, "request buffer full: client_request_buffer_max_size=" << Config.maxRequestBufferSize);
             return false;
         }
         const SBuf::size_type wantCapacity = min(Config.maxRequestBufferSize, haveCapacity*2);
-        in.buf.reserveCapacity(wantCapacity);
-        debugs(33, 2, "growing request buffer: available=" << in.buf.spaceSize() << " used=" << in.buf.length());
+        buf.reserveCapacity(wantCapacity);
+        debugs(33, 2, "growing request buffer: available=" << buf.spaceSize() << " used=" << buf.length());
     }
-    return (in.buf.spaceSize() >= 2);
+    return (buf.spaceSize() >= 2);
 }
 
 void

diff --git a/src/client_side.h b/src/client_side.h
index 6531a68095b36914e40f58a4fbc7862002ae62df..ddd6901b90dc1a946ffee93b48f5f3d18c5b6521 100644 (file)
--- a/src/client_side.h
+++ b/src/client_side.h
@@ -195,7 +195,6 @@ public:
     /// Traffic parsing
     bool clientParseRequests();
     void readNextRequest();
-    bool maybeMakeSpaceAvailable();
     ClientSocketContext::Pointer getCurrentContext() const;
     void addContextToQueue(ClientSocketContext * context);
     int getConcurrentRequestCount() const;
@@ -211,6 +210,7 @@ public:
     struct In {
         In();
         ~In();
+        bool maybeMakeSpaceAvailable();
 
         ChunkedCodingParser *bodyParser; ///< parses chunked request body
         SBuf buf;

diff --git a/src/tests/stub_client_side.cc b/src/tests/stub_client_side.cc
index 04cf52a9aac49e61ac7535b7300c186358565e91..f2173d0ced7551c648e8e0631f751a9928a527b6 100644 (file)
--- a/src/tests/stub_client_side.cc
+++ b/src/tests/stub_client_side.cc
@@ -34,7 +34,6 @@ void ConnStateData::freeAllContexts() STUB
 void ConnStateData::notifyAllContexts(const int xerrno) STUB
 bool ConnStateData::clientParseRequests() STUB_RETVAL(false)
 void ConnStateData::readNextRequest() STUB
-bool ConnStateData::maybeMakeSpaceAvailable() STUB_RETVAL(false)
 void ConnStateData::addContextToQueue(ClientSocketContext * context) STUB
 int ConnStateData::getConcurrentRequestCount() const STUB_RETVAL(0)
 bool ConnStateData::isOpen() const STUB_RETVAL(false)
@@ -74,6 +73,8 @@ void ConnStateData::buildSslCertGenerationParams(Ssl::CertificateProperties &cer
 bool ConnStateData::serveDelayedError(ClientSocketContext *context) STUB_RETVAL(false)
 #endif
 
+bool ConnStateData::In::maybeMakeSpaceAvailable() STUB_RETVAL(false)
+
 void setLogUri(ClientHttpRequest * http, char const *uri, bool cleanUrl) STUB
 const char *findTrailingHTTPVersion(const char *uriAndHTTPVersion, const char *end) STUB_RETVAL(NULL)
 int varyEvaluateMatch(StoreEntry * entry, HttpRequest * req) STUB_RETVAL(0)