Как использовать getaddrinfo_a для асинхронного разрешения с помощью glibc
-
09-06-2019 - |
Вопрос
Часто упускаемая из виду функция, которая не требует внешней библиотеки, но по сути не имеет никакой документации.
Решение
ОБНОВЛЕНИЕ (11 октября 2010 г.):На страницах руководства Linux теперь есть документация по getaddrinfo_a, вы можете найти ее здесь: http://www.kernel.org/doc/man-pages/online/pages/man3/getaddrinfo_a.3.html
В качестве отказа от ответственности я должен добавить, что я новичок в C, но не совсем новичок, поэтому могут быть ошибки или плохие методы кодирования, пожалуйста, поправьте меня (и моя грамматика тоже отстой).
Я лично не знал об этом, пока не наткнулся эта почта Адама Лэнгли, я приведу несколько фрагментов кода, чтобы проиллюстрировать его использование и прояснить некоторые вещи, которые могут быть не столь ясны при первом использовании.Преимущество использования этого метода заключается в том, что вы получаете данные, которые можно легко использовать в разъем(), слушать() и другие функции, и если все сделано правильно, вам не придется беспокоиться и об ipv4/v6.
Итак, начнем с основ, взятых из ссылки выше (вам понадобится ссылка на libanl (-lanl)):
Вот прототип функции:
int getaddrinfo_a(int mode, struct gaicb *list[], int ent,
struct sigevent *);
- А режим это либо GAI_WAIT (что, вероятно, не то, что вам нужно), либо GAI_NOWAIT для асинхронного поиска.
- А гейкб Аргумент принимает массив хостов для поиска с помощью ент аргумент, указывающий, сколько элементов имеет массив
- А Сигевент будет отвечать за указание функции, как нас следует уведомлять, подробнее об этом чуть позже.
Структура gaicb выглядит следующим образом:
struct gaicb {
const char *ar_name;
const char *ar_service;
const struct addrinfo *ar_request;
struct addrinfo *ar_result;
};
Если вы знакомы с getaddrinfo, то эти поля соответствуют им так:
int getaddrinfo(const char *node, const char *service,
const struct addrinfo *hints,
struct addrinfo **res);
Узел — это поле ar_name, служба — это порт, аргументhints соответствует элементу ar_request, а результат сохраняется в остальном.
Теперь вы указываете, как вы хотите получать уведомления через структуру sigevent:
struct sigevent {
sigval_t sigev_value;
int sigev_signo;
int sigev_notify;
void (*sigev_notify_function) (sigval_t);
pthread_addr_t *sigev_notify_attributes;
};
- Вы можете игнорировать уведомление, установив для _sigev_notify_ значение SIGEV_NONE.
- Вы можете активировать сигнал, установив для sigev_notify значение SIGEV_SIGNAL и sigev_signo для желаемого сигнала.Обратите внимание, что при использовании сигнала реального времени (СИГРТМИН-СИГРТМАКС, всегда используйте его с помощью макросов и дополнений СИГРТМИН+2 и т. д.) вы можете передать указатель или значение в члене sigev_value.sival_ptr или sigev_value.sival_int соответственно.
- Вы можете запросить обратный вызов в новом потоке, установив для sigev_notify значение SIGEV_NONE.
По сути, если вы хотите найти имя хоста, вы устанавливаете ar_name для хоста, а все остальное устанавливаете в значение НУЛЕВОЙ, если вы хотите подключиться к хосту, вы устанавливаете ar_name и ar_service, а если вы хотите создать сервер, вы указываете ar_service и поле ar_result.Вы, конечно, можете настроить член ar_request по своему усмотрению, посмотрите мужчина getaddrinfo для получения дополнительной информации.
Если у вас есть цикл событий с select/poll/epoll/kqueue, вы можете использовать сигналфд для удобства.Signalfd создает файловый дескриптор, в котором вы можете использовать обычные механизмы опроса событий, например:
#define _GNU_SOURCE //yes this will not be so standardish
#include <netdb.h>
#include <signal.h>
#include <sys/signalfd.h>
void signalfd_setup(void) {
int sfd;
sigset_t mask;
sigemptyset(&mask);
sigaddset(&mask, SIGRTMIN);
sigprocmask(SIG_BLOCK, &mask, NULL); //we block the signal
sfd = signalfd(-1, &mask, 0);
//add it to the event queue
}
void signalfd_read(int fd) {
ssize_t s;
struct signalfd_siginfo fdsi;
struct gaicb *host;
while((s = read(fd, &fdsi, sizeof(struct signalfd_siginfo))) > 0){
if (s != sizeof(struct signalfd_siginfo)) return; //thats bad
host = fdsi.ssi_ptr; //the pointer passed to the sigevent structure
//the result is in the host->ar_result member
create_server(host);
}
}
void create_server(struct gaicb *host) {
struct addrinfo *rp, *result;
int fd;
result = host->ar_result;
for(rp = result; rp != NULL; rp = rp->ai_next) {
fd = socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol);
bind(fd, rp->ai_addr, rp->ai_addrlen);
listen(fd, SOMAXCONN);
//error checks are missing!
freeaddrinfo(host->ar_request);
freeaddrinfo(result);
//you should free everything you put into the gaicb
}
}
int main(int argc, char *argv[]) {
struct gaicb *host;
struct addrinfo *hints;
struct sigevent sig;
host = calloc(1, sizeof(struct gaicb));
hints = calloc(1, sizeof(struct addrinfo));
hints->ai_family = AF_UNSPEC; //we dont care if its v4 or v6
hints->ai_socktype = SOCK_STREAM;
hints->ai_flags = AI_PASSIVE;
//every other field is NULL-d by calloc
host->ar_service = "8888"; //the port we will listen on
host->ar_request = hints;
sig.sigev_notify = SIGEV_SIGNAL;
sig.sigev_value.sival_ptr = host;
sig.sigev_signo = SIGRTMIN;
getaddrinfo_a(GAI_NOWAIT, &host, 1, &sig);
signalfd_setup();
//start your event loop
return 0;
}
Конечно, вы также можете использовать простой обработчик сигналов для этой задачи, посмотрите человек, подписавшийся для получения дополнительной информации.