Function oncomplete

lib/node.io/process_master.js:238–274

()

        }

        var oncomplete = function () {

            //Output information about job running time, benchmarks, etc. if
            //the `benchmark` op is set
            var time;
            if (job.options.benchmark) {
                var mb_read, mb_written, MB = 1024 * 1024, now = new Date();

                var round = function (val) {
                    return Math.round(val * 1000) / 1000;
                };

                time = (now - job.start_time) / 1000;
                mb_read = round(job.obj.getBytesRead() / MB);
                mb_written = round(job.obj.getBytesWritten() / MB);

                if (mb_read) {
                    self.status(
                        'Read ' + mb_read + 'MB (' + round(mb_read / time) + 'MB/s)'
                    , 'ok');
                }

                if (mb_written) {
                    self.status(
                        'Wrote ' + mb_written + 'MB (' + round(mb_written / time) + 'MB/s)'
                    , 'ok');
                }
            }

            //Wait for output streams to drain, then we're done
            job.obj.waitForOutputStreamDrains.apply(job.obj, [function () {
                self.status('Job complete' + (time ? 'd in ' + time + 's' : ''), 'ok');
                var oncomplete = job.oncomplete;
                self.jobs[job.id] = null;
                oncomplete();
            }]);
        };

        //Call job.complete() if it's defined
        if (typeof job.obj.complete === 'function') {