pthread和UDP

Question

我刚开始使用pthread库，我想并行执行几次这样的函数：

while(true) {
    //Part A
    //do several stuff
    //End of Part A

    //Part B
    //do other stuffs
    //End of Part B
}

我可以通过点击pthread_create()很容易地做到这一点。问题是，主程序似乎在执行B部分之前切换线程。结果，我看到A部分一遍又一遍地执行，但从来没有执行过B部分。有人能帮助我吗？

一些实际的代码=>

#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#include <string.h>
#include <netinet/in.h>
#include <netdb.h>
#include <pthread.h>

#define error(msg) \
        perror(msg); \
        exit(EXIT_FAILURE)


//Declarations
int mastersocket;
struct sockaddr_in addr;
struct hostent *fromhost, *tohost;
int nthread=5;
int  decdomain=13;
long serveurdns=0x0101a8c0;

static void * test(void * p_data) {

    while(1) {
        printf("hello\n");
    }
    return NULL;
}

int main(int argc, char **argv) {

        int k, l;
        pthread_t idt[5];

    //Assignation, mallocs
    //Strings

    //Appel a socket
    if( (mastersocket=socket(PF_INET, SOCK_DGRAM, 0)) < 0 ) {
        error("socket");
    }

    //Configuration de sockaddr pour l'appel a bind
    addr.sin_family=AF_INET;
    addr.sin_addr.s_addr=htonl(INADDR_ANY);
    addr.sin_port=htons(53);

    //Appel a bind
    if( (bind(mastersocket, (struct sockaddr *)&addr, sizeof(addr))) < 0 ) {
        error("bind");
    }

    for(k=0; k<nthread; k++) {

        pthread_create(&idt[k], NULL, mainbis, (void *)mastersocket);

    }
    mainbis((void *)mastersocket);

    return 0;

}

static void * mainbis(void * p_data) {

    int socketh= (int) p_data;
    int found=0, len, cc;
    char *buf, *curfish;
    struct sockaddr_in *from, *to;
    u_long fromaddr, toaddr;
    int lenbuf=5000;

    buf=(char *)malloc(lenbuf);
    curfish=(char *)malloc(100);

    len=sizeof(struct sockaddr_in);
    to=(struct sockaddr_in *)malloc(len);
    from=(struct sockaddr_in *)malloc(len);
    //Structure sockaddr du serveur DNS vers lequel on redirige les requete
    to->sin_family=AF_INET; 
    to->sin_addr.s_addr=serveurdns;
    to->sin_port=htons(53);

    //Let's go
    while(1) {

        found=0;
        curfish=NULL;
        //Reception des requetes
        if((cc=recvfrom(socketh, buf, lenbuf, 0, (struct sockaddr *)from, &len))<0) {
            error("recv");
        }
        buf[cc]='\0';

        //Identification de l'host appelant
        //fromaddr=(*from).sin_addr.s_addr;
        //fromhost=gethostbyaddr((void *)&fromaddr, sizeof(fromaddr), AF_INET);

        //Sortie utilisateur
        printf("\n\n--   New Request From $$ on Port ... Domain = %s ||\n--  ***********************\n", buf+13);

        curfish=somefunction();
        if( curfish!=NULL ) {

            found=1;

        }

        if(sendto(socketh, buf, cc, 0, (struct sockaddr *)to, len)<0) {
            error("send");
        }

        if((cc=recvfrom(socketh, buf, lenbuf, 0, (struct sockaddr *)to, &len))<0) {
            error("recv");
        }
        buf[cc]='\0';

        printf("\n\n--   New Response From $$ on Port ||\n--  ***********************\n");

        if(found) {

            buf[cc-1]=0x81;
            buf[cc-2]=0x2;
            buf[cc-3]=0xa8;
            buf[cc-4]=0xc0;

        }

        if(sendto(socketh, buf, cc, 0, (struct sockaddr *)from, len)<0) {
            error("send");
        }

    }
    return NULL;

}

这是一个用于DNS请求的UDP重定向器，当我启动并尝试使用dig时，例如，我的程序总是输出"New Request...“字符串，但决不是"New Response...“1和dig永远得不到响应。

Jules

Answer 1

你的代码不能工作。您绑定了一个套接字mastersocket，并使用此套接字创建了多个线程。

这本身是可以的，但是mainbis()内部的逻辑假设它将读取对它发送的内容的回复。这可能不会发生，回复可能会被您创建的任何其他线程读取，这些线程正在阻塞同一套接字上的recvfrom，逻辑就会崩溃。

在每个线程中创建一个新的套接字，用于与真实的dns服务器通信，并且只使用socketh与客户端通信。