DumpPipeOutput.php

Go to the documentation of this file.

<?php
class DumpPipeOutput extends DumpFileOutput {
    protected $command, $filename;
    protected $procOpenResource = false;
 
    function __construct( $command, $file = null ) {
        if ( !is_null( $file ) ) {
            $command .= " > " . wfEscapeShellArg( $file );
        }
 
        $this->startCommand( $command );
        $this->command = $command;
        $this->filename = $file;
    }
 
    function writeCloseStream( $string ) {
        parent::writeCloseStream( $string );
        if ( $this->procOpenResource ) {
            proc_close( $this->procOpenResource );
            $this->procOpenResource = false;
        }
    }
 
    function startCommand( $command ) {
        $spec = [
            0 => [ "pipe", "r" ],
        ];
        $pipes = [];
        $this->procOpenResource = proc_open( $command, $spec, $pipes );
        $this->handle = $pipes[0];
    }
 
    function closeRenameAndReopen( $newname ) {
        $this->closeAndRename( $newname, true );
    }
 
    function closeAndRename( $newname, $open = false ) {
        $newname = $this->checkRenameArgCount( $newname );
        if ( $newname ) {
            if ( $this->handle ) {
                fclose( $this->handle );
                $this->handle = false;
            }
            if ( $this->procOpenResource ) {
                proc_close( $this->procOpenResource );
                $this->procOpenResource = false;
            }
            $this->renameOrException( $newname );
            if ( $open ) {
                $command = $this->command;
                $command .= " > " . wfEscapeShellArg( $this->filename );
                $this->startCommand( $command );
            }
        }
    }
}