Replace ConnStateData::addContextToQueue() with Pipeline::add()

diff --git a/src/client_side.cc b/src/client_side.cc
index d3ef7e95a8b556c2e659910799264a541c8912af..06f63d195ae50ea46848af09faea8d6c9caf80a7 100644 (file)
--- a/src/client_side.cc
+++ b/src/client_side.cc
@@ -271,7 +271,7 @@ ClientSocketContext::registerWithConn()
     assert (http);
     assert (http->getConn() != NULL);
     connRegistered_ = true;
-    http->getConn()->addContextToQueue(this);
+    http->getConn()->pipeline.add(ClientSocketContext::Pointer(this));
 }
 
 void
@@ -2260,18 +2260,6 @@ parseHttpRequest(ConnStateData *csd, const Http1::RequestParserPointer &hp)
     return result;
 }
 
-void
-ConnStateData::addContextToQueue(ClientSocketContext * context)
-{
-    ClientSocketContext::Pointer *S;
-
-    for (S = (ClientSocketContext::Pointer *) & currentobject; S->getRaw();
-            S = &(*S)->next);
-    *S = context;
-
-    ++pipeline.nrequests;
-}
-
 int
 ConnStateData::getConcurrentRequestCount() const
 {

diff --git a/src/client_side.h b/src/client_side.h
index 953cd30633ff1bce001b446f6aff6e3aaee94320..ba6babf7830677c778416cdfb7a49d1838277464 100644 (file)
--- a/src/client_side.h
+++ b/src/client_side.h
@@ -188,7 +188,6 @@ public:
     bool clientParseRequests();
     void readNextRequest();
     ClientSocketContext::Pointer getCurrentContext() const;
-    void addContextToQueue(ClientSocketContext * context);
     int getConcurrentRequestCount() const;
     bool isOpen() const;
 

diff --git a/src/tests/stub_client_side.cc b/src/tests/stub_client_side.cc
index 513141b0b49f615e2210549afcf38f7006ee667e..238455410f97db085e147d6517e8fb9f677f8788 100644 (file)
--- a/src/tests/stub_client_side.cc
+++ b/src/tests/stub_client_side.cc
@@ -41,7 +41,6 @@ void ConnStateData::freeAllContexts() STUB
 void ConnStateData::notifyAllContexts(const int xerrno) STUB
 bool ConnStateData::clientParseRequests() STUB_RETVAL(false)
 void ConnStateData::readNextRequest() STUB
-void ConnStateData::addContextToQueue(ClientSocketContext * context) STUB
 int ConnStateData::getConcurrentRequestCount() const STUB_RETVAL(0)
 bool ConnStateData::isOpen() const STUB_RETVAL(false)
 void ConnStateData::sendControlMsg(HttpControlMsg msg) STUB