Cleaned up style in example frameworks.

Review: https://reviews.apache.org/r/61137/


Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/d5a7c222
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/d5a7c222
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/d5a7c222

Branch: refs/heads/master
Commit: d5a7c2229d2aba23f62599b25c651cd2ca669eb7
Parents: 4b9a543
Author: Armand Grillet <agril...@mesosphere.io>
Authored: Thu Aug 10 17:08:32 2017 +0200
Committer: Alexander Rukletsov <al...@apache.org>
Committed: Thu Aug 10 18:26:07 2017 +0200

----------------------------------------------------------------------
 src/examples/balloon_framework.cpp             | 35 ++++++---------
 src/examples/disk_full_framework.cpp           |  6 +--
 src/examples/docker_no_executor_framework.cpp  |  4 +-
 src/examples/dynamic_reservation_framework.cpp |  1 +
 src/examples/load_generator_framework.cpp      |  3 +-
 src/examples/long_lived_framework.cpp          | 34 +++++++--------
 src/examples/no_executor_framework.cpp         | 47 +++++++--------------
 src/examples/persistent_volume_framework.cpp   | 45 +++++++++-----------
 src/examples/test_framework.cpp                | 31 ++++++++------
 src/examples/test_http_framework.cpp           | 42 +++++++++---------
 10 files changed, 108 insertions(+), 140 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/balloon_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/balloon_framework.cpp 
b/src/examples/balloon_framework.cpp
index 08cf566..1a97f56 100644
--- a/src/examples/balloon_framework.cpp
+++ b/src/examples/balloon_framework.cpp
@@ -67,6 +67,7 @@ constexpr char EXECUTOR_BINARY[] = "balloon-executor";
 constexpr char FRAMEWORK_PRINCIPAL[] = "balloon-framework-cpp";
 constexpr char FRAMEWORK_METRICS_PREFIX[] = "balloon_framework";
 
+
 class Flags : public virtual flags::FlagsBase
 {
 public:
@@ -240,8 +241,8 @@ public:
       task.set_data(stringify(flags.task_memory_usage_limit));
 
       task.mutable_executor()->CopyFrom(executor);
-      task.mutable_executor()->mutable_executor_id()
-        ->set_value(stringify(taskId));
+      task.mutable_executor()->mutable_executor_id()->set_value(
+          stringify(taskId));
 
       driver->launchTasks(offer.id(), {task});
 
@@ -397,27 +398,21 @@ public:
   {
     LOG(INFO) << "Registered with framework ID: " << frameworkId;
 
-    process::dispatch(
-        &process,
-        &BalloonSchedulerProcess::registered);
+    process::dispatch(&process, &BalloonSchedulerProcess::registered);
   }
 
   virtual void reregistered(SchedulerDriver*, const MasterInfo& masterInfo)
   {
     LOG(INFO) << "Reregistered";
 
-    process::dispatch(
-        &process,
-        &BalloonSchedulerProcess::registered);
+    process::dispatch(&process, &BalloonSchedulerProcess::registered);
   }
 
   virtual void disconnected(SchedulerDriver* driver)
   {
     LOG(INFO) << "Disconnected";
 
-    process::dispatch(
-        &process,
-        &BalloonSchedulerProcess::disconnected);
+    process::dispatch(&process, &BalloonSchedulerProcess::disconnected);
   }
 
   virtual void resourceOffers(
@@ -433,21 +428,18 @@ public:
         offers);
   }
 
