Унаследованный поток; буферизация в Read()

Я унаследовал класс Stream, в котором я не знаю, как правильно реализовать функцию Read(), поэтому у меня не будет большого количества вложенных ifs и сложного для отладки кода. Дело в том, что чтение из источника этого потока возвращает буфер постоянного размера (например, не изменяемый), а функция Read() принимает разные размеры буфера. Я хотел бы добавить BufferedStream, но я думаю, что это плохая идея. Спасибо за помощь!


stream c# buffer
person Community    schedule 23.02.2009    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Внутренний источник возвращает буферы фиксированного размера? В таком случае это не совсем то, что делает BufferedStream — это просто уменьшает количество обращений к физическому потоку. Вам понадобится отдельный механизм для кэширования - MemoryStream, который вы заполняете и очищаете, был бы разумным выбором. Например (полностью не проверено):

MemoryStream localBuffer = new MemoryStream();
bool ReadNextChunk()
{
    // clear
    localBuffer.Position = 0;
    localBuffer.SetLength(0);
    // get data
    byte[] chunk = null; // TODO - read from source
    if(chunk == null || chunk.Length == 0) return false; // EOF
    localBuffer.Write(chunk, 0, chunk.Length);
    localBuffer.Position = 0;
    return true;
}
public override int Read(byte[] buffer, int offset, int count)
{
    int bytes;
    if ((bytes = localBuffer.Read(buffer, offset, count)) > 0) return bytes;
    if (!ReadNextChunk()) return 0;
    return localBuffer.Read(buffer, offset, count);
}
person Marc Gravell    schedule 23.02.2009

arrow_upward
0
arrow_downward

Вот ваш «стартер на 10» (не уверен, что это переводится глобально).

byte[] myBuffer = new byte[fixedSize];
int myBufferPos = fixedSize;

public int Read(byte[] buffer, int offset, int count)
{
    int copiedCount = 0
    while (copiedCount < count)
    {
        if (myBufferPos >= fixedSize)
        {
            //Read new fixed buffer into myBuffer
            // use break on no more buffer.
            myBufferPos = 0;
        }

        int bytesToCopy = fixedSize - myBufferPos;
        if (bytesToCopy > count - copiedCount)
            byteToCopy = count - copiedCount;

        Array.Copy(myBuffer, myBufferPos, buffer, offset, byteToCopy);

        offset += bytesToCopy;
        myBufferPos += bytesToCopy;
        copiedCount += bytesToCopy;
    }

    return copiedCount;
}

Не проверено, поэтому могут быть некоторые ошибки. Неясно, имеет ли исходный поток длину, кратную его фиксированному размеру. Если нет, то окончательный частичный буфер нуждается в небольшой дополнительной логике.

Основной принцип заключается в поддержании собственного буфера фиксированного размера и отслеживании позиции в этом буфере, до сих пор потребляемой операциями чтения.

person AnthonyWJones    schedule 23.02.2009