tracker_alone.h

Go to the documentation of this file.

/* SPDX-License-Identifier: GPL-2.0 OR BSD-3-Clause
 *
 * Copyright (c) 2022, 郑昱笙，濮雯旭，张典典（牛校牛子队）
 * All rights reserved.
 */
 
#ifndef TRACKER_ALONE_H
#define TRACKER_ALONE_H
 
#include <vector>
 
#include "tracker.h"
 
struct tracker_alone_env
{
  volatile bool *exiting;
 
  int wait_ms_for_read;
  typedef int (*start_func)(int argc, char **argv);
  start_func main_func;
  std::vector<std::string> process_args;
};
 
struct tracker_alone_event
{
  int pid;
 
  std::string process_messages;
};
 
// Run tracker as a standalone process, and communicate with pipe
struct tracker_alone_base : public tracker_with_config<tracker_alone_env, tracker_alone_event>
{
 private:
  constexpr static int MAX_PROCESS_MESSAGE_LENGTH = 1024 * 1024 * 4;
  pid_t child_pid;
  int stdout_pipe_fd[2];
  char stdout_pipe_buf[MAX_PROCESS_MESSAGE_LENGTH];
  void start_child_process();
  void start_parent_process();
 
  int handle_message_event(std::string&& event);
 
 public:
  tracker_alone_base(config_data config);
  ~tracker_alone_base();
 
  void start_tracker();
 
  static std::unique_ptr<tracker_alone_base> create_tracker_with_default_env(tracker_event_handler handler);
 
  struct plain_text_event_printer final : public event_handler<tracker_alone_event>
  {
    void handle(tracker_event<tracker_alone_event> &e);
  };
};
 
#endif