summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--indra/test/io.cpp30
-rw-r--r--indra/test/llhttpclient_tut.cpp8
-rw-r--r--indra/test/lliohttpserver_tut.cpp4
3 files changed, 29 insertions, 13 deletions
diff --git a/indra/test/io.cpp b/indra/test/io.cpp
index c8e53e77a0..38f86b9e57 100644
--- a/indra/test/io.cpp
+++ b/indra/test/io.cpp
@@ -823,13 +823,15 @@ namespace tut
class PumpAndChainTestData
{
protected:
+ apr_pool_t* mPool;
LLPumpIO* mPump;
LLPumpIO::chain_t mChain;
public:
PumpAndChainTestData()
{
- mPump = new LLPumpIO();
+ apr_pool_create(&mPool, NULL);
+ mPump = new LLPumpIO(mPool);
}
~PumpAndChainTestData()
@@ -906,9 +908,12 @@ namespace tut
pipe_and_pump_fitness()
{
- LLFrameTimer::updateFrameTime();
- mPump = new LLPumpIO();
+ apr_pool_create(&mPool, NULL);
+
+ LLFrameTimer::updateFrameTime();
+ mPump = new LLPumpIO(mPool);
mSocket = LLSocket::create(
+ mPool,
LLSocket::STREAM_TCP,
SERVER_LISTEN_PORT);
}
@@ -942,6 +947,7 @@ namespace tut
new LLPipeStringInjector("suckers never play me"));
boost::shared_ptr<LLChainIOFactory> factory(emitter);
LLIOServerSocket* server = new LLIOServerSocket(
+ mPool,
mSocket,
factory);
server->setResponseTimeout(SHORT_CHAIN_EXPIRY_SECS);
@@ -956,7 +962,7 @@ namespace tut
// Set up the client
//lldebugs << "fitness_test_object::test<1> - connecting client."
// << llendl;
- LLSocket::ptr_t client = LLSocket::create(LLSocket::STREAM_TCP);
+ LLSocket::ptr_t client = LLSocket::create(mPool, LLSocket::STREAM_TCP);
LLHost server_host("127.0.0.1", SERVER_LISTEN_PORT);
bool connected = client->blockingConnect(server_host);
ensure("Connected to server", connected);
@@ -988,6 +994,7 @@ namespace tut
emitter_t* emitter = new emitter_t(new LLIOFuzz(1000000));
boost::shared_ptr<LLChainIOFactory> factory(emitter);
LLIOServerSocket* server = new LLIOServerSocket(
+ mPool,
mSocket,
factory);
server->setResponseTimeout(SHORT_CHAIN_EXPIRY_SECS);
@@ -998,7 +1005,7 @@ namespace tut
pump_loop(mPump, 0.1f);
// Set up the client
- LLSocket::ptr_t client = LLSocket::create(LLSocket::STREAM_TCP);
+ LLSocket::ptr_t client = LLSocket::create(mPool, LLSocket::STREAM_TCP);
LLHost server_host("127.0.0.1", SERVER_LISTEN_PORT);
bool connected = client->blockingConnect(server_host);
ensure("Connected to server", connected);
@@ -1030,6 +1037,7 @@ namespace tut
emitter_t* emitter = new emitter_t(new LLIOFuzz(1000000));
boost::shared_ptr<LLChainIOFactory> factory(emitter);
LLIOServerSocket* server = new LLIOServerSocket(
+ mPool,
mSocket,
factory);
server->setResponseTimeout(SHORT_CHAIN_EXPIRY_SECS);
@@ -1040,7 +1048,7 @@ namespace tut
pump_loop(mPump, 0.1f);
// Set up the client
- LLSocket::ptr_t client = LLSocket::create(LLSocket::STREAM_TCP);
+ LLSocket::ptr_t client = LLSocket::create(mPool, LLSocket::STREAM_TCP);
LLHost server_host("127.0.0.1", SERVER_LISTEN_PORT);
bool connected = client->blockingConnect(server_host);
ensure("Connected to server", connected);
@@ -1072,6 +1080,7 @@ namespace tut
emitter_t* emitter = new emitter_t(new LLIOFuzz(1000000));
boost::shared_ptr<LLChainIOFactory> factory(emitter);
LLIOServerSocket* server = new LLIOServerSocket(
+ mPool,
mSocket,
factory);
server->setResponseTimeout(SHORT_CHAIN_EXPIRY_SECS + 1.80f);
@@ -1082,7 +1091,7 @@ namespace tut
pump_loop(mPump, 0.1f);
// Set up the client
- LLSocket::ptr_t client = LLSocket::create(LLSocket::STREAM_TCP);
+ LLSocket::ptr_t client = LLSocket::create(mPool, LLSocket::STREAM_TCP);
LLHost server_host("127.0.0.1", SERVER_LISTEN_PORT);
bool connected = client->blockingConnect(server_host);
ensure("Connected to server", connected);
@@ -1112,6 +1121,7 @@ namespace tut
sleeper_t* sleeper = new sleeper_t(new LLIOSleeper);
boost::shared_ptr<LLChainIOFactory> factory(sleeper);
LLIOServerSocket* server = new LLIOServerSocket(
+ mPool,
mSocket,
factory);
server->setResponseTimeout(1.0);
@@ -1124,7 +1134,7 @@ namespace tut
lldebugs << "** Server is up." << llendl;
// Set up the client
- LLSocket::ptr_t client = LLSocket::create(LLSocket::STREAM_TCP);
+ LLSocket::ptr_t client = LLSocket::create(mPool, LLSocket::STREAM_TCP);
LLHost server_host("127.0.0.1", SERVER_LISTEN_PORT);
bool connected = client->blockingConnect(server_host);
ensure("Connected to server", connected);
@@ -1242,12 +1252,14 @@ namespace tut
LLPumpIO::chain_t mChain;
LLSimpleRPCClient* mClient;
LLSD mResponse;
+ apr_pool_t* mPool;
rpc_server_data() :
mPump(NULL),
mClient(NULL)
{
- mPump = new LLPumpIO();
+ apr_pool_create(&mPool, NULL);
+ mPump = new LLPumpIO(mPool);
mClient = new LLSimpleRPCClient(&mResponse);
mChain.push_back(LLIOPipe::ptr_t(mClient));
mChain.push_back(LLIOPipe::ptr_t(new LLFilterSD2XMLRPCRequest));
diff --git a/indra/test/llhttpclient_tut.cpp b/indra/test/llhttpclient_tut.cpp
index c5e889b860..16a73c03cb 100644
--- a/indra/test/llhttpclient_tut.cpp
+++ b/indra/test/llhttpclient_tut.cpp
@@ -36,6 +36,7 @@
// These are too slow on Windows to actually include in the build. JC
#if !LL_WINDOWS
+#include "llapr.h"
#include "lltut.h"
#include "llhttpclient.h"
#include "llformat.h"
@@ -84,9 +85,10 @@ namespace tut
public:
HTTPClientTestData()
{
+ apr_pool_create(&mPool, NULL);
LLCurl::initClass(false);
- mServerPump = new LLPumpIO();
- mClientPump = new LLPumpIO();
+ mServerPump = new LLPumpIO(mPool);
+ mClientPump = new LLPumpIO(mPool);
LLHTTPClient::setPump(*mClientPump);
}
@@ -98,7 +100,7 @@ namespace tut
void setupTheServer()
{
- LLHTTPNode& root = LLIOHTTPServer::create(*mServerPump, 8888);
+ LLHTTPNode& root = LLIOHTTPServer::create(mPool, *mServerPump, 8888);
LLHTTPStandardServices::useServices();
LLHTTPRegistrar::buildAllServices(root);
diff --git a/indra/test/lliohttpserver_tut.cpp b/indra/test/lliohttpserver_tut.cpp
index b7274b662d..d12733dbee 100644
--- a/indra/test/lliohttpserver_tut.cpp
+++ b/indra/test/lliohttpserver_tut.cpp
@@ -76,12 +76,14 @@ namespace tut
HTTPServiceTestData()
: mResponse(NULL)
{
+ apr_pool_create(&mPool, NULL);
LLHTTPStandardServices::useServices();
LLHTTPRegistrar::buildAllServices(mRoot);
mRoot.addNode("/delayed/echo", new DelayedEcho(this));
mRoot.addNode("/wire/hello", new LLHTTPNodeForPipe<WireHello>);
}
+ apr_pool_t* mPool;
LLHTTPNode mRoot;
LLHTTPNode::ResponsePtr mResponse;
LLSD mResult;
@@ -105,7 +107,7 @@ namespace tut
LLPipeStringExtractor* extractor = new LLPipeStringExtractor();
LLPumpIO* pump;
- pump = new LLPumpIO();
+ pump = new LLPumpIO(mPool);
LLPumpIO::chain_t chain;
LLSD context;
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-03 00:49:08 +0000