ndmspc  v1.2.0-0.1.rc3
Ndmspc::NDimensionalIpcRunner Class Reference

Static Public Member Functions

static bool SendFrames (void *socket, const std::vector< std::string > &frames)
 
static bool ReceiveFrames (void *socket, std::vector< std::string > &outFrames)
 
static std::string BuildWorkerIdentity (size_t workerIndex)
 
static std::string SerializeCoords (const std::vector< int > &coords)
 
static std::string SerializeIds (const std::vector< Long64_t > &ids)
 
static int WorkerLoop (const std::string &endpoint, size_t workerIndex, NThreadData *worker)
 
static int TaskLoop (void *dealer, size_t workerIndex, NThreadData *worker)
 
static bool WaitForChildProcesses (const std::vector< pid_t > &pids, int timeoutMs=-1)
 
static void CleanupChildProcesses (const std::vector< pid_t > &pids)
 

Static Private Member Functions

static std::vector< int > ParseCoords (const std::string &coordsStr)
 
static std::vector< Long64_t > ParseIds (const std::string &idsStr)
 

Detailed Description

Definition at line 13 of file NDimensionalIpcRunner.h.


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