Lines Matching refs:ls

642 static enum logger_parse_entry_ret logger_thread_parse_entry(logentry *e, struct logger_stats *ls,  in logger_thread_parse_entry()  argument
660 static void logger_thread_write_entry(logentry *e, struct logger_stats *ls, in logger_thread_write_entry() argument
684 ls->watcher_skipped++; in logger_thread_write_entry()
693 ls->watcher_skipped++; in logger_thread_write_entry()
701 ls->watcher_sent++; in logger_thread_write_entry()
723 static int logger_thread_read(logger *l, struct logger_stats *ls) { in logger_thread_read() argument
743 ret = logger_thread_parse_entry(e, ls, scratch, &scratch_len); in logger_thread_read()
748 logger_thread_write_entry(e, ls, scratch, scratch_len); in logger_thread_read()
756 ls->worker_written += l->written; in logger_thread_read()
757 ls->worker_dropped += l->dropped; in logger_thread_read()
875 static void logger_thread_flush_stats(struct logger_stats *ls) { in logger_thread_flush_stats() argument
877 stats.log_worker_dropped += ls->worker_dropped; in logger_thread_flush_stats()
878 stats.log_worker_written += ls->worker_written; in logger_thread_flush_stats()
879 stats.log_watcher_skipped += ls->watcher_skipped; in logger_thread_flush_stats()
880 stats.log_watcher_sent += ls->watcher_sent; in logger_thread_flush_stats()
881 stats_state.log_watchers = ls->watcher_count; in logger_thread_flush_stats()
897 struct logger_stats ls; in logger_thread() local
898 memset(&ls, 0, sizeof(struct logger_stats)); in logger_thread()
913 found_logs += logger_thread_read(l, &ls); in logger_thread()
919 ls.watcher_count = watcher_count; in logger_thread()
934 logger_thread_flush_stats(&ls); in logger_thread()