Sync/DiffProvider/Binlog/BinlogParser.php
public function rewind()
    {
        $this->key = 0;

        if ($this->pipe) {
            pclose($this->pipe);
        }

        $this->pipe = null;
        $this->lastLine = null;
        $this->lastLineType = null;
        $this->lastDateTime = null;
        $this->lastLogPosition = null;

        if ($this->status === self::STATE_CLEAN) {
            if (!empty($this->buffer)) {
                $this->status = self::STATE_DIRTY;
            } else {
                $this->nextBufferLine();
            }
        }
    }
public function rewind()
    {
        $this->key = 0;

        if ($this->pipe) {
            pclose($this->pipe);
        }

        $this->pipe = null;
        $this->lastLine = null;
        $this->lastLineType = null;
        $this->lastDateTime = null;
        $this->lastLogPosition = null;

        if ($this->status === self::STATE_CLEAN) {
            if (!empty($this->buffer)) {
                $this->status = self::STATE_DIRTY;
            } else {
                $this->nextBufferLine();
            }
        }
    }
public function rewind ( ) { $ this -> key = 0 ; if ( $ this -> pipe ) { pclose ( $ this -> pipe ) ; } $ this -> pipe = null ; $ this -> lastLine = null ; $ this -> lastLineType = null ; $ this -> lastDateTime = null ; $ this -> lastLogPosition = null ; if ( $ this -> status === self :: STATE_CLEAN ) { if ( ! empty ( $ this -> buffer ) ) { $ this -> status = self :: STATE_DIRTY ; } else { $ this -> nextBufferLine ( ) ; } } }
{@inheritdoc}
{