lib/server_instance.js
function (test) {
    var self = this,
        runner;

    runner = this.runner = cluster.fork({
      WORKER_SCRIPT         : './runner',
      WORKER_TEST           : test,
      WORKER_PORT           : this.getPort(),
      REQUESTED_PORTS       : this.requestedPorts,
      WORKER_MAX_MEMORY     : this.maxMemory,
      WORKER_MAX_TESTS      : this.maxTests,
      WORKER_SLOW           : this.slow,
      WORKER_TIMEOUT        : this.timeout,
      TEST_TYPE             : this.testType,
      SUPPORT_FILES         : this.supportFiles,
      REPORTS_URL           : this.reportsUrl,
      COMPILER_MODULES      : this.compilerModules
    });

    runner.on('message', function (message) {
      switch (message.type) {
        case 'testResults':
        case 'suiteDone':
          self.emit(message.type, message);
          break;
        default:
          try {
            message.runnerId = runner.id
            self.server.send(message);
          } catch (e) {
            self.disconnectNow();
          }
      }
    });

    runner.on('exit', function () {
      self._onDone();
    });

    runner.on('disconnect', function () {
      self._onDone();
    });
  }
function (test) {
    var self = this,
        runner;

    runner = this.runner = cluster.fork({
      WORKER_SCRIPT         : './runner',
      WORKER_TEST           : test,
      WORKER_PORT           : this.getPort(),
      REQUESTED_PORTS       : this.requestedPorts,
      WORKER_MAX_MEMORY     : this.maxMemory,
      WORKER_MAX_TESTS      : this.maxTests,
      WORKER_SLOW           : this.slow,
      WORKER_TIMEOUT        : this.timeout,
      TEST_TYPE             : this.testType,
      SUPPORT_FILES         : this.supportFiles,
      REPORTS_URL           : this.reportsUrl,
      COMPILER_MODULES      : this.compilerModules
    });

    runner.on('message', function (message) {
      switch (message.type) {
        case 'testResults':
        case 'suiteDone':
          self.emit(message.type, message);
          break;
        default:
          try {
            message.runnerId = runner.id
            self.server.send(message);
          } catch (e) {
            self.disconnectNow();
          }
      }
    });

    runner.on('exit', function () {
      self._onDone();
    });

    runner.on('disconnect', function () {
      self._onDone();
    });
  }
function ( test ) { var self = this , runner ; runner = this . runner = cluster . fork ( { WORKER_SCRIPT : './runner' , WORKER_TEST : test , WORKER_PORT : this . getPort ( ) , REQUESTED_PORTS : this . requestedPorts , WORKER_MAX_MEMORY : this . maxMemory , WORKER_MAX_TESTS : this . maxTests , WORKER_SLOW : this . slow , WORKER_TIMEOUT : this . timeout , TEST_TYPE : this . testType , SUPPORT_FILES : this . supportFiles , REPORTS_URL : this . reportsUrl , COMPILER_MODULES : this . compilerModules } ) ; runner . on ( 'message' , function ( message ) { switch ( message . type ) { case 'testResults' : case 'suiteDone' : self . emit ( message . type , message ) ; break ; default : try { message . runnerId = runner . id self . server . send ( message ) ; } catch ( e ) { self . disconnectNow ( ) ; } } } ) ; runner . on ( 'exit' , function ( ) { self . _onDone ( ) ; } ) ; runner . on ( 'disconnect' , function ( ) { self . _onDone ( ) ; } ) ; }
ServerInstance.run(test)
- test (String)
ServerInstance . run ( test ) - test ( String )