Force 32 bits depth on .ico - only for Windows
[fg:hoorays-flightgear.git] / src / Scenery / SceneryPager.cxx
1 // SceneryPager.cxx -- Interface to OSG database pager
2 //
3 // Copyright (C) 2007 Tim Moore timoore@redhat.com
4 //
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.
9 //
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.
14 //
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.
18
19 #ifdef HAVE_CONFIG_H
20 #  include <config.h>
21 #endif
22
23 #include "SceneryPager.hxx"
24 #include <algorithm>
25 #include <functional>
26
27 using namespace osg;
28 using namespace flightgear;
29
30 SceneryPager::SceneryPager()
31 {
32     _pagerRequests.reserve(48);
33     _deleteRequests.reserve(16);
34 }
35
36 SceneryPager::SceneryPager(const SceneryPager& rhs) :
37     DatabasePager(rhs)
38 {
39 }
40
41 SceneryPager::~SceneryPager()
42 {
43 }
44
45 void SceneryPager::queueRequest(const std::string& fileName, Group* group,
46                                 float priority, FrameStamp* frameStamp,
47                                 ref_ptr<Referenced>& databaseRequest,
48                                 osgDB::ReaderWriter::Options* options)
49 {
50     _pagerRequests.push_back(PagerRequest(fileName, group, priority,
51                                           frameStamp,
52                                           databaseRequest,
53                                           options));
54 }
55
56 void SceneryPager::queueDeleteRequest(osg::ref_ptr<osg::Object>& objptr)
57 {
58     _deleteRequests.push_back(objptr);
59     objptr = 0;
60 }
61
62 // Work around interface change in
63 // osgDB::DatabasePager::requestNodeFile
64 namespace
65 {
66 struct NodePathProxy
67 {
68     NodePathProxy(NodePath& nodePath)
69         : _nodePath(nodePath)
70     {
71     }
72     operator Group* () { return static_cast<Group*>(_nodePath.back()); }
73     operator NodePath& () { return _nodePath; }
74     NodePath& _nodePath;
75 };
76 }
77
78 void SceneryPager::PagerRequest::doRequest(SceneryPager* pager)
79 {
80     if (_group->getNumChildren() == 0) {
81         NodePath path;
82         path.push_back(_group.get());
83         pager->requestNodeFile(_fileName, NodePathProxy(path), _priority,
84                                _frameStamp.get(),
85                                *_databaseRequest,
86                                _options.get());
87     }
88 }
89
90 void SceneryPager::signalEndFrame()
91 {
92     using namespace std;
93     bool areDeleteRequests = false;
94     bool arePagerRequests = false;
95     if (!_deleteRequests.empty()) {
96         areDeleteRequests = true;
97         OpenThreads::ScopedLock<OpenThreads::Mutex>
98             lock(_fileRequestQueue->_childrenToDeleteListMutex);
99         ObjectList& deleteList = _fileRequestQueue->_childrenToDeleteList;
100         deleteList.insert(deleteList.end(),
101                           _deleteRequests.begin(),
102                           _deleteRequests.end());
103         _deleteRequests.clear();
104     }
105     if (!_pagerRequests.empty()) {
106         arePagerRequests = true;
107         for_each(_pagerRequests.begin(), _pagerRequests.end(),
108                  bind2nd(mem_fun_ref(&PagerRequest::doRequest), this));
109         _pagerRequests.clear();
110     }
111     if (areDeleteRequests && !arePagerRequests) {
112         _fileRequestQueue->updateBlock();
113     }
114     DatabasePager::signalEndFrame();
115 }
116