03_max_requests_per_child.js

var fs  = require('fs'),
assert  = require('assert'),
http    = require('http'),
cluster = require('cluster'),
async   = require('async'),
angel   = require('../angel'),
app     = require('./_app.js');

// this will be our test app's response body
var expected_body = process.env.NODE_ANGEL_TEST_MESSAGE = "Hello";

angel( app, {
    port                   : 0,
    workers                : 1,
    max_requests_per_child : 2,
} );

function sendRequest( port, callback ) {
    http.get({
        host: 'localhost',
        port: port,
        path: '/'
    }, function(res) {
        var body = '';
        res.on('data', function(chunk) {
            body += chunk;
        });
        res.on('end', function() {
            callback( body );
        });
    });
}

function runTest (port) {
    var jobs = []
    , requests_count = 10;
    while ( requests_count -- ) {
        jobs.push( function(callback) {
            sendRequest( port, function(body) {
                callback( null, body );
            });
        });
    }
    async.series( jobs, function (err, results) {
        assert( err === null, 'no errors' );

        var worker_pids = {};
        results.forEach( function( result ) {
            worker_pids[ result.split(/:/).pop() ] = 1;
        });
        assert( Object.keys( worker_pids ).length === 5,
                '10 requests to 1 worker with 2 max_requests_per_child -> 5' );

        console.log( 'Result: PASS' );

        process.exit(0);
    });
}

if ( process.version.match(/v0\.6/) ) {
    // cheat, 0.6 doesn't have cluster.workers, so forget them
    console.log( "Result: PASS" );
    process.exit(0);
}
// worker tells master where the worker is listening on
// master uses that port to request
if ( cluster.isMaster ) {
    Object.keys(cluster.workers).forEach( function(id) {
        cluster.workers[id].on("message", function(m) {
            switch (m.cmd) {
            case "listening":
                runTest( m.address.port );
                break;
            }
        });
    });
}