lib/server.js
function Server(options) {
  //TcpServer.call(this, options);

  var onError = onFatalError.bind(this);

  /* istanbul ignore next: always in test env */
  if(process.env.NODE_ENV !== Constants.TEST) {
    process
      .on('error', onError)
      .on('uncaughtException', onError);
  }

  this._tcp = null;
  this._unix = null;

  // are we in the daemonized process
  this._daemonized = false;

  // server state
  this._state = new ServerState();

  this._state.pubsub.on('publish', this.publish.bind(this));

  // map of  monitor listener functions keyed by connection id
  // we need to clean listeners on disconnect
  this._monitor = {};

  // list of command exec handlers
  this.execs = null;

  this.connection = this.connection.bind(this);

  // listen for new connections
  this.on('connection', this.connection);

  this.command = this.command.bind(this);

  ScriptManager.on('command', this.command);

  // setup signals listener
  signals.bind(this)();
}
function Server(options) {
  //TcpServer.call(this, options);

  var onError = onFatalError.bind(this);

  /* istanbul ignore next: always in test env */
  if(process.env.NODE_ENV !== Constants.TEST) {
    process
      .on('error', onError)
      .on('uncaughtException', onError);
  }

  this._tcp = null;
  this._unix = null;

  // are we in the daemonized process
  this._daemonized = false;

  // server state
  this._state = new ServerState();

  this._state.pubsub.on('publish', this.publish.bind(this));

  // map of  monitor listener functions keyed by connection id
  // we need to clean listeners on disconnect
  this._monitor = {};

  // list of command exec handlers
  this.execs = null;

  this.connection = this.connection.bind(this);

  // listen for new connections
  this.on('connection', this.connection);

  this.command = this.command.bind(this);

  ScriptManager.on('command', this.command);

  // setup signals listener
  signals.bind(this)();
}
function Server ( options ) { //TcpServer.call(this, options); var onError = onFatalError . bind ( this ) ; /* istanbul ignore next: always in test env */ if ( process . env . NODE_ENV !== Constants . TEST ) { process . on ( 'error' , onError ) . on ( 'uncaughtException' , onError ) ; } this . _tcp = null ; this . _unix = null ; // are we in the daemonized process this . _daemonized = false ; // server state this . _state = new ServerState ( ) ; this . _state . pubsub . on ( 'publish' , this . publish . bind ( this ) ) ; // map of  monitor listener functions keyed by connection id // we need to clean listeners on disconnect this . _monitor = { } ; // list of command exec handlers this . execs = null ; this . connection = this . connection . bind ( this ) ; // listen for new connections this . on ( 'connection' , this . connection ) ; this . command = this . command . bind ( this ) ; ScriptManager . on ( 'command' , this . command ) ; // setup signals listener signals . bind ( this ) ( ) ; }
Redis server.
Redis server .