build/index.js
function pushMS(data, socket) {
    logger.debug(`newJob Packet arrived w/ ${util.format(data)}`);
    logger.silly(` Memory size vs nWorker :: ${liveMemory.size()} <<>> ${nWorker}`);
    if (liveMemory.size("notBound") >= nWorker) {
        logger.debug("must refuse packet, max pool size reached");
        jmServer.bouncer(data, socket);
        return;
        // No early exit yet
    }
    jmServer.granted(data, socket).then((_data) => {
        let jobProfile = _data.jobProfile;
        _data.fromConsumerMS = true;
        //pool size
        if (jobLib.isJobOptProxy(_data)) {
            logger.debug(`jobOpt successfully decoded`);
        }
        let job = push(jobProfile, _data);
    });
}
function pushMS(data, socket) {
    logger.debug(`newJob Packet arrived w/ ${util.format(data)}`);
    logger.silly(` Memory size vs nWorker :: ${liveMemory.size()} <<>> ${nWorker}`);
    if (liveMemory.size("notBound") >= nWorker) {
        logger.debug("must refuse packet, max pool size reached");
        jmServer.bouncer(data, socket);
        return;
        // No early exit yet
    }
    jmServer.granted(data, socket).then((_data) => {
        let jobProfile = _data.jobProfile;
        _data.fromConsumerMS = true;
        //pool size
        if (jobLib.isJobOptProxy(_data)) {
            logger.debug(`jobOpt successfully decoded`);
        }
        let job = push(jobProfile, _data);
    });
}
function pushMS ( data , socket ) { logger . debug ( ` ${ util . format ( data ) } ` ) ; logger . silly ( ` ${ liveMemory . size ( ) } ${ nWorker } ` ) ; if ( liveMemory . size ( "notBound" ) >= nWorker ) { logger . debug ( "must refuse packet, max pool size reached" ) ; jmServer . bouncer ( data , socket ) ; return ; // No early exit yet } jmServer . granted ( data , socket ) . then ( ( _data ) => { let jobProfile = _data . jobProfile ; _data . fromConsumerMS = true ; //pool size if ( jobLib . isJobOptProxy ( _data ) ) { logger . debug ( ` ` ) ; } let job = push ( jobProfile , _data ) ; } ) ; }
New job packet arrived on MS socket, 1st arg is streamMap, 2nd the socket
New job packet arrived on MS socket 1st arg is streamMap 2nd the socket