Lines Matching defs:thread
66 // thread.
68 // This must be uninstalled while there is only a single thread, and of course
466 FillThread *thread = new FillThread();
467 thread->InitThread(i, this, os_, patternlist_, &fill_status);
471 thread->SetFillPages(pages_ / fill_threads_);
472 // The last thread finishes up all the leftover pages.
476 thread->SetFillPages(pages_ - pages_ / fill_threads_ * i);
478 fill_vector.push_back(thread);
492 logprintf(0, "Thread %d failed with status %d at %.2f seconds\n",
708 cpu_freq_test_ = false; // Flag to trigger cpu frequency thread.
950 // Set number of disk random threads for each disk write thread.
953 // Set a tempfile to use in a file thread.
963 // Set a hostname to use in a network thread.
1104 " -d device add a direct write disk thread with block "
1106 " -f filename add a disk thread with "
1117 " -n ipaddr add a network thread connecting to "
1119 " --listen run a thread to listen for and respond "
1140 "write thread (-d)\n"
1187 // Error polling thread.
1192 ErrorPollThread *thread = new ErrorPollThread();
1193 thread->InitThread(total_threads_++, this, os_, patternlist_,
1196 error_vector->insert(error_vector->end(), thread);
1198 logprintf(5, "Log: Skipping error poll thread due to --no_errors flag\n");
1210 CopyThread *thread = new CopyThread();
1211 thread->InitThread(total_threads_++, this, os_, patternlist_,
1220 thread->set_cpu_mask(cpuset);
1221 thread->set_tag(1 << region);
1224 thread->set_cpu_mask(cpuset);
1225 thread->set_tag(region_mask_ & ~(1 << region));
1229 thread->AvailableCpus(&available_cpus);
1231 // Don't restrict thread location if we have more than one
1232 // thread per core. Not so good for performance.
1234 // Place a thread on alternating cores first.
1249 // Set thread affinity.
1250 thread->set_cpu_mask_to_cpu(nthbit);
1253 memory_vector->insert(memory_vector->end(), thread);
1260 FileThread *thread = new FileThread();
1261 thread->InitThread(total_threads_++, this, os_, patternlist_,
1263 thread->SetFile(filename_[i].c_str());
1266 thread->SetPriority(WorkerThread::High);
1268 fileio_vector->insert(fileio_vector->end(), thread);
1276 // Create a network slave thread. This listens for connections.
1277 NetworkListenThread *thread = new NetworkListenThread();
1278 thread->InitThread(total_threads_++, this, os_, patternlist_,
1281 netslave_vector->insert(netslave_vector->end(), thread);
1284 NetworkThread *thread = new NetworkThread();
1285 thread->InitThread(total_threads_++, this, os_, patternlist_,
1287 thread->SetIP(ipaddrs_[i].c_str());
1289 netio_vector->insert(netio_vector->end(), thread);
1297 CheckThread *thread = new CheckThread();
1298 thread->InitThread(total_threads_++, this, os_, patternlist_,
1301 check_vector->insert(check_vector->end(), thread);
1309 InvertThread *thread = new InvertThread();
1310 thread->InitThread(total_threads_++, this, os_, patternlist_,
1313 invert_vector->insert(invert_vector->end(), thread);
1323 DiskThread *thread = new DiskThread(blocktables_[i]);
1324 thread->InitThread(total_threads_++, this, os_, patternlist_,
1326 thread->SetDevice(diskfilename_[i].c_str());
1327 if (thread->SetParameters(read_block_size_, write_block_size_,
1332 disk_vector->insert(disk_vector->end(), thread);
1335 delete thread;
1364 CpuStressThread *thread = new CpuStressThread();
1365 thread->InitThread(total_threads_++, this, os_, patternlist_,
1368 // Don't restrict thread location if we have more than one
1369 // thread per core. Not so good for performance.
1371 thread->AvailableCpus(&available_cpus);
1374 // Place a thread on alternating cores first.
1388 // Set thread affinity.
1389 thread->set_cpu_mask_to_cpu(nthbit);
1393 cpu_vector->insert(cpu_vector->end(), thread);
1448 CpuCacheCoherencyThread *thread =
1451 thread->InitThread(total_threads_++, this, os_, patternlist_,
1453 // Pin the thread to a particular core.
1454 thread->set_cpu_mask_to_cpu(tnum);
1456 // Insert the thread into the vector.
1457 cc_vector->insert(cc_vector->end(), thread);
1463 // Create the frequency test thread.
1466 CpuFreqThread *thread = new CpuFreqThread(CpuCount(), cpu_freq_threshold_,
1468 // This thread should be paused when other threads are paused.
1469 thread->InitThread(total_threads_++, this, os_, NULL,
1473 cpu_freq_vector->insert(cpu_freq_vector->end(), thread);
1509 logprintf(12, "Log: Joining thread %d\n", (*it)->ThreadID());
1527 CheckThread *thread = new CheckThread();
1528 thread->InitThread(total_threads_++, this, os_, patternlist_,
1531 reap_check_vector.push_back(thread);
1542 logprintf(12, "Log: Spawning thread %d\n", (*it)->ThreadID());
1549 logprintf(12, "Log: Joining thread %d\n", (*it)->ThreadID());
1566 logprintf(12, "Log: Reaping thread status %d\n", (*it)->ThreadID());
1568 logprintf(0, "Process Error: Thread %d failed with status %d at "
1577 logprintf(priority, "Log: Thread %d found %lld hardware incidents\n",
1587 logprintf(12, "Log: Reaping thread status %d\n", (*it)->ThreadID());
1589 logprintf(0, "Process Error: Thread %d failed with status %d at "
1599 logprintf(priority, "Log: Thread %d found %lld hardware incidents\n",
1769 // Process worker thread data for bandwidth information, and error results.
1807 logprintf(12, "Log: Spawning thread %d\n", (*it)->ThreadID());
1813 // Delete used worker thread objects.
1820 logprintf(12, "Log: Deleting thread %d\n", (*it)->ThreadID());
1861 // 2) (POSIX) After the value of a variable is changed in one thread, another
1862 // thread is only guaranteed to see the new value after both threads have
1867 // be called in the same thread that reads the "volatile sig_atomic_t"
1869 // the worker threads, forcing them to be handled by this thread.
2081 // Stop the logging thread and verify any pending data is written to the log.
