Method recv

tests/test_opening.py:3720–3727

(self, maxlen)

            self.sock.sendall(data)

        def recv(self, maxlen):
            while len(self.buf) < maxlen:
                chunk = self.sock.recv(maxlen - len(self.buf))
                if not chunk:
                    raise ConnectionError("peer closed connection")
                self.buf += chunk
            ret, self.buf = self.buf[:maxlen], self.buf[maxlen:]
            return ret

    # dualopend doesn't listen for the disconnect, so connectd has to force it.
    l1 = node_factory.get_node(broken_log='Subd did not close, forcing close')