2014-03-04 00:33:55 -08:00
|
|
|
var events = require('events');
|
|
|
|
var cluster = require('cluster');
|
|
|
|
|
|
|
|
var MposCompatibility = require('./mposCompatibility.js');
|
|
|
|
var ShareProcessor = require('./shareProcessor.js');
|
|
|
|
|
|
|
|
|
|
|
|
var processor = module.exports = function processor(logger, poolConfigs){
|
|
|
|
|
|
|
|
var _this = this;
|
|
|
|
|
|
|
|
|
|
|
|
this.init = function(){
|
|
|
|
|
|
|
|
Object.keys(cluster.workers).forEach(function(id) {
|
|
|
|
cluster.workers[id].on('message', function(data){
|
|
|
|
switch(data.type){
|
2014-03-05 14:10:50 -08:00
|
|
|
|
2014-03-04 00:33:55 -08:00
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
processor.prototype.__proto__ = events.EventEmitter.prototype;
|