ndmspc v1.2.0-0.1.rc7
Loading...
Searching...
No Matches
Ndmspc::NDimensionalExecutor::IpcSession Struct Reference

Classes

struct  oldSigIntAction
 

Public Attributes

void * ctx {nullptr}
 
void * router {nullptr}
 
bool isTcp {false}
 
std::string endpointPath
 
std::string endpoint
 
std::vector< pid_t > childPids
 
std::unordered_map< std::string, size_t > identityToWorker
 
std::vector< std::string > workerIdentityVec
 
std::string jobDir
 
std::string treeName
 
std::vector< NThreadData * > * workerObjects {nullptr}
 
size_t maxWorkers {0}
 
std::string currentDefName
 
std::vector< Long64_t > currentDefIds
 
bool hasCurrentDefIds {false}
 
bool hasOldSigIntAction {false}
 
std::string macroList
 
std::string macroParams
 
std::string tmpDir
 
std::string tmpResultsDir
 
size_t bootstrapNextIdx {0}
 
std::unordered_map< std::string, size_t > bootstrapAssignments
 
std::vector< std::string > pendingReadyIdentities
 
NTaskStateManager taskStateManager
 
std::unordered_map< std::string, std::set< size_t > > workerTaskHistory
 
std::set< std::string > earlyDoneWorkers
 
std::unordered_map< std::string, std::chrono::steady_clock::time_point > workerLastActivity
 
std::set< std::string > failedTcpWorkers
 

Detailed Description

Definition at line 78 of file NDimensionalExecutor.cxx.

Member Data Documentation

◆ bootstrapAssignments

std::unordered_map<std::string, size_t> Ndmspc::NDimensionalExecutor::IpcSession::bootstrapAssignments

Definition at line 103 of file NDimensionalExecutor.cxx.

◆ bootstrapNextIdx

size_t Ndmspc::NDimensionalExecutor::IpcSession::bootstrapNextIdx {0}

Definition at line 102 of file NDimensionalExecutor.cxx.

◆ childPids

std::vector<pid_t> Ndmspc::NDimensionalExecutor::IpcSession::childPids

Definition at line 84 of file NDimensionalExecutor.cxx.

◆ ctx

void* Ndmspc::NDimensionalExecutor::IpcSession::ctx {nullptr}

Definition at line 79 of file NDimensionalExecutor.cxx.

◆ currentDefIds

std::vector<Long64_t> Ndmspc::NDimensionalExecutor::IpcSession::currentDefIds

Definition at line 93 of file NDimensionalExecutor.cxx.

◆ currentDefName

std::string Ndmspc::NDimensionalExecutor::IpcSession::currentDefName

Definition at line 92 of file NDimensionalExecutor.cxx.

◆ earlyDoneWorkers

std::set<std::string> Ndmspc::NDimensionalExecutor::IpcSession::earlyDoneWorkers

Definition at line 108 of file NDimensionalExecutor.cxx.

◆ endpoint

std::string Ndmspc::NDimensionalExecutor::IpcSession::endpoint

Definition at line 83 of file NDimensionalExecutor.cxx.

◆ endpointPath

std::string Ndmspc::NDimensionalExecutor::IpcSession::endpointPath

Definition at line 82 of file NDimensionalExecutor.cxx.

◆ failedTcpWorkers

std::set<std::string> Ndmspc::NDimensionalExecutor::IpcSession::failedTcpWorkers

Definition at line 111 of file NDimensionalExecutor.cxx.

◆ hasCurrentDefIds

bool Ndmspc::NDimensionalExecutor::IpcSession::hasCurrentDefIds {false}

Definition at line 94 of file NDimensionalExecutor.cxx.

◆ hasOldSigIntAction

bool Ndmspc::NDimensionalExecutor::IpcSession::hasOldSigIntAction {false}

Definition at line 96 of file NDimensionalExecutor.cxx.

◆ identityToWorker

std::unordered_map<std::string, size_t> Ndmspc::NDimensionalExecutor::IpcSession::identityToWorker

Definition at line 85 of file NDimensionalExecutor.cxx.

◆ isTcp

bool Ndmspc::NDimensionalExecutor::IpcSession::isTcp {false}

Definition at line 81 of file NDimensionalExecutor.cxx.

◆ jobDir

std::string Ndmspc::NDimensionalExecutor::IpcSession::jobDir

Definition at line 88 of file NDimensionalExecutor.cxx.

◆ macroList

std::string Ndmspc::NDimensionalExecutor::IpcSession::macroList

Definition at line 98 of file NDimensionalExecutor.cxx.

◆ macroParams

std::string Ndmspc::NDimensionalExecutor::IpcSession::macroParams

Definition at line 99 of file NDimensionalExecutor.cxx.

◆ maxWorkers

size_t Ndmspc::NDimensionalExecutor::IpcSession::maxWorkers {0}

Definition at line 91 of file NDimensionalExecutor.cxx.

◆ pendingReadyIdentities

std::vector<std::string> Ndmspc::NDimensionalExecutor::IpcSession::pendingReadyIdentities

Definition at line 104 of file NDimensionalExecutor.cxx.

◆ router

void* Ndmspc::NDimensionalExecutor::IpcSession::router {nullptr}

Definition at line 80 of file NDimensionalExecutor.cxx.

◆ taskStateManager

NTaskStateManager Ndmspc::NDimensionalExecutor::IpcSession::taskStateManager

Definition at line 106 of file NDimensionalExecutor.cxx.

◆ tmpDir

std::string Ndmspc::NDimensionalExecutor::IpcSession::tmpDir

Definition at line 100 of file NDimensionalExecutor.cxx.

◆ tmpResultsDir

std::string Ndmspc::NDimensionalExecutor::IpcSession::tmpResultsDir

Definition at line 101 of file NDimensionalExecutor.cxx.

◆ treeName

std::string Ndmspc::NDimensionalExecutor::IpcSession::treeName

Definition at line 89 of file NDimensionalExecutor.cxx.

◆ workerIdentityVec

std::vector<std::string> Ndmspc::NDimensionalExecutor::IpcSession::workerIdentityVec

Definition at line 86 of file NDimensionalExecutor.cxx.

◆ workerLastActivity

std::unordered_map<std::string, std::chrono::steady_clock::time_point> Ndmspc::NDimensionalExecutor::IpcSession::workerLastActivity

Definition at line 110 of file NDimensionalExecutor.cxx.

◆ workerObjects

std::vector<NThreadData *>* Ndmspc::NDimensionalExecutor::IpcSession::workerObjects {nullptr}

Definition at line 90 of file NDimensionalExecutor.cxx.

◆ workerTaskHistory

std::unordered_map<std::string, std::set<size_t> > Ndmspc::NDimensionalExecutor::IpcSession::workerTaskHistory

Definition at line 107 of file NDimensionalExecutor.cxx.


The documentation for this struct was generated from the following file: