| 129 | } |
| 130 | |
| 131 | int TraceLogger::register_queue(std::string process_name, |
| 132 | std::string thread_name) { |
| 133 | // Assign buffer for the thread |
| 134 | queue_map_[thread_count_].process_name = process_name; |
| 135 | queue_map_[thread_count_].thread_name = thread_name; |
| 136 | running_count_++; |
| 137 | thread_count_++; |
| 138 | if (thread_count_ == queue_map_.size()) |
| 139 | thread_count_ = 0; // Back to first buffer to reuse buffer |
| 140 | return thread_count_; |
| 141 | } |
| 142 | |
| 143 | void TraceLogger::close_queue(int thread_id) { |
| 144 | running_count_--; |