networkio.h
上传用户:king477883
上传日期:2021-03-01
资源大小:9553k
文件大小:4k
- /**
- * @file networkio.h
- * @author Nat Goodspeed
- * @date 2009-01-09
- * @brief
- *
- * $LicenseInfo:firstyear=2009&license=viewergpl$
- *
- * Copyright (c) 2009-2010, 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() << " secondsn";
- 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) */