TerminalProcess_WindowsConPTY.h

Go to the documentation of this file.

#pragma once
 
#if EDITOR
#if PLATFORM_WINDOWS
 
#include "ITerminalOutputParser.h"
#include "ITerminalProcess.h"
 
#include <atomic>
#include <memory>
#include <mutex>
#include <thread>
 
class TerminalProcess_WindowsConPTY : public ITerminalProcess
{
public:
    TerminalProcess_WindowsConPTY();
    ~TerminalProcess_WindowsConPTY() 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 true; }
 
    static bool IsConPtyAvailable();
 
private:
    void ReaderLoop();
    void WaitLoop();
    void CloseAllHandles();
 
    void* mProcess = nullptr;        // HANDLE
    unsigned long mProcessId = 0;    // DWORD
    void* mPseudoConsole = nullptr;  // HPCON
 
    void* mInputWrite = nullptr;     // we WRITE here -> ConPTY child stdin
    void* mOutputRead = nullptr;     // we READ here  <- ConPTY child stdout
 
    void* mAttributeListMem = nullptr;  // HeapAlloc'd PROC_THREAD_ATTRIBUTE_LIST*
 
    std::unique_ptr<ITerminalOutputParser> mParser;
 
    std::thread mReader;
    std::thread mWaitThread;
 
    std::atomic<bool> mRunning{ false };
    std::atomic<bool> mStopRequested{ false };
    std::atomic<int>  mExitCode{ 0 };
 
    std::mutex mStdinMutex;
    std::mutex mLifecycleMutex;
};
 
#endif // PLATFORM_WINDOWS
#endif // EDITOR