StreamSocket на WinRT не получает всех данных

Question

У меня есть сервер, на котором работает MPD (демон музыкального плеера), который обменивается данными через сокеты. Теперь я пытаюсь реализовать протокол MPD в приложении хранилища Windows. В основном я посылаю команду и получаю список, который имеет последнюю строку «ОК». Пока список получателей меньше, чем буфер приема, все в порядке. Но если мне нужно загрузить данные, которые больше, чем буфер, начинается проводной материал.

При вызове SendCommand первый раз, когда я получаю только часть данных, остальное принимается при вызове SendCommand второй раз. При вызове еще раз я получаю все данные, как ожидалось. Когда это делается в программе WPF на том же компьютере, все в порядке.

Это мой код:

public async Task<string> SendCommand(MpdProtocol.MpdCommand command) 
    { 
     DataWriter writer = new DataWriter(streamSocket.OutputStream); 
     string res = string.Empty; 

     writer.WriteString(command.ToString()); 
     await writer.StoreAsync(); 
     res = await ReadResponse(); 

     writer.DetachBuffer(); 
     writer.DetachStream(); 
     return res; 
    } 

    private async Task<string> ReadResponse() 
    { 
     DataReader reader = new DataReader(streamSocket.InputStream); 
     reader.InputStreamOptions = InputStreamOptions.Partial; 
     StringBuilder response = new StringBuilder(); 

     const uint MAX_BUFFER = 8 * 1024; 
     uint returnBuffer = 0; 
     do 
     { 
      returnBuffer = await reader.LoadAsync(MAX_BUFFER); 
      response.Append(reader.ReadString(reader.UnconsumedBufferLength)); 

     } while (returnBuffer >= MAX_BUFFER); 

     reader.DetachBuffer(); 
     reader.DetachStream(); 

     return response.ToString(); 
    } 

Я играл с методом ReadResponse, но ничего не получалось.

Может ли кто-нибудь указать мне в правильном направлении?

Answer 1

Наконец-то я нашел решение для работы связи: чтение байта потока байтом с помощью reader.ReadByte() и проверка каждой полученной строки (они разделены "\n") за то, что они «ОК».

Проблема reader.ReadString. Этот метод хорош, когда вы знаете, как долго вы будете пытаться получить строку. В моем случае я понятия не имею о размере строки. Все, что я знаю, это то, что в последней строке будет строка «ОК».

Моя ошибка состояла в том, чтобы верить - как упоминал Петр, - до тех пор, пока данные для извлечения регенерирующего буфера будут заполнены полностью, и только последний вызов reader.ReadString будет меньше максимального размера буфера. Я также пытался переписать функцию ReadResponse по-разному, но ничего не работало для reader.ReadString.