src/Lib/Client.php
protected function readFromRemote($connection)
    {
        $all_buffer = '';
        $total_len = 4;
        $head_read = false;
        while (1) {
            $buffer = fread($connection, 8192);
            if ($buffer === '' || $buffer === false) {
                throw new \Exception('readFromRemote fail');
            }
            $all_buffer .= $buffer;
            $recv_len = strlen($all_buffer);
            if ($recv_len >= $total_len) {
                if ($head_read) {
                    break;
                }
                $unpack_data = unpack('Ntotal_length', $all_buffer);
                $total_len = $unpack_data['total_length'];
                if ($recv_len >= $total_len) {
                    break;
                }
                $head_read = true;
            }
        }
        return unserialize(substr($all_buffer, 4));
    }
protected function readFromRemote($connection)
    {
        $all_buffer = '';
        $total_len = 4;
        $head_read = false;
        while (1) {
            $buffer = fread($connection, 8192);
            if ($buffer === '' || $buffer === false) {
                throw new \Exception('readFromRemote fail');
            }
            $all_buffer .= $buffer;
            $recv_len = strlen($all_buffer);
            if ($recv_len >= $total_len) {
                if ($head_read) {
                    break;
                }
                $unpack_data = unpack('Ntotal_length', $all_buffer);
                $total_len = $unpack_data['total_length'];
                if ($recv_len >= $total_len) {
                    break;
                }
                $head_read = true;
            }
        }
        return unserialize(substr($all_buffer, 4));
    }
protected function readFromRemote ( $ connection ) { $ all_buffer = '' ; $ total_len = 4 ; $ head_read = false ; while ( 1 ) { $ buffer = fread ( $ connection , 8192 ) ; if ( $ buffer === '' || $ buffer === false ) { throw new \ Exception ( 'readFromRemote fail' ) ; } $ all_buffer .= $ buffer ; $ recv_len = strlen ( $ all_buffer ) ; if ( $ recv_len >= $ total_len ) { if ( $ head_read ) { break ; } $ unpack_data = unpack ( 'Ntotal_length' , $ all_buffer ) ; $ total_len = $ unpack_data [ 'total_length' ] ; if ( $ recv_len >= $ total_len ) { break ; } $ head_read = true ; } } return unserialize ( substr ( $ all_buffer , 4 ) ) ; }
Read data from global server.
@throws Exception
Read data from global server .