Class BalloonExecutor

src/examples/balloon_executor.cpp:156–233

class BalloonExecutor : public Executor
{
public:
  BalloonExecutor()
    : launched(false) {}

  ~BalloonExecutor() override {}

  void registered(ExecutorDriver* driver,
                          const ExecutorInfo& executorInfo,
                          const FrameworkInfo& frameworkInfo,
                          const SlaveInfo& slaveInfo) override
  {
    LOG(INFO) << "Registered";
  }

  void reregistered(ExecutorDriver* driver,
                            const SlaveInfo& slaveInfo) override
  {
    LOG(INFO) << "Reregistered";
  }

  void disconnected(ExecutorDriver* driver) override
  {
    LOG(INFO) << "Disconnected";
  }

  void launchTask(ExecutorDriver* driver, const TaskInfo& task) override
  {
    if (launched) {
      TaskStatus status;
      status.mutable_task_id()->MergeFrom(task.task_id());
      status.set_state(TASK_FAILED);
      status.set_message(
          "Attempted to run multiple balloon tasks with the same executor");

      driver->sendStatusUpdate(status);
      return;
    }

    LOG(INFO) << "Starting task " << task.task_id().value();

    // NOTE: The executor driver calls `launchTask` synchronously, which
    // means that calls such as `driver->sendStatusUpdate()` will not execute
    // until `launchTask` returns.
    std::thread thread([=]() {
      run(driver, task);
    });

    thread.detach();

    launched = true;
  }

  void killTask(ExecutorDriver* driver, const TaskID& taskId) override
  {
    LOG(INFO) << "Kill task " << taskId.value();
  }