AGB  ·  Datenschutz  ·  Impressum  







Anmelden
Nützliche Links
Registrieren
Thema durchsuchen
Ansicht
Themen-Optionen

tmemorystream.memory

Ein Thema von Rudirabbit · begonnen am 27. Dez 2008 · letzter Beitrag vom 29. Dez 2008
 
Benutzerbild von himitsu
himitsu

Registriert seit: 11. Okt 2003
Ort: Elbflorenz
44.341 Beiträge
 
Delphi 12 Athens
 
#10

Re: tmemorystream.memory

  Alt 29. Dez 2008, 13:12
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;
Ein Therapeut entspricht 1024 Gigapeut.
  Mit Zitat antworten Zitat
 


Forumregeln

Es ist dir nicht erlaubt, neue Themen zu verfassen.
Es ist dir nicht erlaubt, auf Beiträge zu antworten.
Es ist dir nicht erlaubt, Anhänge hochzuladen.
Es ist dir nicht erlaubt, deine Beiträge zu bearbeiten.

BB-Code ist an.
Smileys sind an.
[IMG] Code ist an.
HTML-Code ist aus.
Trackbacks are an
Pingbacks are an
Refbacks are aus

Gehe zu:

Impressum · AGB · Datenschutz · Nach oben
Alle Zeitangaben in WEZ +1. Es ist jetzt 16:30 Uhr.
Powered by vBulletin® Copyright ©2000 - 2025, Jelsoft Enterprises Ltd.
LinkBacks Enabled by vBSEO © 2011, Crawlability, Inc.
Delphi-PRAXiS (c) 2002 - 2023 by Daniel R. Wolf, 2024-2025 by Thomas Breitkreuz