forgotten!

src/caffe/layers/root_data_layer.cpp

@@ -28,15 +28,15 @@ namespace caffe {
     std::string name  = this->layer_param_.root_data_param().filler_name();
 
     //Instantiate ThreadDatumFiller only once
-    if(!(::larcv::ThreadFillerFactory::exist_filler(name))) {
-      auto& filler = ::larcv::ThreadFillerFactory::get_filler(name);
+    bool first_time = !(::larcv::ThreadFillerFactory::exist_filler(name));
+    auto& filler = ::larcv::ThreadFillerFactory::get_filler(name);
+    if(first_time) {
       filler.configure(this->layer_param_.root_data_param().filler_config());
       // Start read thread
       filler.batch_process(batch_size);
-    }else if(filler.thread_config()){
-      auto& filler = ::larcv::ThreadFillerFactory::get_filler(name);
-      filler.batch_process(batch_size);
     }
+    else if(filler.thread_config())
+      filler.batch_process(batch_size);
 
     root_helper rh;
     rh._filler_name = name;
@@ -53,10 +53,8 @@ namespace caffe {
     root_load_data(rh, root_blobs_[0].get(), root_blobs_[1].get());
 
     // Start read thread
-    if(filler.thread_config()) {
-      auto& filler = ::larcv::ThreadFillerFactory::get_filler(name);
+    if(filler.thread_config())
       filler.batch_process(batch_size);
-    }
 
     // MinTopBlobs==1 guarantees at least one top blob
     CHECK_GE(root_blobs_[0]->num_axes(), 1) << "Input must have at least 1 axis.";