Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
logger.hpp File Reference
+ 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.

Namespaces

 tlx
 

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)   TLX_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)   TLX_sLOGC(cond)
 Explicitly specify the condition for logging. More...
 

Macro Definition Documentation

#define LOG   LOGC(debug)

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

Definition at line 24 of file logger.hpp.

Referenced by Socket::accept(), Dispatcher::AddAsyncRequest(), AlignedAllocator< Type, BaseAllocator, Alignment >::allocate_bytes(), FlowControlChannel::AllReduce(), Group::AllReduceMaximumInt(), Group::AllReduceMaximumLong(), Group::AllReduceMaximumLongLong(), Group::AllReduceMaximumUnsignedInt(), Group::AllReduceMaximumUnsignedLong(), Group::AllReduceMaximumUnsignedLongLong(), Group::AllReduceMinimumInt(), Group::AllReduceMinimumLong(), Group::AllReduceMinimumLongLong(), Group::AllReduceMinimumUnsignedInt(), Group::AllReduceMinimumUnsignedLong(), Group::AllReduceMinimumUnsignedLongLong(), Group::AllReducePlusInt(), Group::AllReducePlusLong(), Group::AllReducePlusLongLong(), Group::AllReducePlusUnsignedInt(), Group::AllReducePlusUnsignedLong(), Group::AllReducePlusUnsignedLongLong(), BlockQueue::AppendBlock(), MixBlockQueue::AppendBlock(), StreamSink::AppendPinnedBlock(), Dispatcher::AsyncRead(), FlowControlChannel::Barrier(), BernoulliSampleNode< ValueType >::BernoulliSampleNode(), Socket::bind(), BlockQueueSink::BlockQueueSink(), FlowControlChannel::Broadcast(), Group::BroadcastInt(), Group::BroadcastLong(), Group::BroadcastLongLong(), Group::BroadcastUnsignedInt(), Group::BroadcastUnsignedLong(), Group::BroadcastUnsignedLongLong(), Dispatcher::Cancel(), SelectDispatcher::Cancel(), MixStreamData::Close(), StreamSink::Close(), MixBlockQueue::Close(), CatStreamData::Close(), Socket::close(), Socket::connect(), Group::ConstructLoopbackMesh(), Socket::Create(), 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(), Group::ExPrefixSumPlusInt(), Group::ExPrefixSumPlusLong(), Group::ExPrefixSumPlusLongLong(), Group::ExPrefixSumPlusUnsignedInt(), Group::ExPrefixSumPlusUnsignedLong(), Group::ExPrefixSumPlusUnsignedLongLong(), FlowControlChannel::ExPrefixSumTotal(), FileBlockSink::FileBlockSink(), SortNode< ValueType, CompareFunction, SortAlgorithm >::FindAndSendSplitters(), 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(), 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(), ReadLinesNode::InputLineIteratorCompressed::HasNext(), ReduceByIndexPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceToIndexNode::Emitter, VolatileKey, ReduceConfig >::Initialize(), ReadLinesNode::InputLineIteratorCompressed::InputLineIteratorCompressed(), ReduceByIndexPostPhase< TableItem, Key, ValueType, KeyExtractor, ReduceFunction, thrill::api::ReduceToIndexNode::Emitter, VolatileKey, ReduceConfig >::Insert(), ReduceProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::Insert(), Multiplexer::IntReleaseCatStream(), Multiplexer::IntReleaseMixStream(), Dispatcher::IRecv(), Dispatcher::ISend(), Socket::listen(), GroupToIndexNode< ValueType, KeyExtractor, GroupFunction >::MainOp(), MergeNode< ValueType, Comparator, kNumInputs >::MainOp(), ReadLinesNode::InputLineIteratorUncompressed::Next(), ReadLinesNode::InputLineIteratorCompressed::Next(), ConsumeBlockQueueSource::NextBlock(), CacheBlockQueueSource::NextBlock(), ReadBinaryNode< ValueType >::VfsFileBlockSource::NextBlock(), Multiplexer::OnMultiplexerHeader(), CatStreamData::OnStreamBlock(), BernoulliSampleNode< ValueType >::operator()(), examples::select::PickPivots(), PinnedBlock::PinnedBlock(), MixBlockQueue::Pop(), FlowControlChannel::Predecessor(), FlowControlChannel::PrefixSumBase(), Group::PrefixSumPlusInt(), Group::PrefixSumPlusLong(), Group::PrefixSumPlusLongLong(), Group::PrefixSumPlusUnsignedInt(), Group::PrefixSumPlusUnsignedLong(), Group::PrefixSumPlusUnsignedLongLong(), MixBlockQueueReader::PullBlock(), Dispatcher::PumpRecvQueue(), Dispatcher::PumpSendQueue(), ConcatNode< ValueType >::PushData(), ReadBinaryNode< ValueType >::ReadBinaryNode(), ReadLinesNode::InputLineIterator::ReadBlock(), Socket::recv(), Socket::recv_one(), Socket::recvfrom(), FlowControlChannel::Reduce(), DIABase::RunScope(), RunSelect(), examples::select::Select(), MergeNode< ValueType, Comparator, kNumInputs >::SelectPivots(), Socket::send(), Socket::send_one(), Socket::sendto(), 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(), DispatcherThread::Work(), BlockQueueSink::~BlockQueueSink(), CatStreamData::~CatStreamData(), Dispatcher::~Dispatcher(), FileBlockSink::~FileBlockSink(), MixStreamData::~MixStreamData(), and PinnedBlock::~PinnedBlock().

