Lines Matching refs:l

112 static void logger_link_q(logger *l) {  in logger_link_q()  argument
114 assert(l != logger_stack_head); in logger_link_q()
116 l->prev = 0; in logger_link_q()
117 l->next = logger_stack_head; in logger_link_q()
118 if (l->next) l->next->prev = l; in logger_link_q()
119 logger_stack_head = l; in logger_link_q()
120 if (logger_stack_tail == 0) logger_stack_tail = l; in logger_link_q()
151 logger *l = NULL; in logger_set_flags() local
162 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_set_flags()
163 pthread_mutex_lock(&l->mutex); in logger_set_flags()
164 l->eflags = f; in logger_set_flags()
165 pthread_mutex_unlock(&l->mutex); in logger_set_flags()
324 static int logger_thread_read(logger *l, struct logger_stats *ls) { in logger_thread_read() argument
330 pthread_mutex_lock(&l->mutex); in logger_thread_read()
331 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
332 pthread_mutex_unlock(&l->mutex); in logger_thread_read()
355 pthread_mutex_lock(&l->mutex); in logger_thread_read()
356 data = bipbuf_poll(l->buf, size); in logger_thread_read()
357 ls->worker_written += l->written; in logger_thread_read()
358 ls->worker_dropped += l->dropped; in logger_thread_read()
359 l->written = 0; in logger_thread_read()
360 l->dropped = 0; in logger_thread_read()
361 pthread_mutex_unlock(&l->mutex); in logger_thread_read()
493 logger *l; in logger_thread() local
501 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_thread()
503 found_logs += logger_thread_read(l, &ls); in logger_thread()
579 logger *l = calloc(1, sizeof(logger)); in logger_create() local
580 if (l == NULL) { in logger_create()
584 l->buf = bipbuf_new(settings.logger_buf_size); in logger_create()
585 if (l->buf == NULL) { in logger_create()
586 free(l); in logger_create()
590 l->entry_map = default_entries; in logger_create()
592 pthread_mutex_init(&l->mutex, NULL); in logger_create()
593 pthread_setspecific(logger_key, l); in logger_create()
596 logger_link_q(l); in logger_create()
597 return l; in logger_create()
640 enum logger_ret_type logger_log(logger *l, const enum log_entry_type event, const void *entry, ...)… in logger_log() argument
641 bipbuf_t *buf = l->buf; in logger_log()
647 const entry_details *d = &l->entry_map[event]; in logger_log()
650 pthread_mutex_lock(&l->mutex); in logger_log()
654 pthread_mutex_unlock(&l->mutex); in logger_log()
655 l->dropped++; in logger_log()
705 pthread_mutex_unlock(&l->mutex); in logger_log()
708 l->written++; in logger_log()
711 pthread_mutex_unlock(&l->mutex); in logger_log()