controller_manager.h

Go to the documentation of this file.

// Copyright 2016 Google Inc.

#ifndef PAGESPEED_CONTROLLER_MANAGER_H_
#define PAGESPEED_CONTROLLER_MANAGER_H_

#include <memory>

#include "pagespeed/kernel/base/basictypes.h"
#include "pagespeed/kernel/base/message_handler.h"
#include "pagespeed/kernel/base/thread.h"
#include "pagespeed/kernel/base/thread_system.h"
#include "pagespeed/system/controller_process.h"
#include "pagespeed/system/system_rewrite_driver_factory.h"

namespace net_instaweb {

class ControllerManager {
 public:
  static void ForkControllerProcess(
      std::unique_ptr<ControllerProcess>&& process,
      SystemRewriteDriverFactory* factory, ThreadSystem* thread_system,
      MessageHandler* handler);

  static void DetachFromControllerProcess();

 private:
  static void Daemonize(MessageHandler* handler);

  static int RunController(int controller_read_fd, ControllerProcess* process,
                           ThreadSystem* thread_system,
                           MessageHandler* handler);

  class ProcessDeathWatcherThread : public ThreadSystem::Thread {
   public:
    ProcessDeathWatcherThread(ThreadSystem* thread_system,
                              int parent_read_fd,
                              ControllerProcess* process,
                              MessageHandler* handler);

    ~ProcessDeathWatcherThread();

    void Run() override;

    void Stop();

    bool parent_death_detected() const { return parent_death_detected_; }

   private:
    MessageHandler* handler_;
    const int parent_read_fd_;
    int stop_read_fd_;
    int stop_write_fd_;
    ControllerProcess* process_;
    bool parent_death_detected_;

    
  };

  static int controller_write_fd_;

  
};

}  

#endif