Lines Matching refs:buf
275 (skip_scr = (char *) bipbuf_request(w->buf, scratch_len + 128)) == NULL) { in logger_thread_write_entry()
297 bipbuf_push(w->buf, total + 1); in logger_thread_write_entry()
301 bipbuf_offer(w->buf, (unsigned char *) scratch, scratch_len); in logger_thread_write_entry()
316 bipbuf_free(w->buf); in logger_thread_close_watcher()
331 data = bipbuf_peek_all(l->buf, &size); in logger_thread_read()
356 data = bipbuf_poll(l->buf, size); in logger_thread_read()
392 data = bipbuf_peek_all(w->buf, &data_size); in logger_thread_poll_watchers()
430 char buf[1]; in logger_thread_poll_watchers() local
431 int res = read(w->sfd, buf, 1); in logger_thread_poll_watchers()
438 if ((data = bipbuf_peek_all(w->buf, &data_size)) != NULL) { in logger_thread_poll_watchers()
456 data_size, bipbuf_used(w->buf)); in logger_thread_poll_watchers()
465 bipbuf_poll(w->buf, total); in logger_thread_poll_watchers()
584 l->buf = bipbuf_new(settings.logger_buf_size); in logger_create()
585 if (l->buf == NULL) { in logger_create()
641 bipbuf_t *buf = l->buf; in logger_log() local
652 e = (logentry *) bipbuf_request(buf, (sizeof(logentry) + reqlen)); in logger_log()
703 if (bipbuf_push(buf, (sizeof(logentry) + e->size)) == 0) { in logger_log()
751 w->buf = bipbuf_new(settings.logger_watcher_buf_size); in logger_add_watcher()
752 if (w->buf == NULL) { in logger_add_watcher()
757 bipbuf_offer(w->buf, (unsigned char *) "OK\r\n", 4); in logger_add_watcher()