1 // SceneryPager.cxx -- Interface to OSG database pager
3 // Copyright (C) 2007 Tim Moore timoore@redhat.com
5 // This program is free software; you can redistribute it and/or
6 // modify it under the terms of the GNU General Public License as
7 // published by the Free Software Foundation; either version 2 of the
8 // License, or (at your option) any later version.
10 // This program is distributed in the hope that it will be useful, but
11 // WITHOUT ANY WARRANTY; without even the implied warranty of
12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 // General Public License for more details.
15 // You should have received a copy of the GNU General Public License
16 // along with this program; if not, write to the Free Software
17 // Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
23 #include "SceneryPager.hxx"
28 using namespace flightgear;
30 SceneryPager::SceneryPager()
32 _pagerRequests.reserve(48);
33 _deleteRequests.reserve(16);
36 SceneryPager::SceneryPager(const SceneryPager& rhs) :
41 SceneryPager::~SceneryPager()
45 void SceneryPager::clearRequests()
47 _pagerRequests.clear();
48 _deleteRequests.clear();
51 void SceneryPager::queueRequest(const std::string& fileName, Group* group,
52 float priority, FrameStamp* frameStamp,
53 ref_ptr<Referenced>& databaseRequest,
54 osgDB::ReaderWriter::Options* options)
56 _pagerRequests.push_back(PagerRequest(fileName, group, priority,
62 void SceneryPager::queueDeleteRequest(osg::ref_ptr<osg::Object>& objptr)
64 _deleteRequests.push_back(objptr);
68 // Work around interface change in
69 // osgDB::DatabasePager::requestNodeFile
74 NodePathProxy(NodePath& nodePath)
78 operator Group* () { return static_cast<Group*>(_nodePath.back()); }
79 operator NodePath& () { return _nodePath; }
84 void SceneryPager::PagerRequest::doRequest(SceneryPager* pager)
86 if (_group->getNumChildren() == 0) {
88 path.push_back(_group.get());
89 pager->requestNodeFile(_fileName, NodePathProxy(path), _priority,
96 void SceneryPager::signalEndFrame()
99 bool areDeleteRequests = false;
100 bool arePagerRequests = false;
101 if (!_deleteRequests.empty()) {
102 areDeleteRequests = true;
103 OpenThreads::ScopedLock<OpenThreads::Mutex>
104 lock(_fileRequestQueue->_childrenToDeleteListMutex);
105 ObjectList& deleteList = _fileRequestQueue->_childrenToDeleteList;
106 deleteList.insert(deleteList.end(),
107 _deleteRequests.begin(),
108 _deleteRequests.end());
109 _deleteRequests.clear();
111 if (!_pagerRequests.empty()) {
112 arePagerRequests = true;
113 for_each(_pagerRequests.begin(), _pagerRequests.end(),
114 bind2nd(mem_fun_ref(&PagerRequest::doRequest), this));
115 _pagerRequests.clear();
117 if (areDeleteRequests && !arePagerRequests) {
118 _fileRequestQueue->updateBlock();
120 DatabasePager::signalEndFrame();