Changeset 303

Timestamp:

Dec 5, 2011, 2:21:38 PM (13 years ago)

Author:

chronos

Message:

• Added: Assign menthod for VarBlockSerializer and VarBlockIndexed.

Files:

• Common/UDelay.pas (modified) (3 diffs)
• CoolStreaming/UVarBlockSerializer.pas (modified) (5 diffs)

Common/UDelay.pas

@@ -16 +16 @@
     function GetEnabled:Boolean;
     function GetOwerflowed:Boolean;
+    function GetRunning: Boolean;
     procedure SetEnabled(const AValue: Boolean);
   public
@@ -24 +25 @@
     constructor Create;
     property Overflowed: Boolean read GetOwerflowed;
+    property Running: Boolean read GetRunning;
     property Enabled: Boolean read GetEnabled write SetEnabled;
   end;
@@ -40 +42 @@
 begin
   Result := ((Now - StartTime) > (Duration * OneMillisecond)) and FEnabled;
+end;
+
+function TDelay.GetRunning: Boolean;
+begin
+  Result := ((Now - StartTime) <= (Duration * OneMillisecond)) and FEnabled;
 end;
 

CoolStreaming/UVarBlockSerializer.pas

@@ -58 +58 @@
     constructor Create;
     destructor Destroy; override;
+    procedure Assign(Source: TVarBlockSerializer);
     property Stream: TStream read FStream write SetStream;
   end;
@@ -100 +101 @@
     constructor Create;
     destructor Destroy; override;
+    procedure Assign(Source: TVarBlockIndexed);
   end;
 
@@ -582 +584 @@
 end;
 
+procedure TVarBlockSerializer.Assign(Source: TVarBlockSerializer);
+var
+  Helper: TStreamHelper;
+  LastPos: Integer;
+begin
+  OwnsStream := Source.OwnsStream;
+  FStream.Size := 0;
+  try
+    Helper := TStreamHelper.Create(Source.FStream);
+    LastPos := Source.FStream.Position;
+    Source.FStream.Position := 0;
+    Helper.ReadStream(FStream, Source.FStream.Size);
+    Source.FStream.Position := LastPos;
+  finally
+    Helper.Free;
+  end;
+  FStream.Position := Source.FStream.Position;
+end;
+
 { TVarBlockIndexed }
 
@@ -777 +798 @@
   if (Index >= 0) and (Index < Items.Count) then
     Result := Assigned(Items[Index])
-    else Result := False
+    else Result := False;
 end;
 
@@ -864 +885 @@
 end;
 
+procedure TVarBlockIndexed.Assign(Source: TVarBlockIndexed);
+var
+  I: Integer;
+begin
+  Enclose := Source.Enclose;
+  Items.Count := Source.Items.Count;
+  for I := 0 to Items.Count - 1 do begin
+    CheckItem(I);
+    TVarBlockSerializer(Items[I]).Assign(TVarBlockSerializer(Source.Items[I]));
+  end;
+end;
+
 end.