Changeset 25 for trunk/UDriveScan.pas

Timestamp:

Apr 5, 2016, 10:54:28 PM (8 years ago)

Author:

chronos

Message:

• Added: Record transfer speed to chart during scan operation.

File:

• trunk/UDriveScan.pas (modified) (17 diffs)

trunk/UDriveScan.pas

@@ -7 +7 @@
 uses
   Classes, SysUtils, Syncobjs, UBlockMap, Forms, DOM, UConfig, UPhysDrive,
-  UXMLUtils, Contnrs;
+  UXMLUtils, Contnrs, ExtCtrls, DateUtils;
 
 type
   TDriveScan = class;
 
-  TRunMode = (rmRead, rmWrite, rmNone);
+  TRunMode = (rmRead, rmWrite, rmNone, rmSpeed);
   TExceptionEvent = procedure (Sender: TObject; E: Exception) of object;
 
@@ -47 +47 @@
   end;
 
+  { TSpeedValue }
+
+  TSpeedValue = record
+    Null: Boolean;
+    Max: Int64;
+    Average: Int64;
+    Min: Int64;
+    procedure Reset;
+    procedure UpdateValue(Value: Int64);
+  end;
+
   { TDriveScan }
 
@@ -57 +68 @@
     ScanThread: TScanThread;
     LastExceptionMessage: string;
+    SpeedTimer: TTimer;
+    SpeedTimeLast: TDateTime;
+    SectorLast: Integer;
     procedure DoOnExceptionSync;
     procedure DoOnException(Sender: TObject; E: Exception);
@@ -65 +79 @@
     procedure SetDriveName(AValue: string);
     procedure SetSectorCount(AValue: Integer);
+    procedure SpeedTimerExecute(Sender: TObject);
   public
     Lock: TCriticalSection;
@@ -77 +92 @@
     SectorStart: Integer;
     SectorEnd: Integer;
+    SpeedSteps: array of TSpeedValue;
+    SpeedStepsCount: Integer;
     function GetName: string;
     function GetElapsedTime: TDateTime;
@@ -107 +124 @@
   SUnknownRunMode = 'Unknown run mode';
 
+{ TSpeedValue }
+
+procedure TSpeedValue.Reset;
+begin
+  Null := True;
+end;
+
+procedure TSpeedValue.UpdateValue(Value: Int64);
+begin
+  if Null then begin
+    Min := High(Int64);
+    Max := Low(Int64);
+    Average := 0;
+  end;
+  Null := False;
+  if Value > Max then Max := Value;
+  // TODO: Computer average
+  Average := Value;
+  if Value < Min then Min := Value;
+end;
+
 { TDriveScanProfile }
 
@@ -213 +251 @@
 
 procedure TDriveScan.Reset;
+var
+  I: Integer;
 begin
   TimeStart := Now;
@@ -218 +258 @@
   BlockMap.Clear;
   FSectorCurrent := SectorStart;
+  SetLength(SpeedSteps, SpeedStepsCount);
+  for I := 0 to Length(SpeedSteps) - 1 do
+    SpeedSteps[I].Reset;
 end;
 
@@ -228 +271 @@
     ScanThread.Scan := Self;
     ScanThread.Start;
+    SpeedTimeLast := Now;
+    SectorLast := SectorCurrent;
+    SpeedTimer.Enabled := True;
   end;
 end;
@@ -294 +340 @@
 end;
 
+procedure TDriveScan.SpeedTimerExecute(Sender: TObject);
+var
+  SpeedTimeCurrent: TDateTime;
+  Index: Integer;
+begin
+  SpeedTimeCurrent := Now;
+  Index := Trunc(SectorCurrent / SectorCount * SpeedStepsCount);
+  if Index >= Length(SpeedSteps) then Index := Length(SpeedSteps) - 1;
+  SpeedSteps[Index].UpdateValue(
+    Trunc((SectorCurrent - SectorLast) * SectorSize / ((SpeedTimeCurrent - SpeedTimeLast) / OneSecond)));
+  SpeedTimeLast := SpeedTimeCurrent;
+  SectorLast := SectorCurrent;
+end;
+
 function TDriveScan.GetName: string;
 begin
@@ -305 +365 @@
 begin
   if not Terminated then begin
+    SpeedTimer.Enabled := False;
     Terminated := True;
     ScanThread.Terminate;
@@ -324 +385 @@
   Lock := TCriticalSection.Create;
   BlockMap := TBlockMap.Create;
+  SpeedTimer := TTimer.Create(nil);
+  SpeedTimer.Interval := 500;
+  SpeedTimer.Enabled := False;
+  SpeedTimer.OnTimer := SpeedTimerExecute;
+  SpeedStepsCount := 1000;
   SectorSize := 4096;
   Terminated := True;
@@ -333 +399 @@
 begin
   Stop;
+  FreeAndNil(SpeedTimer);
   FreeAndNil(BlockMap);
   FreeAndNil(Lock);
@@ -341 +408 @@
 var
   NewNode: TDOMNode;
+  NewNode2: TDOMNode;
+  NewNode3: TDOMNode;
+  I: Integer;
 begin
   with Node do begin
@@ -358 +428 @@
     AppendChild(NewNode);
     BlockMap.SaveToNode(NewNode);
+
+    NewNode := OwnerDocument.CreateElement('Speed');
+    AppendChild(NewNode);
+    WriteInt64(NewNode, 'Count', Length(SpeedSteps));
+    NewNode2 := OwnerDocument.CreateElement('Steps');
+    NewNode.AppendChild(NewNode2);
+    for I := 0 to Length(SpeedSteps) - 1 do
+    if not SpeedSteps[I].Null then begin
+      NewNode3 := OwnerDocument.CreateElement('Step');
+      NewNode2.AppendChild(NewNode3);
+      WriteInteger(NewNode3, 'Index', I);
+      WriteInt64(NewNode3, 'Avg', SpeedSteps[I].Average);
+      WriteInt64(NewNode3, 'Min', SpeedSteps[I].Min);
+      WriteInt64(NewNode3, 'Max', SpeedSteps[I].Max);
+    end;
   end;
 end;
@@ -364 +449 @@
 var
   NewNode: TDOMNode;
+  NewNode2: TDOMNode;
+  NewNode3: TDOMNode;
+  I: Integer;
 begin
   with Node do begin
@@ -381 +469 @@
     if Assigned(NewNode) then
       BlockMap.LoadFromNode(NewNode);
-  end;
+
+    NewNode := FindNode('Speed');
+    if Assigned(NewNode) then begin
+      SpeedStepsCount := ReadInt64(NewNode, 'Count', 0);
+      SetLength(SpeedSteps, SpeedStepsCount);
+      NewNode2 := NewNode.FindNode('Steps');
+      if Assigned(NewNode2) then begin
+        NewNode3 := NewNode2.FirstChild;
+        while Assigned(NewNode3) and (NewNode3.NodeName = 'Step') do begin
+          I := ReadInteger(NewNode3, 'Index', 0);
+          SpeedSteps[I].Average := ReadInt64(NewNode3, 'Avg', 0);
+          SpeedSteps[I].Min := ReadInt64(NewNode3, 'Min', 0);
+          SpeedSteps[I].Max := ReadInt64(NewNode3, 'Max', 0);
+          SpeedSteps[I].Null := False;
+          NewNode3 := NewNode3.NextSibling;
+        end;
+      end;
+    end;
+end;
 end;