wenchongyang

i changed code to below it's success: if not self._socket or self._family != family: self._socket = socket.socket(family, socket.SOCK_STREAM) self._socket.setblocking(True)# added by myself pass self._dst_addr = addr self._family = family try:...

修订源码ServerConnection public void setTxInterrupted(boolean txInterrupted) { this.txInterrupted = txInterrupted; } 修订SingleNodeHandler.backConnectionErr 方法 在返回客户端信息后回收TxInterrupted errPkg.write(source); recycleResources(); source.setTxInterrupted(false);

@magicdoom 如果代码遗漏rollback 就会出问题，而且这个链接会一直堵死在这条语句。即是下一条语句是一条select 语句。参见我的示例，