Rewrote section to only have to call WaitOne once.

Author: Steve Powell

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

@@ -424,50 +424,42 @@ public void Abort(ushort reasonCode, string reasonText,
         ///</remarks>
         public void Close(ShutdownEventArgs reason, bool abort, int timeout)
         {
-            if (!SetCloseReason(reason))
-                if (abort)
-                {
-                    if (!m_appContinuation.WaitOne(BlockingCell.validatedTimeout(timeout), true))
-                        m_frameHandler.Close();
-                    return;
-                } else {
-                    throw new AlreadyClosedException(m_closeReason);
-                }
-                                           
-            OnShutdown();
-            m_session0.SetSessionClosing(false);
+            bool reasonSet = SetCloseReason(reason);
+            if (!reasonSet && !abort)
+                throw new AlreadyClosedException(m_closeReason);
 
-            try
-            {
-                // Try to send connection.close
-                // Wait for CloseOk in the MainLoop
-                m_session0.Transmit(ConnectionCloseWrapper(reason.ReplyCode,
-                                                          reason.ReplyText));
-            }
-            catch (AlreadyClosedException ace)
-            {
-                if (abort) {
-                    if (!m_appContinuation.WaitOne(BlockingCell.validatedTimeout(timeout), true))
-                        m_frameHandler.Close();
-                    return;
-                } else {
-                    throw ace;
+            if (reasonSet)
+            {                               
+                OnShutdown();
+                m_session0.SetSessionClosing(false);
+
+                try
+                {
+                    // Try to send connection.close
+                    // Wait for CloseOk in the MainLoop
+                    m_session0.Transmit(ConnectionCloseWrapper(reason.ReplyCode,
+                                                              reason.ReplyText));
                 }
-            }
-            catch (IOException ioe)
-            {
-                if (m_model0.CloseReason == null)
+                catch (AlreadyClosedException ace)
                 {
                     if (!abort)
-                        throw ioe;
-                    else
-                        LogCloseError("Couldn't close connection cleanly. " 
-                                      + "Socket closed unexpectedly", ioe);
+                        throw ace;
+                }
+                catch (IOException ioe)
+                {
+                    if (m_model0.CloseReason == null)
+                    {
+                        if (!abort)
+                            throw ioe;
+                        else
+                            LogCloseError("Couldn't close connection cleanly. " 
+                                          + "Socket closed unexpectedly", ioe);
+                    }
+                }
+                finally
+                {
+                    TerminateMainloop();
                 }
-            }
-            finally
-            {
-                TerminateMainloop();
             }
             if (!m_appContinuation.WaitOne(BlockingCell.validatedTimeout(timeout),true))
                 m_frameHandler.Close();