- move command line wrapper support to rtphone

src/engine/helper/HL_Process.cpp

@@ -0,0 +1,96 @@
+#include "HL_Process.h"
+
+
+#ifdef TARGET_WIN
+# define popen _popen
+# define pclose _pclose
+#endif
+
+#if defined(TARGET_WIN)
+#include <Windows.h>
+std::string OsProcess::execCommand(const std::string& cmd)
+{
+    std::string output;
+    HANDLE hPipeRead, hPipeWrite;
+
+    SECURITY_ATTRIBUTES saAttr = { sizeof(SECURITY_ATTRIBUTES) };
+    saAttr.bInheritHandle = TRUE;   //Pipe handles are inherited by child process.
+    saAttr.lpSecurityDescriptor = NULL;
+
+    // Create a pipe to get results from child's stdout.
+    if ( !CreatePipe(&hPipeRead, &hPipeWrite, &saAttr, 0) )
+        return output;
+
+    STARTUPINFOA si = { sizeof(STARTUPINFOA) };
+    si.dwFlags     = STARTF_USESHOWWINDOW | STARTF_USESTDHANDLES;
+    si.hStdOutput  = hPipeWrite;
+    si.hStdError   = hPipeWrite;
+    si.wShowWindow = SW_HIDE;       // Prevents cmd window from flashing. Requires STARTF_USESHOWWINDOW in dwFlags.
+
+    PROCESS_INFORMATION pi  = { 0 };
+
+    char* cmdline = (char*)_alloca(cmd.size()+1);
+    strcpy(cmdline, StringHelper::replace(cmd, "/", "\\").c_str());
+
+    BOOL fSuccess = CreateProcessA( NULL, cmdline, NULL, NULL, TRUE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pi);
+    if (! fSuccess)
+    {
+        CloseHandle( hPipeWrite );
+        CloseHandle( hPipeRead );
+        return output;
+    }
+
+    bool bProcessEnded = false;
+    for (; !bProcessEnded ;)
+    {
+        // Give some timeslice (50ms), so we won't waste 100% cpu.
+        bProcessEnded = WaitForSingleObject( pi.hProcess, 50) == WAIT_OBJECT_0;
+
+        // Even if process exited - we continue reading, if there is some data available over pipe.
+        for (;;)
+        {
+            char buf[1024];
+            DWORD dwRead = 0;
+            DWORD dwAvail = 0;
+
+            if (!::PeekNamedPipe(hPipeRead, NULL, 0, NULL, &dwAvail, NULL))
+                break;
+
+            if (!dwAvail) // no data available, return
+                break;
+
+            if (!::ReadFile(hPipeRead, buf, min(sizeof(buf) - 1, dwAvail), &dwRead, NULL) || !dwRead)
+                // error, the child process might ended
+                break;
+
+            buf[dwRead] = 0;
+            output += buf;
+        }
+    } //for
+
+    CloseHandle( hPipeWrite );
+    CloseHandle( hPipeRead );
+    CloseHandle( pi.hProcess );
+    CloseHandle( pi.hThread );
+
+    return output;
+}
+#else
+std::string OsProcess::execCommand(const std::string& cmd)
+{
+    std::string cp = cmd;
+
+    std::shared_ptr<FILE> pipe(popen(cp.c_str(), "r"), pclose);
+    if (!pipe)
+        throw std::runtime_error("Failed to run.");
+
+    char buffer[1024];
+    std::string result = "";
+    while (!feof(pipe.get()))
+    {
+        if (fgets(buffer, 1024, pipe.get()) != nullptr)
+            result += buffer;
+    }
+    return result;
+}
+#endif

src/engine/helper/HL_Process.h

@@ -0,0 +1,12 @@
+#ifndef __HL_PROCESS_H
+#define __HL_PROCESS_H
+
+#include <string>
+
+class OsProcess
+{
+public:
+    std::string execCommand(const std::string& cmdline);
+};
+
+#endif