Possible deadlock with web socket #64

Demayl · 2018-04-02T08:47:27Z

When using the example code below:

After a while it hangs ( for new connections too ) and memory usage goes crazy.
~~2. In some cases it hangs only for a particular connection and after new connect it works.~~
Edit: case 2 is ok in 0.7.4

Tried with some other web-socket servers and the html example works as expected.

This is Rakudo version 2018.03-147-g232c664 built on MoarVM version 2018.03-68-ged4201e
implementing Perl 6.c.

Perl 6 code

#!/usr/bin/env perl6
use v6.c;
my $chat = Supplier.new;
use Cro::HTTP::Router;
use Cro::HTTP::Router::WebSocket;
use Cro::HTTP::Server;

my $app = route {
        get -> 'chat' {
            web-socket -> $incoming {
                supply {
                    whenever $incoming -> $message {
                        $chat.emit("OK-"~(await $message.body-text));
                    }
                    whenever $chat -> $text {
                        emit $text;
                    }
                }
            }
        }
};

say "BEGIN";
my $service = Cro::HTTP::Server.new: :host('127.0.0.1'), :port(8888), :application($app);
say "Start";
$service.start;

say "Listen";

react whenever signal(SIGINT) { say "GOT KILL INT.....EXIT"; $service.stop; exit; }

HTML client

<!doctype html>
<html>
    <body>
    <div id="terminal"><textarea id="area"></textarea></div>
    <script src="https://code.jquery.com/jquery-3.2.1.min.js" integrity="sha256-hwg4gsxgFZhOsEEamdOYGBf13FyQuiTwlAQgxVSNgt4=" crossorigin="anonymous"></script>

    <script type="text/javascript">
        var socket = new WebSocket('ws://127.0.0.1:8888/chat');
        socket.onopen = function(){ console.log("opened"); test() };
        socket.onclose = function(){ console.log("closed") };
        socket.onmessage = function(ev){ $("#area").html(ev.data); };
        socket.onerror = function(ev){ console.log("ERROR: " + ev.data) };

        $(window).on('beforeunload', function(){
            console.log("Close socket");
            socket.close();
        });
        function test(){
            setInterval(function(){ socket.send("PING");},10);
            setTimeout(function(){for(var i=0; i<2000; i++){ for(var x=0; x<10; x++){ socket.send(i+":"+x) } }},100);
            setTimeout(function(){for(var i=0; i<2000; i++){ for(var x=0; x<10; x++){ socket.send(i+":"+x) } }},100);
        }
    </script>
    </body>
</html>

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Possible deadlock with web socket #64

Possible deadlock with web socket #64

Demayl commented Apr 2, 2018 •

edited

Loading

Possible deadlock with web socket #64

Possible deadlock with web socket #64

Comments

Demayl commented Apr 2, 2018 • edited Loading

Demayl commented Apr 2, 2018 •

edited

Loading