Merge pull request #569 from zhuomingliang/backlog

Expose the backlog arg for listen
rakudo · Dec 4, 2015 · 8d6ac86 · 8d6ac86
2 parents 5b8c080 + c981d28
commit 8d6ac86
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/src/core/IO/Socket/Async.pm b/src/core/IO/Socket/Async.pm
@@ -108,7 +108,7 @@ my class IO::Socket::Async {
         $p
     }
 
-    method listen(IO::Socket::Async:U: Str() $host, Int() $port,
+    method listen(IO::Socket::Async:U: Str() $host, Int() $port, Int() $backlog = 128,
                   :$scheduler = $*SCHEDULER) {
         my $cancellation;
         Supply.on-demand(-> $s {
@@ -124,7 +124,7 @@ my class IO::Socket::Async {
                         $s.emit($client_socket);
                     }
                 },
-                $host, $port, SocketCancellation);
+                $host, $port, $backlog, SocketCancellation);
         },
         closing => {
             $cancellation && nqp::cancel($cancellation)

diff --git a/src/core/IO/Socket/INET.pm b/src/core/IO/Socket/INET.pm
@@ -21,6 +21,7 @@ my class IO::Socket::INET does IO::Socket {
     has Int $.port = 80;
     has Str $.localhost;
     has Int $.localport;
+    has Int $.backlog;
     has Bool $.listening;
     has $.family = PIO::PF_INET;
     has $.proto = PIO::PROTO_TCP;
@@ -72,7 +73,7 @@ my class IO::Socket::INET does IO::Socket {
         #which is derived from the protocol, is SOCK_STREAM then connect() is called.
         if $.listening || $.localhost || $.localport {
             nqp::bindsock($PIO, nqp::unbox_s($.localhost || "0.0.0.0"),
-                                 nqp::unbox_i($.localport || 0));
+                                 nqp::unbox_i($.localport || 0), nqp::unbox_i($.backlog || 128));
         }
 
         if $.listening {

diff --git a/tools/build/NQP_REVISION b/tools/build/NQP_REVISION
@@ -1 +1 @@
-2015.11-28-g01aba47
+2015.11-33-g52ded1d