Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
logger.hpp File Reference
#include <thrill/mem/allocator.hpp>
#include <thrill/mem/pool.hpp>
#include <sstream>
#include <string>
+ Include dependency graph for logger.hpp:
+ This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes

class  Logger
 LOG and sLOG for development and debugging. More...
 
class  LoggerVoidify
 
class  SpacingLogger
 A logging class which outputs spaces between elements pushed via operator<<. More...
 

Namespaces

 thrill
 
 thrill::common
 Contains many common tools and helpers shared by higher layers. See common.
 

Macros

#define LOG   LOGC(debug)
 Default logging method: output if the local debug variable is true. More...
 
#define LOG0   LOGC(false)
 Override default output: never or always output log. More...
 
#define LOG1   LOGC(true)
 
#define LOGC(cond)
 Explicitly specify the condition for logging. More...
 
#define sLOG   sLOGC(debug)
 Default logging method: output if the local debug variable is true. More...
 
#define sLOG0   sLOGC(false)
 Override default output: never or always output log. More...
 
#define sLOG1   sLOGC(true)
 
#define sLOGC(cond)
 Explicitly specify the condition for logging. More...
 
#define THRILL_COMMON_LOGGER_HEADER
 

Functions

std::string GetNameForThisThread ()
 Returns the name of the current thread or 'unknown [id]'. More...
 
void NameThisThread (const mem::by_string &name)
 Defines a name for the current thread, only if no name was set previously. More...
 

Macro Definition Documentation

#define LOG   LOGC(debug)

Default logging method: output if the local debug variable is true.

Definition at line 167 of file logger.hpp.

Referenced by Socket::accept(), DiskAllocator::AddFreeRegion(), AlignedAllocator< Type, BaseAllocator, Alignment >::allocate_bytes(), BlockQueue::AppendBlock(), MixBlockQueue::AppendBlock(), MixBlockQueueSink::AppendBlock(), StreamSink::AppendPinnedBlock(), Dispatcher::AsyncRead(), BernoulliSampleNode< ValueType >::BernoulliSampleNode(), Socket::bind(), LinuxaioRequest::cancel(), Dispatcher::Cancel(), SelectDispatcher::Cancel(), Request::cancel(), LinuxaioRequest::cancel_aio(), StreamSink::Close(), MixStream::Close(), MixBlockQueue::Close(), CatStream::Close(), MixBlockQueueSink::Close(), Socket::close(), LinuxaioRequest::completed(), Request::completed(), Socket::connect(), Group::ConstructLoopbackMesh(), Socket::Create(), DiskAllocator::DeleteBlock(), MemoryFile::discard(), Dispatcher::Dispatch(), SelectDispatcher::DispatchOne(), Dispatcher::DispatchOne(), ZipNode< ValueType, ZipFunction, Pad, UnequalCheck, NoRebalance, kNumInputs >::DoScatter(), ZipWindowNode< ValueType, ZipFunction_, Pad_, UnequalCheck, UseStdArray, kNumInputs_ >::DoScatter(), ConcatNode< ValueType >::Execute(), thrill::api::FindStages(), ReduceByHashPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceNode::Emitter, VolatileKey, ReduceConfig, thrill::core::ReduceByHash, KeyEqualFunction >::Flush(), LocationDetection< thrill::api::JoinNode::HashCount >::Flush(), ReduceByIndexPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceToIndexNode::Emitter, VolatileKey, ReduceConfig >::Flush(), ReduceOldProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::FlushPartitionEmit(), ReduceProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::FlushPartitionEmit(), ReduceBucketHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig, IndexFunction, KeyEqualFunction >::FlushPartitionEmit(), File::GetIndexOf(), Socket::GetLocalAddress(), Socket::GetPeerAddress(), Socket::getsockopt(), MixStream::GetWriters(), CatStream::GetWriters(), ReadLinesNode::InputLineIteratorCompressed::HasNext(), ReadLinesNode::InputLineIteratorCompressed::InputLineIteratorCompressed(), ReduceProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::Insert(), LinuxaioRequest::LinuxaioRequest(), Socket::listen(), GroupToIndexNode< ValueType, KeyExtractor, GroupFunction >::MainOp(), MergeNode< ValueType, Comparator, kNumInputs >::MainOp(), DiskAllocator::NewBlocks(), ReadLinesNode::InputLineIteratorUncompressed::Next(), ReadLinesNode::InputLineIteratorCompressed::Next(), ConsumeBlockQueueSource::NextBlock(), CacheBlockQueueSource::NextBlock(), ReadBinaryNode< ValueType >::FileBlockSource::NextBlock(), Multiplexer::OnMultiplexerHeader(), BernoulliSampleNode< ValueType >::operator()(), examples::select::PickPivots(), PinnedBlock::PinnedBlock(), MixBlockQueue::Pop(), LinuxaioRequest::post(), MixBlockQueueReader::PullBlock(), ConcatNode< ValueType >::PushData(), TypedBlock< RawSize, Type, NRef, MetaInfoType >::read(), ReadBinaryNode< ValueType >::ReadBinaryNode(), ReadLinesNode::InputLineIterator::ReadBlock(), Socket::recv(), Socket::recv_one(), Socket::recvfrom(), Request::Request(), DIABase::RunScope(), RunSelect(), examples::select::Select(), MergeNode< ValueType, Comparator, kNumInputs >::SelectPivots(), Socket::send(), Socket::send_one(), Socket::sendto(), ServingRequest::serve(), Socket::SetKeepAlive(), Socket::SetNoDelay(), Socket::SetNonBlocking(), Socket::SetRcvBuf(), Socket::SetReuseAddr(), Socket::SetSndBuf(), Socket::setsockopt(), SortNode< ValueType, CompareFunction, SortAlgorithm >::SortAndWriteToFile(), ReduceOldProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::SpillPartition(), ReduceProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::SpillPartition(), UnionNode< ValueType >::StartPreOp(), JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >::StartPreOp(), UnionNode< ValueType >::StopPreOp(), JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >::StopPreOp(), Connection::SyncRecv(), Connection::SyncSend(), Connection::SyncSendRecv(), TypedBlock< RawSize, Type, NRef, MetaInfoType >::TypedBlock(), Request::wait(), RequestQueueImplQwQr::worker(), TypedBlock< RawSize, Type, NRef, MetaInfoType >::write(), BlockManager::~BlockManager(), PinnedBlock::~PinnedBlock(), and Request::~Request().

