Method _reopenStream

lib/utilities/serverAccessLogger.js:85–131

()

    }

    _reopenStream() {
        fs.open(this._filename, 'a', 0o644, (err, fd) => {
            if (err) {
                logger.error('ServerAccessLogger: failed to reopenStream: open error', err);
                setTimeout(() => { this._reopenStream(); }, this._retryReopenDelayMS);
                return;
            }

            fs.fstat(fd, (err, stat) => {
                if (err || this._terminated) {
                    if (this._terminated) {
                        logger.error('ServerAccessLogger: terminated aborting reopen');
                        fs.close(fd);
                        return;
                    }

                    logger.error('ServerAccessLogger: failed to reopenStream: stat error', err);
                    fs.close(fd);
                    setTimeout(() => { this._reopenStream(); }, this._retryReopenDelayMS);
                    return;
                }

                if (this.stream) {
                    this._cleanOldStream(true);
                }

                this._stat = stat;
                this.stream = fs.createWriteStream(this._filename, {
                    encoding: 'utf-8',
                    flush: true,
                    highWaterMark: this._highWaterMarkBytes,
                    fd,
                });

                this.stream.on('error', err => {
                    logger.error('ServerAccessLogger: stream error', err);
                    // close is called after error so no need to reopen here.
                });

                this.stream.on('close', () => {
                    logger.info('ServerAccessLogger: stream closed');
                    this._cleanOldStream(false);
                    this._reopenStream();
                });
            });
        });
    }

    write(data) {
        if (this._waitingDrain) {