lcio_parallel_processing.cc File Reference

#include "lcio.h"
#include "MT/Types.h"
#include "MT/LCReader.h"
#include "MT/LCReaderListener.h"
#include "UTIL/LCTOOLS.h"
#include "IMPL/LCEventImpl.h"
#include <cstdlib>
#include <mutex>
#include <future>
#include <functional>
#include <thread>
#include <unistd.h>

Include dependency graph for lcio_parallel_processing.cc:

Go to the source code of this file.

Classes
class	Scheduler

Macros
#define	SAFE_PRINT(message)   { std::lock_guard<std::mutex> lock(printMutex); std::cout << message << std::endl; }
#define	SAFE_CODE(code)   { std::lock_guard<std::mutex> lock(printMutex); code; }

Typedefs
using	LCEventPtr = MT::LCEventPtr
using	LCRunHeaderPtr = MT::LCRunHeaderPtr

Functions
int	main (int argc, char **argv)
	Small utility to dump events in parallel from different files. More...

Variables
static std::vector< std::string >	FILEN
std::mutex	printMutex

Macro Definition Documentation

#define SAFE_CODE

(

code

)

{ std::lock_guard<std::mutex> lock(printMutex); code; }

Definition at line 25 of file lcio_parallel_processing.cc.

#define SAFE_PRINT

(

message

)

{ std::lock_guard<std::mutex> lock(printMutex); std::cout << message << std::endl; }

Definition at line 24 of file lcio_parallel_processing.cc.

Referenced by Scheduler::Scheduler(), Scheduler::startTask(), and Scheduler::waitForAll().

Typedef Documentation

using LCEventPtr = MT::LCEventPtr

Definition at line 20 of file lcio_parallel_processing.cc.

using LCRunHeaderPtr = MT::LCRunHeaderPtr

Definition at line 21 of file lcio_parallel_processing.cc.

Function Documentation

int main	(	int	argc,
		char **	argv
	)

Small utility to dump events in parallel from different files.

Definition at line 109 of file lcio_parallel_processing.cc.

References std::atoi(), MT::LCReader::directAccess, std::endl(), std::exit(), std::getenv(), std::thread::hardware_concurrency(), std::unordered_set< K >::insert(), MT::LCReader::open(), std::vector< T >::push_back(), and MT::LCReader::readNextRecord().

Variable Documentation

std::vector<std::string> FILEN

static

Definition at line 16 of file lcio_parallel_processing.cc.

std::mutex printMutex

Definition at line 23 of file lcio_parallel_processing.cc.

Referenced by main().