From e7d1f524f3d8e76b864bbed0cdd373a9210db2e9 Mon Sep 17 00:00:00 2001 From: Qiao Longfei Date: Tue, 27 Nov 2018 12:56:57 +0800 Subject: [PATCH] change log level test=develop --- paddle/fluid/operators/gaussian_random_op.cc | 2 +- paddle/fluid/operators/reader/ctr_reader.cc | 26 ++++++++++---------- 2 files changed, 14 insertions(+), 14 deletions(-) diff --git a/paddle/fluid/operators/gaussian_random_op.cc b/paddle/fluid/operators/gaussian_random_op.cc index c70d5b8bc75..783460b6eec 100644 --- a/paddle/fluid/operators/gaussian_random_op.cc +++ b/paddle/fluid/operators/gaussian_random_op.cc @@ -126,7 +126,7 @@ Used to initialize tensors with gaussian random generator. } // namespace paddle namespace ops = paddle::operators; -REGISTER_OP_WITHOUT_GRADIENT(gaussian_random, ops::GaussianRandomOp, +REGISTER_OP_WITHOUT_GRADIENT(ctr_reader.cc, ops::GaussianRandomOp, ops::GaussianRandomOpMaker); REGISTER_OP_CPU_KERNEL(gaussian_random, ops::CPUGaussianRandomKernel, ops::CPUGaussianRandomKernel); diff --git a/paddle/fluid/operators/reader/ctr_reader.cc b/paddle/fluid/operators/reader/ctr_reader.cc index 60d7742bce4..d1d3ddc89dc 100644 --- a/paddle/fluid/operators/reader/ctr_reader.cc +++ b/paddle/fluid/operators/reader/ctr_reader.cc @@ -125,36 +125,36 @@ class MultiGzipReader : public Reader { void MonitorThread(std::vector* thread_status, std::shared_ptr queue) { - VLOG(3) << "monitor thread in"; + VLOG(30) << "monitor thread in"; bool reader_thread_is_running = true; while (reader_thread_is_running) { - VLOG(3) << "reader_thread_is_running"; + VLOG(30) << "reader_thread_is_running"; reader_thread_is_running = false; for (size_t i = 0; i < (*thread_status).size(); ++i) { if ((*thread_status)[i] == Running) { - VLOG(3) << "reader is running!"; + VLOG(30) << "reader is running!"; reader_thread_is_running = true; } } std::this_thread::sleep_for(std::chrono::milliseconds(1000)); } - VLOG(3) << "all reader thread is stopped, push empty data into queue"; + VLOG(30) << "all reader thread is stopped, push empty data into queue"; queue->Push({}); - VLOG(3) << "monitor thread exited"; + VLOG(30) << "monitor thread exited"; } void ReadThread(const std::vector& file_list, const std::vector& slots, int batch_size, int thread_id, std::vector* thread_status, std::shared_ptr queue) { - VLOG(3) << "[" << thread_id << "]" - << " reader thread start! thread_id = " << thread_id; + VLOG(30) << "[" << thread_id << "]" + << " reader thread start! thread_id = " << thread_id; for (auto& file : file_list) { - VLOG(3) << "[" << thread_id << "]" - << " file " << file; + VLOG(30) << "[" << thread_id << "]" + << " file " << file; } (*thread_status)[thread_id] = Running; - VLOG(3) << "set status to running"; + VLOG(30) << "set status to running"; std::unordered_map slot_to_index; for (size_t i = 0; i < slots.size(); ++i) { @@ -168,7 +168,7 @@ void ReadThread(const std::vector& file_list, MultiGzipReader reader(file_list); - VLOG(3) << "reader inited"; + VLOG(30) << "reader inited"; while (reader.HasNext()) { batch_data.clear(); @@ -226,11 +226,11 @@ void ReadThread(const std::vector& file_list, lod_datas.push_back(label_tensor); queue->Push(lod_datas); - VLOG(4) << "push one data, queue_size=" << queue->Size(); + VLOG(40) << "push one data, queue_size=" << queue->Size(); } (*thread_status)[thread_id] = Stopped; - VLOG(3) << "set status to stopped, thread " << thread_id << " exited"; + VLOG(30) << "set status to stopped, thread " << thread_id << " exited"; } } // namespace reader -- GitLab