Lines Matching refs:buf
674 (skip_scr = (char *) bipbuf_request(w->buf, scratch_len + 128)) == NULL) { in logger_thread_write_entry()
696 bipbuf_push(w->buf, total); in logger_thread_write_entry()
700 bipbuf_offer(w->buf, (unsigned char *) scratch, scratch_len); in logger_thread_write_entry()
715 bipbuf_free(w->buf); in logger_thread_close_watcher()
730 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
755 data = bipbuf_poll(l->buf, size); in logger_thread_read()
791 data = bipbuf_peek_all(w->buf, &data_size); in logger_thread_poll_watchers()
829 char buf[1]; in logger_thread_poll_watchers() local
830 int res = ((conn*)w->c)->read(w->c, buf, 1); in logger_thread_poll_watchers()
838 if ((data = bipbuf_peek_all(w->buf, &data_size)) != NULL) { in logger_thread_poll_watchers()
856 data_size, bipbuf_used(w->buf)); in logger_thread_poll_watchers()
865 bipbuf_poll(w->buf, total); in logger_thread_poll_watchers()
1001 l->buf = bipbuf_new(settings.logger_buf_size); in logger_create()
1002 if (l->buf == NULL) { in logger_create()
1022 bipbuf_t *buf = l->buf; in logger_log() local
1032 e = (logentry *) bipbuf_request(buf, (sizeof(logentry) + reqlen)); in logger_log()
1062 if (bipbuf_push(buf, (sizeof(logentry) + e->size + e->pad)) == 0) { in logger_log()
1113 w->buf = bipbuf_new(settings.logger_watcher_buf_size); in logger_add_watcher()
1114 if (w->buf == NULL) { in logger_add_watcher()
1119 bipbuf_offer(w->buf, (unsigned char *) "OK\r\n", 4); in logger_add_watcher()