Skip to content

Commit

Permalink
[api] Worker spawn command
Browse files Browse the repository at this point in the history
  • Loading branch information
mmalecki committed Dec 9, 2011
1 parent 768f074 commit 831f76f
Showing 1 changed file with 17 additions and 0 deletions.
17 changes: 17 additions & 0 deletions lib/forever/worker.js
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,23 @@ Worker.prototype.start = function (cb) {
socket.data(['data'], function () {
socket.send(['data'], self.monitor.data);
});

socket.data(['spawn'], function (data) {
if (!data.script) {
return socket.send(['spawn', 'error'], { error: new Error('No script given') });
}

if (this.monitor) {
return socket.send(['spawn', 'error'], { error: new Error("Already running") });
}

var monitor = new (forever.Monitor)(data.script, data.options);
monitor.start();

monitor.on('start', function () {
socket.send(['spawn', 'start']);
});
});
});

findSocket(self.sockPath, function (err, sock) {
Expand Down

0 comments on commit 831f76f

Please sign in to comment.