MapUpdater Class Reference

#include <MapUpdater.h>

Public Member Functions
	MapUpdater ()
	~MapUpdater ()
void	schedule_update (Map &map, uint32 diff)
void	wait ()
void	activate (size_t num_threads)
void	deactivate ()
bool	activated ()

Private Member Functions
void	update_finished ()
void	WorkerThread ()

Private Attributes
ProducerConsumerQueue < MapUpdateRequest * >	_queue
std::vector< std::thread >	_workerThreads
std::atomic< bool >	_cancelationToken
std::mutex	_lock
std::condition_variable	_condition
size_t	pending_requests

Friends
class	MapUpdateRequest

Constructor & Destructor Documentation

MapUpdater::MapUpdater ( )

inline

: _cancelationToken(false), pending_requests(0) {}

MapUpdater::~MapUpdater ( )

inline

{ };

Member Function Documentation

void MapUpdater::activate

(

size_t

num_threads

)

{
 for (size_t i = 0; i < num_threads; ++i)
 {
 _workerThreads.push_back(std::thread(&MapUpdater::WorkerThread, this));
 }
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool MapUpdater::activated

(

)

{
 return _workerThreads.size() > 0;
}

Here is the caller graph for this function:

void MapUpdater::deactivate

(

)

{
 _cancelationToken = true;

 wait();

 _queue.Cancel();

 for (auto& thread : _workerThreads)
 {
 thread.join();
 }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void MapUpdater::schedule_update	(	Map &	map,
		uint32	diff
	)

{
 std::lock_guard<std::mutex> lock(_lock);

 ++pending_requests;

 _queue.Push(new MapUpdateRequest(map, *this, diff));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void MapUpdater::update_finished ( )

private

{
 std::lock_guard<std::mutex> lock(_lock);

 --pending_requests;

 _condition.notify_all();
}

Here is the caller graph for this function:

void MapUpdater::wait

(

)

{
 std::unique_lock<std::mutex> lock(_lock);

 while (pending_requests > 0)
 _condition.wait(lock);

 lock.unlock();
}

Here is the caller graph for this function:

void MapUpdater::WorkerThread ( )

private

{
 while (1)
 {
 MapUpdateRequest* request = nullptr;

 _queue.WaitAndPop(request);

 if (_cancelationToken)
 return;

 request->call();

 delete request;
 }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

friend class MapUpdateRequest

friend

Member Data Documentation

std::atomic<bool> MapUpdater::_cancelationToken

private

std::condition_variable MapUpdater::_condition

private

std::mutex MapUpdater::_lock

private

ProducerConsumerQueue<MapUpdateRequest*> MapUpdater::_queue

private

std::vector<std::thread> MapUpdater::_workerThreads

private

size_t MapUpdater::pending_requests

private

---

The documentation for this class was generated from the following files:

• src/server/game/Maps/MapUpdater.h
• src/server/game/Maps/MapUpdater.cpp