txredis client hangs up after "multi" command fail

[aim110]

Hi,

you can launch that code:

from twisted.internet import reactor, defer
import time
from txredisapi import ConnectionPool as Redis

class A(object):
    def __init__(self, db):
        self.db = db

    @defer.inlineCallbacks
    def do(self):
        print 'hello'
        try:
            pipe = yield self.db.multi()
            t = int(time.time())
            val = None
            if pipe:
                yield pipe.set('b', t)
                yield pipe.get('b')
                val = yield pipe.commit()
                print val
        except Exception as e:
            print e

        reactor.callLater(1.0, self.do)

@defer.inlineCallbacks
def main():
    db = yield Redis(dbid=1, poolsize=2)
    print "connected: %s" % db

    a = A(db)
    reactor.callLater(1.0, a.do)

main()
reactor.run()

and restart redis server to reproduce issue

I did a fix for that: 8e04e65

[fiorix]

Pull requests are welcome, thanks!

On Feb 24, 2014, at 5:11 AM, IVan [email protected] wrote:

Reopened #58.

—
Reply to this email directly or view it on GitHub.