Lines Matching refs:l

583 static void logger_link_q(logger *l) {  in logger_link_q()  argument
585 assert(l != logger_stack_head); in logger_link_q()
587 l->prev = 0; in logger_link_q()
588 l->next = logger_stack_head; in logger_link_q()
589 if (l->next) l->next->prev = l; in logger_link_q()
590 logger_stack_head = l; in logger_link_q()
591 if (logger_stack_tail == 0) logger_stack_tail = l; in logger_link_q()
622 logger *l = NULL; in logger_set_flags() local
633 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_set_flags()
634 pthread_mutex_lock(&l->mutex); in logger_set_flags()
635 l->eflags = f; in logger_set_flags()
636 pthread_mutex_unlock(&l->mutex); in logger_set_flags()
723 static int logger_thread_read(logger *l, struct logger_stats *ls) { in logger_thread_read() argument
729 pthread_mutex_lock(&l->mutex); in logger_thread_read()
730 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
731 pthread_mutex_unlock(&l->mutex); in logger_thread_read()
754 pthread_mutex_lock(&l->mutex); in logger_thread_read()
755 data = bipbuf_poll(l->buf, size); in logger_thread_read()
756 ls->worker_written += l->written; in logger_thread_read()
757 ls->worker_dropped += l->dropped; in logger_thread_read()
758 l->written = 0; in logger_thread_read()
759 l->dropped = 0; in logger_thread_read()
760 pthread_mutex_unlock(&l->mutex); in logger_thread_read()
896 logger *l; in logger_thread() local
911 for (l = logger_stack_head; l != NULL; l=l->next) { in logger_thread()
913 found_logs += logger_thread_read(l, &ls); in logger_thread()
996 logger *l = calloc(1, sizeof(logger)); in logger_create() local
997 if (l == NULL) { in logger_create()
1001 l->buf = bipbuf_new(settings.logger_buf_size); in logger_create()
1002 if (l->buf == NULL) { in logger_create()
1003 free(l); in logger_create()
1007 l->entry_map = default_entries; in logger_create()
1009 pthread_mutex_init(&l->mutex, NULL); in logger_create()
1010 pthread_setspecific(logger_key, l); in logger_create()
1013 logger_link_q(l); in logger_create()
1014 return l; in logger_create()
1021 enum logger_ret_type logger_log(logger *l, const enum log_entry_type event, const void *entry, ...)… in logger_log() argument
1022 bipbuf_t *buf = l->buf; in logger_log()
1027 const entry_details *d = &l->entry_map[event]; in logger_log()
1030 pthread_mutex_lock(&l->mutex); in logger_log()
1034 l->dropped++; in logger_log()
1035 pthread_mutex_unlock(&l->mutex); in logger_log()
1064 pthread_mutex_unlock(&l->mutex); in logger_log()
1067 l->written++; in logger_log()
1071 pthread_mutex_unlock(&l->mutex); in logger_log()