minetest.git - modified minetest for gpcfs purposes

	Commit message (Collapse)	Author	Age
*	Translated using Weblate (Dutch)	b p	2014-02-16
\|
*	Translated using Weblate (Dutch)	Mitchell Ward	2014-02-16
\|
*	Run updatepo.sh	PilzAdam	2013-11-23
\|
*	Translated using Weblate (Dutch)	Rutger NL	2013-10-08
\|
*	Translated using Weblate (Dutch)	Rutger NL	2013-10-08
\|
*	Run updatepo.sh	Ilya Zhuravlev	2013-09-08
\|
*	Run util/updatepo.sh	PilzAdam	2013-08-25
\|
*	Translated using Weblate (Dutch)	Sasikaa Lacikaa	2013-08-25
\|
*	Translated using Weblate (Dutch)	sfan5	2013-08-25
\|
*	Fix i18n of some strings.	arsdragonfly	2013-07-02
\|
*	Update po files	PilzAdam	2013-05-13
\|
*	Translated using Weblate (Dutch)	sfan5	2013-05-13
\|
*	Add dutch translation	LS-Steeef	2013-04-18

GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #pragma once #include <vector> #include <deque> #include <map> #include "threading/semaphore.h" #include "threading/thread.h" #include "lua.h" #include "cpp_api/s_base.h" // Forward declarations class AsyncEngine; // Declarations // Data required to queue a job struct LuaJobInfo { LuaJobInfo() = default; // Function to be called in async environment std::string serializedFunction = ""; // Parameter to be passed to function std::string serializedParams = ""; // Result of function call std::string serializedResult = ""; // JobID used to identify a job and match it to callback unsigned int id = 0; bool valid = false; }; // Asynchronous working environment class AsyncWorkerThread : public Thread, public ScriptApiBase { public: AsyncWorkerThread(AsyncEngine* jobDispatcher, const std::string &name); virtual ~AsyncWorkerThread(); void *run(); private: AsyncEngine *jobDispatcher = nullptr; }; // Asynchornous thread and job management class AsyncEngine { friend class AsyncWorkerThread; typedef void (*StateInitializer)(lua_State *L, int top); public: AsyncEngine() = default; ~AsyncEngine(); /** * Register function to be called on new states * @param func C function to be called */ void registerStateInitializer(StateInitializer func); /** * Create async engine tasks and lock function registration * @param numEngines Number of async threads to be started */ void initialize(unsigned int numEngines); /** * Queue an async job * @param func Serialized lua function * @param params Serialized parameters * @return jobid The job is queued */ unsigned int queueAsyncJob(const std::string &func, const std::string &params); /** * Engine step to process finished jobs * the engine step is one way to pass events back, PushFinishedJobs another * @param L The Lua stack */ void step(lua_State *L); /** * Push a list of finished jobs onto the stack * @param L The Lua stack */ void pushFinishedJobs(lua_State *L); protected: /** * Get a Job from queue to be processed * this function blocks until a job is ready * @return a job to be processed */ LuaJobInfo getJob(); /** * Put a Job result back to result queue * @param result result of completed job */ void putJobResult(const LuaJobInfo &result); /** * Initialize environment with current registred functions * this function adds all functions registred by registerFunction to the * passed lua stack * @param L Lua stack to initialize * @param top Stack position */ void prepareEnvironment(lua_State* L, int top); private: // Variable locking the engine against further modification bool initDone = false; // Internal store for registred state initializers std::vector<StateInitializer> stateInitializers; // Internal counter to create job IDs unsigned int jobIdCounter = 0; // Mutex to protect job queue std::mutex jobQueueMutex; // Job queue std::deque<LuaJobInfo> jobQueue; // Mutex to protect result queue std::mutex resultQueueMutex; // Result queue std::deque<LuaJobInfo> resultQueue; // List of current worker threads std::vector<AsyncWorkerThread*> workerThreads; // Counter semaphore for job dispatching Semaphore jobQueueCounter; };