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>();