ruby-dev

岡と申します。

Windows版Ruby (mingwおよびmswin) で、Socket を利用したサーバーを
作ろうとして気づいたのですが、Socket::open によって作成されたソケ
ットに対して、bind, connect, listen, getsockopt, setsockopt を
実行しようとすると、

irb(main):001:0> require 'socket'
true
irb(main):002:0> s = Socket.open(Socket::AF_INET, Socket::SOCK_STREAM, 0)
#<Socket:0x2afd948>
irb(main):003:0> a =  [Socket::AF_INET, 9876, 0, ""].pack("snNa8")
"\002\000&\224\000\000\000\000\000\000\000\000\000\000\000\000"
irb(main):004:0> s.bind(a)
Errno::E10038: ソケット以外のものに対して操作を実行しようとしました。 - "bind(2)"

というようなエラーになります。

win32.c を調べてみると、これらのメソッドの下請けである mybind など、
myxxxx という関数が、渡ってきた SOCKET 引数をそのまま使って、
Winsock の xxxx を呼んでいるのが原因のようです。

mybind には、TCPServer::open の内部から呼ばれるときは、生のソケッ
トハンドルがそのまま渡されますが、Socket#bind からは、rb_fdopen
(Winの場合は、_open_osfhandle) によって関連付けされた別のハンドル
が渡ってきます。

ということで、渡ってきた SOCKET引数が、本当にソケットハンドルかど
うかを確認してやればよかろう、と考え、添付のようなパッチを当てま
した。当方のビルド環境 (VC6 + SP4) では、うまく動いているようです。
--
岡 俊行 (OKA, Toshiyuki) oka@langedge.com


---- 以下、パッチ ----
--- win32.c.orig	Wed Sep 27 16:36:35 2000
+++ win32.c	Wed Nov 15 01:08:21 2000
@@ -2013,8 +2013,15 @@
     if (!NtSocketsInitialized++) {
 	StartSockets();
     }
-    if ((r = bind (s, addr, addrlen)) == SOCKET_ERROR)
+    if ((r = bind (s, addr, addrlen)) == SOCKET_ERROR) {
 	errno = WSAGetLastError();
+	if (errno == WSAENOTSOCK) {
+	    if ((s = TO_SOCKET(s)) >= 0) {
+		if ((r = bind (s, addr, addrlen)) == SOCKET_ERROR)
+		    errno = WSAGetLastError();
+	    }	    
+	}
+    }
     return r;
 }
 
@@ -2027,8 +2034,15 @@
     if (!NtSocketsInitialized++) {
 	StartSockets();
     }
-    if ((r = connect (s, addr, addrlen)) == SOCKET_ERROR)
+    if ((r = connect (s, addr, addrlen)) == SOCKET_ERROR) {
 	errno = WSAGetLastError();
+	if (errno == WSAENOTSOCK) {
+	    if ((s = TO_SOCKET(s)) >= 0) {
+		if ((r = connect (s, addr, addrlen)) == SOCKET_ERROR)
+		    errno = WSAGetLastError();
+	    }	    
+	}
+    }
     return r;
 }
 
@@ -2070,8 +2084,15 @@
     if (!NtSocketsInitialized++) {
 	StartSockets();
     }
-    if ((r = getsockopt (s, level, optname, optval, optlen)) == SOCKET_ERROR)
+    if ((r = getsockopt (s, level, optname, optval, optlen)) == SOCKET_ERROR) {
 	errno = WSAGetLastError();
+	if (errno == WSAENOTSOCK) {
+	    if ((s = TO_SOCKET(s)) >= 0) {
+		if ((r = getsockopt (s, level, optname, optval, optlen)) == SOCKET_ERROR)
+		    errno = WSAGetLastError();
+	    }	    
+	}
+    }
     return r;
 }
 
@@ -2098,8 +2119,15 @@
     if (!NtSocketsInitialized++) {
 	StartSockets();
     }
-    if ((r = listen (s, backlog)) == SOCKET_ERROR)
+    if ((r = listen (s, backlog)) == SOCKET_ERROR) {
 	errno = WSAGetLastError();
+	if (errno == WSAENOTSOCK) {
+	    if ((s = TO_SOCKET(s)) >= 0) {
+		if ((r = listen (s, backlog)) == SOCKET_ERROR)
+		    errno = WSAGetLastError();
+	    }	    
+	}
+    }
     return r;
 }
 
@@ -2171,8 +2199,15 @@
 	StartSockets();
     }
     if ((r = setsockopt (s, level, optname, optval, optlen))
-    		 == SOCKET_ERROR)
+    		 == SOCKET_ERROR) {
 	errno = WSAGetLastError();
+	if (errno == WSAENOTSOCK) {
+	    if ((s = TO_SOCKET(s)) >= 0) {
+		if ((r = setsockopt (s, level, optname, optval, optlen)) == SOCKET_ERROR)
+		    errno = WSAGetLastError();
+	    }	    
+	}
+    }
     return r;
 }
     
---- ここまで ----

Thread

Prev Next

In This Thread

Prev Next