-  virtual void offerRescinded(
-      SchedulerDriver* driver,
-      const OfferID& offerId)
+  virtual void offerRescinded(SchedulerDriver* driver, const OfferID& offerId)
   {
     LOG(INFO) << "Offer rescinded";
   }
 
   virtual void statusUpdate(SchedulerDriver* driver, const TaskStatus& status)
   {
-    LOG(INFO)
-      << "Task " << status.task_id() << " in state "
-      << TaskState_Name(status.state())
-      << ", Source: " << status.source()
-      << ", Reason: " << status.reason()
-      << (status.has_message() ? ", Message: " + status.message() : "");
+    LOG(INFO) << "Task " << status.task_id() << " in state "
+              << TaskState_Name(status.state())
+              << ", Source: " << status.source()
+              << ", Reason: " << status.reason()
+              << (status.has_message() ? ", Message: " + status.message() : 
"");
 
     process::dispatch(
         &process,
@@ -601,8 +593,7 @@ int main(int argc, char** argv)
   } else {
     framework.set_principal(FRAMEWORK_PRINCIPAL);
 
-    driver = new MesosSchedulerDriver(
-        &scheduler, framework, flags.master);
+    driver = new MesosSchedulerDriver(&scheduler, framework, flags.master);
   }
 
   int status = driver->run() == DRIVER_STOPPED ? 0 : 1;

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/disk_full_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/disk_full_framework.cpp 
b/src/examples/disk_full_framework.cpp
index 5eacc81..f9d5af5 100644
--- a/src/examples/disk_full_framework.cpp
+++ b/src/examples/disk_full_framework.cpp
@@ -40,7 +40,6 @@
 #include <stout/os.hpp>
 #include <stout/try.hpp>
 
-
 using namespace mesos;
 
 using std::string;
@@ -51,7 +50,6 @@ using process::defer;
 using process::metrics::Gauge;
 using process::metrics::Counter;
 
-
 const double CPUS_PER_TASK = 0.1;
 const int MEMORY_PER_TASK = 16;
 const Bytes DISK_PER_TASK = Megabytes(5);
@@ -59,6 +57,7 @@ const Bytes DISK_PER_TASK = Megabytes(5);
 constexpr char FRAMEWORK_PRINCIPAL[] = "disk-full-framework-cpp";
 constexpr char FRAMEWORK_METRICS_PREFIX[] = "disk_full_framework";
 
+
 class Flags : public virtual flags::FlagsBase
 {
 public:
@@ -485,8 +484,7 @@ int main(int argc, char** argv)
   } else {
     framework.set_principal(FRAMEWORK_PRINCIPAL);
 
-    driver = new MesosSchedulerDriver(
-        &scheduler, framework, flags.master);
+    driver = new MesosSchedulerDriver(&scheduler, framework, flags.master);
   }
 
   int status = driver->run() == DRIVER_STOPPED ? 0 : 1;

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/docker_no_executor_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/docker_no_executor_framework.cpp 
b/src/examples/docker_no_executor_framework.cpp
index 312d281..8e1844e 100644
--- a/src/examples/docker_no_executor_framework.cpp
+++ b/src/examples/docker_no_executor_framework.cpp
@@ -42,6 +42,7 @@ const int32_t MEM_PER_TASK = 32;
 constexpr char FRAMEWORK_NAME[] = "Docker No Executor Framework (C++)";
 constexpr char FRAMEWORK_PRINCIPAL[] = "no-executor-framework-cpp";
 
+
 class DockerNoExecutorScheduler : public Scheduler
 {
 public:
@@ -214,8 +215,7 @@ int main(int argc, char** argv)
   } else {
     framework.set_principal(FRAMEWORK_PRINCIPAL);
 
-    driver = new MesosSchedulerDriver(
-        &scheduler, framework, argv[1]);
+    driver = new MesosSchedulerDriver(&scheduler, framework, argv[1]);
   }
 
   int status = driver->run() == DRIVER_STOPPED ? 0 : 1;

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/dynamic_reservation_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/dynamic_reservation_framework.cpp 
b/src/examples/dynamic_reservation_framework.cpp
index f378479..bb6f58b 100644
--- a/src/examples/dynamic_reservation_framework.cpp
+++ b/src/examples/dynamic_reservation_framework.cpp
@@ -44,6 +44,7 @@ const int32_t MEM_PER_TASK = 128;
 
 constexpr char FRAMEWORK_NAME[] = "Dynamic Reservation Framework (C++)";
 
+
 // The framework reserves resources to run at most one task at a time
 // on each agent; the resources are reserved when they are offered to
 // the framework for the first time, and are unreserved when all tasks

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/load_generator_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/load_generator_framework.cpp 
b/src/examples/load_generator_framework.cpp
index f30895b..653ae81 100644
--- a/src/examples/load_generator_framework.cpp
+++ b/src/examples/load_generator_framework.cpp
@@ -43,6 +43,7 @@ using std::vector;
 
 constexpr char FRAMEWORK_NAME[] = "Load Generator Framework (C++)";
 
+
 // Generate load towards the master (by repeatedly sending
 // ReconcileTasksMessages) at the specified rate and for the
 // specified duration.
@@ -66,7 +67,7 @@ private:
     watch.start();
 
     while (true) {
-      Duration elapsed =  watch.elapsed();
+      Duration elapsed = watch.elapsed();
 
       if (duration.isSome() && elapsed >= duration.get()) {
         LOG(INFO) << "LoadGenerator generated " << messages

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/long_lived_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/long_lived_framework.cpp 
b/src/examples/long_lived_framework.cpp
index 61ea64f..3de4a02 100644
--- a/src/examples/long_lived_framework.cpp
+++ b/src/examples/long_lived_framework.cpp
@@ -84,7 +84,6 @@ using process::http::OK;
 using process::metrics::Gauge;
 using process::metrics::Counter;
 
-
 // NOTE: Per-task resources are nominal because all of the resources for the
 // container are provisioned when the executor is created. The executor can
 // run multiple tasks at once, but uses a constant amount of resources
@@ -100,6 +99,7 @@ constexpr char EXECUTOR_NAME[] = "Long Lived Executor (C++)";
 constexpr char FRAMEWORK_NAME[] = "Long Lived Framework (C++)";
 constexpr char FRAMEWORK_METRICS_PREFIX[] = "long_lived_framework";
 
+
 // This scheduler picks one agent and repeatedly launches sleep tasks on it,
 // using a single multi-task executor. If the agent or executor fails, the
 // scheduler will pick another agent and continue launching sleep tasks.
@@ -136,13 +136,14 @@ protected:
   {
     // We initialize the library here to ensure that callbacks are only invoked
     // after the process has spawned.
-    mesos.reset(new Mesos(
-      master,
-      mesos::ContentType::PROTOBUF,
-      process::defer(self(), &Self::connected),
-      process::defer(self(), &Self::disconnected),
-      process::defer(self(), &Self::received, lambda::_1),
-      credential));
+    mesos.reset(
+        new Mesos(
+            master,
+            mesos::ContentType::PROTOBUF,
+            process::defer(self(), &Self::connected),
+            process::defer(self(), &Self::disconnected),
+            process::defer(self(), &Self::received, lambda::_1),
+            credential));
   }
 
   void connected()
@@ -190,8 +191,7 @@ protected:
 
       switch (event.type()) {
         case Event::SUBSCRIBED: {
-          framework.mutable_id()->
-            CopyFrom(event.subscribed().framework_id());
+          framework.mutable_id()->CopyFrom(event.subscribed().framework_id());
 
           LOG(INFO) << "Subscribed with ID '" << framework.id() << "'";
 
@@ -263,11 +263,11 @@ protected:
         // No active executor running in the cluster.
         // Launch a new task with executor.
 
-        if (Resources(offer.resources()).toUnreserved()
-            .contains(taskResources + executorResources)) {
-          LOG(INFO)
-            << "Starting executor and task " << tasksLaunched
-            << " on " << offer.hostname();
+        if (Resources(offer.resources())
+              .toUnreserved()
+              .contains(taskResources + executorResources)) {
+          LOG(INFO) << "Starting executor and task " << tasksLaunched << " on "
+                    << offer.hostname();
 
           launch(offer);
 
@@ -282,8 +282,8 @@ protected:
         if (Resources(offer.resources())
               .toUnreserved()
               .contains(taskResources)) {
-          LOG(INFO)
-            << "Starting task " << tasksLaunched << " on " << offer.hostname();
+          LOG(INFO) << "Starting task " << tasksLaunched << " on "
+                    << offer.hostname();
 
           launch(offer);
         } else {

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/no_executor_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/no_executor_framework.cpp 
b/src/examples/no_executor_framework.cpp
index 8d31db3..2ca240b 100644
--- a/src/examples/no_executor_framework.cpp
+++ b/src/examples/no_executor_framework.cpp
@@ -93,8 +93,7 @@ public:
     LOG(INFO) << "Reregistered with master " << masterInfo;
   }
 
-  virtual void disconnected(
-      SchedulerDriver* driver)
+  virtual void disconnected(SchedulerDriver* driver)
   {
     LOG(INFO) << "Disconnected!";
   }
@@ -132,16 +131,12 @@ public:
     }
   }
 
-  virtual void offerRescinded(
-      SchedulerDriver* driver,
-      const OfferID& offerId)
+  virtual void offerRescinded(SchedulerDriver* driver, const OfferID& offerId)
   {
     LOG(INFO) << "Offer " << offerId << " has been rescinded";
   }
 
-  virtual void statusUpdate(
-      SchedulerDriver* driver,
-      const TaskStatus& status)
+  virtual void statusUpdate(SchedulerDriver* driver, const TaskStatus& status)
   {
     if (!activeTasks.contains(status.task_id())) {
       LOG(WARNING) << "Unknown task '" << status.task_id() << "'"
@@ -194,9 +189,7 @@ public:
                << "' on agent " << slaveId << ": '" << data << "'";
   }
 
-  virtual void slaveLost(
-      SchedulerDriver* driver,
-      const SlaveID& slaveId)
+  virtual void slaveLost(SchedulerDriver* driver, const SlaveID& slaveId)
   {
     LOG(INFO) << "Lost agent " << slaveId;
   }
@@ -211,9 +204,7 @@ public:
               << slaveId << ", " << WSTRINGIFY(status);
   }
 
-  virtual void error(
-      SchedulerDriver* driver,
-      const string& message)
+  virtual void error(SchedulerDriver* driver, const string& message)
   {
     LOG(ERROR) << message;
   }
@@ -302,8 +293,7 @@ int main(int argc, char** argv)
   Try<flags::Warnings> load = flags.load("MESOS_", argc, argv);
 
   if (load.isError()) {
-    EXIT(EXIT_FAILURE)
-      << flags.usage(load.error());
+    EXIT(EXIT_FAILURE) << flags.usage(load.error());
   }
 
   // Log any flag warnings.
@@ -312,19 +302,17 @@ int main(int argc, char** argv)
   }
 
   if (flags.help) {
-    EXIT(EXIT_SUCCESS)
-      << flags.usage();
+    EXIT(EXIT_SUCCESS) << flags.usage();
   }
 
   if (flags.master.isNone()) {
-    EXIT(EXIT_FAILURE)
-      << flags.usage("Missing required option --master");
+    EXIT(EXIT_FAILURE) << flags.usage("Missing required option --master");
   }
 
   if (flags.principal.isSome() != flags.secret.isSome()) {
-    EXIT(EXIT_FAILURE)
-      << flags.usage("Both --principal and --secret are required"
-                     " to enable authentication");
+    EXIT(EXIT_FAILURE) << flags.usage(
+        "Both --principal and --secret are required"
+        " to enable authentication");
   }
 
   FrameworkInfo framework;
@@ -343,13 +331,11 @@ int main(int argc, char** argv)
     framework.set_principal(flags.principal.get());
   }
 
-  Try<Resources> resources =
-    Resources::parse(flags.task_resources);
+  Try<Resources> resources = Resources::parse(flags.task_resources);
 
   if (resources.isError()) {
-    EXIT(EXIT_FAILURE)
-      << flags.usage("Invalid --task_resources: " +
-                     resources.error());
+    EXIT(EXIT_FAILURE) << flags.usage(
+        "Invalid --task_resources: " + resources.error());
   }
 
   Resources taskResources = resources.get();
@@ -359,9 +345,8 @@ int main(int argc, char** argv)
       Resources::parse(flags.task_revocable_resources.get());
 
     if (revocableResources.isError()) {
-      EXIT(EXIT_FAILURE)
-        << flags.usage("Invalid --task_revocable_resources: " +
-                       revocableResources.error());
+      EXIT(EXIT_FAILURE) << flags.usage(
+          "Invalid --task_revocable_resources: " + revocableResources.error());
     }
 
     foreach (Resource revocable, revocableResources.get()) {

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/persistent_volume_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/persistent_volume_framework.cpp 
b/src/examples/persistent_volume_framework.cpp
index 46add06..bce2a2d 100644
--- a/src/examples/persistent_volume_framework.cpp
+++ b/src/examples/persistent_volume_framework.cpp
@@ -54,6 +54,7 @@ using std::vector;
 
 constexpr char FRAMEWORK_NAME[] = "Persistent Volume Framework (C++)";
 
+
 // TODO(jieyu): Currently, persistent volume is only allowed for
 // reserved resources.
 static Resources SHARD_INITIAL_RESOURCES(const string& role)
@@ -145,20 +146,22 @@ public:
   {
     // Initialize the shards using regular persistent volume.
     for (size_t i = 0; i < numShards; i++) {
-      shards.push_back(Shard(
-          "shard-" + stringify(i),
-          frameworkInfo.role(),
-          tasksPerShard,
-          false));
+      shards.push_back(
+          Shard(
+              "shard-" + stringify(i),
+              frameworkInfo.role(),
+              tasksPerShard,
+              false));
     }
 
     // Initialize the shards using shared persistent volume.
     for (size_t i = 0; i < numSharedShards; i++) {
-      shards.push_back(Shard(
-          "shared-shard-" + stringify(i),
-          frameworkInfo.role(),
-          tasksPerShard,
-          true));
+      shards.push_back(
+          Shard(
+              "shared-shard-" + stringify(i),
+              frameworkInfo.role(),
+              tasksPerShard,
+              true));
     }
   }
 
@@ -180,8 +183,7 @@ public:
     LOG(INFO) << "Reregistered with master " << masterInfo;
   }
 
-  virtual void disconnected(
-      SchedulerDriver* driver)
+  virtual void disconnected(SchedulerDriver* driver)
   {
     LOG(INFO) << "Disconnected!";
   }
@@ -343,16 +345,12 @@ public:
     }
   }
 
-  virtual void offerRescinded(
-      SchedulerDriver* driver,
-      const OfferID& offerId)
+  virtual void offerRescinded(SchedulerDriver* driver, const OfferID& offerId)
   {
     LOG(INFO) << "Offer " << offerId << " has been rescinded";
   }
 
-  virtual void statusUpdate(
-      SchedulerDriver* driver,
-      const TaskStatus& status)
+  virtual void statusUpdate(SchedulerDriver* driver, const TaskStatus& status)
   {
     LOG(INFO) << "Task '" << status.task_id() << "' is in state "
               << status.state();
@@ -402,9 +400,7 @@ public:
               << "' on agent " << slaveId << ": '" << data << "'";
   }
 
-  virtual void slaveLost(
-      SchedulerDriver* driver,
-      const SlaveID& slaveId)
+  virtual void slaveLost(SchedulerDriver* driver, const SlaveID& slaveId)
   {
     LOG(INFO) << "Lost agent " << slaveId;
   }
@@ -419,9 +415,7 @@ public:
               << slaveId << ", " << WSTRINGIFY(status);
   }
 
