UDP sendto()가 "invalid user space address"오류를 나타냅니다.

Question

업데이트 : 문제가있는 함수에서 하드 코딩 된 struct를 초기화 했는데도 오류가 발생했습니다.

void sendjoin(unsigned int ipaddress, unsigned short port, unsigned short preferredID){ 
    printf("Sending join-request...\n"); 
    char msg[9]; 
    memset(msg, 0, 9); 
    msg[0] = JOIN_MASK | INTERN_MASK; 
    ipaddress = ipaddress; 
    port = port; 
    preferredID = htons(preferredID); 
    memcpy(&msg[1], &ipaddress, 4); 
    memcpy(&msg[5], &port, 2); 
    memcpy(&msg[7], &preferredID, 2); 

    errno = 0; 

    //printMSG((void *)&succAddr, sizeof(succAddr), 0); 
    socklen_t addrlen = sizeof(struct sockaddr_in); 
    struct sockaddr_in *temp = (struct sockaddr_in *) malloc(sizeof(struct sockaddr_in)); 
    temp->sin_family = AF_INET; 
    temp->sin_port = htons((short)8888); 
    temp->sin_addr.s_addr = htonl(16777343); 

    if(0 > sendto(sock, msg, 9, 0, (struct sockaddr *)temp, addrlen)){ 
     perror("Error while sending a packet.\n"); 
     switch(errno){ 
      case EFAULT: 
       printf("Invalid user space address.\n"); 
       break; 
      case EAGAIN: 
       printf("Something with blocking.\n"); 
       break; 
      case EBADF: 
       printf("Invalid descriptor.\n"); 
       break; 
      case EINVAL: 
       printf("Invalid argument.\n"); 
       break; 
      case EDESTADDRREQ: 
       printf("No Peer address.\n"); 
       break; 
      case EISCONN: 
       printf("Connection mode socket.\n"); 
       break; 
      case ENOTSOCK: 
       printf("The given socket is not a socket.\n"); 
       break; 
      case ENOTCONN: 
       printf("No Target.\n"); 
       break; 
      case ENOBUFS: 
       printf("Network output is full.\n"); 
       break; 
      default: 
       printf("No spezific error.\n"); 
     } 
     exit(1); 
    } 
    printf("Send to: %u %u\n", ntohl(succAddr.sin_addr.s_addr), ntohs(succAddr.sin_port)); 
} 

이 분산 해시 테이블 서버를 쓰고 있습니다. 그것은 아주 간단한 버전입니다. 나는 방금 처음에 패키지를 청취하는 서버를 가지고 있습니다. 다른 사람은 첫 번째 사람의 dht 네트워크에 참여하려고합니다. 그래서 나는 포트 번호, 패밀리 AF_INET, IP 주소로 글로벌 struct sockaddr_in을 채우고있다.

필자는 "localhost"문자열을 inet 구조체로 변환하는 inet_ntop() 함수를 사용합니다. 나중에 sendto()를 사용하여 dht 네트워크와 통신을 시작합니다. 그러나 "잘못된 사용자 공간 주소"오류가 발생합니다.

sendto()는 열린 소켓 (open serversocket!), 초기화 된 버퍼, 그의 길이, sockaddr_in 구조체 주소 및 길이를 가져옵니다.

꽤 코드입니다. 일부 사용되지 않는 함수를 삭제하고 변수가 사용되는 함수 만 포함하려고했습니다. main()에서 세 가지 기능을 볼 수 있습니다. 하나는 정말 흥미 롭지 않은 checkarguments()입니다. 그런 다음 setsocket() 함수를 사용하여 사용할 서버 소켓을 얻습니다. 이 함수의 끝에서 나는 이것의 선행 및 후속 서버에 대한 IP 주소, 포트 및 ID를 채운다. 그리고 dht 네트워크에 연결하려고하는 letsgo() 함수가 있습니다. sendjoin() 함수에 대한 호출은 항상 succAddr로 송신되기 때문에 전역 struct sockaddr_in succAddr을 알려진 dht 노드의 주소로 채 웁니다. 그리고 sendjoin()에서 succAddr로 보내려고하지만 실패합니다. 그리고 나는 이유를 모른다. 내 succAddr이 초기화되고 유효하지 않은 사용자 공간을 가리켜 야합니다.

Pls는 도움말 : 여기

내 코드입니다 :

//================================= 
//=Variablen======================= 
//================================= 

unsigned short myID = 0; 
char *myIP= NULL; 
char *myPORT = NULL; 
char *nodeIP = NULL; 
char *nodePORT = NULL; 

int sock = 0; 
struct sockaddr_in preAddr; 
unsigned short preID = 0; 
int preknown = 1; 
struct sockaddr_in succAddr; 
unsigned short succID = 0; 

char packet[PACKETSIZE]; 
struct sockaddr_storage sender; 
socklen_t sendersize = sizeof sender; 
int tablefunctionstarted = 0; 

