46 int avahi_netlink_work(AvahiNetlink *nl, int block) {  in avahi_netlink_work()  argument
55     assert(nl);  in avahi_netlink_work()
57     iov.iov_base = nl->buffer;  in avahi_netlink_work()
58     iov.iov_len = nl->buffer_length;  in avahi_netlink_work()
68     if ((bytes = recvmsg(nl->fd, &smsg, 0)) < 0) {  in avahi_netlink_work()
88     p = (struct nlmsghdr *) nl->buffer;  in avahi_netlink_work()
90     assert(nl->callback);  in avahi_netlink_work()
98         nl->callback(nl, p, nl->userdata);  in avahi_netlink_work()
105     AvahiNetlink *nl = userdata;  in socket_event()  local
108     assert(nl);  in socket_event()
109     assert(fd == nl->fd);  in socket_event()
111     avahi_netlink_work(nl, 0);  in socket_event()
114 …_new(const AvahiPoll *poll_api, uint32_t groups, void (*cb) (AvahiNetlink *nl, struct nlmsghdr *n,…  in avahi_netlink_new()  argument
118     AvahiNetlink *nl = NULL;  in avahi_netlink_new()  local
143     if (!(nl = avahi_new(AvahiNetlink, 1))) {  in avahi_netlink_new()
148     nl->poll_api = poll_api;  in avahi_netlink_new()
149     nl->fd = fd;  in avahi_netlink_new()
150     nl->seq = 0;  in avahi_netlink_new()
151     nl->callback = cb;  in avahi_netlink_new()
152     nl->userdata = userdata;  in avahi_netlink_new()
154     if (!(nl->buffer = avahi_new(uint8_t, nl->buffer_length = 64*1024))) {  in avahi_netlink_new()
159     if (!(nl->watch = poll_api->watch_new(poll_api, fd, AVAHI_WATCH_IN, socket_event, nl))) {  in avahi_netlink_new()
164     return nl;  in avahi_netlink_new()
171     if (nl) {  in avahi_netlink_new()
172         avahi_free(nl->buffer);  in avahi_netlink_new()
173         avahi_free(nl);  in avahi_netlink_new()
179 void avahi_netlink_free(AvahiNetlink *nl) {  in avahi_netlink_free()  argument
180     assert(nl);  in avahi_netlink_free()
182     if (nl->watch)  in avahi_netlink_free()
183         nl->poll_api->watch_free(nl->watch);  in avahi_netlink_free()
185     if (nl->fd >= 0)  in avahi_netlink_free()
186         close(nl->fd);  in avahi_netlink_free()
188     avahi_free(nl->buffer);  in avahi_netlink_free()
189     avahi_free(nl);  in avahi_netlink_free()
192 int avahi_netlink_send(AvahiNetlink *nl, struct nlmsghdr *m, unsigned *ret_seq) {  in avahi_netlink_send()  argument
193     assert(nl);  in avahi_netlink_send()
196     m->nlmsg_seq = nl->seq++;  in avahi_netlink_send()
199     if (send(nl->fd, m, m->nlmsg_len, 0) < 0) {  in avahi_netlink_send()