#define LOG1   LOGC(true)

Definition at line 171 of file logger.hpp.

Referenced by UfsFileBase::_after_open(), RequestQueueImpl1Q::AddRequest(), RequestQueueImplQwQr::AddRequest(), LinuxaioQueue::AddRequest(), AlignedAllocator< Type, BaseAllocator, Alignment >::allocate_bytes(), RequestQueueImpl1Q::CancelRequest(), RequestQueueImplQwQr::CancelRequest(), LinuxaioQueue::CancelRequest(), Request::check_alignment(), Request::check_nref_failed(), examples::suffix_sorting::CheckSA(), UfsFileBase::close_remove(), CountTrianglesGenerated(), Socket::CreatePair(), thrill::common::CreateThread(), DiskAllocator::DeallocationError(), Dispatcher::DispatchOne(), DiskAllocator::Dump(), SelectDispatcher::Interrupt(), JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >::JoinAllElements(), JoinTPCH4(), Context::Launch(), LinuxaioQueue::LinuxaioQueue(), main(), MergeNode< ValueType, Comparator, kNumInputs >::MainOp(), ZipfDistribution::make_dist(), DiskAllocator::NewBlocks(), thrill::io::open_file_impl(), AsyncWriteMemory::operator()(), AsyncWriteBuffer::operator()(), AsyncWriteBlock::operator()(), StochasticGradientDescent< Vector >::optimize(), thrill::data::OurNewHandler(), Percentiles(), examples::suffix_sorting::PrefixDoubling(), examples::suffix_sorting::PrefixDoublingDementiev(), examples::suffix_sorting::PrefixDoublingDiscardingDementiev(), examples::suffix_sorting::PrefixQuadrupling(), examples::suffix_sorting::PrefixQuadruplingDiscarding(), Context::PrintCollectiveMeanStdev(), MergeNode< ValueType, Comparator, kNumInputs >::Stats::PrintToSQLPlotTool(), Buffer::Resize(), RunHashWordCount(), RunJoinPageRankEdgePerLine(), RunKMeansFile(), RunKMeansGenerated(), RunPageRankEdgePerLine(), RunPageRankGenerated(), RunPageRankJoinGenerated(), RunStochasticGradFile(), RunStochasticGradGenerated(), RunWordCount(), SelectDispatcher::SelectDispatcher(), WincallFile::serve(), thrill::common::SetCpuAffinity(), thrill::vfs::SysOpenReadStream(), thrill::vfs::SysOpenWriteStream(), UfsFileBase::UfsFileBase(), UfsFileBase::unlink(), and WfsFileBase::WfsFileBase().

