Wait for socket to become writeable

michaelklishin · michaelklishin · commit 9221d2ccb8f4 · 2015-06-28T19:43:46.000+03:00
References rabbitmq/rabbitmq-server#156.
diff --git a/projects/client/RabbitMQ.Client/src/client/impl/SocketFrameHandler.cs b/projects/client/RabbitMQ.Client/src/client/impl/SocketFrameHandler.cs
@@ -218,6 +218,7 @@ public void WriteFrame(Frame frame)
         {
             lock (m_writer)
             {
+                m_socket.Client.Poll(-1, SelectMode.SelectWrite);
                 frame.WriteTo(m_writer);
                 m_writer.Flush();
             }
@@ -227,6 +228,7 @@ public void WriteFrameSet(IList<Frame> frames)
         {
             lock (m_writer)
             {
+                m_socket.Client.Poll(-1, SelectMode.SelectWrite);
                 foreach(var f in frames)
                 {
                     f.WriteTo(m_writer);

Original file line number	Diff line number	Diff line change
`@@ -218,6 +218,7 @@ public void WriteFrame(Frame frame)`
`218`	`218`	`{`
`219`	`219`	`lock (m_writer)`
`220`	`220`	`{`
	`221`	`+ m_socket.Client.Poll(-1, SelectMode.SelectWrite);`
`221`	`222`	`frame.WriteTo(m_writer);`
`222`	`223`	`m_writer.Flush();`
`223`	`224`	`}`
`@@ -227,6 +228,7 @@ public void WriteFrameSet(IList<Frame> frames)`
`227`	`228`	`{`
`228`	`229`	`lock (m_writer)`
`229`	`230`	`{`
	`231`	`+ m_socket.Client.Poll(-1, SelectMode.SelectWrite);`
`230`	`232`	`foreach(var f in frames)`
`231`	`233`	`{`
`232`	`234`	`f.WriteTo(m_writer);`