210     ngx_stream_log_buf_t       *buffer;  in ngx_stream_log_handler()  local
272         buffer = log[l].file ? log[l].file->data : NULL;  in ngx_stream_log_handler()
274         if (buffer) {  in ngx_stream_log_handler()
276             if (len > (size_t) (buffer->last - buffer->pos)) {  in ngx_stream_log_handler()
278                 ngx_stream_log_write(s, &log[l], buffer->start,  in ngx_stream_log_handler()
279                                      buffer->pos - buffer->start);  in ngx_stream_log_handler()
281                 buffer->pos = buffer->start;  in ngx_stream_log_handler()
284             if (len <= (size_t) (buffer->last - buffer->pos)) {  in ngx_stream_log_handler()
286                 p = buffer->pos;  in ngx_stream_log_handler()
288                 if (buffer->event && p == buffer->start) {  in ngx_stream_log_handler()
289                     ngx_add_timer(buffer->event, buffer->flush);  in ngx_stream_log_handler()
298                 buffer->pos = p;  in ngx_stream_log_handler()
303             if (buffer->event && buffer->event->timer_set) {  in ngx_stream_log_handler()
304                 ngx_del_timer(buffer->event);  in ngx_stream_log_handler()
362     ngx_stream_log_buf_t  *buffer;  in ngx_stream_log_write()  local
369         buffer = log->file->data;  in ngx_stream_log_write()
371         if (buffer && buffer->gzip) {  in ngx_stream_log_write()
372             n = ngx_stream_log_gzip(log->file->fd, buf, len, buffer->gzip,  in ngx_stream_log_write()
615     ngx_stream_log_buf_t  *buffer;  in ngx_stream_log_flush()  local
617     buffer = file->data;  in ngx_stream_log_flush()
619     len = buffer->pos - buffer->start;  in ngx_stream_log_flush()
626     if (buffer->gzip) {  in ngx_stream_log_flush()
627         n = ngx_stream_log_gzip(file->fd, buffer->start, len, buffer->gzip,  in ngx_stream_log_flush()
630         n = ngx_write_fd(file->fd, buffer->start, len);  in ngx_stream_log_flush()
633     n = ngx_write_fd(file->fd, buffer->start, len);  in ngx_stream_log_flush()
647     buffer->pos = buffer->start;  in ngx_stream_log_flush()
649     if (buffer->event && buffer->event->timer_set) {  in ngx_stream_log_flush()
650         ngx_del_timer(buffer->event);  in ngx_stream_log_flush()
981     ngx_stream_log_buf_t                *buffer;  in ngx_stream_log_set_log()  local
1212             buffer = log->file->data;  in ngx_stream_log_set_log()
1214             if (buffer->last - buffer->start != size  in ngx_stream_log_set_log()
1215                 || buffer->flush != flush  in ngx_stream_log_set_log()
1216                 || buffer->gzip != gzip)  in ngx_stream_log_set_log()
1228         buffer = ngx_pcalloc(cf->pool, sizeof(ngx_stream_log_buf_t));  in ngx_stream_log_set_log()
1229         if (buffer == NULL) {  in ngx_stream_log_set_log()
1233         buffer->start = ngx_pnalloc(cf->pool, size);  in ngx_stream_log_set_log()
1234         if (buffer->start == NULL) {  in ngx_stream_log_set_log()
1238         buffer->pos = buffer->start;  in ngx_stream_log_set_log()
1239         buffer->last = buffer->start + size;  in ngx_stream_log_set_log()
1242             buffer->event = ngx_pcalloc(cf->pool, sizeof(ngx_event_t));  in ngx_stream_log_set_log()
1243             if (buffer->event == NULL) {  in ngx_stream_log_set_log()
1247             buffer->event->data = log->file;  in ngx_stream_log_set_log()
1248             buffer->event->handler = ngx_stream_log_flush_handler;  in ngx_stream_log_set_log()
1249             buffer->event->log = &cf->cycle->new_log;  in ngx_stream_log_set_log()
1250             buffer->event->cancelable = 1;  in ngx_stream_log_set_log()
1252             buffer->flush = flush;  in ngx_stream_log_set_log()
1255         buffer->gzip = gzip;  in ngx_stream_log_set_log()
1258         log->file->data = buffer;  in ngx_stream_log_set_log()