ノンブロッキングソケット

ノンブロッキングでUDPパケットの受信を待つサンプル

通常設定では、recv関数はデータが届くまでブロッキングします。 複数のソケットを扱うプログラムや、その他入力と併用するようなプログラムではブロックさせずにrecv関数を使いたい場合があります。 winsockでは、ioctlsocket関数にFIONBIOを渡すことにより、ブロッキング/ノンブロッキングの設定を行えます。

ノンブロッキング状態に設定したソケットでデータが無い時にrecvを行うとrecv関数はエラーを返します。 recv関数がエラーで返った時にWSAGetLastErrorを実行してエラー状態がWSAEWOULDBLOCKの時には、ただ単にデータが無いという事をあらわしています。

下記サンプルでは、データが無いときには「まだ来ない」と表示し、1秒間待つという処理をしています。 下記サンプルはUDPのポート12345番にデータを受信すると、終了します。 下記サンプルへのUDPでのデータ送信には、UDP送信サンプルで示した物をご利用ください。

#include <stdio.h>
#include <winsock2.h>

int
main()
{
 WSADATA wsaData;

 SOCKET sock;
 struct sockaddr_in addr;

 char buf[2048];

 WSAStartup(MAKEWORD(2,0), &wsaData);

 sock = socket(AF_INET, SOCK_DGRAM, 0);

 addr.sin_family = AF_INET;
 addr.sin_port = htons(12345);
 addr.sin_addr.S_un.S_addr = INADDR_ANY;

 bind(sock, (struct sockaddr *)&addr, sizeof(addr));

 // ここで、ノンブロッキングに設定しています。
 // val = 0でブロッキングモードに設定できます。
 // ソケットの初期設定はブロッキングモードです。
 u_long val=1;
 ioctlsocket(sock, FIONBIO, &val);

 int n;

 memset(buf, 0, sizeof(buf));
 while (1) {
	n = recv(sock, buf, sizeof(buf), 0);
	if (n < 1) {
		if (WSAGetLastError() == WSAEWOULDBLOCK) {
			// まだ来ない。
			printf("MADA KONAI\n");
		} else {
			printf("error : 0x%x\n", WSAGetLastError());
			break;
		}
	} else {
		printf("received data\n");
		printf("%s\n", buf);
		break;
	}

	// とりあえず一秒待ってみる
	Sleep(1000);
 }

 closesocket(sock);

 WSACleanup();

 return 0;
}

ioctlsocket関数の使い方はUDPとTCPで変わりません。 ここでは、説明のためにUDPソケットを利用しましたが、ioctlsocketはTCPソケットでも利用できます。

• winsockプログラミング記事一覧
• Windowsでのネットワーク情報取得と設定用のIP Helper API記事一覧