Lines Matching refs:it
483 for (WorkerVector::const_iterator it = fill_vector.begin(); in InitializePages() local
484 it != fill_vector.end(); ++it) in InitializePages()
485 (*it)->SpawnThread(); in InitializePages()
488 for (WorkerVector::const_iterator it = fill_vector.begin(); in InitializePages() local
489 it != fill_vector.end(); ++it) { in InitializePages()
490 (*it)->JoinThread(); in InitializePages()
491 if ((*it)->GetStatus() != 1) { in InitializePages()
493 (*it)->ThreadID(), (*it)->GetStatus(), in InitializePages()
494 (*it)->GetRunDurationUSec() * 1.0/1000000); in InitializePages()
498 delete (*it); in InitializePages()
1507 for (WorkerVector::const_iterator it = map_it->second->begin(); in JoinThreads() local
1508 it != map_it->second->end(); ++it) { in JoinThreads()
1509 logprintf(12, "Log: Joining thread %d\n", (*it)->ThreadID()); in JoinThreads()
1510 (*it)->JoinThread(); in JoinThreads()
1540 for (WorkerVector::const_iterator it = reap_check_vector.begin(); in JoinThreads() local
1541 it != reap_check_vector.end(); ++it) { in JoinThreads()
1542 logprintf(12, "Log: Spawning thread %d\n", (*it)->ThreadID()); in JoinThreads()
1543 (*it)->SpawnThread(); in JoinThreads()
1547 for (WorkerVector::const_iterator it = reap_check_vector.begin(); in JoinThreads() local
1548 it != reap_check_vector.end(); ++it) { in JoinThreads()
1549 logprintf(12, "Log: Joining thread %d\n", (*it)->ThreadID()); in JoinThreads()
1550 (*it)->JoinThread(); in JoinThreads()
1564 for (WorkerVector::const_iterator it = map_it->second->begin(); in JoinThreads() local
1565 it != map_it->second->end(); ++it) { in JoinThreads()
1566 logprintf(12, "Log: Reaping thread status %d\n", (*it)->ThreadID()); in JoinThreads()
1567 if ((*it)->GetStatus() != 1) { in JoinThreads()
1570 (*it)->ThreadID(), (*it)->GetStatus(), in JoinThreads()
1571 (*it)->GetRunDurationUSec()*1.0/1000000); in JoinThreads()
1575 if ((*it)->GetErrorCount()) in JoinThreads()
1578 (*it)->ThreadID(), (*it)->GetErrorCount()); in JoinThreads()
1585 for (WorkerVector::const_iterator it = reap_check_vector.begin(); in JoinThreads() local
1586 it != reap_check_vector.end(); ++it) { in JoinThreads()
1587 logprintf(12, "Log: Reaping thread status %d\n", (*it)->ThreadID()); in JoinThreads()
1588 if ((*it)->GetStatus() != 1) { in JoinThreads()
1591 (*it)->ThreadID(), (*it)->GetStatus(), in JoinThreads()
1592 (*it)->GetRunDurationUSec()*1.0/1000000); in JoinThreads()
1595 errorcount_ += (*it)->GetErrorCount(); in JoinThreads()
1597 if ((*it)->GetErrorCount()) in JoinThreads()
1600 (*it)->ThreadID(), (*it)->GetErrorCount()); in JoinThreads()
1601 delete (*it); in JoinThreads()
1620 for (WorkerVector::const_iterator it = map_it->second->begin(); in AnalysisAllStats() local
1621 it != map_it->second->end(); ++it) { in AnalysisAllStats()
1622 thread_runtime_sec = (*it)->GetRunDurationUSec()*1.0/1000000.; in AnalysisAllStats()
1623 total_data += (*it)->GetMemoryCopiedData(); in AnalysisAllStats()
1624 total_data += (*it)->GetDeviceCopiedData(); in AnalysisAllStats()
1651 for (WorkerVector::const_iterator it = mem_it->second->begin(); in MemoryStats() local
1652 it != mem_it->second->end(); ++it) { in MemoryStats()
1653 memcopy_data += (*it)->GetMemoryCopiedData(); in MemoryStats()
1654 memcopy_bandwidth += (*it)->GetMemoryBandwidth(); in MemoryStats()
1656 for (WorkerVector::const_iterator it = file_it->second->begin(); in MemoryStats() local
1657 it != file_it->second->end(); ++it) { in MemoryStats()
1658 memcopy_data += (*it)->GetMemoryCopiedData(); in MemoryStats()
1659 memcopy_bandwidth += (*it)->GetMemoryBandwidth(); in MemoryStats()
1678 for (WorkerVector::const_iterator it = file_it->second->begin(); in FileStats() local
1679 it != file_it->second->end(); ++it) { in FileStats()
1680 file_data += (*it)->GetDeviceCopiedData(); in FileStats()
1681 file_bandwidth += (*it)->GetDeviceBandwidth(); in FileStats()
1694 for (WorkerVector::const_iterator it = check_it->second->begin(); in CheckStats() local
1695 it != check_it->second->end(); ++it) { in CheckStats()
1696 check_data += (*it)->GetMemoryCopiedData(); in CheckStats()
1697 check_bandwidth += (*it)->GetMemoryBandwidth(); in CheckStats()
1713 for (WorkerVector::const_iterator it = netio_it->second->begin(); in NetStats() local
1714 it != netio_it->second->end(); ++it) { in NetStats()
1715 net_data += (*it)->GetDeviceCopiedData(); in NetStats()
1716 net_bandwidth += (*it)->GetDeviceBandwidth(); in NetStats()
1718 for (WorkerVector::const_iterator it = netslave_it->second->begin(); in NetStats() local
1719 it != netslave_it->second->end(); ++it) { in NetStats()
1720 net_data += (*it)->GetDeviceCopiedData(); in NetStats()
1721 net_bandwidth += (*it)->GetDeviceBandwidth(); in NetStats()
1734 for (WorkerVector::const_iterator it = invert_it->second->begin(); in InvertStats() local
1735 it != invert_it->second->end(); ++it) { in InvertStats()
1736 invert_data += (*it)->GetMemoryCopiedData(); in InvertStats()
1737 invert_bandwidth += (*it)->GetMemoryBandwidth(); in InvertStats()
1753 for (WorkerVector::const_iterator it = disk_it->second->begin(); in DiskStats() local
1754 it != disk_it->second->end(); ++it) { in DiskStats()
1755 disk_data += (*it)->GetDeviceCopiedData(); in DiskStats()
1756 disk_bandwidth += (*it)->GetDeviceBandwidth(); in DiskStats()
1758 for (WorkerVector::const_iterator it = random_it->second->begin(); in DiskStats() local
1759 it != random_it->second->end(); ++it) { in DiskStats()
1760 disk_data += (*it)->GetDeviceCopiedData(); in DiskStats()
1761 disk_bandwidth += (*it)->GetDeviceBandwidth(); in DiskStats()
1788 for (WorkerVector::const_iterator it = map_it->second->begin(); in GetTotalErrorCount() local
1789 it != map_it->second->end(); ++it) { in GetTotalErrorCount()
1790 errors += (*it)->GetErrorCount(); in GetTotalErrorCount()
1805 for (WorkerVector::const_iterator it = map_it->second->begin(); in SpawnThreads() local
1806 it != map_it->second->end(); ++it) { in SpawnThreads()
1807 logprintf(12, "Log: Spawning thread %d\n", (*it)->ThreadID()); in SpawnThreads()
1808 (*it)->SpawnThread(); in SpawnThreads()
1818 for (WorkerVector::const_iterator it = map_it->second->begin(); in DeleteThreads() local
1819 it != map_it->second->end(); ++it) { in DeleteThreads()
1820 logprintf(12, "Log: Deleting thread %d\n", (*it)->ThreadID()); in DeleteThreads()
1821 delete (*it); in DeleteThreads()