MCPcopy Create free account
hub / github.com/OpenDDS/OpenDDS / harvest

Method harvest

dds/DCPS/ThreadStatusManager.cpp:209–224  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

207}
208
209void ThreadStatusManager::ThreadContainer::harvest(const MonotonicTimePoint& start,
210 ThreadStatusManager::List& running, ThreadStatusManager::List& finished) const
211{
212 ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
213 for (Map::const_iterator pos = map_.begin(), limit = map_.end(); pos != limit; ++pos) {
214 if (pos->second.last_update() > start) {
215 running.push_back(pos->second);
216 }
217 }
218
219 for (List::const_iterator pos = finished_.begin(), limit = finished_.end(); pos != limit; ++pos) {
220 if (pos->last_update() > start) {
221 finished.push_back(*pos);
222 }
223 }
224}
225
226ThreadStatusManager::ThreadContainer& ThreadStatusManager::get_container(const ThreadId& tid)
227{

Callers 1

thread_status_taskMethod · 0.80

Calls 2

beginMethod · 0.45
endMethod · 0.45

Tested by

no test coverage detected