lib/job-manager.js
/*
 * aborts the job running on the current host
 * @param reason {String}: the reason for abortion
 */
aborts the job running on the current host
@param reason {String}: the reason for abortion
aborts the job running on the current host @param reason { String } : the reason for abortion
function abort(reason) {
     router.ignoreMonitorSocketErrors();
     router.routeToParent({type: 'job:aborted', reason: reason});
     var locals = router.getLocalChannels();
     for(var rank in locals) {
         var proc = locals[rank];
         proc.kill();
     }
     setTimeout(() => {
         console.log();
         for(var socketId in ipc.klyngRemote.of) {
             ipc.klyngRemote.disconnect(socketId);
         }
         router.clear();
     }, 1000);
 }
function abort ( reason ) { router . ignoreMonitorSocketErrors ( ) ; router . routeToParent ( { type : 'job:aborted' , reason : reason } ) ; var locals = router . getLocalChannels ( ) ; for ( var rank in locals ) { var proc = locals [ rank ] ; proc . kill ( ) ; } setTimeout ( ( ) => { console . log ( ) ; for ( var socketId in ipc . klyngRemote . of ) { ipc . klyngRemote . disconnect ( socketId ) ; } router . clear ( ) ; } , 1000 ) ; }
aborts the job running on the current host
 @param reason {String}: the reason for abortion
aborts the job running on the current host @param reason { String } : the reason for abortion
// the nodes by now already recieved a signal to abort the job // handeling any monitor_socket error now (aka aborting the job) // is redundent and useless // kill all local processes // wait for a second to ensure that job:aborted is on the network if possible // disconnect from all remote beacon