worker.js

• Classes
  • Worker
    • constructor
    • configure
    • getIPC

app/cluster/worker.js
  
/**
 * Multi-Threading High Availability Application Worker
 *
 * @module greppy/app/cluster/worker
 * @author Hermann Mayer <hermann.mayer92@gmail.com>
 */
var util      = require('util');
var extend    = require('extend');
var AppWorker = require('../worker');
var WorkerIPC = require('./worker/ipc');
var IPCLogger = require('./worker/ipc/logger');
/**
 * @constructor
 *
 * @param {Object} options - Options object
 * @param {Function} callback - Function to call on finish
 */
var Worker = function(options, callback)
{
    // Setup IPC connection
    this.ipc = new WorkerIPC();
    // Setup the IPC logger transport
    var workerConf = {
        logger: {
            transports: [
                new (IPCLogger)({
                    worker    : this,
                    colorize  : true,
                    timestamp : function() {
                        var part = moment().format().yellow.bold;
                        if (cluster.isMaster) {
                            part += ' [Master]'.red.bold;
                        } else {
                            part += ' [Worker]'.white.bold;
                        }
                        return part;
                    },
                    level  : 'debug',
                    silent : false
                })
            ]
        },
        requestLogger: {
            transports: [
                new (IPCLogger)({
                    type     : 'request',
                    worker   : this,
                    colorize : false,
                    level    : 'info',
                    silent   : false
                })
            ]
        }
    };
    // Extend the given worker configuration
    arguments[0] = extend(true, workerConf, arguments[2] || {});
    // Call the super constructor
    Worker.super_.call(this, options);
};
/**
 * Extend Greppy framework single threading worker
 */
util.inherits(Worker, AppWorker);
/**
 * Setup the worker.
 *
 * @param {Object} app - Express application object
 * @param {Object} server - HTTP(S) server object
 * @param {Function} callback - Function to call on finish
 */
Worker.prototype.configure = function(app, server, callback)
{
    var self = this;
    var setupWorker = function(callback)
    {
        // Bind POSIX and IPC signals
        self.ipc.addBroadcastListener('gracefull.shutdown', function() {
            // Quick shutdown for the debugging mode
            if (self.cliArgs.options.debug) {
                return process.exit(0);
            }
            var shutdown = function()
            {
                logger.info('HTTP server went offline - not accepting connections anymore');
                greppy.db.close(function() {
                    logger.info('Closed all backend connections');
                    // Shutdown the process, without errors
                    process.exit(0);
                });
            };
            try {
                // Close HTTP server
                self.server.close(shutdown);
            } catch (e) {
                console.log(e.stack);
                shutdown();
            }
        });
        // Annotate the worker context to the master via IPC
        self.getIPC().request('worker.annotateContext', self.context);
        callback && callback();
    };
    // Call the super constructor
    Worker.super_.prototype.configure.call(this, app, server, function() {
        setupWorker(callback);
    });
};
/**
 * Get the worker IPC implementation object.
 *
 * @return {Object} The IPC Object
 */
Worker.prototype.getIPC = function()
{
    return this.ipc;
};
module.exports = Worker;