You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by be...@apache.org on 2011/06/05 05:31:59 UTC

svn commit: r1131629 - in /incubator/mesos/trunk/frameworks/daemon: DaemonExecutor.java DaemonScheduler.java

Author: benh
Date: Sun Jun  5 03:31:59 2011
New Revision: 1131629

URL: http://svn.apache.org/viewvc?rev=1131629&view=rev
Log:
Matches the interface now

Modified:
    incubator/mesos/trunk/frameworks/daemon/DaemonExecutor.java
    incubator/mesos/trunk/frameworks/daemon/DaemonScheduler.java

Modified: incubator/mesos/trunk/frameworks/daemon/DaemonExecutor.java
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/frameworks/daemon/DaemonExecutor.java?rev=1131629&r1=1131628&r2=1131629&view=diff
==============================================================================
--- incubator/mesos/trunk/frameworks/daemon/DaemonExecutor.java (original)
+++ incubator/mesos/trunk/frameworks/daemon/DaemonExecutor.java Sun Jun  5 03:31:59 2011
@@ -8,7 +8,7 @@ public class DaemonExecutor extends Exec
   }
 
   @Override
-  public void startTask(final TaskDescription task) {
+  public void launchTask(ExecutorDriver driver, final TaskDescription task) {
     System.out.println("Running task " + task.getName());
     try {
       Thread.sleep(100000);
@@ -16,12 +16,12 @@ public class DaemonExecutor extends Exec
     TaskStatus status = new TaskStatus(task.getTaskId(),
 				       TaskState.TASK_FAILED,
 				       new byte[0]);
-    sendStatusUpdate(status);
+    driver.sendStatusUpdate(status);
   }
 
   
 
   public static void main(String[] args) throws Exception {
-    new DaemonExecutor().run();
+    new NexusExecutorDriver(new DaemonExecutor()).run();
   }
 }

Modified: incubator/mesos/trunk/frameworks/daemon/DaemonScheduler.java
URL: http://svn.apache.org/viewvc/incubator/mesos/trunk/frameworks/daemon/DaemonScheduler.java?rev=1131629&r1=1131628&r2=1131629&view=diff
==============================================================================
--- incubator/mesos/trunk/frameworks/daemon/DaemonScheduler.java (original)
+++ incubator/mesos/trunk/frameworks/daemon/DaemonScheduler.java Sun Jun  5 03:31:59 2011
@@ -6,7 +6,7 @@ import nexus.*;
 public class DaemonScheduler extends Scheduler {
 
   final static String executorScript =
-    "/Users/benh/nexus-github-master/frameworks/daemon/daemon_executor";
+    "/Users/florian/code/nexus-src/frameworks/daemon/daemon_executor";
 
   static Map<String, Configuration> configs =
     new HashMap<String, Configuration>();