117 lines
3.7 KiB
C++
117 lines
3.7 KiB
C++
/**
|
|
* @file networkio.h
|
|
* @author Nat Goodspeed
|
|
* @date 2009-01-09
|
|
* @brief
|
|
*
|
|
* $LicenseInfo:firstyear=2009&license=viewergpl$
|
|
*
|
|
* Copyright (c) 2009, Linden Research, Inc.
|
|
*
|
|
* Second Life Viewer Source Code
|
|
* The source code in this file ("Source Code") is provided by Linden Lab
|
|
* to you under the terms of the GNU General Public License, version 2.0
|
|
* ("GPL"), unless you have obtained a separate licensing agreement
|
|
* ("Other License"), formally executed by you and Linden Lab. Terms of
|
|
* the GPL can be found in doc/GPL-license.txt in this distribution, or
|
|
* online at http://secondlifegrid.net/programs/open_source/licensing/gplv2
|
|
*
|
|
* There are special exceptions to the terms and conditions of the GPL as
|
|
* it is applied to this Source Code. View the full text of the exception
|
|
* in the file doc/FLOSS-exception.txt in this software distribution, or
|
|
* online at
|
|
* http://secondlifegrid.net/programs/open_source/licensing/flossexception
|
|
*
|
|
* By copying, modifying or distributing this software, you acknowledge
|
|
* that you have read and understood your obligations described above,
|
|
* and agree to abide by those obligations.
|
|
*
|
|
* ALL LINDEN LAB SOURCE CODE IS PROVIDED "AS IS." LINDEN LAB MAKES NO
|
|
* WARRANTIES, EXPRESS, IMPLIED OR OTHERWISE, REGARDING ITS ACCURACY,
|
|
* COMPLETENESS OR PERFORMANCE.
|
|
* $/LicenseInfo$
|
|
*/
|
|
|
|
#if ! defined(LL_NETWORKIO_H)
|
|
#define LL_NETWORKIO_H
|
|
|
|
#include "llmemory.h" // LLSingleton
|
|
#include "llapr.h"
|
|
#include "llares.h"
|
|
#include "llpumpio.h"
|
|
#include "llhttpclient.h"
|
|
|
|
/*****************************************************************************
|
|
* NetworkIO
|
|
*****************************************************************************/
|
|
// Doing this initialization in a class constructor makes sense. But we don't
|
|
// want to redo it for each different test. Nor do we want to do it at static-
|
|
// init time. Use the lazy, on-demand initialization we get from LLSingleton.
|
|
class NetworkIO: public LLSingleton<NetworkIO>
|
|
{
|
|
public:
|
|
NetworkIO():
|
|
mServicePump(NULL),
|
|
mDone(false)
|
|
{
|
|
ll_init_apr();
|
|
if (! gAPRPoolp)
|
|
{
|
|
throw std::runtime_error("Can't initialize APR");
|
|
}
|
|
|
|
// Create IO Pump to use for HTTP Requests.
|
|
mServicePump = new LLPumpIO(gAPRPoolp);
|
|
LLHTTPClient::setPump(*mServicePump);
|
|
if (ll_init_ares() == NULL || !gAres->isInitialized())
|
|
{
|
|
throw std::runtime_error("Can't start DNS resolver");
|
|
}
|
|
|
|
// You can interrupt pump() without waiting the full timeout duration
|
|
// by posting an event to the LLEventPump named "done".
|
|
LLEventPumps::instance().obtain("done").listen("self",
|
|
boost::bind(&NetworkIO::done, this, _1));
|
|
}
|
|
|
|
bool pump(F32 timeout=10)
|
|
{
|
|
// Reset the done flag so we don't pop out prematurely
|
|
mDone = false;
|
|
// Evidently the IO structures underlying LLHTTPClient need to be
|
|
// "pumped". Do some stuff normally performed in the viewer's main
|
|
// loop.
|
|
LLTimer timer;
|
|
while (timer.getElapsedTimeF32() < timeout)
|
|
{
|
|
if (mDone)
|
|
{
|
|
// std::cout << "NetworkIO::pump(" << timeout << "): breaking loop after "
|
|
// << timer.getElapsedTimeF32() << " seconds\n";
|
|
return true;
|
|
}
|
|
pumpOnce();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void pumpOnce()
|
|
{
|
|
gAres->process();
|
|
mServicePump->pump();
|
|
mServicePump->callback();
|
|
}
|
|
|
|
bool done(const LLSD&)
|
|
{
|
|
mDone = true;
|
|
return false;
|
|
}
|
|
|
|
private:
|
|
LLPumpIO* mServicePump;
|
|
bool mDone;
|
|
};
|
|
|
|
#endif /* ! defined(LL_NETWORKIO_H) */
|