char INTERN_MASK = 0b10000000; 
char STABILIZE_MASK = 0b00000100; 
char NOTIFY_MASK = 0b00000010; 
char JOIN_MASK = 0b00000001; 
char SNJ_MASK = 0b00000111; 

//================================= 
//=Functions======================= 
//================================= 


void setSocket(); 
int checkarguments(int argc, char **argv); 
int letsgo(); 
void printMSG(char *msg, int msglength, int plain); 
void handleintern(unsigned long msglength); 
void handleoutside(unsigned long msglength); 
void sendjoin(unsigned int ipaddress,unsigned short port, unsigned short preferredID); 
void sendnotify(unsigned int ipaddress,unsigned short port, unsigned short preferredID); 
void sendstabilize(); 

int main(int argc, char **argv){ 
    printf("Starting server...\n"); 
    int einklinken = checkarguments(argc, argv); 
    setSocket(); 
    if(einklinken) if(letsgo()){ perror("Problem while joining DHT network!\n"); exit(2);}; 

    /* 
    //Hauptpacketannahmeverarbeitungsschleife 
    long check = 0; 
    while(1){ 
     printf("Server is waiting for packets... \n"); 
     if(-1 == (check = recvfrom(sock, packet, PACKETSIZE, 0, (struct sockaddr *)&sender, &sendersize))){ 
      perror("Error with new packet!\n"); 
      exit(2); 
     } 
     printf("Found packet... \n"); 
     //printMSG(packet, check, 1); 

     if(0 != (packet[0] & INTERN_MASK)) handleintern(check); 
     else handleoutside(check); 
    } 
    */ 
} 


int checkarguments(int argc, char **argv){ 
    if(argc < 3){ fprintf(stderr,"Too few arguments! \nUsage: %s myip myport\nOptions:\n-id preferredID (Your preferred id in the DHT network.)\n-new ip port (IP address and port of a DHT network node.)", argv[0]); exit(1);} 
    if(argc > 8){ fprintf(stderr,"Too many arguments! \nUsage: %s myip myport\nOptions:\n-id preferredID (Your preferred id in the DHT network.)\n-new ip port (IP address and port of a DHT network node.)", argv[0]); exit(1);} 

    /* printf("Arguments:\n"); 
    for(int i = 0; i < argc; ++i){ 
     printf("%s\n", argv[i]); 
    } */ 
    printf("Parsing arguments...\n"); 
    myIP = argv[1]; 
    myPORT = argv[2]; 
    printf("My ip: %s\n", myIP); 
    printf("My port: %s\n", myPORT); 

    int newNode = 0; 
    int count = 3; 
    while(argc > count){ 
     if(argv[count][0]!='-'){fprintf(stderr,"Wrong usage! \nUsage: %s myip myport\nOptions:\n-id preferredID (Your preferred id in the DHT network.)\n-new ip port (IP address and port of a DHT network node.)", argv[0]); exit(1);} 
     if(argv[count][1]=='i'){ 
      ++count; 
      errno = 0; 
      long value = 0; 
      value = strtol(argv[count++], NULL, 10); 
      switch(errno){ 
       case ERANGE: 
        printf("The ID could not be represented.\n"); 
        exit(1); 
       case EINVAL: 
        printf("Unsupported base/radix.\n"); 
        exit(1); 
      } 
      if(value > 65536){ perror("Your desired ID is over the max value of 65536!\n"); exit(1);} 
      myID = (short) value; 
      printf("My id: %u\n", myID); 
     } 
     else if(argv[count][1]=='n'){ 
      ++count; 
      nodeIP = argv[count++]; 
      nodePORT = argv[count++]; 
      printf("The nodes ip: %s\n", nodeIP); 
      printf("The nodes port: %s\n", nodePORT); 
      newNode = 1; 
     } 
    } 

    printf("Finished parsing arguments.\n"); 
    return newNode; 
} 


void setSocket(){ 

    printf("Configuring the socket...\n"); 
    struct addrinfo hints, *locations, *p; 
    int yes=1; 

    memset(&hints, 0, sizeof hints); 
    hints.ai_family = AF_UNSPEC; 
    hints.ai_socktype = SOCK_DGRAM; 
    hints.ai_flags = AI_PASSIVE; 

    int rv = getaddrinfo(NULL, myPORT, &hints, &locations); 

    if(rv != 0){ 
     fprintf(stderr, "getaddrinfo threw an error! Maybe your port is used?\n"); 
     exit(1); 
    } 

    for(p = locations; p!=NULL; p=p->ai_next){ 

     sock = socket(p->ai_family, p->ai_socktype, p->ai_protocol); 
     if(sock == -1){perror("SocketError");continue;} 

     if(setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1){perror("Can't clean socket!\n"); exit(1);} 

     if(bind(sock, p->ai_addr, p->ai_addrlen) == -1){perror("BindError");close(sock);continue;} 

     break; 
    } 

    if(p==NULL){ 
     perror("Failed to bind!\n"); 
     exit(2); 
    } 

    int check = 0; 
    if(-1 == (check = inet_pton(AF_INET, myIP, &(preAddr.sin_addr)))){ perror("Wrong ip format!\n"); exit(1);} 
    if(-1 == (check = inet_pton(AF_INET, myIP, &(succAddr.sin_addr)))){ perror("Wrong ip format!\n"); exit(1);} 
    memcpy(&(succAddr.sin_port), &(((struct sockaddr_in *)p->ai_addr)->sin_port), 2); 
    memcpy(&(preAddr.sin_port), &(((struct sockaddr_in *)p->ai_addr)->sin_port), 2); 
    memset(preAddr.sin_zero, 0, 8); 
    memset(succAddr.sin_zero, 0, 8); 
    preID = myID; 
    succID = myID; 

    printf("Finished configuring the socket.\n"); 

    freeaddrinfo(locations); 
} 


