| ------------------------------------------------------------------------------ |
| -- -- |
| -- GNAT COMPILER COMPONENTS -- |
| -- -- |
| -- G N A T . S E R I A L _ C O M M U N I C A T I O N S -- |
| -- -- |
| -- B o d y -- |
| -- -- |
| -- Copyright (C) 2007-2008, AdaCore -- |
| -- -- |
| -- GNAT is free software; you can redistribute it and/or modify it under -- |
| -- terms of the GNU General Public License as published by the Free Soft- -- |
| -- ware Foundation; either version 2, or (at your option) any later ver- -- |
| -- sion. GNAT is distributed in the hope that it will be useful, but WITH- -- |
| -- OUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY -- |
| -- or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License -- |
| -- for more details. You should have received a copy of the GNU General -- |
| -- Public License distributed with GNAT; see file COPYING. If not, write -- |
| -- to the Free Software Foundation, 51 Franklin Street, Fifth Floor, -- |
| -- Boston, MA 02110-1301, USA. -- |
| -- -- |
| -- As a special exception, if other files instantiate generics from this -- |
| -- unit, or you link this unit with other files to produce an executable, -- |
| -- this unit does not by itself cause the resulting executable to be -- |
| -- covered by the GNU General Public License. This exception does not -- |
| -- however invalidate any other reasons why the executable file might be -- |
| -- covered by the GNU Public License. -- |
| -- -- |
| -- GNAT was originally developed by the GNAT team at New York University. -- |
| -- Extensive contributions were provided by Ada Core Technologies Inc. -- |
| -- -- |
| ------------------------------------------------------------------------------ |
| |
| -- This is the Windows implementation of this package |
| |
| with Ada.Unchecked_Deallocation; use Ada; |
| with Ada.Streams; use Ada.Streams; |
| with System.Win32.Ext; use System, System.Win32, System.Win32.Ext; |
| |
| package body GNAT.Serial_Communications is |
| |
| -- Common types |
| |
| type Port_Data is new HANDLE; |
| |
| C_Bits : constant array (Data_Bits) of Interfaces.C.unsigned := (8, 7); |
| C_Parity : constant array (Parity_Check) of Interfaces.C.unsigned := |
| (None => NOPARITY, Odd => ODDPARITY, Even => EVENPARITY); |
| C_Stop_Bits : constant array (Stop_Bits_Number) of Interfaces.C.unsigned := |
| (One => ONESTOPBIT, Two => TWOSTOPBITS); |
| |
| ----------- |
| -- Files -- |
| ----------- |
| |
| procedure Raise_Error (Message : String; Error : DWORD := GetLastError); |
| pragma No_Return (Raise_Error); |
| |
| ----------- |
| -- Close -- |
| ----------- |
| |
| procedure Close (Port : in out Serial_Port) is |
| procedure Unchecked_Free is |
| new Unchecked_Deallocation (Port_Data, Port_Data_Access); |
| |
| Success : BOOL; |
| |
| begin |
| if Port.H /= null then |
| Success := CloseHandle (HANDLE (Port.H.all)); |
| Unchecked_Free (Port.H); |
| |
| if Success = Win32.FALSE then |
| Raise_Error ("error closing the port"); |
| end if; |
| end if; |
| end Close; |
| |
| ---------- |
| -- Name -- |
| ---------- |
| |
| function Name (Number : Positive) return Port_Name is |
| N_Img : constant String := Positive'Image (Number); |
| begin |
| return Port_Name ("COM" & N_Img (N_Img'First + 1 .. N_Img'Last) & ':'); |
| end Name; |
| |
| ---------- |
| -- Open -- |
| ---------- |
| |
| procedure Open |
| (Port : out Serial_Port; |
| Name : Port_Name) |
| is |
| C_Name : constant String := String (Name) & ASCII.NUL; |
| Success : BOOL; |
| pragma Unreferenced (Success); |
| |
| begin |
| if Port.H = null then |
| Port.H := new Port_Data; |
| else |
| Success := CloseHandle (HANDLE (Port.H.all)); |
| end if; |
| |
| Port.H.all := CreateFile |
| (lpFileName => C_Name (C_Name'First)'Address, |
| dwDesiredAccess => GENERIC_READ or GENERIC_WRITE, |
| dwShareMode => 0, |
| lpSecurityAttributes => null, |
| dwCreationDisposition => OPEN_EXISTING, |
| dwFlagsAndAttributes => 0, |
| hTemplateFile => 0); |
| |
| if Port.H.all = 0 then |
| Raise_Error ("cannot open com port"); |
| end if; |
| end Open; |
| |
| ----------------- |
| -- Raise_Error -- |
| ----------------- |
| |
| procedure Raise_Error (Message : String; Error : DWORD := GetLastError) is |
| begin |
| raise Serial_Error with Message & " (" & DWORD'Image (Error) & ')'; |
| end Raise_Error; |
| |
| ---------- |
| -- Read -- |
| ---------- |
| |
| overriding procedure Read |
| (Port : in out Serial_Port; |
| Buffer : out Stream_Element_Array; |
| Last : out Stream_Element_Offset) |
| is |
| Success : BOOL; |
| Read_Last : aliased DWORD; |
| |
| begin |
| if Port.H = null then |
| Raise_Error ("read: port not opened", 0); |
| end if; |
| |
| Success := |
| ReadFile |
| (hFile => HANDLE (Port.H.all), |
| lpBuffer => Buffer (Buffer'First)'Address, |
| nNumberOfBytesToRead => DWORD (Buffer'Length), |
| lpNumberOfBytesRead => Read_Last'Access, |
| lpOverlapped => null); |
| |
| if Success = Win32.FALSE then |
| Raise_Error ("read error"); |
| end if; |
| |
| Last := Buffer'First - 1 + Stream_Element_Offset (Read_Last); |
| end Read; |
| |
| --------- |
| -- Set -- |
| --------- |
| |
| procedure Set |
| (Port : Serial_Port; |
| Rate : Data_Rate := B9600; |
| Bits : Data_Bits := CS8; |
| Stop_Bits : Stop_Bits_Number := One; |
| Parity : Parity_Check := None; |
| Block : Boolean := True; |
| Timeout : Duration := 10.0) |
| is |
| Success : BOOL; |
| Com_Time_Out : aliased COMMTIMEOUTS; |
| Com_Settings : aliased DCB; |
| |
| begin |
| if Port.H = null then |
| Raise_Error ("set: port not opened", 0); |
| end if; |
| |
| Success := GetCommState (HANDLE (Port.H.all), Com_Settings'Access); |
| |
| if Success = Win32.FALSE then |
| Success := CloseHandle (HANDLE (Port.H.all)); |
| Port.H.all := 0; |
| Raise_Error ("set: cannot get comm state"); |
| end if; |
| |
| Com_Settings.BaudRate := DWORD (Data_Rate_Value (Rate)); |
| Com_Settings.fParity := 1; |
| Com_Settings.fBinary := Bits1 (System.Win32.TRUE); |
| Com_Settings.fOutxCtsFlow := 0; |
| Com_Settings.fOutxDsrFlow := 0; |
| Com_Settings.fDsrSensitivity := 0; |
| Com_Settings.fDtrControl := DTR_CONTROL_DISABLE; |
| Com_Settings.fOutX := 0; |
| Com_Settings.fInX := 0; |
| Com_Settings.fRtsControl := RTS_CONTROL_DISABLE; |
| Com_Settings.fAbortOnError := 0; |
| Com_Settings.ByteSize := BYTE (C_Bits (Bits)); |
| Com_Settings.Parity := BYTE (C_Parity (Parity)); |
| Com_Settings.StopBits := BYTE (C_Stop_Bits (Stop_Bits)); |
| |
| Success := SetCommState (HANDLE (Port.H.all), Com_Settings'Access); |
| |
| if Success = Win32.FALSE then |
| Success := CloseHandle (HANDLE (Port.H.all)); |
| Port.H.all := 0; |
| Raise_Error ("cannot set comm state"); |
| end if; |
| |
| -- Set the timeout status |
| |
| if Block then |
| Com_Time_Out := (others => 0); |
| else |
| Com_Time_Out := |
| (ReadTotalTimeoutConstant => DWORD (1000 * Timeout), |
| others => 0); |
| end if; |
| |
| Success := |
| SetCommTimeouts |
| (hFile => HANDLE (Port.H.all), |
| lpCommTimeouts => Com_Time_Out'Access); |
| |
| if Success = Win32.FALSE then |
| Raise_Error ("cannot set the timeout"); |
| end if; |
| end Set; |
| |
| ----------- |
| -- Write -- |
| ----------- |
| |
| overriding procedure Write |
| (Port : in out Serial_Port; |
| Buffer : Stream_Element_Array) |
| is |
| Success : BOOL; |
| Temp_Last : aliased DWORD; |
| |
| begin |
| if Port.H = null then |
| Raise_Error ("write: port not opened", 0); |
| end if; |
| |
| Success := |
| WriteFile |
| (hFile => HANDLE (Port.H.all), |
| lpBuffer => Buffer'Address, |
| nNumberOfBytesToWrite => DWORD (Buffer'Length), |
| lpNumberOfBytesWritten => Temp_Last'Access, |
| lpOverlapped => null); |
| |
| if Success = Win32.FALSE |
| or else Stream_Element_Offset (Temp_Last) /= Buffer'Length |
| then |
| Raise_Error ("failed to write data"); |
| end if; |
| end Write; |
| |
| end GNAT.Serial_Communications; |