/systemd/src/journal/ |
H A D | journald.c | 28 #include "journald-server.h" 33 Server server; local 50 r = server_init(&server); 54 server_vacuum(&server, false, false); 55 server_flush_to_var(&server); 56 server_flush_dev_kmsg(&server); 59 server_driver_message(&server, SD_MESSAGE_JOURNAL_START, 66 r = sd_event_get_state(server.event); 74 if (server.max_retention_usec > 0 && server [all...] |
H A D | journald-stream.c | 38 #include "journald-server.h" 64 Server *server; member in struct:StdoutStream 97 if (s->server) { 98 assert(s->server->n_stdout_streams > 0); 99 s->server->n_stdout_streams --; 100 LIST_REMOVE(stdout_stream, s->server->stdout_streams, s); 103 LIST_REMOVE(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s); 207 LIST_PREPEND(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s); 210 if (s->server->notify_event_source) { 211 r = sd_event_source_set_enabled(s->server [all...] |
/systemd/src/journal-remote/ |
H A D | journal-remote-write.h | 43 RemoteServer *server; member in struct:Writer 51 Writer* writer_new(RemoteServer* server);
|
H A D | journal-remote-write.c | 68 Writer* writer_new(RemoteServer *server) { argument 84 w->server = server; 98 if (w->server && w->hashmap_key) 99 hashmap_remove(w->server->writers, w->hashmap_key); 147 if (w->server) 148 w->server->event_count += 1; 165 if (w->server) 166 w->server->event_count += 1;
|
H A D | journal-remote.c | 288 static RemoteServer *server; variable 464 r = get_writer(server, hostname, &writer); 613 if (server->check_trust) { 845 assert(server == NULL); 846 server = s; 1065 remove_source(server, fd); 1079 r = handle_raw_source(event, source->fd, EPOLLIN, server); 1099 r = handle_raw_source(event, fd, EPOLLIN, server); 1112 return handle_raw_source(event, source->fd, EPOLLIN, server);
|
/systemd/src/libsystemd/sd-bus/ |
H A D | test-bus-server.c | 41 static void *server(void *p) { function 172 r = pthread_create(&s, NULL, server, &c);
|
H A D | test-bus-chat.c | 78 log_error_errno(r, "Failed to get server ID: %m"); 126 static int server(sd_bus *bus) { function 542 r = server(bus);
|
H A D | test-bus-benchmark.c | 43 static void server(sd_bus *b, size_t *result) { function 57 if (sd_bus_message_is_method_call(m, "benchmark.server", "Ping")) 59 else if (sd_bus_message_is_method_call(m, "benchmark.server", "Work")) { 68 } else if (sd_bus_message_is_method_call(m, "benchmark.server", "Exit")) { 84 assert_se(sd_bus_message_new_method_call(b, &m, server_name, "/", "benchmark.server", "Work") >= 0); 107 r = sd_bus_call_method(b, server_name, "/", "benchmark.server", "Ping", NULL, NULL, NULL); 159 assert_se(sd_bus_message_new_method_call(b, &x, server_name, "/", "benchmark.server", "Exit") >= 0); 189 r = sd_bus_call_method(b, server_name, "/", "benchmark.server", "Ping", NULL, NULL, NULL); 236 assert_se(sd_bus_message_new_method_call(b, &x, server_name, "/", "benchmark.server", "Exit") >= 0); 360 server( [all...] |
H A D | test-bus-objects.c | 240 static void *server(void *p) { function 264 log_error("Entering event loop on server"); 535 r = pthread_create(&s, NULL, server, &c);
|
/systemd/src/initctl/ |
H A D | initctl.c | 58 Server *server; member in struct:Fifo 220 request_process(f->server, &f->buffer); 230 if (f->server) { 231 assert(f->server->n_fifos > 0); 232 f->server->n_fifos--; 233 LIST_REMOVE(fifo, f->server->fifos, f); 237 if (f->server) 238 epoll_ctl(f->server->epoll_fd, EPOLL_CTL_DEL, f->fd, NULL); 316 f->server = s; 358 Server server; local [all...] |
/systemd/src/resolve/ |
H A D | resolved-link.c | 577 log_info("Switching to DNS server %s for interface %s.", dns_server_string(s), l->name); 604 * list only if this server is actually still linked. */ 623 DnsServer *server; local 630 server = link_get_dns_server(l); 631 if (server) 632 return dns_server_dnssec_supported(server);
|
H A D | resolved-dns-scope.c | 303 DnsServer *server, 314 if (server) { 318 sa.sa.sa_family = server->family; 319 if (server->family == AF_INET) { 321 sa.in.sin_addr = server->address.in; 323 } else if (server->family == AF_INET6) { 325 sa.in6.sin6_addr = server->address.in6; 397 int dns_scope_socket_udp(DnsScope *s, DnsServer *server, uint16_t port) { argument 398 return dns_scope_socket(s, SOCK_DGRAM, AF_UNSPEC, NULL, server, port); 401 int dns_scope_socket_tcp(DnsScope *s, int family, const union in_addr_union *address, DnsServer *server, uint16_ argument 298 dns_scope_socket( DnsScope *s, int type, int family, const union in_addr_union *address, DnsServer *server, uint16_t port) argument [all...] |
H A D | resolved-dns-server.c | 23 #include "resolved-dns-server.h" 99 assert_not_reached("Unknown server type"); 104 /* A new DNS server that isn't fallback is added and the one 147 /* This removes the specified server from the linked list of 148 * servers, but any server might still stay around if it has 224 assert_not_reached("Unknown server type"); 235 log_debug("Verified we get a response at feature level %s from DNS server %s.", 275 /* Remember the size of the largest UDP packet we received from a server, 307 /* Invoked whenever we get a FORMERR, SERVFAIL or NOTIMP rcode from a server. */ 405 log_info("Grace period over, resuming full feature set (%s) for DNS server 492 dns_server_adjust_opt(DnsServer *server, DnsPacket *packet, DnsServerFeatureLevel level) argument 520 dns_server_string(DnsServer *server) argument 529 dns_server_dnssec_supported(DnsServer *server) argument 550 dns_server_warn_downgrade(DnsServer *server) argument [all...] |
H A D | resolved-dns-transaction.h | 113 /* The active server */ 114 DnsServer *server; member in struct:DnsTransaction 116 /* The features of the DNS server at time of transaction start */
|
H A D | resolved-dns-transaction.c | 89 dns_server_unref(t->server); 300 "DNS_SERVER=%s", dns_server_string(t->server), 301 "DNS_SERVER_FEATURE_LEVEL=%s", dns_server_feature_level_to_string(t->server->possible_feature_level), 371 DnsServer *server; local 376 server = dns_scope_get_dns_server(t->scope); 377 if (!server) 380 t->current_feature_level = dns_server_possible_feature_level(server); 382 if (server == t->server) 385 dns_server_unref(t->server); [all...] |
H A D | resolved-manager.c | 1192 DnsServer *server; local 1201 server = manager_get_dns_server(m); 1202 if (server && !dns_server_dnssec_supported(server))
|
/systemd/src/libsystemd-network/ |
H A D | sd-dhcp-server.c | 23 #include "sd-dhcp-server.h" 27 #include "dhcp-server-internal.h" 36 /* configures the server's address and subnet, and optionally the pool's size and offset into the subnet 38 * moreover, the server's own address may be in the pool, and is in that case reserved in order not to 40 int sd_dhcp_server_configure_pool(sd_dhcp_server *server, struct in_addr *address, unsigned char prefixlen, uint32_t offset, uint32_t size) { argument 45 assert_return(server, -EINVAL); 49 assert_return(server->address == INADDR_ANY, -EBUSY); 57 /* the server address cannot be the subnet address */ 80 server->bound_leases = new0(DHCPLease*, size); 81 if (!server 97 sd_dhcp_server_is_running(sd_dhcp_server *server) argument 103 sd_dhcp_server_ref(sd_dhcp_server *server) argument 153 sd_dhcp_server_unref(sd_dhcp_server *server) argument 211 sd_dhcp_server_attach_event(sd_dhcp_server *server, sd_event *event, int priority) argument 231 sd_dhcp_server_detach_event(sd_dhcp_server *server) argument 239 sd_dhcp_server_get_event(sd_dhcp_server *server) argument 245 sd_dhcp_server_stop(sd_dhcp_server *server) argument 259 dhcp_server_send_unicast_raw(sd_dhcp_server *server, DHCPPacket *packet, size_t len) argument 283 dhcp_server_send_udp(sd_dhcp_server *server, be32_t destination, DHCPMessage *message, size_t len) argument 342 dhcp_server_send_packet(sd_dhcp_server *server, DHCPRequest *req, DHCPPacket *packet, int type, size_t optoffset) argument 410 server_message_init(sd_dhcp_server *server, DHCPPacket **ret, uint8_t type, size_t *_optoffset, DHCPRequest *req) argument 443 server_send_offer(sd_dhcp_server *server, DHCPRequest *req, be32_t address) argument 480 server_send_ack(sd_dhcp_server *server, DHCPRequest *req, be32_t address) argument 544 server_send_nak(sd_dhcp_server *server, DHCPRequest *req) argument 556 server_send_forcerenew(sd_dhcp_server *server, be32_t address, be32_t gateway, uint8_t chaddr[]) argument 648 ensure_sane_request(sd_dhcp_server *server, DHCPRequest *req, DHCPMessage *message) argument 682 get_pool_offset(sd_dhcp_server *server, be32_t requested_ip) argument 697 dhcp_server_handle_message(sd_dhcp_server *server, DHCPMessage *message, size_t length) argument 949 sd_dhcp_server *server = userdata; local 1001 sd_dhcp_server_start(sd_dhcp_server *server) argument 1046 sd_dhcp_server_forcerenew(sd_dhcp_server *server) argument 1071 sd_dhcp_server_set_timezone(sd_dhcp_server *server, const char *tz) argument 1087 sd_dhcp_server_set_max_lease_time(sd_dhcp_server *server, uint32_t t) argument 1097 sd_dhcp_server_set_default_lease_time(sd_dhcp_server *server, uint32_t t) argument 1107 sd_dhcp_server_set_dns(sd_dhcp_server *server, const struct in_addr dns[], unsigned n) argument 1133 sd_dhcp_server_set_ntp(sd_dhcp_server *server, const struct in_addr ntp[], unsigned n) argument [all...] |