Method MesosProcess

src/executor/executor.cpp:162–349

{
public:
  MesosProcess(
      ContentType _contentType,
      const lambda::function<void(void)>& connected,
      const lambda::function<void(void)>& disconnected,
      const lambda::function<void(const queue<Event>&)>& received,
      const std::map<std::string, std::string>& environment)
    : ProcessBase(generate("executor")),
      state(DISCONNECTED),
      contentType(_contentType),
      callbacks {connected, disconnected, received}
  {
    GOOGLE_PROTOBUF_VERIFY_VERSION;

    // Load any logging flags from the environment.
    logging::Flags flags;

    // Filter out environment variables whose keys don't start with "MESOS_".
    //
    // TODO(alexr): This should be supported by `FlagsBase`, see MESOS-9001.
    std::map<std::string, std::string> mesosEnvironment;

    foreachpair (const string& key, const string& value, environment) {
      if (strings::startsWith(key, "MESOS_")) {
        mesosEnvironment.emplace(key, value);
      }
    }

    Try<flags::Warnings> load = flags.load(mesosEnvironment, true);

    if (load.isError()) {
      EXIT(EXIT_FAILURE) << "Failed to load flags: " << load.error();
    }

    // Initialize libprocess.
    process::initialize();

    // Initialize logging.
    if (flags.initialize_driver_logging) {
      logging::initialize("mesos", false, flags);
    } else {
      VLOG(1) << "Disabling initialization of GLOG logging";
    }

    // Log any flag warnings (after logging is initialized).
    foreach (const flags::Warning& warning, load->warnings) {
      LOG(WARNING) << warning.message;
    }

    LOG(INFO) << "Version: " << MESOS_VERSION;

    spawn(new VersionProcess(), true);

    hashmap<string, string> env(mesosEnvironment);

    // Check if this is local (for example, for testing).
    local = env.contains("MESOS_LOCAL");

    Option<string> value;