util_concurrency.h File Reference

#include <pthread.h>
#include <cassert>
#include <queue>
#include <set>
#include <vector>
#include "atomic.h"
#include "util/async.h"
#include "util/single_copy.h"
#include "util_concurrency_impl.h"

Include dependency graph for util_concurrency.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	Lockable
struct	_RAII_Polymorphism
class	RAII< T, P >
class	LockGuard< LockableT >
class	Future< T >
class	SynchronizingCounter< T >
class	Observable< ParamT >
class	Observable< ParamT >
class	Signal
class	FifoChannel< T >
class	ConcurrentWorkers< WorkerT >
struct	ConcurrentWorkers< WorkerT >::Job< DataT >
struct	ConcurrentWorkers< WorkerT >::RunBinding
struct	ConcurrentWorkers< WorkerT >::WorkerRunBinding
class	ConcurrentWorker< DerivedWorkerT >

Typedefs
typedef RAII< pthread_mutex_t >	MutexLockGuard
typedef RAII< pthread_rwlock_t, _RAII_Polymorphism::ReadLock >	ReadLockGuard
typedef RAII< pthread_rwlock_t, _RAII_Polymorphism::WriteLock >	WriteLockGuard

Functions
unsigned int	GetNumberOfCpuCores ()

Variables
static const unsigned int	kFallbackNumberOfCpus = 1

Typedef Documentation

typedef RAII<pthread_mutex_t> MutexLockGuard

Definition at line 114 of file util_concurrency.h.

typedef RAII<pthread_rwlock_t, _RAII_Polymorphism::ReadLock> ReadLockGuard

Definition at line 137 of file util_concurrency.h.

typedef RAII<pthread_rwlock_t, _RAII_Polymorphism::WriteLock> WriteLockGuard

Definition at line 138 of file util_concurrency.h.

Function Documentation

unsigned int GetNumberOfCpuCores

(

)

Returns the number of CPU cores present in the system or a fallback number if it failed to determine the number of CPU cores.

Returns

the number of active CPU cores in the system

This file is part of the CernVM File System.

Definition at line 16 of file util_concurrency.cc.

Referenced by anonymous_namespace{shrinkwrap.cc}::Params::Complete(), swissknife::CommandMigrate::DoMigrationAndCommit(), IngestionPipeline::IngestionPipeline(), and ScrubbingPipeline::ScrubbingPipeline().

Here is the caller graph for this function:

Variable Documentation

const unsigned int kFallbackNumberOfCpus = 1

static

Definition at line 412 of file util_concurrency.h.

Referenced by GetNumberOfCpuCores().