Changeset 360 for CoolStreaming

Timestamp:

May 7, 2012, 10:32:41 AM (13 years ago)

Author:

chronos

Message:

 

File:

• CoolStreaming/UStreamHelper.pas (modified) (3 diffs)

CoolStreaming/UStreamHelper.pas

@@ -6 +6 @@
 
 uses
-  Classes, DateUtils, syncobjs;
+  Classes, DateUtils, syncobjs, SysUtils;
 
 type
@@ -49 +49 @@
     procedure ReadStream(AStream: TStream; Count: Integer);
     procedure ReadStreamPart(AStream: TStream; Count: Integer);
+    function EqualTo(Source: TStream): Boolean;
     function Sum: Byte;
     procedure FillByte(Data: Byte; Count: Integer);
@@ -159 +160 @@
 end;
 
+function TStreamHelper.EqualTo(Source: TStream): Boolean;
+const
+  BlockSize = 4096;
+var
+  Buffer1: array[0..BlockSize - 1] of Byte;
+  Buffer2: array[0..BlockSize - 1] of Byte;
+  BufferLength: Integer;
+  OldPos1, OldPos2: Integer;
+begin
+  OldPos1 := Source.Position;
+  Source.Position := 0;
+  OldPos2 := Position;
+  Position := 0;
+  Result := True;
+  if Source.Size = Size then begin
+    while Source.Position < Source.Size do begin
+      BufferLength := Source.Read(Buffer1, BlockSize);
+      Read(Buffer2, BlockSize);
+      if not CompareMem(@Buffer1, @Buffer2, BufferLength) then begin
+        Result := False;
+        Break;
+      end;
+    end;
+  end else Result := False;
+  Source.Position := OldPos1;
+  Position := OldPos2;
+end;
+
 procedure TStreamHelper.WriteStreamPart(AStream: TStream; Count: Integer);
 var