Changeset 119 for Comm/USerialPort.pas

Timestamp:

Jan 5, 2011, 1:16:30 PM (14 years ago)

Author:

george

Message:

• Created: New Lazarus package as container for few classes with bidirectional pin interconnection system .

Location:

Comm

Files:

• . (modified) (1 prop)
• USerialPort.pas (modified) (17 diffs)

Comm/USerialPort.pas

@@ -6 +6 @@
 
 uses
-  Classes, SysUtils, SynaSer, StdCtrls, Windows, Dialogs;
+  Classes, SysUtils, SynaSer, StdCtrls, Dialogs;
 
 type
@@ -24 +24 @@
   TSerialPortReceiveThread = class(TThread)
     Parent: TSerialPort;
-    Stream: TMemoryStream;
     procedure Execute; override;
-    constructor Create(CreateSuspended: Boolean;
-      const StackSize: SizeUInt = DefaultStackSize);
     destructor Destroy; override;
   end;
@@ -46 +43 @@
     FStopBits: TStopBits;
     FReceiveThread: TSerialPortReceiveThread;
+    FReceiveBuffer: TMemoryStream;
     function GetBaudRateNumeric: Integer;
     function GetName: string;
-    function GetReceiveBuffer:TMemoryStream;
     procedure SetBaudRate(const AValue: TBaudRate);
     procedure SetBaudRateNumeric(const AValue: Integer);
@@ -71 +68 @@
     property RTS: Boolean read FRTS write SetRTS;
     property DTR: Boolean read FDTR write SetDTR;
-    property ReceiveBuffer: TMemoryStream read GetReceiveBuffer;
+    property ReceiveBuffer: TMemoryStream read FReceiveBuffer;
 
     property BaudRateNumeric: Integer read GetBaudRateNumeric write SetBaudRateNumeric;
@@ -88 +85 @@
 implementation
 
+resourcestring
+  SAssignmentError = 'Assignment error';
+  SWrongNumericBaudRate = 'Wrong numeric baud rate %s';
+  SWrongDataBitsNumber = 'Wrong data bits number %s';
+
 { TSerialPort }
 
@@ -95 +97 @@
     FActive := True;
     Open;
-    FActive := FHandle <> INVALID_HANDLE_VALUE
+    FActive := FHandle <> INVALID_HANDLE_VALUE;
+    if not FActive then FreeAndNil(FReceiveThread);
   end else
   if FActive and not AValue then begin
@@ -137 +140 @@
 begin
   Connect(FName);
+  //set_fDtrControl(DCB, 1);
+  //DCB.flags := ;
   SetBaudRate(FBaudRate);
   SetParity(FParity);
@@ -144 +149 @@
   SetDTR(FDTR);
   SetRTS(FRTS);
+
+  FReceiveThread := TSerialPortReceiveThread.Create(True);
+  FReceiveThread.FreeOnTerminate := False;
+  FReceiveThread.Parent := Self;
+  FReceiveThread.Start;
 end;
 
 procedure TSerialPort.Close;
 begin
+  FreeAndNil(FReceiveThread);
   CloseSocket;
 end;
@@ -154 +165 @@
 begin
   inherited Create;
+  FReceiveBuffer := TMemoryStream.Create;
   FBaudRate := br9600;
   FName := 'COM1';
@@ -163 +175 @@
   FRTS := False;
   Active := False;
-
-  FReceiveThread := TSerialPortReceiveThread.Create(True);
-  FReceiveThread.FreeOnTerminate := False;
-  FReceiveThread.Parent := Self;
-  FReceiveThread.Resume;
 end;
 
 destructor TSerialPort.Destroy;
 begin
-  FReceiveThread.Terminate;
-  FReceiveThread.WaitFor;
-  FReceiveThread.Destroy;
+  Active := False;
+  FReceiveThread.Free;
+  ReceiveBuffer.Free;
   inherited Destroy;
 end;
@@ -189 +196 @@
     DTR := TSerialPort(Source).DTR;
     RTS := TSerialPort(Source).RTS;
-  end else raise Exception.Create('Assignment error');
+  end else raise Exception.Create(SAssignmentError);
 end;
 
