tmemorystream.memory

[himitsu]

Was mir grad noch eingefallen ist, du kannst auch 2 Memory-Streams aus den selben speicherbereich loslassen und dann einen zum lesen und den anderen zum schreiben verwenden.
(mußt aber ebenfalls aufpassen, daß sich die Speicheradresse nicht verschiebt)

[add]
k.A. ob's richtig läuft (hab's nur mal schnell zusammengeschrieben),
aber eine/zwei Nachteile wird man bestimmt sofort sehen...
* da es kein Nachfahre von TStream ist, ist es auch nicht zu TStream und seinen Nachkommen kompatibel
* wenn das Ende es Puffers erreicht wird, wird nicht automatisch an den Anfang gesprungen
* das Schreiben über das Ende Puffers hinaus vegrößert den Speicher und es wird nicht am Anfang das Überhängende weitergeschriben (hier könnte man aber statt 'ner Vergrößerung des Speichers auch einfach 'ne Exception auslösen ... würde auch das ständige Ändern des ReadStream-Speichers ersparen)
* das Ganze ist so nicht Threadsicher
* ...

Delphi-Quellcode:

Type THackMemoryStream = Class(TMemoryStream);

  TMemRingBuffer = Class
  Private
    ReadStream:  THackMemoryStream;
    WriteStream: TMemoryStream;
    Function  GetReadPosition:    LongInt;
    Procedure SetReadPosition (P: LongInt);
    Function  GetWritePosition:   LongInt;
    Procedure SetWritePosition(P: LongInt);
    Function  GetSize:            LongInt;
    Procedure SetSize         (S: LongInt);
  Public
    Constructor Create(Size: LongInt);
    Destructor  Destroy; Override;

    Procedure Clear;
    Function  ReadSeek (Offset: LongInt; Origin: TSeekOrigin): LongInt;
    Function  WriteSeek(Offset: LongInt; Origin: TSeekOrigin): LongInt;

    Function  Read       (Var   Buffer; Count: LongInt): LongInt;
    Function  Write      (Const Buffer; Count: LongInt): LongInt;
    Procedure ReadBuffer (Var   Buffer; Count: LongInt);
    Procedure WriteBuffer(Const Buffer; Count: LongInt);

    Property ReadPosition:  LongInt Read GetReadPosition  Write SetReadPosition;
    Property WritePosition: LongInt Read GetWritePosition write SetWritePosition;
    Property Size:          LongInt Read GetSize Write SetSize;
  End;

Function TMemRingBuffer.GetReadPosition: LongInt;
  Begin
    Result := ReadStream.Position;
  End;

Procedure TMemRingBuffer.SetReadPosition(P: LongInt);
  Begin
    ReadSeek(P, soBeginning);
  End;

Function TMemRingBuffer.GetWritePosition: LongInt;
  Begin
    Result := WriteStream.Position;
  End;

Procedure TMemRingBuffer.SetWritePosition(P: LongInt);
  Begin
    WriteSeek(P, soBeginning);
  End;

Function TMemRingBuffer.GetSize: LongInt;
  Begin
    Result := WriteStream.Size;
  End;

Procedure TMemRingBuffer.SetSize(S: LongInt);
  Begin
    WriteStream.Size := S;
    ReadStream.SetPointer(ReadStream.Memory, ReadStream.Size);
  End;

Constructor TMemRingBuffer.Create(Size: LongInt);
  Begin
    ReadStream  := THackMemoryStream.Create;
    WriteStream := TMemoryStream.Create;
    SetSize(Size);
  End;

Destructor TMemRingBuffer.Destroy;
  Begin
    ReadStream.SetPointer(nil, 0);
    ReadStream.Free;
    WriteStream.Free;
  End;

Procedure TMemRingBuffer.Clear;
  Begin
    WriteStream.Clear;
    ReadStream.SetPointer(ReadStream.Memory, ReadStream.Size);
  End;

Function TMemRingBuffer.ReadSeek(Offset: LongInt; Origin: TSeekOrigin): LongInt;
  Begin
    Result := ReadStream.Seek(Offset, Origin);
  End;

Function TMemRingBuffer.WriteSeek(Offset: LongInt; Origin: TSeekOrigin): LongInt;
  Begin
    Result := WriteStream.Seek(Offset, Origin);
  End;

Function TMemRingBuffer.Read(Var Buffer; Count: LongInt): LongInt;
  Begin
    Result := ReadStream.Read(Buffer, Count);
  End;

Function TMemRingBuffer.Write(Const Buffer; Count: LongInt): LongInt;
  Begin
    Result := WriteStream.Write(Buffer, Count);
    ReadStream.SetPointer(ReadStream.Memory, ReadStream.Size);
  End;

Procedure TMemRingBuffer.ReadBuffer(Var Buffer; Count: LongInt);
  Begin
    ReadStream.ReadBuffer(Buffer, Count);
  End;

Procedure TMemRingBuffer.WriteBuffer(Const Buffer; Count: LongInt);
  Begin
    WriteStream.WriteBuffer(Buffer, Count);
    ReadStream.SetPointer(ReadStream.Memory, ReadStream.Size);
  End;