#include <fairmq/TransportFactory.h>
#include <fairmq/Channel.h>
#include <fairmq/Message.h>
#include <cstdlib>
#include <unistd.h>
#include <ctime>
#include <sstream>
#include <iostream>
#include <cstdio>
#include <fcntl.h>
#include <SimConfig/SimConfig.h>
#include <sys/wait.h>
#include <vector>
#include <functional>
#include <thread>
#include <csignal>
#include "TStopwatch.h"
#include <fairlogger/Logger.h>
#include "CommonUtils/ShmManager.h"
#include "TFile.h"
#include "TTree.h"
#include <sys/types.h>
#include "CommonUtils/NameConf.h"
#include "SimulationDataFormat/MCEventHeader.h"
#include "O2Version.h"
#include <unordered_map>
#include <filesystem>
#include <atomic>
#include "Framework/SourceInfoHeader.h"
#include "Headers/Stack.h"
#include "SimPublishChannelHelper.h"
#include <CommonUtils/FileSystemUtils.h>
#include <CCDB/BasicCCDBManager.h>

Functions
std::string	getServerLogName ()

std::string	getWorkerLogName ()

std::string	getMergerLogName ()

void	remove_tmp_files ()

void	cleanup ()

int	checkresult ()

std::string	getControlAddress ()

std::string	getInternalControlAddress ()

bool	isBusy ()

void	launchControlThread ()

void	launchWorkerListenerThread ()

void	launchThreadMonitoringEvents (int pipefd, std::string text, std::vector< int > &eventcontainer, std::function< bool(std::vector< int > const &)> callback=[](std::vector< int > const &) { return true;})

void	launchShutdownThread ()

void	empty (int)

void	sighandler (int sig)

std::vector< char * >	checkArgs (int argc, char *argv[])

int	main (int argc, char *argv[])

Variables
std::vector< int >	gChildProcesses

std::vector< int >	gDistributedEvents

std::vector< int >	gFinishedEvents

int	gAskedEvents

std::atomic< bool >	gPrimServerIsInitialized = false

Function Documentation

◆ checkArgs()

std::vector< char * > checkArgs	(	int	argc,
		char *	argv[]
	)

Definition at line 392 of file o2sim_parallel.cxx.

◆ checkresult()

int checkresult ( )

Definition at line 146 of file o2sim_parallel.cxx.

◆ cleanup()

void cleanup ( )

Definition at line 92 of file o2sim_parallel.cxx.

◆ empty()

void empty ( int )

Definition at line 362 of file o2sim_parallel.cxx.

◆ getControlAddress()

std::string getControlAddress ( )

Definition at line 186 of file o2sim_parallel.cxx.

◆ getInternalControlAddress()

std::string getInternalControlAddress ( )

Definition at line 192 of file o2sim_parallel.cxx.

◆ getMergerLogName()

std::string getMergerLogName ( )

Definition at line 67 of file o2sim_parallel.cxx.

◆ getServerLogName()

std::string getServerLogName ( )

Author: Sandro Wenzel

Definition at line 51 of file o2sim_parallel.cxx.

◆ getWorkerLogName()

std::string getWorkerLogName ( )

Definition at line 59 of file o2sim_parallel.cxx.

◆ isBusy()

bool isBusy ( )

Definition at line 205 of file o2sim_parallel.cxx.

◆ launchControlThread()

void launchControlThread ( )

Definition at line 215 of file o2sim_parallel.cxx.

◆ launchShutdownThread()

void launchShutdownThread ( )

Definition at line 338 of file o2sim_parallel.cxx.

◆ launchThreadMonitoringEvents()

void launchThreadMonitoringEvents	(	int	pipefd,
		std::string	text,
		std::vector< int > &	eventcontainer,
		std::function< bool(std::vector< int > const &)>	callback = `[](std::vector<int> const&) { return true; }`
	)

Definition at line 308 of file o2sim_parallel.cxx.

◆ launchWorkerListenerThread()

void launchWorkerListenerThread ( )

Definition at line 281 of file o2sim_parallel.cxx.

◆ main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 433 of file o2sim_parallel.cxx.

◆ remove_tmp_files()

void remove_tmp_files ( )

Definition at line 75 of file o2sim_parallel.cxx.

◆ sighandler()

void sighandler ( int sig )

Definition at line 365 of file o2sim_parallel.cxx.

Variable Documentation

◆ gAskedEvents

int gAskedEvents

Definition at line 183 of file o2sim_parallel.cxx.

◆ gChildProcesses

std::vector<int> gChildProcesses

Definition at line 178 of file o2sim_parallel.cxx.

◆ gDistributedEvents

std::vector<int> gDistributedEvents

Definition at line 180 of file o2sim_parallel.cxx.

◆ gFinishedEvents

std::vector<int> gFinishedEvents

Definition at line 182 of file o2sim_parallel.cxx.

◆ gPrimServerIsInitialized

std::atomic<bool> gPrimServerIsInitialized = false

Definition at line 184 of file o2sim_parallel.cxx.

Functions

Variables