Как использовать getaddrinfo_a для асинхронного разрешения с помощью glibc - PullRequest
Новая
       55

Как использовать getaddrinfo_a для асинхронного разрешения с помощью glibc

16 голосов
/ 12 сентября 2008

Часто пропускаемая функция, которая не требует внешней библиотеки, но в основном не имеет никакой документации.

1 Ответ

17 голосов
/ 12 сентября 2008

ОБНОВЛЕНИЕ (2010-10-11) : на man-страницах linux теперь есть документация getaddrinfo_a, вы можете найти ее здесь: http://www.kernel.org/doc/man-pages/online/pages/man3/getaddrinfo_a.3.html

В качестве отказа от ответственности я должен добавить, что я довольно новичок в C, но не совсем новичок, поэтому могут быть ошибки или плохие методы кодирования, пожалуйста, исправьте меня (и моя грамматика тоже отстой).

Я лично не знал об этом, пока не наткнулся на это сообщение Адама Лэнгли. Я приведу несколько фрагментов кода, чтобы проиллюстрировать его использование и прояснить некоторые вещи, которые могут быть не столь ясными. при первом использовании. Преимущество использования этого заключается в том, что вы возвращаете данные, легко используемые в socket () , listen () и других функциях, и если все сделано правильно, вам не придется беспокоиться о ipv4 / v6 либо.
Итак, чтобы начать с основ, как взято по ссылке выше (вам нужно будет ссылаться на libanl (-lanl)):
Вот прототип функции: 

int getaddrinfo_a(int mode, struct gaicb *list[], int ent, 
                  struct sigevent *);
  1. Режим - это либо GAI_WAIT (что, вероятно, не то, что вам нужно) и GAI_NOWAIT для асинхронных поисков
  2. Аргумент gaicb принимает массив хостов для поиска с аргументом ent , указывающим, сколько элементов в массиве
  3. sigevent будет отвечать за сообщение функции, как мы должны быть уведомлены, подробнее об этом в данный момент

Структура 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, service - порт, аргумент 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;
};
  1. Вы можете игнорировать уведомление, установив для _sigev_notify_ значение SIGEV_NONE
  2. Вы можете запустить сигнал, установив sigev_notify в SIGEV_SIGNAL и sigev_signo в нужный сигнал. Обратите внимание, что при использовании сигнала в реальном времени ( SIGRTMIN - SIGRTMAX , всегда используйте его с помощью макросов и добавив SIGRTMIN + 2 и т. Д.), Вы можете передавать его указатель или значение в sigev_value.sival_ptr или sigev_value.sival_int член respectivley
  3. Вы можете запросить обратный вызов в новом потоке, установив sigev_notify в SIGEV_NONE

В общем, если вы хотите найти имя хоста, вы устанавливаете ar_name для хоста и устанавливаете все остальное на NULL , если вы хотите подключиться к хосту, вы устанавливаете ar_name и ar_service, и если вы хотите чтобы создать сервер, вы указываете ar_service и поле ar_result. Конечно, вы можете настроить член ar_request для своего сердца, посмотрите man getaddrinfo для получения дополнительной информации.

Если у вас есть цикл обработки событий с select / poll / epoll / kqueue, вы можете использовать signalfd для удобства. 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;
}

Конечно, вы также можете использовать простой обработчик сигналов для этой работы, для получения дополнительной информации посмотрите man sigaction .

...