Made the LogLevel variable thread local

Author: dkeeney

src/htm/engine/Input.cpp

@@ -330,7 +330,7 @@ void Input::uninitialize() {
 
 namespace htm {
   std::ostream &operator<<(std::ostream &f, const Input &d) {
-    f << "Input: " << d.getRegion()->getName() << "." << d.getName() << " " << d.getData();
+    f << "Input:  " << d.getRegion()->getName() << "." << d.getName() << " " << d.getData();
     return f;
   }
 }

src/htm/engine/Link.cpp

@@ -27,7 +27,7 @@
 #include <htm/ntypes/BasicType.hpp>
 #include <htm/utils/Log.hpp>
 
-// By calling  NTA_LOG_LEVEL = LogLevel::LogLevel_Verbose
+// By calling  Network::setLogLevel(LogLevel_Verbose)
 // you can enable the NTA_DEBUG macros below.
 
 namespace htm {
@@ -187,7 +187,7 @@ void Link::compute() {
   const Array &src = propagationDelay_ ? propagationDelayBuffer_.front() : src_->getData();
   Array &dest = dest_->getData();
 
-  NTA_DEBUG << "Link::compute: " << getMoniker() << "; copying to dest input"
+  NTA_DEBUG << "compute Link: copying " << getMoniker()
               << "; delay=" << propagationDelay_ << "; size=" << src.getCount()
               << " type=" << BasicType::getName(src.getType())
               << " --> " << BasicType::getName(dest.getType()) << std::endl;

src/htm/engine/Network.cpp

@@ -40,19 +40,22 @@ namespace htm {
 
 class RegisteredRegionImpl;
 
+thread_local LogLevel NTA_LOG_LEVEL; 
+
+
 Network::Network() {
   commonInit();
 }
 
 // move constructor
-Network::Network(Network && n) {
+Network::Network(Network &&n) noexcept {
   regions_ = std::move(n.regions_);
   minEnabledPhase_ = n.minEnabledPhase_;
   maxEnabledPhase_ = n.maxEnabledPhase_;
   phaseInfo_ = std::move(n.phaseInfo_);
   callbacks_ = n.callbacks_;
   iteration_ = n.iteration_;
-}  
+}
 
 Network::Network(const std::string& filename) {
   commonInit();

src/htm/engine/Network.hpp

@@ -67,7 +67,7 @@ class Link;
   /**
    * Cannot copy or assign a Network object. But can be moved.
    */
-  Network(Network&&);  // move is allowed
+  Network(Network &&) noexcept; // move is allowed
   Network(const Network&) = delete;
   void operator=(const Network&) = delete;
 
@@ -378,8 +378,10 @@ class Link;
   /**
    * Set one of the debug levels: LogLevel_None = 0, LogLevel_Minimal, LogLevel_Normal, LogLevel_Verbose
    */
-  static void setLogLevel(LogLevel level) {
+  static LogLevel setLogLevel(LogLevel level) {
+    LogLevel prev = NTA_LOG_LEVEL;
     NTA_LOG_LEVEL = level;
+    return prev;
   }
 
 

src/htm/engine/Output.cpp

@@ -118,7 +118,7 @@ void Output::removeLink(const std::shared_ptr<Link>& link) {
 
 namespace htm {
   std::ostream &operator<<(std::ostream &f, const Output &d) {
-    f << "Output:" << d.getRegion()->getName() << "." << d.getName() << " " << d.getData();
+    f << "Output: " << d.getRegion()->getName() << "." << d.getName() << " " << d.getData();
     return f;
   }
 }

src/htm/regions/SPRegion.cpp

@@ -158,7 +158,7 @@ void SPRegion::compute() {
   // Call SpatialPooler compute
   sp_->compute(inputBuffer.getSDR(), args_.learningMode, outputBuffer.getSDR());
 
-
+  // trace facility
   NTA_DEBUG << "compute " << *getOutput("bottomUpOut") << "\n";
 
 }

src/htm/regions/ScalarSensor.cpp

@@ -102,6 +102,9 @@ void ScalarSensor::compute()
 {
   SDR &output = getOutput("encoded")->getData().getSDR();
   encoder_->encode((Real64)sensedValue_, output);
+
+  // trace facility
+  NTA_DEBUG << "compute " << getOutput("encoded") << std::endl;
 }
 
 ScalarSensor::~ScalarSensor() {}

src/htm/regions/TMRegion.cpp

@@ -210,6 +210,7 @@ void TMRegion::compute() {
   Array &externalPredictiveInputsWinners = getInput("externalPredictiveInputsWinners")->getData();
   SDR& externalPredictiveInputsWinnerCells = (args_.externalPredictiveInputs) ? (externalPredictiveInputsWinners.getSDR()) : nullSDR;
 
+  // Trace facility
   NTA_DEBUG << "compute " << *in << std::endl;
 
   // Perform Bottom up compute()
@@ -231,34 +232,32 @@ void TMRegion::compute() {
   //
   std::shared_ptr<Output> out;
   out = getOutput("bottomUpOut");
-  //set 
-  NTA_LOG_LEVEL = htm::LogLevel::LogLevel_Verbose;
-  NTA_CHECK(NTA_LOG_LEVEL == LogLevel::LogLevel_Verbose) << "setting Verbose failed, man";
-  //to output the NTA_DEBUG statements below
+  //call Network::setLogLevel(LogLevel::LogLevel_Verbose);
+  //     to output the NTA_DEBUG statements below
     SDR& sdr = out->getData().getSDR();
     tm_->getActiveCells(sdr); //active cells
     if (args_.orColumnOutputs) { //output as columns
       sdr = tm_->cellsToColumns(sdr);
     }
-    NTA_DEBUG << "bottomUpOut " << *out << std::endl;
+    NTA_DEBUG << "compute "<< *out << std::endl;
 
   out = getOutput("activeCells");
     tm_->getActiveCells(out->getData().getSDR());
-    NTA_DEBUG << "active " << *out << std::endl;
+    NTA_DEBUG << "compute "<< *out << std::endl;
 
   out = getOutput("predictedActiveCells");
     tm_->activateDendrites();
     tm_->getWinnerCells(out->getData().getSDR());
-    NTA_DEBUG << "winners " << *out << std::endl;
+    NTA_DEBUG << "compute "<< *out << std::endl;
 
   out = getOutput("anomaly");
     Real32* buffer = reinterpret_cast<Real32*>(out->getData().getBuffer());
     buffer[0] = tm_->anomaly; //only the first field is valid
-    NTA_DEBUG << "anomaly " << *out << std::endl;
+    NTA_DEBUG << "compute "<< *out << std::endl;
 
   out = getOutput("predictiveCells");
     out->getData().getSDR() = tm_->getPredictiveCells();
-    NTA_DEBUG << "predictive " << *out << std::endl;
+    NTA_DEBUG << "compute " << *out << std::endl;
 }
 
 

src/htm/regions/TMRegion.hpp

@@ -182,7 +182,7 @@ class TMRegion : public RegionImpl, Serializable {
     Size iter;
   } args_;
 
-  bool isConnected_(std::string name) const;
+
 
   computeCallbackFunc computeCallback_;
   std::unique_ptr<TemporalMemory> tm_;

src/htm/regions/TestNode.cpp

@@ -172,6 +172,10 @@ void TestNode::compute() {
   Array &inputArray = bottomUpIn_->getData();
   Real64* inputBuffer = (Real64*)inputArray.getBuffer();
   size_t count = inputArray.getCount();
+
+    // trace facility
+  NTA_DEBUG << "compute " << bottomUpIn_ << std::endl;
+
 
   // See TestNode.hpp for description of the computation
 
@@ -198,6 +202,10 @@ void TestNode::compute() {
     }
   }
 
+  // trace facility
+  NTA_DEBUG << "compute " << bottomUpOut_ << "\n";
+
+
   iter_++;
 }