@@ -210 +217 @@
 begin
   Result := FName;
-end;
-
-function TSerialPort.GetReceiveBuffer:TMemoryStream;
-begin
-  Result := FReceiveThread.Stream;
 end;
 
@@ -235 +237 @@
     128000: BaudRate := br128000;
     256000: BaudRate := br256000;
-    else raise Exception.Create('Wrong numeric baud rate');
+    else raise Exception.CreateFmt(SWrongNumericBaudRate, [AValue]);
   end;
 end;
@@ -242 +244 @@
 begin
   if (AValue >= 5) and (AValue <= 8) then FDataBits := AValue
-    else raise Exception.Create('Wrong data bits number');
+    else raise Exception.CreateFmt(SWrongDataBitsNumber, [IntToStr(AValue)]);
   if FActive then begin
     GetCommState;
@@ -253 +255 @@
 begin
   FDTR := AValue;
-  if FActive then SetDTRF(FDTR);
+  if FFlowControl = fcNone then
+    DCB.flags := DCB.flags and (not (dcb_DtrControlEnable * 3)) or
+    (dcb_DtrControlEnable * Byte(AValue));
+  if FActive then begin
+    if FFlowControl = fcNone then SetCommState
+    else SetDTRF(FDTR);
+  end;
 end;
 
@@ -263 +271 @@
     case AValue of
       fcNone: DCB.flags := 0;
-      fcSoftware: DCB.flags := DCB.Flags or dcb_OutX or dcb_InX;
-      fcHardware: DCB.flags := DCB.Flags
-        or dcb_OutxCtsFlow or dcb_OutxDsrFlow
-        or dcb_DtrControlHandshake  or dcb_RtsControlHandshake;
+      fcSoftware: DCB.flags := dcb_OutX or dcb_InX or
+        dcb_DtrControlEnable or dcb_RtsControlEnable;
+      fcHardware: DCB.flags := dcb_OutxCtsFlow or dcb_OutxDsrFlow
+        or dcb_DtrControlHandshake or dcb_RtsControlHandshake;
     end;
     SetCommState;
@@ -280 +288 @@
 begin
   InBufferUsed := 0;
-  with Parent do
-  repeat
-    if InBufferUsed = 0 then Sleep(1);
-    if Active then begin
-      InBufferUsed := WaitingData;
-      if InBufferUsed > 0 then begin
-        SetLength(Buffer, InBufferUsed);
-        RecvBuffer(Buffer, Length(Buffer));
-
-        Stream.Size := Length(Buffer);
-        Stream.Position := 0;
-        Stream.Write(Buffer[0], Length(Buffer));
-        if Assigned(Parent.FOnReceiveData) then
-          Parent.FOnReceiveData(Stream);
+  with Parent do repeat
+    try
+      if InBufferUsed = 0 then Sleep(1);
+      if Active then begin
+        InBufferUsed := WaitingData;
+        if InBufferUsed > 0 then begin
+          SetLength(Buffer, InBufferUsed);
+          RecvBuffer(Buffer, Length(Buffer));
+
+          Parent.FReceiveBuffer.Size := Length(Buffer);
+          Parent.FReceiveBuffer.Position := 0;
+          Parent.FReceiveBuffer.Write(Buffer[0], Length(Buffer));
+          if Assigned(Parent.FOnReceiveData) then
+            Parent.FOnReceiveData(Parent.FReceiveBuffer);
+        end else InBufferUsed := 0;
       end else InBufferUsed := 0;
-    end else InBufferUsed := 0;
+    except
+      on E: Exception do
+        //MainForm.ExceptionLogger1.ThreadExceptionHandler(Self, E);
+    end;
   until Terminated;
 end;
 
-constructor TSerialPortReceiveThread.Create(CreateSuspended: Boolean;
-  const StackSize: SizeUInt);
+destructor TSerialPortReceiveThread.Destroy;
 begin
   inherited;
-  Stream := TMemoryStream.Create;
-end;
-
-destructor TSerialPortReceiveThread.Destroy;
-begin
-  Stream.Destroy;
-  inherited;
 end;