Changeset 21249

Timestamp:

10/13/08 20:42:16 (5 years ago)

Author:

tokuhirom

Message:

added socketpair supporrt

Location:

lang/cplusplus/llv8call/trunk

Files:

• ext/socket/socket.cc (modified) (4 diffs)
• t/100_socket/06_socketpair.js (added)

lang/cplusplus/llv8call/trunk/ext/socket/socket.cc

@@ -160 +160 @@
 FUNCTION(_open)
     // USAGE: new Socket(Socket.AF_INET, Socket.SOCK_STREAM)
-    if (args.Length() == 2 && args[0]->IsExternal()) {
+    if (args.Length() == 5 && args[0]->IsExternal()) {
         args.This()->SetInternalField(0, args[1]);
         args.This()->Set(String::New("family"), args[2]);
@@ -240 +240 @@
     int newsock = accept(sock, &addr, &len);
     if (newsock >= 0) {
-        Handle<Value> argv[2];
-        argv[0] = External::New(&len);
+        Handle<Value> argv[5];
+        argv[0] = External::New(&len); // dummy field
         argv[1] = Int32::New(newsock);
         argv[2] = args.This()->Get(String::New("family"));
         argv[3] = args.This()->Get(String::New("type"));
         argv[4] = args.This()->Get(String::New("proto"));
-        return Handle<Function>::Cast( socket_namespace()->Get(String::New("Socket")) )->NewInstance(2, argv);
+        return Handle<Function>::Cast( socket_namespace()->Get(String::New("Socket")) )->NewInstance(5, argv);
     } else {
         return throw_stderr("accept error: ");
@@ -422 +422 @@
 END
 
+FUNCTION(_socketpair)
+    // @prototype socket.socketpair([family[, type[, proto]]])
+    ARG_BETWEEN(0, 3);
+    ARG_int(family, 0);
+    ARG_int(type,   1);
+    ARG_int(protocol,  2);
+
+    if (args.Length() < 1) {
+#if defined(AF_UNIX)
+        family = AF_UNIX;
+#else
+        family = AF_INET;
+#endif
+    }
+    if (args.Length() < 2) {
+        type = SOCK_STREAM;
+    }
+    if (args.Length() < 3) {
+        protocol = 0;
+    }
+
+    int socket_vector[2];
+    if (socketpair(family, type, protocol, socket_vector) == 0) {
+        Handle<Array> ret = Array::New(2);
+        for (int i=0; i<2; i++) {
+            Handle<Value> argv[5];
+            argv[0] = External::New((void*)&family); // dummy field
+            argv[1] = Int32::New(socket_vector[i]);
+            argv[2] = Int32::New(family);
+            argv[3] = Int32::New(type);
+            argv[4] = Int32::New(protocol);
+            Handle<Object> obj = Handle<Function>::Cast( socket_namespace()->Get(String::New("Socket")) )->NewInstance(5, argv);
+            ret->Set(Int32::New(i), obj);
+        }
+        return ret;
+    } else {
+        return throw_stderr("inet_aton");
+    }
+END
+
 MODULE()
     {
@@ -441 +481 @@
         BIND_CM("inet_aton",      _inet_aton);
         BIND_CM("inet_ntoa",      _inet_ntoa);
+        BIND_CM("socketpair",     _socketpair);
 
         BIND_IM("bind",           _bind);