Changeset 88 for branches/DirectWeb/UHTTPSessionFile.pas

Timestamp:

Dec 18, 2009, 12:21:39 PM (14 years ago)

Author:

george

Message:

• Upraveno: Nedokončené přepracování správy vláken. Použit systém přidělování ze společné sady o dané velikosti namísto přidělování vláken ke každému požadavku samostatně. Vlákna jsou inicializována při spuštění aplikace, jsou opakovaně používána a uvolněna až při ukončení běhu aplikace.
• Přidáno: Třída pro práci s opakovaně spustitelnými vlákny.
• Přidáno: Třída přidělování objektů ze zásoby o dané velikosti.
• Přidáno: Třída pro zobrazování stránkování seznamů položek.

File:

• branches/DirectWeb/UHTTPSessionFile.pas (modified) (2 diffs)

branches/DirectWeb/UHTTPSessionFile.pas

@@ -6 +6 @@
 
 uses
-  Classes, SysUtils, UHTTPServer;
+  Classes, SysUtils, UHTTPServer, syncobjs;
 
-type 
+type
 
-  { THTTPSessionFile }
+  { TFileHTTPSessionStorage }
 
-  THTTPSessionFile = class(THTTPSession)
+  TFileHTTPSessionStorage = class(THTTPSessionStorage)
+  private
+    Lock: TCriticalSection;
+    procedure GetSessionId(HandlerData: THTTPHandlerData);
+  public
     Directory: string;
     SessionIdCookieName: string;
-    SessionId: string;
-    procedure Load(Request: THTTPRequest); override;
-    procedure Save(Response: THTTPResponse); override;
+    Sessions: TStringList;
+    procedure Load(HandlerData: THTTPHandlerData); override;
+    procedure Save(HandlerData: THTTPHandlerData); override;
     constructor Create; override;
     destructor Destroy; override;
@@ -26 +30 @@
 { THTTPSession }
 
-procedure THTTPSessionFile.Load(Request: THTTPRequest);
+procedure TFileHTTPSessionStorage.GetSessionId(HandlerData: THTTPHandlerData);
 begin
+  with HandlerData do
   if Request.Cookies.IndexOfName(SessionIdCookieName) <> -1 then begin
-    SessionId := Request.Cookies.Values[SessionIdCookieName];
-  end else begin
-    SessionId := IntToStr(Random(1000));
-    // TODO: Check if new id already used
+      SessionId := Request.Cookies.Values[SessionIdCookieName];
+    end else begin
+      SessionId := IntToStr(Random(2000000000));
+      // TODO: Check if new id already used
+    end;
+end;
+
+procedure TFileHTTPSessionStorage.Load(HandlerData: THTTPHandlerData);
+var
+  SessionFile: string;
+begin
+  GetSessionId(HandlerData);
+  try
+    Lock.Acquire;
+    SessionFile := Directory + '/' + HandlerData.SessionId;
+    if FileExists(SessionFile) then
+      HandlerData.Session.LoadFromFile(SessionFile);
+  finally
+    Lock.Release;
   end;
-
-  if FileExists(Directory + '/' + SessionId) then
-    Variables.LoadFromFile(Directory + '/' + SessionId);
   inherited;
 end;
 
-procedure THTTPSessionFile.Save(Response: THTTPResponse);
+procedure TFileHTTPSessionStorage.Save(HandlerData: THTTPHandlerData);
+var
+  SessionFile: string;
 begin
-  ForceDirectories(Directory);
-  if DirectoryExists(Directory) then
-    Variables.SaveToFile(Directory + '/' + SessionId)
-    else raise Exception.Create('Can''t create session storage directory.');
+  try
+    Lock.Acquire;
+    SessionFile := Directory + '/' + HandlerData.SessionId;
+    ForceDirectories(Directory);
+    if DirectoryExists(Directory) then begin
+      DeleteFile(SessionFile);
+      HandlerData.Session.SaveToFile(SessionFile)
+    end else raise Exception.Create('Can''t create session storage directory.');
 
-  Response.Cookies.Values[SessionIdCookieName] := SessionId;
-  inherited Save(Response);
+    HandlerData.Response.Cookies.Values[SessionIdCookieName] := HandlerData.SessionId;
+  finally
+    Lock.Release;
+  end;
+  inherited;
 end;
 
-constructor THTTPSessionFile.Create;
+constructor TFileHTTPSessionStorage.Create;
 begin
-  inherited;
+  inherited Create;
+  Lock := TCriticalSection.Create;
+  Sessions := TStringList.Create;
   SessionIdCookieName := 'SessionId';
   Directory := 'Session';
 end;
 
-destructor THTTPSessionFile.Destroy;
+destructor TFileHTTPSessionStorage.Destroy;
 begin
+  Sessions.Destroy;
+  Lock.Destroy;
   inherited Destroy;
 end;