Argthtjtr

I have built a node js http server and need to send an answer automatically if the request takes more than a period. I need the process to be stopped, because I want resources to be freed for other requests. I have succeeded to get my automatic answer but in my logs I still have traces that the code is still executed until the end... How can I do that?

Here is a sample of my code:

function processWithQueries(path, params, res) {

        switch (path) {

            case '/join' : 

                mountjoin(params, res);

                break;

            case '/left' : 

                mountleft(params, res);

                break;

            ....

            default:

                illegal(path, params, res);

        }



}

var server = http.createServer(function (req, res) {

    try {

        var body = '';

        var myreq = '';

        var path = '';

        var data = null;



        res.setTimeout(maxtimeout, function(){

            res.writeHead(200, {'custom-header': 1, 'Access-Control-Allow-Origin': '*'});

            res.end();

            accesslogger.info(os.hostname() + ' [200] path ' + path + ' req timeout ' + maxtimeout + 'ms exceeded', data);

            req.socket.destroy();

            return;

        });

        host = req.headers.host.split(':');

        if (host[0] != 'localhost') {

            applogger.error(os.hostname() + ' no local host');

            res.writeHead(403);

            res.end('Forbidden');

        } else {

            if (req.method == 'POST') {

                req.on('data', function (data) {

                    body += data;

                    if (body.length > 40000) { // FLOOD ATTACK OR FAULTY CLIENT, NUKE REQUEST

                        applogger.error(os.hostname() + ' FLOOD ATTACK OR FAULTY CLIENT', body);

                        req.connection.destroy();

                        res.writeHead(500);

                        res.end('Internal Server Error');

                    }

                });

                req.on('end', function () {

                    myreq = url.parse(req.url, true);

                    path = myreq.pathname;

                    data = qs.parse(body);

                    processWithQueries(path, data, res);

                });

            } else if (req.method == 'GET') { // for tests only

                myreq = url.parse(req.url, true);

                path = myreq.pathname;

                data = myreq.query;

                processWithQueries(path, data, res);

            } else {

                illegal(res);

            }

        }

    } catch (err) {

        res.writeHead(200, {'custom-header': 1, 'Access-Control-Allow-Origin': '*'});

        res.end();

        applogger.error(os.hostname() + ' Icecasttreatment exception', err);

        accesslogger.info(os.hostname() + ' [200] exception but auth sent', err);

    }

}).on('error', function (err) {

    applogger.error(os.hostname() + ' server error', err);

}).listen(listenport);

catch code never happens, nor the error case. However functions like mountjoin and mountleft are completely executed but should be interrupted.