Changeset 6 for trunk/UKernel.pas

Timestamp:

Nov 23, 2014, 11:17:11 PM (9 years ago)

Author:

chronos

Message:

• Added: Preparation for support for IPC messaging.

File:

• trunk/UKernel.pas (modified) (7 diffs)

trunk/UKernel.pas

@@ -10 +10 @@
 type
   TTask = class;
+  TScheduler = class;
 
   TTaskEvent = procedure(Task: TTask) of object;
 
-  TTaskState = (tsStopped, tsRunning, tsSuspended);
+  TTaskState = (tsStopped, tsRunning, tsSuspended, tsWaiting);
+
+  TIPCMessage = class
+    Name: string;
+    Action: string;
+
+  end;
+
+  TWaitReason = (wrSleep, wrMessage);
 
   { TTask }
 
   TTask = class(TNamedObject)
-    Name: string;
+    Scheduler: TScheduler;
     State: TTaskState;
+    WaitReason: TWaitReason;
+    WakeUpTime: TDateTime;
     Terminated: Boolean;
     EntryPoint: TTaskEvent;
+    Messages: TObjectQueue; // TQueue<TIPMessage>
+    procedure WaitForMessage;
+    procedure Sleep(Duration: TDateTime);
     constructor Create; virtual;
+    destructor Destroy; override;
   end;
 
@@ -33 +48 @@
     Tasks: TNamedObjectList; // TList<TTask>
     Running: Boolean;
+    function GetCurrentTask: TTask; virtual;
     procedure Start; virtual;
     procedure Stop; virtual;
     function AddTask(Name: string; EntryPoint: TTaskEvent): TTask; virtual;
+    procedure SwitchNext; virtual;
     constructor Create; virtual;
     destructor Destroy; override;
@@ -56 +73 @@
     constructor Create; virtual;
     procedure Service(Index: Integer; DataIn, DataOut: TMemory); virtual;
+  end;
+
+  TTimer = class
+    Period: TDateTime;
+  end;
+
+  TScreen = class
+    Size: TPoint;
+    DPI: Integer;
   end;
 
@@ -67 +93 @@
     FileSystemClass: TFileSystemClass;
     Devices: TNamedObjectList; // TList<TDevice>
+    Screens: TObjectList; // TList<TScreen>
     procedure AppExecute(AFile: TFile);
     procedure Init;
@@ -106 +133 @@
 { TTask }
 
+procedure TTask.WaitForMessage;
+begin
+  WaitReason := wrMessage;
+  State := tsWaiting;
+  Scheduler.SwitchNext;
+end;
+
+procedure TTask.Sleep(Duration: TDateTime);
+begin
+  WakeUpTime := Now + Duration;
+  State := tsWaiting;
+  WaitReason := wrSleep;
+  Scheduler.SwitchNext;
+end;
+
 constructor TTask.Create;
 begin
-
+  Messages := TObjectQueue.Create;
+end;
+
+destructor TTask.Destroy;
+begin
+  Messages.Free;
+  inherited Destroy;
 end;
 
 { TScheduler }
 
+function TScheduler.GetCurrentTask: TTask;
+begin
+  Result := nil;
+end;
+
 procedure TScheduler.Start;
 begin
@@ -128 +181 @@
 begin
   NewTask := TaskClass.Create;
+  NewTask.Scheduler := Self;
   NewTask.Name := Name;
   NewTask.EntryPoint := EntryPoint;
   Tasks.Add(NewTask);
   Result := NewTask;
+end;
+
+procedure TScheduler.SwitchNext;
+begin
+
 end;
 
@@ -201 +260 @@
   Apps := TNamedObjectList.Create;
   Scheduler := TScheduler.Create;
+  Screens := TObjectList.Create;
 end;
 
 destructor TKernel.Destroy;
 begin
+  Screens.Free;
   Scheduler.Free;
   Apps.Free;