Lines Matching refs:log_stream
179 struct zlog_stream *log_stream; local
193 create_log_stream = !child->log_stream;
195 log_stream = child->log_stream = malloc(sizeof(struct zlog_stream));
196 zlog_stream_init_ex(log_stream, ZLOG_WARNING, STDERR_FILENO);
197 zlog_stream_set_decorating(log_stream, child->wp->config->decorate_workers_output);
198 zlog_stream_set_wrapping(log_stream, ZLOG_TRUE);
199 zlog_stream_set_msg_prefix(log_stream, STREAM_SET_MSG_PREFIX_FMT,
201 zlog_stream_set_msg_quoting(log_stream, ZLOG_TRUE);
202 zlog_stream_set_is_stdout(log_stream, is_stdout);
203 zlog_stream_set_child_pid(log_stream, (int)child->pid);
205 log_stream = child->log_stream;
208 …if (log_stream->is_stdout != (unsigned int)is_stdout || log_stream->child_pid != (int)child->pid) {
209 zlog_stream_finish(log_stream);
210 zlog_stream_set_msg_prefix(log_stream, STREAM_SET_MSG_PREFIX_FMT,
212 zlog_stream_set_is_stdout(log_stream, is_stdout);
213 zlog_stream_set_child_pid(log_stream, (int)child->pid);
231 zlog_stream_finish(log_stream);
234 zlog_stream_str(log_stream, &FPM_STDIO_CMD_FLUSH[0], cmd_pos);
241 zlog_stream_str(log_stream, buf + start, pos - start);
242 zlog_stream_finish(log_stream);
248 zlog_stream_str(log_stream, buf + start, pos - start);
249 zlog_stream_finish(log_stream);
255 zlog_stream_str(log_stream, buf + start, pos - start);
262 zlog_stream_str(log_stream, buf + start, pos - start);
268 zlog_stream_set_msg_suffix(log_stream, NULL, ", pipe is closed");
269 zlog_stream_finish(log_stream);
