return bool from wxStreamTempInputBuffer::Update() indicating if anything was done; don't sleep in wxExecute() if IO is coming

git-svn-id: https://svn.wxwidgets.org/svn/wx/wxWidgets/trunk@52678 c3d73ce0-8a6f-49c7-b76d-6d57e0e08775

src/common/execcmn.cpp

@@ -52,7 +52,9 @@ public:
     void Init(wxPipeInputStream *stream);
 
     // check for input on our stream and cache it in our buffer if any
-    void Update();
+    //
+    // return true if anything was done
+    bool Update();
 
     ~wxStreamTempInputBuffer();
 
@@ -82,10 +84,11 @@ inline void wxStreamTempInputBuffer::Init(wxPipeInputStream *stream)
 }
 
 inline
-void wxStreamTempInputBuffer::Update()
+bool wxStreamTempInputBuffer::Update()
-{
-    if ( m_stream && m_stream->CanRead() )
 {
+    if ( !m_stream || !m_stream->CanRead() )
+        return false;
+
     // realloc in blocks of 4Kb: this is the default (and minimal) buffer
     // size of the Unix pipes so it should be the optimal step
     //
@@ -105,7 +108,8 @@ void wxStreamTempInputBuffer::Update()
         m_stream->Read((char *)m_buffer + m_size, incSize);
         m_size += m_stream->LastRead();
     }
-    }
+
+    return true;
 }
 
 inline

src/msw/utilsexc.cpp

@@ -987,13 +987,13 @@ long wxExecute(const wxString& cmd, int flags, wxProcess *handler)
     while ( data->state )
     {
 #if wxUSE_STREAMS && !defined(__WXWINCE__)
-        bufOut.Update();
+        if ( !bufOut.Update() && !bufErr.Update() )
-        bufErr.Update();
 #endif // wxUSE_STREAMS
-
+        {
             // don't eat 100% of the CPU -- ugly but anything else requires
             // real async IO which we don't have for the moment
             ::Sleep(50);
+        }
 
         // we must process messages or we'd never get wxWM_PROC_TERMINATED
         traits->AlwaysYield();

src/unix/utilsunx.cpp

@@ -1313,17 +1313,11 @@ bool wxAppTraits::CheckForRedirectedIO(wxExecuteData& execData)
 #if HAS_PIPE_INPUT_STREAM
     bool hasIO = false;
 
-    if ( execData.bufOut )
+    if ( execData.bufOut && execData.bufOut->Update() )
-    {
-        execData.bufOut->Update();
         hasIO = true;
-    }
 
-    if ( execData.bufErr )
+    if ( execData.bufErr && execData.bufErr->Update() )
-    {
-        execData.bufErr->Update();
         hasIO = true;
-    }
 
     return hasIO;
 #else // !HAS_PIPE_INPUT_STREAM