-// SceneryPager.hxx -- Interface to OSG database pager
+// SceneryPager.cxx -- Interface to OSG database pager
//
// Copyright (C) 2007 Tim Moore timoore@redhat.com
//
// along with this program; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <simgear/scene/model/SGPagedLOD.hxx>
+#include <simgear/math/SGMath.hxx>
#include "SceneryPager.hxx"
#include <algorithm>
#include <functional>
+using namespace osg;
using namespace flightgear;
-using osg::ref_ptr;
-using osg::Node;
SceneryPager::SceneryPager()
{
{
}
-void SceneryPager::queueRequest(const std::string& fileName, osg::Group* group,
- float priority, osg::FrameStamp* frameStamp)
+#if SG_PAGEDLOD_HAS_OPTIONS
+#else
+void SceneryPager::requestNodeFile(const std::string& fileName, Group* group,
+ float priority, const FrameStamp* framestamp,
+ ref_ptr<Referenced>& databaseRequest,
+ osgDB::ReaderWriter::Options* options)
+{
+ simgear::SGPagedLOD *sgplod = dynamic_cast<simgear::SGPagedLOD*>(group);
+ if(sgplod)
+ DatabasePager::requestNodeFile(fileName, group, priority, framestamp,
+ databaseRequest,
+ sgplod->getReaderWriterOptions());
+ else
+ DatabasePager::requestNodeFile(fileName, group, priority, framestamp,
+ databaseRequest,
+ options);
+}
+#endif
+
+void SceneryPager::queueRequest(const std::string& fileName, Group* group,
+ float priority, FrameStamp* frameStamp,
+ ref_ptr<Referenced>& databaseRequest,
+ osgDB::ReaderWriter::Options* options)
{
_pagerRequests.push_back(PagerRequest(fileName, group, priority,
- frameStamp));
+ frameStamp,
+ databaseRequest,
+ options));
}
void SceneryPager::queueDeleteRequest(osg::ref_ptr<osg::Object>& objptr)
_deleteRequests.push_back(objptr);
objptr = 0;
}
+
+// Work around interface change in
+// osgDB::DatabasePager::requestNodeFile
+namespace
+{
+struct NodePathProxy
+{
+ NodePathProxy(NodePath& nodePath)
+ : _nodePath(nodePath)
+ {
+ }
+ operator Group* () { return static_cast<Group*>(_nodePath.back()); }
+ operator NodePath& () { return _nodePath; }
+ NodePath& _nodePath;
+};
+}
+
+void SceneryPager::PagerRequest::doRequest(SceneryPager* pager)
+{
+ if (_group->getNumChildren() == 0) {
+ NodePath path;
+ path.push_back(_group.get());
+ pager->requestNodeFile(_fileName, NodePathProxy(path), _priority,
+ _frameStamp.get(),
+ *_databaseRequest,
+ _options.get());
+ }
+}
+
void SceneryPager::signalEndFrame()
{
using namespace std;
if (!_deleteRequests.empty()) {
areDeleteRequests = true;
OpenThreads::ScopedLock<OpenThreads::Mutex>
- lock(_childrenToDeleteListMutex);
- _childrenToDeleteList.insert(_childrenToDeleteList.end(),
- _deleteRequests.begin(),
- _deleteRequests.end());
+ lock(_fileRequestQueue->_childrenToDeleteListMutex);
+ ObjectList& deleteList = _fileRequestQueue->_childrenToDeleteList;
+ deleteList.insert(deleteList.end(),
+ _deleteRequests.begin(),
+ _deleteRequests.end());
_deleteRequests.clear();
}
if (!_pagerRequests.empty()) {
bind2nd(mem_fun_ref(&PagerRequest::doRequest), this));
_pagerRequests.clear();
}
- if (areDeleteRequests && !arePagerRequests)
- updateDatabasePagerThreadBlock();
+ if (areDeleteRequests && !arePagerRequests) {
+ _fileRequestQueue->updateBlock();
+ }
DatabasePager::signalEndFrame();
}