We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dbc4f8e commit a2ee5abCopy full SHA for a2ee5ab
iocore/aio/test_AIO.cc
@@ -422,12 +422,9 @@ main(int /* argc ATS_UNUSED */, char *argv[])
422
main_thread->set_specific();
423
424
#if AIO_MODE == AIO_MODE_NATIVE
425
- int etype = ET_NET;
426
- int n_netthreads = eventProcessor.n_threads_for_type[etype];
427
- EThread **netthreads = eventProcessor.eventthread[etype];
428
- for (int i = 0; i < n_netthreads; ++i) {
429
- netthreads[i]->diskHandler = new DiskHandler();
430
- netthreads[i]->schedule_imm(netthreads[i]->diskHandler);
+ for (EThread *et : eventProcessor.active_group_threads(ET_NET)) {
+ et->diskHandler = new DiskHandler();
+ et->schedule_imm(et->diskHandler);
431
}
432
#endif
433
0 commit comments