Windshaft-cartodb/cluster.js

/*
 * Windshaft-CartoDB
 * ===============
 *
 * ./app.js [environment]
 *
 * environments: [development, production]
 */

var Cluster = require('cluster2');

// sanity check
var ENV = process.argv[2]
if (ENV != 'development' && ENV != 'production' && ENV != 'staging'){
    console.error("\nnode app.js [environment]");
    console.error("environments: [development, production, staging]\n");
    process.exit(1);
}

var _ = require('underscore')
    , Step       = require('step')
	, CartodbWindshaft = require('./lib/cartodb/cartodb_windshaft');
    

// set environment specific variables
global.settings     = require(__dirname + '/config/settings');
global.environment  = require(__dirname + '/config/environments/' + ENV);
_.extend(global.settings, global.environment);

// Include cart_data.js only _after_ the "global" variable is set
// See https://github.com/Vizzuality/Windshaft-cartodb/issues/28
var cartoData = require('./lib/cartodb/carto_data');

var Windshaft = require('windshaft');
var serverOptions = require('./lib/cartodb/server_options');

var ws = CartodbWindshaft(serverOptions);

// Maximum number of connections for one process (see apps.js)
ws.maxConnections = global.environment.maxConnections || 128;

//.use(cluster.logger('logs'))
//.use(cluster.stats())
//.use(cluster.pidfiles('pids'))
var cluster = new Cluster({
  port: global.environment.port,
  host: global.environment.host,
  monPort: global.environment.port+1,
  monHost: global.environment.host,
  timeout: global.environment.socket_timeout,
  noWorkers: 1 
});

console.log(new Date().toISOString() + " - " + process.pid + " - Windshaft cluster starting");

cluster.listen(function(cb) {
  cb(ws);
}, function() {
  console.log("Windshaft tileserver started on port " + global.environment.port);
});

process.on('SIGUSR1', function() {
  ws.dumpCacheStats();
});