-  virtual void error(
-      SchedulerDriver* driver,
-      const string& message)
+  virtual void error(SchedulerDriver* driver, const string& message)
   {
     LOG(ERROR) << message;
   }
@@ -458,8 +452,7 @@ private:
     // The persistent volume associated with this shard.
     struct Volume
     {
-      explicit Volume(bool _isShared)
-        : isShared(_isShared) {}
+      explicit Volume(bool _isShared) : isShared(_isShared) {}
 
       // `Resource` object for this volume.
       Option<Resource> resource;

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/test_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/test_framework.cpp b/src/examples/test_framework.cpp
index 0f2f97d..a6b38f0 100644
--- a/src/examples/test_framework.cpp
+++ b/src/examples/test_framework.cpp
@@ -56,6 +56,7 @@ constexpr char EXECUTOR_NAME[] = "Test Executor (C++)";
 constexpr char FRAMEWORK_NAME[] = "Test Framework (C++)";
 constexpr char FRAMEWORK_PRINCIPAL[] = "test-framework-cpp";
 
+
 class TestScheduler : public Scheduler
 {
 public:
@@ -135,8 +136,8 @@ public:
     }
   }
 
-  virtual void offerRescinded(SchedulerDriver* driver,
-                              const OfferID& offerId) {}
+  virtual void offerRescinded(SchedulerDriver* driver, const OfferID& offerId)
+  {}
 
   virtual void statusUpdate(SchedulerDriver* driver, const TaskStatus& status)
   {
@@ -155,8 +156,7 @@ public:
            << " is in unexpected state " << status.state()
            << " with reason " << status.reason()
            << " from source " << status.source()
-           << " with message '" << status.message() << "'"
-           << endl;
+           << " with message '" << status.message() << "'" << endl;
       driver->abort();
     }
 