#define sLOG   sLOGC(debug)

Default logging method: output if the local debug variable is true.

Definition at line 179 of file logger.hpp.

Referenced by BlockWriter< BlockSink >::AllocateBlock(), StreamSink::AppendPinnedBlock(), Group::BroadcastBinomialTree(), CatStream::Close(), ReducePrePhaseEmitter< TableItem, VolatileKey >::CloseAll(), Group::ConstructLocalRealTCPMesh(), examples::suffix_sorting::ConstructWaveletTree(), ConstructWaveletTree(), Dispatcher::Dispatch(), Dispatcher::DispatchOne(), OverlapWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >::Execute(), ConcatNode< ValueType >::Execute(), DisjointWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >::Execute(), thrill::vfs::FillFilePattern(), DuplicateDetection::FindNonDuplicates(), ReduceByHashPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceNode::Emitter, VolatileKey, ReduceConfig, thrill::core::ReduceByHash, KeyEqualFunction >::Flush(), BlockWriter< BlockSink >::Flush(), ReduceByIndexPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceToIndexNode::Emitter, VolatileKey, ReduceConfig >::Flush(), ReduceByIndexPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceToIndexNode::Emitter, VolatileKey, ReduceConfig >::FlushTableInto(), BlockQueue::GetBlockSource(), BlockReader< CatBlockSource >::GetItemBatch(), File::GetReaderAt(), ReduceProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::GrowPartition(), ReduceBucketHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig, IndexFunction, KeyEqualFunction >::Initialize(), ReadLinesNode::InputLineIteratorCompressed::InputLineIteratorCompressed(), ReadLinesNode::InputLineIteratorUncompressed::InputLineIteratorUncompressed(), LocationDetection< thrill::api::JoinNode::HashCount >::LocationDetection(), CatStream::loopback_queue(), ZipNode< ValueType, ZipFunction, Pad, UnequalCheck, NoRebalance, kNumInputs >::MainOp(), ZipWindowNode< ValueType, ZipFunction_, Pad_, UnequalCheck, UseStdArray, kNumInputs_ >::MainOp(), SortNode< ValueType, CompareFunction, SortAlgorithm >::MainOp(), Multiplexer::OnCatStreamBlock(), MixStream::OnCloseStream(), CatStream::OnCloseStream(), Multiplexer::OnMixStreamBlock(), Multiplexer::OnMultiplexerHeader(), MixStream::OnStreamBlock(), CatStream::OnStreamBlock(), WriteBinaryNode< ValueType >::OpenNextFile(), ByteBlock::Deleter::operator()(), Group::PrefixSumDoubling(), Group::PrefixSumHypercube(), MergeNode< ValueType, Comparator, kNumInputs >::PushData(), OverlapWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >::PushData(), DisjointWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >::PushData(), BlockWriter< BlockSink >::PutSafe(), ReadBinaryNode< ValueType >::ReadBinaryNode(), ReadLinesNode::ReadLinesNode(), Group::Reduce(), ReducePrePhase< TableItem, Key, Value, KeyExtractor, ReduceFunction, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction, HashFunction, false >::ReducePrePhase(), Group::Send(), ReduceBucketHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig, IndexFunction, KeyEqualFunction >::SpillPartition(), thrill::vfs::SysOpenReadStream(), thrill::vfs::SysOpenWriteStream(), and SocketAddress::ToStringHost().

#define sLOG0   sLOGC(false)
#define sLOGC (   cond)
Value:
!(cond) ? (void)0 : \
::thrill::common::LoggerVoidify() & ::thrill::common::SpacingLogger()
A logging class which outputs spaces between elements pushed via operator<<.
Definition: logger.hpp:127

Explicitly specify the condition for logging.

Definition at line 174 of file logger.hpp.

Referenced by FlowControlChannel::~FlowControlChannel().

#define THRILL_COMMON_LOGGER_HEADER

Definition at line 15 of file logger.hpp.