Lines Matching refs:transporter

13   QSharedPointer<DummyTransporter> transporter(  in readPartialResponses()  local
17 transporter->setFakeReadBuffer("+QUEUED"); in readPartialResponses()
18 transporter->readyRead(); in readPartialResponses()
19 transporter->setFakeReadBuffer("\r\n+QUEUED\r\n"); in readPartialResponses()
20 transporter->readyRead(); in readPartialResponses()
23 QCOMPARE(transporter->catchedResponses.size(), 2); in readPartialResponses()
33 QSharedPointer<DummyTransporter> transporter( in handleClusterRedirects() local
53 transporter->infoReply = infoReply; in handleClusterRedirects()
56 transporter->addFakeResponse(clusterSlotsReply); in handleClusterRedirects()
57 transporter->addFakeResponse(QString("+PONG\r\n")); in handleClusterRedirects()
60 transporter->addFakeResponse(movedReply); in handleClusterRedirects()
64 transporter->addFakeResponse(QString("+PONG\r\n")); in handleClusterRedirects()
65 transporter->fakeResponses.push_back( in handleClusterRedirects()
67 transporter->addFakeResponse(clusterSlotsReply); in handleClusterRedirects()
68 transporter->addFakeResponse(QString("+PONG\r\n")); in handleClusterRedirects()
69 transporter->addFakeResponse(movedReply); in handleClusterRedirects()
75 connection->setTransporter(transporter); in handleClusterRedirects()
80 [this, transporter, &commandReturnedResult](const RedisClient::Response& r) { in handleClusterRedirects()
82 qDebug() << "commands:" << transporter->executedCommands.size(); in handleClusterRedirects()
88 QCOMPARE(transporter->executedCommands.size(), 30); in handleClusterRedirects()