@@ -169,17 +169,21 @@ public:
     }
   }
 
-  virtual void frameworkMessage(SchedulerDriver* driver,
-                                const ExecutorID& executorId,
-                                const SlaveID& slaveId,
-                                const string& data) {}
+  virtual void frameworkMessage(
+      SchedulerDriver* driver,
+      const ExecutorID& executorId,
+      const SlaveID& slaveId,
+      const string& data)
+  {}
 
   virtual void slaveLost(SchedulerDriver* driver, const SlaveID& sid) {}
 
-  virtual void executorLost(SchedulerDriver* driver,
-                            const ExecutorID& executorID,
-                            const SlaveID& slaveID,
-                            int status) {}
+  virtual void executorLost(
+      SchedulerDriver* driver,
+      const ExecutorID& executorID,
+      const SlaveID& slaveID,
+      int status)
+  {}
 
   virtual void error(SchedulerDriver* driver, const string& message)
   {
@@ -266,8 +270,7 @@ int main(int argc, char** argv)
 
   value = os::getenv("MESOS_CHECKPOINT");
   if (value.isSome()) {
-    framework.set_checkpoint(
-        numify<bool>(value.get()).get());
+    framework.set_checkpoint(numify<bool>(value.get()).get());
   }
 
   bool implicitAcknowledgements = true;

http://git-wip-us.apache.org/repos/asf/mesos/blob/d5a7c222/src/examples/test_http_framework.cpp
----------------------------------------------------------------------
diff --git a/src/examples/test_http_framework.cpp 
b/src/examples/test_http_framework.cpp
index 7000897..693dd47 100644
--- a/src/examples/test_http_framework.cpp
+++ b/src/examples/test_http_framework.cpp
@@ -15,8 +15,8 @@
 // limitations under the License.
 
 #include <iostream>
-#include <string>
 #include <queue>
+#include <string>
 
 #include <boost/lexical_cast.hpp>
 
@@ -39,7 +39,6 @@
 #include <stout/numify.hpp>
 #include <stout/option.hpp>
 #include <stout/os.hpp>
-#include <stout/option.hpp>
 #include <stout/path.hpp>
 #include <stout/stringify.hpp>
 
@@ -69,6 +68,7 @@ constexpr char EXECUTOR_BINARY[] = "test-http-executor";
 constexpr char EXECUTOR_NAME[] = "Test Executor (C++)";
 constexpr char FRAMEWORK_NAME[] = "Event Call Scheduler using libprocess 
(C++)";
 
+
 class HTTPScheduler : public process::Process<HTTPScheduler>
 {
 public:
@@ -205,26 +205,26 @@ public:
   }
 
 protected:
-virtual void initialize()
-{
-  // We initialize the library here to ensure that callbacks are only invoked
-  // after the process has spawned.
-  mesos.reset(new scheduler::Mesos(
-      master,
-      mesos::ContentType::PROTOBUF,
-      process::defer(self(), &Self::connected),
-      process::defer(self(), &Self::disconnected),
-      process::defer(self(), &Self::received, lambda::_1),
-      None()));
-}
+  virtual void initialize()
+  {
+    // We initialize the library here to ensure that callbacks are only invoked
+    // after the process has spawned.
+    mesos.reset(
+        new scheduler::Mesos(
+            master,
+            mesos::ContentType::PROTOBUF,
+            process::defer(self(), &Self::connected),
+            process::defer(self(), &Self::disconnected),
+            process::defer(self(), &Self::received, lambda::_1),
+            None()));
+  }
 
 private:
   void resourceOffers(const vector<Offer>& offers)
   {
     foreach (const Offer& offer, offers) {
       cout << "Received offer " << offer.id() << " with "
-           << Resources(offer.resources())
-           << endl;
+           << Resources(offer.resources()) << endl;
 
       Resources taskResources = Resources::parse(
           "cpus:" + stringify(CPUS_PER_TASK) +
@@ -244,8 +244,7 @@ private:
 
         TaskInfo task;
         task.set_name("Task " + lexical_cast<string>(taskId));
-        task.mutable_task_id()->set_value(
-            lexical_cast<string>(taskId));
+        task.mutable_task_id()->set_value(lexical_cast<string>(taskId));
         task.mutable_agent_id()->MergeFrom(offer.agent_id());
         task.mutable_executor()->MergeFrom(executor);
 
@@ -348,9 +347,7 @@ private:
 
     mesos->send(call);
 
-    process::delay(Seconds(1),
-                   self(),
-                   &Self::doReliableRegistration);
+    process::delay(Seconds(1), self(), &Self::doReliableRegistration);
   }
 
   void finalize()
@@ -451,8 +448,7 @@ int main(int argc, char** argv)
 
   value = os::getenv("MESOS_CHECKPOINT");
   if (value.isSome()) {
-    framework.set_checkpoint(
-        numify<bool>(value.get()).get());
+    framework.set_checkpoint(numify<bool>(value.get()).get());
   }
 
   ExecutorInfo executor;

Reply via email to