Lines Matching refs:me
328 static void setup_thread(LIBEVENT_THREAD *me) { in setup_thread() argument
329 me->base = event_init(); in setup_thread()
330 if (! me->base) { in setup_thread()
336 event_set(&me->notify_event, me->notify_receive_fd, in setup_thread()
337 EV_READ | EV_PERSIST, thread_libevent_process, me); in setup_thread()
338 event_base_set(me->base, &me->notify_event); in setup_thread()
340 if (event_add(&me->notify_event, 0) == -1) { in setup_thread()
345 me->new_conn_queue = malloc(sizeof(struct conn_queue)); in setup_thread()
346 if (me->new_conn_queue == NULL) { in setup_thread()
350 cq_init(me->new_conn_queue); in setup_thread()
352 if (pthread_mutex_init(&me->stats.mutex, NULL) != 0) { in setup_thread()
357 me->suffix_cache = cache_create("suffix", SUFFIX_SIZE, sizeof(char*), in setup_thread()
359 if (me->suffix_cache == NULL) { in setup_thread()
369 LIBEVENT_THREAD *me = arg; in worker_libevent() local
374 me->l = logger_create(); in worker_libevent()
375 if (me->l == NULL) { in worker_libevent()
381 event_base_loop(me->base, 0); in worker_libevent()
391 LIBEVENT_THREAD *me = arg; in thread_libevent_process() local
404 item = cq_pop(me->new_conn_queue); in thread_libevent_process()
409 me->base); in thread_libevent_process()
422 c->thread = me; in thread_libevent_process()