int letsgo(){ 
    printf("Trying to join an existent DHT network...\n"); 
    preknown = 0; 


    int check = 0; 
    succAddr.sin_family = AF_INET; 
    if(-1 == (check = inet_pton(AF_INET, nodeIP, &(succAddr.sin_addr)))){ perror("Wrong ip format!\n"); exit(1);} 
    errno = 0; 
    long value = 0; 
    value = strtol(nodePORT, NULL, 10); 
    switch(errno){ 
     case ERANGE: 
      printf("The node port could not be represented.\n"); 
      exit(1); 
     case EINVAL: 
      printf("Unsupported base/radix.\n"); 
      exit(1); 
    } 
    if(value > 65536){ perror("Your node port is over the max value of 65536!\n"); exit(1);} 
    succAddr.sin_port = htons((short) value); 

    unsigned int ipaddress = preAddr.sin_addr.s_addr; 
    unsigned short port = preAddr.sin_port; 
    unsigned short preferredID = 0; 

    sendjoin(ipaddress, port, myID); 

    while(1){ 
     printf("Wait for notify answer... \n"); 
     if(-1 == (check = recvfrom(sock, packet, PACKETSIZE, 0, (struct sockaddr *)&sender, &sendersize))){ 
      perror("Error with new packet!\n"); 
      exit(2); 
     } 
     printf("Got answer... \n"); 

     if(0 == (packet[0] & INTERN_MASK)){ printf("Can't understand the packet.\n"); continue;} 
     if(0 == (packet[0] & NOTIFY_MASK || check < 8)){ printf("Not a notify packet.\n"); continue;} 

     memcpy(&preferredID, &packet[7], 2); 
     preferredID = ntohs(preferredID); 
     if(preferredID > TABLE_LENGTH){ perror("Preferred id is too big!\n"); continue;} 
     memcpy(&ipaddress, &packet[1], 4); 
     memcpy(&port, &packet[5], 2); 

     succAddr.sin_addr.s_addr = ipaddress; 
     succAddr.sin_port = port; 
     succID = preferredID; 
     break; 
    } 


    return 0; 
} 


void sendjoin(unsigned int ipaddress, unsigned short port, unsigned short preferredID){ 
    printf("Sending join-request...\n"); 
    char msg[9]; 
    memset(&msg, 0, 9); 
    msg[0] = JOIN_MASK | INTERN_MASK; 
    ipaddress = ipaddress; 
    port = port; 
    preferredID = htons(preferredID); 
    memcpy(&msg[1], &ipaddress, 4); 
    memcpy(&msg[5], &port, 2); 
    memcpy(&msg[7], &preferredID, 2); 

    errno = 0; 

    //printMSG((void *)&succAddr, sizeof(succAddr), 0); 
    socklen_t addrlen = sizeof(struct sockaddr_in); 

    if(0 > sendto(sock, msg, 9, 0, (struct sockaddr *)&succAddr, addrlen)){ 
     perror("Error while sending a packet.\n"); 
     switch(errno){ 
      case EFAULT: 
       printf("Invalid user space address.\n"); 
       break; 
      case EAGAIN: 
       printf("Something with blocking.\n"); 
       break; 
      case EBADF: 
       printf("Invalid descriptor.\n"); 
       break; 
      case EINVAL: 
       printf("Invalid argument.\n"); 
       break; 
      case EDESTADDRREQ: 
       printf("No Peer address.\n"); 
       break; 
      case EISCONN: 
       printf("Connection mode socket.\n"); 
       break; 
      case ENOTSOCK: 
       printf("The given socket is not a socket.\n"); 
       break; 
      case ENOTCONN: 
       printf("No Target.\n"); 
       break; 
      case ENOBUFS: 
       printf("Network output is full.\n"); 
       break; 
      default: 
       printf("No spezific error.\n"); 
     } 
     exit(1); 
    } 
    printf("Send to: %u %u\n", ntohl(succAddr.sin_addr.s_addr), ntohs(succAddr.sin_port)); 
} 

Answer 1

이 줄 :

socklen_t addrlen = sizeof(struct sockaddr); 

요구가 될 :

socklen_t addrlen = sizeof(struct sockaddr_in);