q->state = state;
if (q->question_utf8 && state == DNS_TRANSACTION_SUCCESS && set_size(q->manager->varlink_subscription) > 0)
- (void) send_dns_notification(q->manager, q->answer, dns_question_first_name(q->question_utf8));
+ (void) manager_monitor_send(q->manager, q->answer, dns_question_first_name(q->question_utf8));
dns_query_stop(q);
if (q->complete)
return sendmsg_loop(fd, &mh, 0);
}
-int send_dns_notification(Manager *m, DnsAnswer *answer, const char *query_name) {
+int manager_monitor_send(Manager *m, DnsAnswer *answer, const char *query_name) {
_cleanup_free_ char *normalized = NULL;
DnsResourceRecord *rr;
int ifindex, r;
Hashmap *polkit_registry;
VarlinkServer *varlink_server;
- VarlinkServer *varlink_notification_server;
+ VarlinkServer *varlink_monitor_server;
Set *varlink_subscription;
uint32_t manager_find_mtu(Manager *m);
-int send_dns_notification(Manager *m, DnsAnswer *answer, const char *query_name);
+int manager_monitor_send(Manager *m, DnsAnswer *answer, const char *query_name);
int manager_write(Manager *m, int fd, DnsPacket *p);
int manager_send(Manager *m, int fd, int ifindex, int family, const union in_addr_union *destination, uint16_t port, const union in_addr_union *source, DnsPacket *p);
return 1;
}
-static int varlink_notification_server_init(Manager *m) {
+static int varlink_monitor_server_init(Manager *m) {
_cleanup_(varlink_server_unrefp) VarlinkServer *server = NULL;
int r;
assert(m);
- if (!m->enable_varlink_notifications || m->varlink_notification_server)
+ if (!m->enable_varlink_notifications || m->varlink_monitor_server)
return 0;
r = varlink_server_new(&server, VARLINK_SERVER_ROOT_ONLY);
if (r < 0)
return log_error_errno(r, "Failed to attach varlink connection to event loop: %m");
- m->varlink_notification_server = TAKE_PTR(server);
+ m->varlink_monitor_server = TAKE_PTR(server);
return 0;
}
m->varlink_server = TAKE_PTR(s);
- r = varlink_notification_server_init(m);
+ r = varlink_monitor_server_init(m);
if (r < 0)
return r;
assert(m);
m->varlink_server = varlink_server_unref(m->varlink_server);
- m->varlink_notification_server = varlink_server_unref(m->varlink_notification_server);
+ m->varlink_monitor_server = varlink_server_unref(m->varlink_monitor_server);
}