Akkariin/wrk
1
0
Fork 0
mirror of https://github.com/wg/wrk synced 2025-02-13 22:53:06 +08:00
Code Issues Releases Wiki Activity

handle failure to create event loop

Browse Source
This commit is contained in:
Will 2013-10-05 12:23:09 +09:00
parent 6845a10ca3
commit 796f4e1226
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/wrk.c
View File

@ -134,6 +134,7 @@ int main(int argc, char **argv) {
for (uint64_t i = 0; i < cfg.threads; i++) { for (uint64_t i = 0; i < cfg.threads; i++) {
thread *t = &threads[i]; thread *t = &threads[i];
t->loop = aeCreateEventLoop(10 + cfg.connections * 3);
t->connections = connections; t->connections = connections;
t->stop_at = stop_at; t->stop_at = stop_at;
@ -151,9 +152,9 @@ int main(int argc, char **argv) {
} }
} }
if (pthread_create(&t->thread, NULL, &thread_main, t)) { if (!t->loop || pthread_create(&t->thread, NULL, &thread_main, t)) {
char *msg = strerror(errno); char *msg = strerror(errno);
fprintf(stderr, "unable to create thread %"PRIu64" %s\n", i, msg); fprintf(stderr, "unable to create thread %"PRIu64": %s\n", i, msg);
exit(2); exit(2);
} }
} }
@ -225,10 +226,9 @@ int main(int argc, char **argv) {
void *thread_main(void *arg) { void *thread_main(void *arg) {
thread *thread = arg; thread *thread = arg;
aeEventLoop *loop = thread->loop;
aeEventLoop *loop = aeCreateEventLoop(10 + cfg.connections * 3);
thread->cs = zmalloc(thread->connections * sizeof(connection)); thread->cs = zmalloc(thread->connections * sizeof(connection));
thread->loop = loop;
tinymt64_init(&thread->rand, time_us()); tinymt64_init(&thread->rand, time_us());
thread->latency = stats_alloc(100000); thread->latency = stats_alloc(100000);