worker mixin.

examples/stock-quotes/app.js

@@ -2,6 +2,7 @@ var path = require('path')
   , connect = require('connect')
   , sio = require('socket.io')
   , RedisStore = sio.RedisStore
+  , worker = require('../../').worker
 
 var port = process.argv[2] || 8880
   , id = process.argv[3] || 0

examples/stock-quotes/data.js

@@ -5,6 +5,7 @@
  */
 
 var announce = require('socket.io-announce').createClient()
+  , worker = require('../../').worker
 
 /* fake data stream */
 var symbols = 'THOO GOOF EXIT BOP SDD ALPP RIGM OPPL HPBG'.split(' ')

index.js

@@ -15,3 +15,9 @@ exports = module.exports = require('./lib/mixture.js')
  */
 
 exports.version = require('./package.json').version
+
+/**
+ * Worker mixin
+ */
+
+exports.worker = require('./lib/worker')

lib/task.js

@@ -79,6 +79,7 @@ Task.prototype.fork = function(filename, args, options) {
 
   // Node's `NODE_WORKER_ID` has too much behavior attached to it.
   envCopy['MIXTURE_WORKER_ID'] = id
+  envCopy['MIXTURE_TASK_NAME'] = this.name
 
   for (var x in this.options) {
     mergedOptions[x] = this.options[x]

lib/worker.js

@@ -0,0 +1,37 @@
+/*!
+ * mixture
+ * Copyright(c) 2011 Daniel D. Shaw <dshaw@dshaw.com>
+ * MIT Licensed
+ */
+
+/**
+ * Exports.
+ */
+
+var send     = exports.send     = process.send || noop
+var taskName = exports.taskName = process.env.MIXTURE_TASK_NAME
+var workerId = exports.workerId = parseInt(process.env.MIXTURE_WORKER_ID)
+
+/**
+ * Noop.
+ */
+
+function noop () { console.log('worker noop', arguments) }
+
+/**
+ * Master Message handler.
+ */
+
+function onMasterMessage () { console.log('worker message', arguments) }
+
+/**
+ * Receive messages from Mix Master.
+ */
+
+process.on('message', onMasterMessage)
+
+/**
+ * Notify Mix Master.
+ */
+
+send({ 'worker:online' : workerId, task: taskName, pid: process.pid })