Файлы по сокету приходят не полностью

<?php
    header('Content-Type: text/plain;');
    error_reporting( E_ALL );
    
    clearstatcache();
    
    set_time_limit(0);
    ob_implicit_flush();
   
    echo "-= Server =-\n\n";
 
    $address = '62.152.35.61';
    $port    = 10001;
 
    try {
        
        echo 'Create socket ... ';
        if (($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) {
            throw new Exception('socket_create() failed: '.socket_strerror(socket_last_error())."\n");
        } else {
            echo "OK\n";
        }
        
        echo 'Bind socket ... ';
        if (($ret = socket_bind($sock, $address, $port)) < 0) {
            throw new Exception('socket_bind() failed: '.socket_strerror(socket_last_error())."\n");
        } else {
            echo "OK\n";
        }
 
        echo 'Listen socket ... ';
        if (($ret = socket_listen($sock, 5)) < 0) {
            throw new Exception('socket_listen() failed: '.socket_strerror(socket_last_error())."\n");
        } else {
            echo "OK\n";
        }
 
        do {
            echo 'Accept socket ... ';
            if (($msgsock = socket_accept($sock)) < 0) {
                throw new Exception('socket_accept() failed: '.socket_strerror(socket_last_error())."\n");
            } else {
                echo "OK\n";
            }
           
            $msg = "Hello, Client!";
            echo "Say to client ($msg) ... ";
            socket_write($msgsock, $msg, strlen($msg));
            echo "OK\n";
 
            do {
                echo 'Client said: ';
                
                if (false === ($buf = socket_read($msgsock, 2048))) {
                    throw new Exception('socket_read() failed: '.socket_strerror(socket_last_error())."\n");
                } else {
                        $buf_array = explode( "|" , $buf );
                    
                            if ( trim( $buf_array[0] ) == 'ADD' ) 
                                {
                                    file_put_contents( trim( $buf_array[1] ), trim( $buf_array[2] ) );
                                                                $fp = fopen('registry.txt', 'a');
                                                                fwrite($fp, $buf_array[1] . '|');
                                                                fclose($fp);
                                    
                                    $say = "ADDOK" ;
                                    echo "Say to client ( $say ) ... ";
                                    socket_write($msgsock, $say, strlen($say));
                                    echo "OK\n";
                                }
                        
                           if ($buf == 'GETLIST') 
                            {
                                $h = fopen("registry.txt","r"); 
                                                            while (!feof ($h)) {
                                                            $content = fgets($h);                                                                                                       
                                                              }
                                                              fclose($h);                                                         
                                                              $comm = "LIST|";
                                                              $request = $comm . $content;
                                                              socket_write($msgsock, $request, strlen($request) );  
                        
                               
                                                                            
 
                        }
                    else
                        {
                            
                            
                            echo "OK\n";
                        }
                }
               
                if (!$buf = trim($buf)) {
                    continue;
                }
               
                if ($buf == 'shutdown') {
                    socket_close($msgsock);
                    break 2;
                }
                
            } while (true);
           
        } while (true);
 
    } catch (Exception $e) {
        echo "\nError: ".$e->getMessage();
    }
   
    if (isset($sock)) {
   
        echo 'Close socket ... ';
        socket_close($sock);
        echo "OK\n";
   
    }
?>