Backed out changeset 39d010399f9d

When network connection fails right before a connection negotiation/tuning
frame is sent, we want OperationInterruptedException to be thrown and not
AlreadyClosedException.

SessionBase#Transmit will throw the latter,
if we handle it, method continuation will eventually throw an OIE.

Author: michaelklishin

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

@@ -1397,8 +1397,15 @@ public ConnectionSecureOrTune ConnectionStartOk(IDictionary<string, object> clie
         {
             ConnectionStartRpcContinuation k = new ConnectionStartRpcContinuation();
             Enqueue(k);
-            _Private_ConnectionStartOk(clientProperties, mechanism,
+            try
+            {
+                _Private_ConnectionStartOk(clientProperties, mechanism,
                                            response, locale);
+            }
+            catch (AlreadyClosedException)
+            {
+                // Ignored, see BasicGet
+            }
             k.GetReply();
             return k.m_result;
         }
@@ -1420,7 +1427,14 @@ public ConnectionSecureOrTune ConnectionSecureOk(byte[] response)
         {
             ConnectionStartRpcContinuation k = new ConnectionStartRpcContinuation();
             Enqueue(k);
-            _Private_ConnectionSecureOk(response);
+            try
+            {
+                _Private_ConnectionSecureOk(response);
+            }
+            catch (AlreadyClosedException)
+            {
+                // Ignored, see BasicGet
+            }
             k.GetReply();
             return k.m_result;
         }
@@ -1459,7 +1473,13 @@ public string ConnectionOpen(string virtualHost,
         {
             ConnectionOpenContinuation k = new ConnectionOpenContinuation();
             Enqueue(k);
-            _Private_ConnectionOpen(virtualHost, capabilities, insist);
+            try {
+                _Private_ConnectionOpen(virtualHost, capabilities, insist);
+            }
+            catch (AlreadyClosedException)
+            {
+                // Ignored, see BasicGet
+            }
             k.GetReply();
             if (k.m_redirect) {
                 throw new RedirectException(m_session.Connection.Protocol,