r2pipe_impl.h

#pragma once

#include "include/common.h"
#include "include/subprocess.h"
#include "r2pipe.h"

#include <deque>
#include <condition_variable>
#include <stop_token> // C++20
#include <chrono>


class RingBuffer {
public:
  void push(std::string_view data);

  /*
    可以用于清空缓冲区.
  */
  vector<char> pop_all();

  /*
    非阻塞版本. 未找到分隔符, 则直接退出.
    执行命令后, 可能 stdout 未完全输出, 这时用该函数可能会失败.
  */
  vector<char> pop_until_nonblock(char delimiter); 

  /*
    阻塞版本. 可能导致阻塞. 遇到 delimiter / EOF 返回.
    注意, 返回的结果包含分隔符. 如果分隔符是 \0, 则可以视作字符串.
  */
  vector<char> pop_until(char delimiter);

  void set_eof();

private:
  std::deque<char> buffer_;
  bool eof = false;
  std::mutex mutex_;
  std::condition_variable not_empty_;
};


/*
  Process 类的具体细节 
*/
struct Process::Impl {
    subprocess_s process{};
    std::jthread reader_thread;
    RingBuffer buffer;

    explicit Impl(ArgvT args);
    ~Impl();

    int join();
    int terminate();
    bool is_alive();
    std::vector<char> read_all();
    std::vector<char> read_until(char delimiter);
    std::vector<char> read_until_nonblock(char delimiter);
    void write(std::span<const char> data);
    static bool in_path(ArgvT exe);

private:
    void start_reader_thread();
    void create_subprocess(const std::vector<const char*>& args);
    static std::vector<const char*> make_argv(ArgvT args);
};