Lines Matching defs:thread
66 // thread.
68 // This must be uninstalled while there is only a single thread, and of course
446 FillThread *thread = new FillThread();
447 thread->InitThread(i, this, os_, patternlist_, &fill_status);
451 thread->SetFillPages(pages_ / fill_threads_);
452 // The last thread finishes up all the leftover pages.
456 thread->SetFillPages(pages_ - pages_ / fill_threads_ * i);
458 fill_vector.push_back(thread);
472 logprintf(0, "Thread %d failed with status %d at %.2f seconds\n",
891 // Set number of disk random threads for each disk write thread.
894 // Set a tempfile to use in a file thread.
904 // Set a hostname to use in a network thread.
985 " -d device add a direct write disk thread with block "
987 " -f filename add a disk thread with "
996 " -n ipaddr add a network thread connecting to "
998 " --listen run a thread to listen for and respond "
1019 "write thread (-d)\n"
1053 // Error polling thread.
1058 ErrorPollThread *thread = new ErrorPollThread();
1059 thread->InitThread(total_threads_++, this, os_, patternlist_,
1062 error_vector->insert(error_vector->end(), thread);
1064 logprintf(5, "Log: Skipping error poll thread due to --no_errors flag\n");
1076 CopyThread *thread = new CopyThread();
1077 thread->InitThread(total_threads_++, this, os_, patternlist_,
1086 thread->set_cpu_mask(cpuset);
1087 thread->set_tag(1 << region);
1090 thread->set_cpu_mask(cpuset);
1091 thread->set_tag(region_mask_ & ~(1 << region));
1095 thread->AvailableCpus(&available_cpus);
1097 // Don't restrict thread location if we have more than one
1098 // thread per core. Not so good for performance.
1100 // Place a thread on alternating cores first.
1115 // Set thread affinity.
1116 thread->set_cpu_mask_to_cpu(nthbit);
1119 memory_vector->insert(memory_vector->end(), thread);
1126 FileThread *thread = new FileThread();
1127 thread->InitThread(total_threads_++, this, os_, patternlist_,
1129 thread->SetFile(filename_[i].c_str());
1132 thread->SetPriority(WorkerThread::High);
1134 fileio_vector->insert(fileio_vector->end(), thread);
1142 // Create a network slave thread. This listens for connections.
1143 NetworkListenThread *thread = new NetworkListenThread();
1144 thread->InitThread(total_threads_++, this, os_, patternlist_,
1147 netslave_vector->insert(netslave_vector->end(), thread);
1150 NetworkThread *thread = new NetworkThread();
1151 thread->InitThread(total_threads_++, this, os_, patternlist_,
1153 thread->SetIP(ipaddrs_[i].c_str());
1155 netio_vector->insert(netio_vector->end(), thread);
1163 CheckThread *thread = new CheckThread();
1164 thread->InitThread(total_threads_++, this, os_, patternlist_,
1167 check_vector->insert(check_vector->end(), thread);
1175 InvertThread *thread = new InvertThread();
1176 thread->InitThread(total_threads_++, this, os_, patternlist_,
1179 invert_vector->insert(invert_vector->end(), thread);
1189 DiskThread *thread = new DiskThread(blocktables_[i]);
1190 thread->InitThread(total_threads_++, this, os_, patternlist_,
1192 thread->SetDevice(diskfilename_[i].c_str());
1193 if (thread->SetParameters(read_block_size_, write_block_size_,
1198 disk_vector->insert(disk_vector->end(), thread);
1201 delete thread;
1230 CpuStressThread *thread = new CpuStressThread();
1231 thread->InitThread(total_threads_++, this, os_, patternlist_,
1234 // Don't restrict thread location if we have more than one
1235 // thread per core. Not so good for performance.
1237 thread->AvailableCpus(&available_cpus);
1240 // Place a thread on alternating cores first.
1254 // Set thread affinity.
1255 thread->set_cpu_mask_to_cpu(nthbit);
1259 cpu_vector->insert(cpu_vector->end(), thread);
1301 CpuCacheCoherencyThread *thread =
1304 thread->InitThread(total_threads_++, this, os_, patternlist_,
1306 // Pin the thread to a particular core.
1307 thread->set_cpu_mask_to_cpu(tnum);
1309 // Insert the thread into the vector.
1310 cc_vector->insert(cc_vector->end(), thread);
1333 logprintf(12, "Log: Joining thread %d\n", (*it)->ThreadID());
1351 CheckThread *thread = new CheckThread();
1352 thread->InitThread(total_threads_++, this, os_, patternlist_,
1355 reap_check_vector.push_back(thread);
1366 logprintf(12, "Log: Spawning thread %d\n", (*it)->ThreadID());
1373 logprintf(12, "Log: Joining thread %d\n", (*it)->ThreadID());
1390 logprintf(12, "Log: Reaping thread status %d\n", (*it)->ThreadID());
1392 logprintf(0, "Process Error: Thread %d failed with status %d at "
1401 logprintf(priority, "Log: Thread %d found %lld hardware incidents\n",
1411 logprintf(12, "Log: Reaping thread status %d\n", (*it)->ThreadID());
1413 logprintf(0, "Process Error: Thread %d failed with status %d at "
1423 logprintf(priority, "Log: Thread %d found %lld hardware incidents\n",
1593 // Process worker thread data for bandwidth information, and error results.
1631 logprintf(12, "Log: Spawning thread %d\n", (*it)->ThreadID());
1637 // Delete used worker thread objects.
1644 logprintf(12, "Log: Deleting thread %d\n", (*it)->ThreadID());
1685 // 2) (POSIX) After the value of a variable is changed in one thread, another
1686 // thread is only guaranteed to see the new value after both threads have
1691 // be called in the same thread that reads the "volatile sig_atomic_t"
1693 // the worker threads, forcing them to be handled by this thread.
