소켓의 파일 디스크립터에 접근하기

Question

이것은 쓰레드 당 하나의 클라이언트를 가진 tcp 서버 - 클라이언트 메시지 서비스에 포함 된 .c 파일의 일부이다. 서버 스레드 내부에서 select를 사용하여 새로운 들어오는 연결이나 버퍼에 쓰여지는 데이터를 처리하고 싶지만 문제는 클라이언트와 서버의 소켓 파일 설명자를 필요로한다는 것입니다.

코드의이 부분에서는 서버의 소켓 설명자가 s-> sd 안에 있지만이 함수 외부에서 (소켓)을 반환하기 때문에 액세스 할 수 있습니다.

어떻게해야합니까?

#include <sys/types.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 

typedef struct { 
    int sd; //id of the socket?? 
    char *ip_addr; 
    int port; 
    } MySocket; 

Socket tcp_passive_open(int port) 
{                      
    MySocket *s = (MySocket *)malloc(sizeof(MySocket)); 
    struct sockaddr_in addr; 
    s->sd = socket(PROTOCOLFAMILY, TYPE, PROTOCOL); 

    memset(&addr, 0, sizeof(struct sockaddr_in)); 
    addr.sin_family = PROTOCOLFAMILY; 
    addr.sin_addr.s_addr = htonl(INADDR_ANY); 
    addr.sin_port = htons(port); 

    if (bind(s->sd, (struct sockaddr *)&addr, sizeof(addr)) != 0) { 
    die("tcp_open_server failed(): bind() failed"); 
    } 

    s->port = port; 
    s->ip_addr = NULL; //INADDR_ANY ... 
    return (Socket)s; 
} 

주 (코드의 대부분은 그것을 읽을 수 있도록 생략) :

Socket server = tcp_passive_open(PORT); 
FD_SET(SOCKETDESCRIPTOR_SERVER??,&master_socketDescriptors); 

Answer 1

MySocket::sd는 select()와 함께 사용하는 데 필요한 설명이다. socket() 및 accept()은 select()과 함께 사용할 수있는 소켓 설명자를 반환합니다. 예를 들어, 다음 주 서버 스레드가 들어오는 연결을 검출 select()에 전달할 서버의 소켓 기술자에 액세스 할 수 있습니다하는 MySocket* 대신 Socket의를 반환하는 tcp_passive_open() 변경 :

#include <sys/types.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 

typedef struct { 
    int sd; 
    char *ip_addr; 
    int port; 
} MySocket; 

MySocket* tcp_passive_open(int port) { 
    MySocket *s = (MySocket *)malloc(sizeof(MySocket)); 
    if (s == NULL) { 
     die("tcp_open_server failed(): malloc() failed"); 
    } 

    s->sd = socket(PROTOCOLFAMILY, TYPE, PROTOCOL); 
    if (s->sd == -1) { 
     die("tcp_open_server failed(): socket() failed"); 
    } 

    struct sockaddr_in addr; 
    memset(&addr, 0, sizeof(struct sockaddr_in)); 
    addr.sin_family = PROTOCOLFAMILY; 
    addr.sin_addr.s_addr = htonl(INADDR_ANY); 
    addr.sin_port = htons(port); 

    if (bind(s->sd, (struct sockaddr *)&addr, sizeof(addr)) != 0) { 
     die("tcp_open_server failed(): bind() failed"); 
    } 

    s->port = port; 
    s->ip_addr = NULL; //INADDR_ANY ... 
    return s; 
} 

합니다. 이후

MySocket* server = tcp_passive_open(PORT); 
FD_SET(server->sd, &master_socketDescriptors); 

때 select() 보고서 서버 소켓에 보류중인 인바운드 연결 연결, 당신은 그것을위한 별도의 MySocket 할당 할 수있는 연결을 받아 소켓 기술자를 얻기 위해 accept() 전화 :

int sd = accept(server->sd, ...); 
if (sd != -1) { 
    MySocket *client = (MySocket*) malloc(sizeof(MySocket)); 
    client->sd = sd; 
    ... 
} 

을

그런 다음 MySocket에 대한 새 스레드를 만들 수 있으며 해당 스레드는 select()을 호출하여 필요에 따라 해당 연결의 인바운드 데이터를 감지 할 수 있습니다.