1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
/* This file is part of the Spring engine (GPL v2 or later), see LICENSE.html */
#ifndef QTPFS_PATHMANAGER_HDR
#define QTPFS_PATHMANAGER_HDR
#include <vector>
#include "Sim/Path/IPathManager.h"
#include "NodeLayer.hpp"
#include "PathCache.hpp"
#include "PathSearch.hpp"
#include "System/UnorderedMap.hpp"
struct MoveDef;
struct SRectangle;
class CSolidObject;
#ifdef QTPFS_ENABLE_THREADED_UPDATE
namespace spring {
class mutex;
class thread;
class condition_variable;
};
#endif
namespace QTPFS {
struct QTNode;
class PathManager: public IPathManager {
public:
PathManager();
~PathManager();
static void InitStatic();
unsigned int GetPathFinderType() const { return PFS_TYPE_QTPFS; }
std::uint32_t GetPathCheckSum() const { return pfsCheckSum; }
std::int64_t Finalize();
bool PathUpdated(unsigned int pathID);
void TerrainChange(unsigned int x1, unsigned int z1, unsigned int x2, unsigned int z2, unsigned int type);
void Update();
void UpdatePath(const CSolidObject* owner, unsigned int pathID);
void DeletePath(unsigned int pathID);
unsigned int RequestPath(
CSolidObject* object,
const MoveDef* moveDef,
float3 sourcePos,
float3 targetPos,
float radius,
bool synced
);
float3 NextWayPoint(
const CSolidObject*, // owner
unsigned int pathID,
unsigned int, // numRetries
float3 point,
float radius,
bool synced
);
void GetPathWayPoints(
unsigned int pathID,
std::vector<float3>& points,
std::vector<int>& starts
) const;
int2 GetNumQueuedUpdates() const;
private:
void ThreadUpdate();
void Load();
std::uint64_t GetMemFootPrint() const;
typedef void (PathManager::*MemberFunc)(
unsigned int threadNum,
unsigned int numThreads,
const SRectangle& rect
);
typedef spring::unordered_map<unsigned int, unsigned int> PathTypeMap;
typedef spring::unordered_map<unsigned int, unsigned int>::iterator PathTypeMapIt;
typedef spring::unordered_map<unsigned int, PathSearchTrace::Execution*> PathTraceMap;
typedef spring::unordered_map<unsigned int, PathSearchTrace::Execution*>::iterator PathTraceMapIt;
typedef spring::unordered_map<std::uint64_t, IPath*> SharedPathMap;
typedef spring::unordered_map<std::uint64_t, IPath*>::iterator SharedPathMapIt;
typedef std::vector<IPathSearch*> PathSearchVect;
typedef std::vector<IPathSearch*>::iterator PathSearchVectIt;
void SpawnSpringThreads(MemberFunc f, const SRectangle& r);
void InitNodeLayersThreaded(const SRectangle& rect);
void UpdateNodeLayersThreaded(const SRectangle& rect);
void InitNodeLayersThread(
unsigned int threadNum,
unsigned int numThreads,
const SRectangle& rect
);
void UpdateNodeLayersThread(
unsigned int threadNum,
unsigned int numThreads,
const SRectangle& rect
);
void InitNodeLayer(unsigned int layerNum, const SRectangle& r);
void UpdateNodeLayer(unsigned int layerNum, const SRectangle& r);
#ifdef QTPFS_STAGGERED_LAYER_UPDATES
void QueueNodeLayerUpdates(const SRectangle& r);
void ExecQueuedNodeLayerUpdates(unsigned int layerNum, bool flushQueue);
#endif
void ExecuteQueuedSearches(unsigned int pathType);
void QueueDeadPathSearches(unsigned int pathType);
unsigned int QueueSearch(
const IPath* oldPath,
const CSolidObject* object,
const MoveDef* moveDef,
const float3& sourcePoint,
const float3& targetPoint,
const float radius,
const bool synced
);
bool ExecuteSearch(
PathSearchVect& searches,
PathSearchVectIt& searchesIt,
NodeLayer& nodeLayer,
PathCache& pathCache,
unsigned int pathType
);
bool IsFinalized() const { return (!nodeTrees.empty()); }
std::string GetCacheDirName(std::uint32_t mapCheckSum, std::uint32_t modCheckSum) const;
void Serialize(const std::string& cacheFileDir);
std::vector<NodeLayer> nodeLayers;
std::vector<QTNode*> nodeTrees;
std::vector<PathCache> pathCaches;
std::vector< std::vector<IPathSearch*> > pathSearches;
spring::unordered_map<unsigned int, unsigned int> pathTypes;
spring::unordered_map<unsigned int, PathSearchTrace::Execution*> pathTraces;
// maps "hashes" of executed searches to the found paths
spring::unordered_map<std::uint64_t, IPath*> sharedPaths;
std::vector<unsigned int> numCurrExecutedSearches;
std::vector<unsigned int> numPrevExecutedSearches;
static unsigned int LAYERS_PER_UPDATE;
static unsigned int MAX_TEAM_SEARCHES;
unsigned int searchStateOffset;
unsigned int numTerrainChanges;
unsigned int numPathRequests;
unsigned int maxNumLeafNodes;
std::uint32_t pfsCheckSum;
bool layersInited;
bool haveCacheDir;
#ifdef QTPFS_ENABLE_THREADED_UPDATE
spring::thread* updateThread;
spring::mutex* mutexThreadUpdate;
spring::condition_variable* condThreadUpdate;
spring::condition_variable* condThreadUpdated;
#endif
};
}
#endif
|
