mirror of https://github.com/OpenMW/openmw.git
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
138 lines
4.4 KiB
C++
138 lines
4.4 KiB
C++
#ifndef OPENMW_COMPONENTS_DETOURNAVIGATOR_ASYNCNAVMESHUPDATER_H
|
|
#define OPENMW_COMPONENTS_DETOURNAVIGATOR_ASYNCNAVMESHUPDATER_H
|
|
|
|
#include "navmeshcacheitem.hpp"
|
|
#include "offmeshconnectionsmanager.hpp"
|
|
#include "tilecachedrecastmeshmanager.hpp"
|
|
#include "tileposition.hpp"
|
|
#include "navmeshtilescache.hpp"
|
|
#include "waitconditiontype.hpp"
|
|
|
|
#include <osg/Vec3f>
|
|
|
|
#include <atomic>
|
|
#include <chrono>
|
|
#include <condition_variable>
|
|
#include <memory>
|
|
#include <mutex>
|
|
#include <deque>
|
|
#include <set>
|
|
#include <thread>
|
|
#include <tuple>
|
|
#include <list>
|
|
|
|
class dtNavMesh;
|
|
|
|
namespace Loading
|
|
{
|
|
class Listener;
|
|
}
|
|
|
|
namespace DetourNavigator
|
|
{
|
|
enum class ChangeType
|
|
{
|
|
remove = 0,
|
|
mixed = 1,
|
|
add = 2,
|
|
update = 3,
|
|
};
|
|
|
|
inline std::ostream& operator <<(std::ostream& stream, ChangeType value)
|
|
{
|
|
switch (value) {
|
|
case ChangeType::remove:
|
|
return stream << "ChangeType::remove";
|
|
case ChangeType::mixed:
|
|
return stream << "ChangeType::mixed";
|
|
case ChangeType::add:
|
|
return stream << "ChangeType::add";
|
|
case ChangeType::update:
|
|
return stream << "ChangeType::update";
|
|
}
|
|
return stream << "ChangeType::" << static_cast<int>(value);
|
|
}
|
|
|
|
struct Job
|
|
{
|
|
const osg::Vec3f mAgentHalfExtents;
|
|
const std::weak_ptr<GuardedNavMeshCacheItem> mNavMeshCacheItem;
|
|
const TilePosition mChangedTile;
|
|
const std::chrono::steady_clock::time_point mProcessTime;
|
|
unsigned mTryNumber = 0;
|
|
ChangeType mChangeType;
|
|
int mDistanceToPlayer;
|
|
const int mDistanceToOrigin;
|
|
|
|
Job(const osg::Vec3f& agentHalfExtents, std::weak_ptr<GuardedNavMeshCacheItem> navMeshCacheItem,
|
|
const TilePosition& changedTile, ChangeType changeType, int distanceToPlayer,
|
|
std::chrono::steady_clock::time_point processTime);
|
|
};
|
|
|
|
using JobIt = std::list<Job>::iterator;
|
|
|
|
class AsyncNavMeshUpdater
|
|
{
|
|
public:
|
|
AsyncNavMeshUpdater(const Settings& settings, TileCachedRecastMeshManager& recastMeshManager,
|
|
OffMeshConnectionsManager& offMeshConnectionsManager);
|
|
~AsyncNavMeshUpdater();
|
|
|
|
void post(const osg::Vec3f& agentHalfExtents, const SharedNavMeshCacheItem& mNavMeshCacheItem,
|
|
const TilePosition& playerTile, const std::map<TilePosition, ChangeType>& changedTiles);
|
|
|
|
void wait(Loading::Listener& listener, WaitConditionType waitConditionType);
|
|
|
|
void reportStats(unsigned int frameNumber, osg::Stats& stats) const;
|
|
|
|
private:
|
|
std::reference_wrapper<const Settings> mSettings;
|
|
std::reference_wrapper<TileCachedRecastMeshManager> mRecastMeshManager;
|
|
std::reference_wrapper<OffMeshConnectionsManager> mOffMeshConnectionsManager;
|
|
std::atomic_bool mShouldStop;
|
|
mutable std::mutex mMutex;
|
|
std::condition_variable mHasJob;
|
|
std::condition_variable mDone;
|
|
std::condition_variable mProcessed;
|
|
std::list<Job> mJobs;
|
|
std::deque<JobIt> mWaiting;
|
|
std::set<std::tuple<osg::Vec3f, TilePosition>> mPushed;
|
|
Misc::ScopeGuarded<TilePosition> mPlayerTile;
|
|
NavMeshTilesCache mNavMeshTilesCache;
|
|
Misc::ScopeGuarded<std::set<std::tuple<osg::Vec3f, TilePosition>>> mProcessingTiles;
|
|
std::map<std::tuple<osg::Vec3f, TilePosition>, std::chrono::steady_clock::time_point> mLastUpdates;
|
|
std::set<std::tuple<osg::Vec3f, TilePosition>> mPresentTiles;
|
|
std::vector<std::thread> mThreads;
|
|
|
|
void process() noexcept;
|
|
|
|
bool processJob(const Job& job);
|
|
|
|
JobIt getNextJob();
|
|
|
|
JobIt getJob(std::deque<JobIt>& jobs, bool changeLastUpdate);
|
|
|
|
void postThreadJob(JobIt job, std::deque<JobIt>& queue);
|
|
|
|
void writeDebugFiles(const Job& job, const RecastMesh* recastMesh) const;
|
|
|
|
void repost(JobIt job);
|
|
|
|
bool lockTile(const osg::Vec3f& agentHalfExtents, const TilePosition& changedTile);
|
|
|
|
void unlockTile(const osg::Vec3f& agentHalfExtents, const TilePosition& changedTile);
|
|
|
|
inline std::size_t getTotalJobs() const;
|
|
|
|
void cleanupLastUpdates();
|
|
|
|
int waitUntilJobsDoneForNotPresentTiles(const std::size_t initialJobsLeft, std::size_t& maxJobsLeft, Loading::Listener& listener);
|
|
|
|
void waitUntilAllJobsDone();
|
|
|
|
inline void removeJob(JobIt job);
|
|
};
|
|
}
|
|
|
|
#endif
|