| 2301 | } |
| 2302 | |
| 2303 | void Task::addOperatorStats(OperatorStats& stats) { |
| 2304 | std::lock_guard<std::timed_mutex> l(mutex_); |
| 2305 | BOLT_CHECK( |
| 2306 | stats.pipelineId >= 0 && |
| 2307 | stats.pipelineId < taskStats_.pipelineStats.size()); |
| 2308 | BOLT_CHECK( |
| 2309 | stats.operatorId >= 0 && |
| 2310 | stats.operatorId < |
| 2311 | taskStats_.pipelineStats[stats.pipelineId].operatorStats.size()); |
| 2312 | aggregateOperatorRuntimeStats(stats.runtimeStats); |
| 2313 | addRunningTimeOperatorMetrics(stats); |
| 2314 | taskStats_.pipelineStats[stats.pipelineId] |
| 2315 | .operatorStats[stats.operatorId] |
| 2316 | .add(stats); |
| 2317 | } |
| 2318 | |
| 2319 | TaskStats Task::taskStats() const { |
| 2320 | std::lock_guard<std::timed_mutex> l(mutex_); |
no test coverage detected