[PROTON-1631] [cpp] Stopping container in on_container_start after opening a socket will hang with libuv io

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: proton-c-0.18.0
• Component/s: cpp-binding

Environment

Linux, libuv-1.14.1, git tip at commit 72b7ea0508e94aae3e5d9470293bc5c7e8250a45 (upstream/master) PROTON-1592 : [python] restore original tx_recv.py example

• Assignee: Clifford Jansen
• Reporter: Jiri Daněk
• Created: 13/Oct/17 15:23
• Updated: 22/Feb/18 15:50

Description

Make yourself a libuv build with

cmake .. -DBUILD_GO=OFF -DCMAKE_BUILD_TYPE=Release -GNinja -DPROACTOR=libuv

Run the following test

struct less_immediate_stop_tester : public proton::messaging_handler {
    listen_port port;
    proton::listener listener;
    bool done;
    int scheduled_work;

    less_immediate_stop_tester() : done(false), scheduled_work(0) {}

    void connect(proton::container* c) {
    }

    void on_container_start(proton::container& c) PN_CPP_OVERRIDE {
        listener = c.listen(port.url());
        c.connect(port.url("localhost"));
        c.stop();
    }
};

// FIXME: this test has some Invalid reads in Valgrind  // with t.listener.stop() line commented out it doesn't
int test_container_less_immediate_stop() {
    less_immediate_stop_tester t;
    proton::container c(t);
    c.run();
//    t.listener.stop(); // saw this done in another test...
    return 0;
}

It will hang with the following output

{nofornat}
ninja && PN_TRACE_FRM=1 proton-c/bindings/cpp/container_test && echo pass
[...]
TEST: test_container_less_immediate_stop()
[0x17cc4c0]: -> AMQP
[0x17cc4c0]:0 -> @open(16) [container-id="e038fe4b-9996-4874-be7d-50274e1e193e", hostname="localhost", channel-max=32767]
[0x17c9110]: <- AMQP
[0x17c9110]:0 <- @open(16) [container-id="e038fe4b-9996-4874-be7d-50274e1e193e", hostname="localhost", channel-max=32767]
[0x17c9110]: -> AMQP
[0x17c9110]:0 -> @open(16) [container-id="e038fe4b-9996-4874-be7d-50274e1e193e", channel-max=32767]
[0x17cc4c0]: <- AMQP
[0x17cc4c0]:0 <- @open(16) [container-id="e038fe4b-9996-4874-be7d-50274e1e193e", channel-max=32767] {nofornat}

Now, this exact code does not hang with epoll io.