#define LOG1   LOGC(true)

Definition at line 28 of file logger.hpp.

Referenced by AlignedAllocator< Type, BaseAllocator, Alignment >::allocate_bytes(), examples::suffix_sorting::CheckSA(), Multiplexer::Close(), CountTrianglesGenerated(), Socket::CreatePair(), thrill::common::CreateThread(), Dispatcher::DispatchOne(), SelectDispatcher::Interrupt(), JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >::JoinAllElements(), JoinTPCH4(), Context::Launch(), main(), MergeNode< ValueType, Comparator, kNumInputs >::MainOp(), ZipfDistribution::make_dist(), AsyncWriteBuffer::operator()(), AsyncWriteBlock::operator()(), StochasticGradientDescent< Vector >::optimize(), thrill::data::OurNewHandler(), Percentiles(), examples::suffix_sorting::PrefixDoublingDiscarding(), examples::suffix_sorting::PrefixDoublingPack(), examples::suffix_sorting::PrefixDoublingSorting(), examples::suffix_sorting::PrefixDoublingWindow(), 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(), thrill::common::SetCpuAffinity(), thrill::vfs::SysOpenReadStream(), thrill::vfs::SysOpenWriteStream(), and Dispatcher::~Dispatcher().

#define sLOG   sLOGC(debug)

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

Definition at line 34 of file logger.hpp.

Referenced by ReservoirSamplingGrow< SampleIndexPair >::add(), BlockWriter< BlockSink >::AllocateBlock(), Group::BroadcastBinomialTree(), CatStreamData::Close(), ReducePrePhaseEmitter< TableItem, VolatileKey, BlockWriter >::CloseAll(), Group::ConstructLocalRealTCPMesh(), examples::suffix_sorting::ConstructWaveletTree(), ConstructWaveletTree(), Dispatcher::Dispatch(), Dispatcher::DispatchOne(), Sampling< RNG >::do_sample(), 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(), BlockQueue::GetBlockSource(), BlockReader< CatBlockSource >::GetItemBatch(), File::GetReaderAt(), ReduceProbingHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig_, IndexFunction, KeyEqualFunction >::GrowPartition(), Sampling< RNG >::hash_sample(), ReduceBucketHashTable< TableItem, Key, Value, KeyExtractor, ReduceFunction, Emitter, VolatileKey, ReduceConfig, IndexFunction, KeyEqualFunction >::Initialize(), ReadLinesNode::InputLineIteratorCompressed::InputLineIteratorCompressed(), ReadLinesNode::InputLineIteratorUncompressed::InputLineIteratorUncompressed(), Multiplexer::IntReleaseCatStream(), Multiplexer::IntReleaseMixStream(), LocationDetection< thrill::api::JoinNode::HashCount >::LocationDetection(), CatStreamData::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(), Multiplexer::OnMixStreamBlock(), Multiplexer::OnMultiplexerHeader(), MixStreamData::OnStreamBlock(), CatStreamData::OnStreamBlock(), MixStreamData::OnStreamBlockOrdered(), CatStreamData::OnStreamBlockOrdered(), 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, BlockWriter, 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)

Override default output: never or always output log.

Definition at line 37 of file logger.hpp.

Referenced by ReservoirSamplingGrow< SampleIndexPair >::add(), Dispatcher::DispatchOne(), BlockReader< CatBlockSource >::NextBlock(), and thrill::common::qsort_three_pivots().

#define sLOGC (   cond)    TLX_sLOGC(cond)

Explicitly specify the condition for logging.

Definition at line 31 of file logger.hpp.

Referenced by BlockPool::DestroyBlock(), BlockPool::OnReadComplete(), BlockPool::OnWriteComplete(), and FlowControlChannel::~FlowControlChannel().