[Truffle] Add socket posix send

jruby · Oct 4, 2016 · 56ae861 · 56ae861 · bjfish · Oct 4, 2016
1 parent 16e383d
commit 56ae861
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 0 deletions.
diff --git a/truffle/src/main/java/org/jruby/truffle/extra/TrufflePosixNodes.java b/truffle/src/main/java/org/jruby/truffle/extra/TrufflePosixNodes.java
@@ -688,6 +688,17 @@ public int getppid() {
 
     }
 
+    @CoreMethod(names = "send", isModuleFunction = true, required = 4, lowerFixnum = {1, 3, 4}, unsafe = UnsafeGroup.IO)
+    public abstract static class SendNode extends CoreMethodArrayArgumentsNode {
+
+        @TruffleBoundary
+        @Specialization(guards = "isRubyPointer(buffer)")
+        public int send(int descriptor, DynamicObject buffer, int bytes, int flags) {
+            return nativeSockets().send(descriptor, Layouts.POINTER.getPointer(buffer), bytes, flags);
+        }
+
+    }
+
     @CoreMethod(names = "symlink", isModuleFunction = true, required = 2, unsafe = UnsafeGroup.IO)
     public abstract static class SymlinkNode extends CoreMethodArrayArgumentsNode {
 

diff --git a/truffle/src/main/java/org/jruby/truffle/platform/java/JavaSockets.java b/truffle/src/main/java/org/jruby/truffle/platform/java/JavaSockets.java
@@ -85,6 +85,11 @@ public int connect(int socket, Pointer address, int address_len) {
         throw new UnsupportedOperationException();
     }
 
+    @Override
+    public int send(int sockfd, Pointer buf, int len, int flags) {
+        throw new UnsupportedOperationException();
+    }
+
     @Override
     public int shutdown(int socket, int how) {
         throw new UnsupportedOperationException();

diff --git a/truffle/src/main/java/org/jruby/truffle/platform/posix/Sockets.java b/truffle/src/main/java/org/jruby/truffle/platform/posix/Sockets.java
@@ -119,6 +119,11 @@ public interface Sockets {
 
     int connect(int socket, Pointer address, int address_len);
 
+    /**
+     * int send(int sockfd, Pointer buf, int len, int flags);
+     */
+    int send(int sockfd, Pointer buf, int len, int flags);
+
     /**
      * int shutdown(int sockfd, int how);
      */