Page MenuHomePhabricator (Chris)
Files F631828

Win32Process.cpp
No OneTemporary
Actions

Authored By
Unknown
Size
6 KB
Referenced Files
None
Subscribers
None

Win32Process.cpp
View Options

#include <windows.h>
#include "Win32Process.h"
#include <QThread>
#include <QTextCodec>
#include <deque>
#include <QDir>
#include <QDebug>
#include <QDateTime>
#include <QMutex>
class OutputReaderThread : public QThread {
private:
HANDLE hRead;
QMutex *mutex;
std::deque<char> *buffer;
protected:
void run() override
{
while (1) {
char buf[256];
DWORD len = 0;
if (!ReadFile(hRead, buf, sizeof(buf), &len, nullptr)) break;
if (len < 1) break;
if (buffer) {
QMutexLocker lock(mutex);
buffer->insert(buffer->end(), buf, buf + len);
}
}
}
public:
OutputReaderThread(HANDLE hRead, QMutex *mutex, std::deque<char> *buffer)
: hRead(hRead)
, mutex(mutex)
, buffer(buffer)
{
}
};
class Win32ProcessThread : public QThread {
friend class Win32Process2;
private:
public:
QMutex *mutex = nullptr;
std::string command;
DWORD exit_code = -1;
std::deque<char> inq;
std::deque<char> outq;
std::deque<char> errq;
bool use_input = false;
HANDLE hInputWrite = INVALID_HANDLE_VALUE;
bool close_input_later = false;
void reset()
{
mutex = nullptr;
command.clear();
exit_code = -1;
inq.clear();
outq.clear();
errq.clear();
use_input = false;
hInputWrite = INVALID_HANDLE_VALUE;
close_input_later = false;
}
protected:
void run() override
{
try {
hInputWrite = INVALID_HANDLE_VALUE;
HANDLE hOutputRead = INVALID_HANDLE_VALUE;
HANDLE hErrorRead = INVALID_HANDLE_VALUE;
HANDLE hInputWriteTmp = INVALID_HANDLE_VALUE;
HANDLE hOutputReadTmp = INVALID_HANDLE_VALUE;
HANDLE hErrorReadTmp = INVALID_HANDLE_VALUE;
HANDLE hInputRead = INVALID_HANDLE_VALUE;
HANDLE hOutputWrite = INVALID_HANDLE_VALUE;
HANDLE hErrorWrite = INVALID_HANDLE_VALUE;
SECURITY_ATTRIBUTES sa;
sa.nLength = sizeof(SECURITY_ATTRIBUTES);
sa.lpSecurityDescriptor = nullptr;
sa.bInheritHandle = TRUE;
HANDLE currproc = GetCurrentProcess();
// パイプを作成
if (!CreatePipe(&hInputRead, &hInputWriteTmp, &sa, 0))
throw std::string("Failed to CreatePipe");
if (!CreatePipe(&hOutputReadTmp, &hOutputWrite, &sa, 0))
throw std::string("Failed to CreatePipe");
if (!CreatePipe(&hErrorReadTmp, &hErrorWrite, &sa, 0))
throw std::string("Failed to CreatePipe");
// 子プロセスの標準入力
if (!DuplicateHandle(currproc, hInputWriteTmp, currproc, &hInputWrite, 0, FALSE, DUPLICATE_SAME_ACCESS))
throw std::string("Failed to DupliateHandle");
// 子プロセスの標準出力
if (!DuplicateHandle(currproc, hOutputReadTmp, currproc, &hOutputRead, 0, FALSE, DUPLICATE_SAME_ACCESS))
throw std::string("Failed to DupliateHandle");
// 子プロセスのエラー出力
if (!DuplicateHandle(currproc, hErrorReadTmp, currproc, &hErrorRead, 0, FALSE, DUPLICATE_SAME_ACCESS))
throw std::string("Failed to DuplicateHandle");
// 不要なハンドルを閉じる
CloseHandle(hInputWriteTmp);
CloseHandle(hOutputReadTmp);
CloseHandle(hErrorReadTmp);
// プロセス起動
PROCESS_INFORMATION pi;
STARTUPINFOA si;
ZeroMemory(&si, sizeof(STARTUPINFO));
si.cb = sizeof(STARTUPINFO);
si.dwFlags = STARTF_USESTDHANDLES | STARTF_USESHOWWINDOW;
si.wShowWindow = SW_HIDE;
si.hStdInput = hInputRead; // 標準入力ハンドル
si.hStdOutput = hOutputWrite; // 標準出力ハンドル
si.hStdError = hErrorWrite; // エラー出力ハンドル
char *tmp = (char *)alloca(command.size() + 1);
strcpy(tmp, command.c_str());
if (!CreateProcessA(nullptr, tmp, nullptr, nullptr, TRUE, CREATE_NO_WINDOW, nullptr, nullptr, &si, &pi)) {
throw std::string("Failed to CreateProcess");
}
// 不要なハンドルを閉じる
CloseHandle(hInputRead);
CloseHandle(hOutputWrite);
CloseHandle(hErrorWrite);
if (!use_input) {
closeInput();
}
OutputReaderThread t1(hOutputRead, mutex, &outq);
OutputReaderThread t2(hErrorRead, mutex, &errq);
t1.start();
t2.start();
while (WaitForSingleObject(pi.hProcess, 1) != WAIT_OBJECT_0) {
QMutexLocker lock(mutex);
int n = inq.size();
if (n > 0) {
while (n > 0) {
char tmp[1024];
int l = n;
if (l > sizeof(tmp)) {
l = sizeof(tmp);
}
std::copy(inq.begin(), inq.begin() + l, tmp);
inq.erase(inq.begin(), inq.begin() + l);
if (hInputWrite != INVALID_HANDLE_VALUE) {
DWORD written;
WriteFile(hInputWrite, tmp, l, &written, nullptr);
}
n -= l;
}
} else if (close_input_later) {
closeInput();
}
}
t1.wait();
t2.wait();
CloseHandle(hOutputRead);
CloseHandle(hErrorRead);
GetExitCodeProcess(pi.hProcess, &exit_code);
// 終了
CloseHandle(pi.hThread);
CloseHandle(pi.hProcess);
} catch (std::string const &e) { // 例外
OutputDebugStringA(e.c_str());
}
}
public:
void closeInput()
{
CloseHandle(hInputWrite);
hInputWrite = INVALID_HANDLE_VALUE;
}
void writeInput(char const *ptr, int len)
{
QMutexLocker lock(mutex);
inq.insert(inq.end(), ptr, ptr + len);
}
};
QString toQString(const std::vector<char> &vec)
{
if (vec.empty()) return QString();
return QString::fromUtf8(&vec[0], vec.size());
}
struct Win32Process::Private {
QMutex mutex;
Win32ProcessThread th;
};
Win32Process::Win32Process()
: m(new Private)
{
}
Win32Process::~Win32Process()
{
delete m;
}
void Win32Process::start(QString const &command, bool use_input)
{
QTextCodec *sjis = QTextCodec::codecForName("Shift_JIS");
Q_ASSERT(sjis);
QByteArray ba = sjis->fromUnicode(command);
ba.push_back((char)0);
char const *cmd = ba.data();
m->th.mutex = &m->mutex;
m->th.use_input = use_input;
m->th.command = cmd;
m->th.start();
}
int Win32Process::wait()
{
m->th.wait();
outbytes.clear();
errbytes.clear();
outbytes.insert(outbytes.end(), m->th.outq.begin(), m->th.outq.end());
errbytes.insert(errbytes.end(), m->th.errq.begin(), m->th.errq.end());
int exit_code = m->th.exit_code;
m->th.reset();
return exit_code;
}
QString Win32Process::outstring() const
{
return toQString(outbytes);
}
QString Win32Process::errstring() const
{
return toQString(errbytes);
}
void Win32Process::writeInput(char const *ptr, int len)
{
m->th.writeInput(ptr, len);
}
void Win32Process::closeInput(bool justnow)
{
if (justnow) {
m->th.closeInput();
} else {
m->th.close_input_later = true;
}
}

File Metadata

Mime Type
text/x-c++
Expires
Sun, Nov 15, 12:53 PM (1 d, 21 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
126748
Default Alt Text
Win32Process.cpp (6 KB)

Event Timeline