ADD: update libs

Author: PascalCorpsman

src/ufifo.pas

@@ -1,7 +1,7 @@
 (******************************************************************************)
 (* uFifo.pas                                                     23.09.2005   *)
 (*                                                                            *)
-(* Version     : 0.04                                                         *)
+(* Version     : 0.05                                                         *)
 (*                                                                            *)
 (* Author      : Uwe Schächterle (Corpsman)                                   *)
 (*                                                                            *)
@@ -28,6 +28,7 @@
 (*                      Bugfix Verlust von Daten beim Push                    *)
 (*               0.03 - property count                                        *)
 (*               0.04 - TFifo thread Safe gemacht                             *)
+(*               0.05 - TBufferedFifo.BufferSize                              *)
 (*                                                                            *)
 (******************************************************************************)
 
@@ -62,6 +63,9 @@
       fCount: integer;
       cs: TCriticalSection;
     public
+    Type
+    TComparefunction = Function(Const a, b: T): Boolean Of Object;
+
       Property Count: integer read fCount; // Anzahl der Aktuell enthaltenen Elemente
       // Initialisieren
       Constructor create;
@@ -77,6 +81,8 @@
       Function Top: T;
       // Gibt True zurück wenn Leer
       Function isempty: Boolean;
+      // Zum Prüfen ob die queue einen eintrag aElement hat
+      Function ContainsElement(Const aElement: T; CompareFunction: TComparefunction): Boolean;
   End;
 
   FifoException = Class(Exception);
@@ -97,8 +103,10 @@
     fCount: integer;
     fHead: integer;
     fTail: integer;
+    Function getBufferSize: integer;
   public
     Property Count: integer read fCount; // Anzahl der Aktuell enthaltenen Elemente
+    Property BufferSize: integer read getBufferSize;
     // Initialisieren
     Constructor create; overload; // Ruft Create(16) auf.
     Constructor create(InitialBufferSize: integer); overload;
@@ -230,6 +238,29 @@
   Result := Not assigned(Front);
 End;
 
+Function TFifo.ContainsElement(Const aElement: T;
+  CompareFunction: TComparefunction): Boolean;
+Var
+  p: PGenQ;
+Begin
+  result := false;
+  cs.Acquire;
+  Try
+    p := front;
+    While assigned(p) Do Begin
+      result := CompareFunction(aElement, p^.Value);
+      If result Then Begin
+        p := Nil;
+      End
+      Else Begin
+        p := p^.Next;
+      End;
+    End;
+  Finally
+    cs.Release;
+  End;
+End;
+
 { TBufferedFifo }
 
 Constructor TBufferedFifo.create;
@@ -243,18 +274,22 @@
   If InitialBufferSize <= 2 Then Begin
     Raise BufferedFifoException.Create('Invalid InitialBufferSize, has to be > 2');
   End;
-  fHead := 0;
-  fTail := 0;
-  fCount := 0;
   setlength(fBuffer, InitialBufferSize);
+  Clear();
 End;
 
 Destructor TBufferedFifo.Destroy;
 Begin
   setlength(fbuffer, 0);
+  fbuffer := Nil;
   Inherited Destroy;
 End;
 
+Function TBufferedFifo.getBufferSize: integer;
+Begin
+  result := length(fBuffer);
+End;
+
 Procedure TBufferedFifo.Clear;
 Begin
   // Die Indexe werden gelöscht, der Puffer bleibt Allokiert => die Query ist Leer ;)
@@ -317,7 +352,3 @@
 
 End.
 
-
-
-
-