|
|
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 std::vector< int > | ParseCoords (const std::string &coordsStr) |
| |
|
static std::vector< Long64_t > | ParseIds (const std::string &idsStr) |
| |
Definition at line 13 of file NDimensionalIpcRunner.h.
The documentation for this class was generated from the following files: