【问题标题】:How to use getaddrinfo_a to do async resolve with glibc如何使用 getaddrinfo_a 与 glibc 进行异步解析
【发布时间】:2010-09-08 15:42:40
【问题描述】:

一个经常被忽视的函数,它不需要外部库,但基本上没有任何文档。

【问题讨论】:

  • 我看不出这个函数有什么用处。只需使用执行getaddrinfo 的函数调用pthread_create,然后再调用您将在回调中放入的任何代码,这似乎比为getaddrinfo_a 设置所有控制结构要容易得多。
  • 对于什么是“更简单”的方法来实现这个功能,我们肯定有不同的看法,处理线程对我来说并不容易
  • 这里处理线程只是几行代码,实际上getaddrinfo_a内部无论如何都使用线程...
  • 取决于您是只针对一个地址还是针对多个地址进行操作
  • getaddrinfo_a 是可取消的,线程中的同步 getaddrinfo 调用是不可取消的。

标签: c dns glibc getaddrinfo-a


【解决方案1】:

更新 (2010-10-11):linux 手册页现在有 getaddrinfo_a 的文档,您可以在这里找到它:http://www.kernel.org/doc/man-pages/online/pages/man3/getaddrinfo_a.3.html

作为免责声明,我应该补充一点,我是 C 的新手,但并不完全是新手,所以可能存在错误或错误的编码习惯,请纠正我(我的语法也很烂)。

我个人并不知道它,直到我遇到 Adam Langley 的 this post,我将给出一些代码 sn-ps 来说明它的用法并澄清一些在第一次使用时可能不太清楚的事情.使用它的好处是您可以轻松获取 socket()listen() 和其他函数中可用的数据,如果操作正确,您将不必担心关于 ipv4/v6。
因此,从上面的链接中获取的基础知识开始(您需要链接到 libanl (-lanl)):
这是函数原型:

int getaddrinfo_a(int mode, struct gaicb *list[], int ent, 
                  struct sigevent *);
  1. mode 是 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);

node为ar_name字段,service为port,hints参数对应ar_request成员,结果存放在rest中。
现在您指定希望通过 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 成员各自的指针或值
  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 了解更多信息。

【讨论】:

  • 如果这回答了您的问题(似乎您知道如何使用它),那么您应该将其标记为“已接受”答案。此外,您可以将您在另一个答案中的句子合并到这个句子中,这样信息就集中在一个地方。
  • 在我写答案时已经这样做了,不知道为什么它会恢复。
  • “亚当·兰格的这篇文章”的链接已损坏
猜你喜欢
  • 2011-06-08
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2016-08-23
相关资源
最近更新 更多