Lines Matching refs:server
74 Server *server; member
111 if (s->server) { in stdout_stream_free()
113 client_context_release(s->server, s->context); in stdout_stream_free()
115 assert(s->server->n_stdout_streams > 0); in stdout_stream_free()
116 s->server->n_stdout_streams--; in stdout_stream_free()
117 LIST_REMOVE(stdout_stream, s->server->stdout_streams, s); in stdout_stream_free()
120 … LIST_REMOVE(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s); in stdout_stream_free()
122 (void) server_start_or_stop_idle_timer(s->server); /* Maybe we are idle now? */ in stdout_stream_free()
166 …r = asprintf(&s->state_file, "%s/streams/%lu:%lu", s->server->runtime_directory, (unsigned long) s… in stdout_stream_save()
228 LIST_PREPEND(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s); in stdout_stream_save()
231 if (s->server->notify_event_source) { in stdout_stream_save()
232 … r = sd_event_source_set_enabled(s->server->notify_event_source, SD_EVENT_ON); in stdout_stream_save()
265 … (void) client_context_maybe_refresh(s->server, s->context, NULL, NULL, 0, NULL, USEC_INFINITY); in stdout_stream_log()
267 …r = client_context_acquire(s->server, s->ucred.pid, &s->ucred, s->label, strlen_ptr(s->label), s->… in stdout_stream_log()
283 if (s->forward_to_syslog || s->server->forward_to_syslog) in stdout_stream_log()
284 …server_forward_syslog(s->server, syslog_fixup_facility(priority), s->identifier, p, &s->ucred, NUL… in stdout_stream_log()
286 if (s->forward_to_kmsg || s->server->forward_to_kmsg) in stdout_stream_log()
287 server_forward_kmsg(s->server, priority, s->identifier, p, &s->ucred); in stdout_stream_log()
289 if (s->forward_to_console || s->server->forward_to_console) in stdout_stream_log()
290 server_forward_console(s->server, priority, s->identifier, p, &s->ucred); in stdout_stream_log()
292 if (s->server->forward_to_wall) in stdout_stream_log()
293 server_forward_wall(s->server, priority, s->identifier, p, &s->ucred); in stdout_stream_log()
334 server_dispatch_message(s->server, iovec, n, m, s->context, NULL, priority, 0); in stdout_stream_log()
481 return s->server->line_max; in stdout_stream_line_max()
585 limit = MIN(allocated - 1, MAX(s->server->line_max, STDOUT_STREAM_SETUP_PROTOCOL_LINE_MAX)); in stdout_stream_process()
615 s->context = client_context_release(s->server, s->context); in stdout_stream_process()
693 stream->server = s; in stdout_stream_install()
763 stream->state_file = path_join(stream->server->runtime_directory, "streams", fname); in stdout_stream_load()
962 assert(s->server); in stdout_stream_send_notify()
963 assert(s->server->notify_fd >= 0); in stdout_stream_send_notify()
978 l = sendmsg(s->server->notify_fd, &msghdr, MSG_DONTWAIT|MSG_NOSIGNAL); in stdout_stream_send_notify()
989 LIST_REMOVE(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s); in stdout_stream_send_notify()