ndmspc v1.2.0-0.1.rc7
Loading...
Searching...
No Matches
Static Public Member Functions | Static Private Member Functions | List of all members
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.

Member Function Documentation

◆ BuildWorkerIdentity()

std::string Ndmspc::NDimensionalIpcRunner::BuildWorkerIdentity ( size_t workerIndex)
static

Definition at line 94 of file NDimensionalIpcRunner.cxx.

◆ CleanupChildProcesses()

void Ndmspc::NDimensionalIpcRunner::CleanupChildProcesses ( const std::vector< pid_t > & pids)
static

Definition at line 496 of file NDimensionalIpcRunner.cxx.

◆ ParseCoords()

std::vector< int > Ndmspc::NDimensionalIpcRunner::ParseCoords ( const std::string & coordsStr)
staticprivate

Definition at line 533 of file NDimensionalIpcRunner.cxx.

◆ ParseIds()

std::vector< Long64_t > Ndmspc::NDimensionalIpcRunner::ParseIds ( const std::string & idsStr)
staticprivate

Definition at line 545 of file NDimensionalIpcRunner.cxx.

◆ ReceiveFrames()

bool Ndmspc::NDimensionalIpcRunner::ReceiveFrames ( void * socket,
std::vector< std::string > & outFrames )
static

Definition at line 75 of file NDimensionalIpcRunner.cxx.

◆ SendFrames()

bool Ndmspc::NDimensionalIpcRunner::SendFrames ( void * socket,
const std::vector< std::string > & frames )
static

Definition at line 64 of file NDimensionalIpcRunner.cxx.

◆ SerializeCoords()

std::string Ndmspc::NDimensionalIpcRunner::SerializeCoords ( const std::vector< int > & coords)
static

Definition at line 101 of file NDimensionalIpcRunner.cxx.

◆ SerializeIds()

std::string Ndmspc::NDimensionalIpcRunner::SerializeIds ( const std::vector< Long64_t > & ids)
static

Definition at line 111 of file NDimensionalIpcRunner.cxx.

◆ TaskLoop()

int Ndmspc::NDimensionalIpcRunner::TaskLoop ( void * dealer,
size_t workerIndex,
NThreadData * worker )
static

Definition at line 169 of file NDimensionalIpcRunner.cxx.

◆ WaitForChildProcesses()

bool Ndmspc::NDimensionalIpcRunner::WaitForChildProcesses ( const std::vector< pid_t > & pids,
int timeoutMs = -1 )
static

Definition at line 456 of file NDimensionalIpcRunner.cxx.

◆ WorkerLoop()

int Ndmspc::NDimensionalIpcRunner::WorkerLoop ( const std::string & endpoint,
size_t workerIndex,
NThreadData * worker )
static

Definition at line 121 of file NDimensionalIpcRunner.cxx.

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