fixed missing connection unlock after close
@@ -271,8 +271,9 @@ public class ONetworkProtocolBinary extends ONetworkProtocol {
} finally {
afterOperationRequest(connection);
}
- } else if (response != null) {
+ } else{
try {
+ if (response != null) {
beginResponse();
try {
sendOk(connection, clientTxId);
@@ -280,6 +281,7 @@ public class ONetworkProtocolBinary extends ONetworkProtocol {
} finally {
endResponse();
}
+ }
} catch (IOException e) {
OLogManager.instance().debug(this, "I/O Error on client clientId=%d reqType=%d", clientTxId, requestType, e);
sendShutdown();
