TerminalProcess_Windows.h

Go to the documentation of this file.

#pragma once
 
#if EDITOR
#if PLATFORM_WINDOWS
 
#include "ITerminalProcess.h"
 
#include <atomic>
#include <mutex>
#include <thread>
 
class TerminalProcess_Windows : public ITerminalProcess
{
public:
    TerminalProcess_Windows();
    ~TerminalProcess_Windows() override;
 
    bool Start(const TerminalLaunchConfig& cfg, std::string& outError) override;
    bool WriteStdin(const char* data, size_t len) override;
    void RequestStop() override;
    void ForceKill() override;
    bool IsRunning() const override { return mRunning.load(); }
    int  GetExitCode() const override { return mExitCode.load(); }
    void Join() override;
    bool IsTty() const override { return false; }
 
private:
    void ReaderLoop(void* pipeHandle, TerminalEntryKind kind);
    void WaitLoop();
    void CloseAllHandles();
 
    static std::string BuildCommandLine(const std::string& exe,
                                        const std::vector<std::string>& args);
 
    void* mProcess = nullptr;       // HANDLE
    unsigned long mProcessId = 0;   // DWORD
    void* mJob = nullptr;           // HANDLE (Job Object)
 
    void* mStdoutRead = nullptr;
    void* mStdoutWrite = nullptr;
    void* mStderrRead = nullptr;
    void* mStderrWrite = nullptr;
    void* mStdinRead = nullptr;
    void* mStdinWrite = nullptr;
 
    std::thread mStdoutReader;
    std::thread mStderrReader;
    std::thread mWaitThread;
 
    std::atomic<bool> mRunning{ false };
    std::atomic<bool> mStopRequested{ false };
    std::atomic<int>  mExitCode{ 0 };
 
    std::mutex mStdinMutex;
    std::mutex mLifecycleMutex;  // protects Start/Join/CloseAllHandles
};
 
#endif // PLATFORM_WINDOWS
#endif // EDITOR