txamqp-user team mailing list archive

[matteo brancaleoni <mbrancaleoni@xxxxxxxxx>]

nevermind,

> The patch is very trivial and "works for me":
>
> --- txamqp.orig/src/txamqp/protocol.py  2010-08-05 13:18:05.000000000 +0200
> +++ txamqp/src/txamqp/protocol.py       2010-08-30 10:32:22.000000000 +0200
> @@ -32,9 +32,11 @@
>         self.closed = False
>         self.reason = None
>
> +    @defer.inlineCallbacks
>     def close(self, reason):
>         if self.closed:
>             return
> +        yield self.channel_close()
>         self.closed = True
>         self.reason = reason
>         self.incoming.close()
>


this patch introduces a memory leak, so another solution to properly
close the channel
must be found.

regards,
matteo.