1

これは、スレッドごとに 1 つのクライアントを持つ tcp サーバー クライアント メッセージ サービスに含まれる .c ファイルの一部です。サーバースレッド内でselectを使用して、新しい着信接続またはバッファーに書き込まれるデータを処理したいのですが、問題は、クライアントとサーバーのそれを行うためにソケットファイル記述子が必要なことです。

コードのこの部分では、サーバーのソケット記述子は s->sd 内にありますが、(socket) を返すため、この関数の外でアクセスできるようです。

私に何ができる？(読みやすいようにコードの大部分は省略されています)

#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);
4

1 に答える 1

2

MySocket::sdで使用する必要のある記述子ですselect()。とで使用できるsocket()とリターンソケット記述子の両方。の代わりにを返すように変更すると、メインサーバースレッドはサーバーのソケット記述子にアクセスして、着信接続を検出するために渡すことができます。例：accept()select()tcp_passive_open()MySocket*Socketselect()

#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()サーバーソケットで保留中のインバウンド接続接続を報告したら、呼び出しaccept()て接続を受け入れ、そのソケット記述子を取得します。次に、別の接続を割り当てることができますMySocket。

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

次に、そのための新しいスレッドを作成できます。そのスレッドは、必要に応じて、その接続でインバウンドデータを検出するためにMySocket呼び出すことができます。select()

于 2012-05-28T21:40:54.510 に答える