ulan.pas

一个linux下rs485驱动程序的源代码

unit ulan;
interface

uses
{$IFDEF FPC}
  LResources,
{$ELSE}
  Windows,
{$ENDIF}
  SysUtils, Classes, ul_drvdef;

{$IFDEF FPC}

{$IFDEF WINDOWS}
  {$DEFINE DYNLINK}
{$ENDIF}

{$IFDEF DYNLINK}
const
{$IF Defined(WINDOWS)}
  ulanlib = 'libulan.dll';
{$ELSEIF Defined(UNIX)}
  ulanlib = 'libulan.so';
{$ELSE}
  {$MESSAGE ERROR 'DYNLINK not supported'}
{$IFEND}
{$ELSE}
  {$LINKLIB ulan}
{$ENDIF}

{$PACKRECORDS C}
{$ENDIF}

type

{$IFDEF UNIX}
  size_t = longint;
{$ENDIF}

  uloi_coninfo_t = record
    adr : longint;        	{ address of target module  }
    cmd : longint;        	{ service/cmd number for uLOI on target  }
    bcmd : longint;       	{ service/cmd number for returned messages  }
    sn : longint;         	{ sequence counter  }
    bsn : longint;        	{ sequence counter of target module  }
    outflg : longint;     	{ flags used for outgoing messages  }
    ul_fd : ul_fd_t;      	{ handle for ul_drv  }
    ul_fd1 : ul_fd_t;     	{ the auxiliary handle for ULOI direct reply  }
    timeout : longint;    	{ timeout  }
    error : longint;      	{ error condition occurred  }
    state : Longword;      	{ internal state  }
  end;

  pplongint = ^plongint;
  pul_msginfo  = ^ul_msginfo;
  puloi_coninfo_t  = ^uloi_coninfo_t;
  ppbyte  = ^pbyte;

{$IFNDEF FPC}
  size_t = longint;
{$ENDIF}
  ssize_t = longint;

  function ul_open(dev_name:pchar; options:Pchar):ul_fd_t;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_close(ul_fd:ul_fd_t):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_drv_version(ul_fd:ul_fd_t):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_read(ul_fd:ul_fd_t; buffer:pointer; size:size_t):ssize_t;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_write(ul_fd:ul_fd_t; buffer:pointer; size:size_t):ssize_t;cdecl;external{$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_newmsg(ul_fd:ul_fd_t; msginfo:pul_msginfo):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_tailmsg(ul_fd:ul_fd_t; msginfo:pul_msginfo):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_freemsg(ul_fd:ul_fd_t):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_acceptmsg(ul_fd:ul_fd_t; msginfo:pul_msginfo):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_actailmsg(ul_fd:ul_fd_t; msginfo:pul_msginfo):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_addfilt(ul_fd:ul_fd_t; msginfo:pul_msginfo):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_abortmsg(ul_fd:ul_fd_t):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_rewmsg(ul_fd:ul_fd_t):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_inepoll(ul_fd:ul_fd_t):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_drv_debflg(ul_fd:ul_fd_t; debug_msk:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_fd_wait(ul_fd:ul_fd_t; wait_sec:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};

  { simple message operations  }
  function ul_send_command(ul_fd:ul_fd_t; dadr:longint; cmd:longint; flg:longint; buf:pointer;
             len:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_send_command_wait(ul_fd:ul_fd_t; dadr:longint; cmd:longint; flg:longint; buf:pointer;
             len:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_send_query(ul_fd:ul_fd_t; dadr:longint; cmd:longint; flg:longint; buf:pointer;
             len:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function ul_send_query_wait(ul_fd:ul_fd_t; dadr:longint; cmd:longint; flg:longint; bufin:pointer;
             lenin:longint; bufout:Ppointer; lenout:Plongint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};

  { basic uLan commands/services  }

  const
     UL_CMD_OISV = $10;     	{ Object Interface Service  }
     UL_CMD_LCDABS = $4f;       { Absorbance data block  }
     UL_CMD_LCDMRK = $4e;       { Mark  }
     UL_CMD_NCS = $7f;          { Network Control Service  }
     UL_CMD_GST = $c1;          { Fast module get status  }

  { definitions of basic uLan OI commands  }

     ULOI_AOID = 10;     	{ name is defined in ASCII for DOIx  }
     ULOI_DOII = 12;     	{ description of input objects  }
     ULOI_DOIO = 14;     	{ description of output objects  }
     ULOI_QOII = 16;     	{ ID numbers of recognized input objects  }
     ULOI_QOIO = 18;     	{ ID numbers of recognized output objects  }
     ULOI_RDRQ = 20;     	{ object values read request  }
     ULOI_STATUS = 30;          { read instrument status  }
     ULOI_ERRCLR = 31;   	{ clear error status  }


  { definitions of basic uLan OI functions  }

  function uloi_open(ul_dev_name:Pchar; adr:longint; cmd:longint; bcmd:longint; timeout:longint):puloi_coninfo_t;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  procedure uloi_close(coninfo:puloi_coninfo_t);cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_transfer(coninfo:puloi_coninfo_t; bufin:Pchar; lenin:longint; bufout:PPchar; lenout:Plongint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_set_var(coninfo:puloi_coninfo_t; oid:longint; val:pointer; size:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_get_var(coninfo:puloi_coninfo_t; oid:longint; val:pointer; size:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_set_var_u2(coninfo:puloi_coninfo_t; oid:longint; val:longword):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_get_var_u2(coninfo:puloi_coninfo_t; oid:longint; val:Plongword):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_send_cmd(coninfo:puloi_coninfo_t; oid:longint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_get_oids(coninfo:puloi_coninfo_t; list:longint; oids_list:pplongint):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_get_oiddes(coninfo:puloi_coninfo_t; list:longint; oid:longint; poiddespack:ppbyte):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_get_aoiddes(coninfo:puloi_coninfo_t; list:longint; aoid:pchar; poiddespack:ppbyte):longint;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_oiddespack_getloc(despack:pbyte;strindex:longint):pbyte;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  function uloi_oiddespack_strdup(despack:pbyte;strindex:longint):pchar;cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};
  procedure uloi_cfree(p:pointer);cdecl;external {$IFDEF DYNLINK}ulanlib{$ENDIF};

  { UL_CMD_NCS	Network Control Service  }

const
     ULNCS_ADR_RQ = $C0;     	{ SN0 SN1 SN2 SN3  }
     ULNCS_SET_ADDR = $C1;      { SN0 SN1 SN2 SN3 NEW_ADR  }
     ULNCS_SID_RQ = $C2;        { send serial num and ID string request  }
     ULNCS_SID_RPLY = $C3;      { SN0 SN1 SN2 SN3 ID ...  }
     ULNCS_ADDR_NVSV = $C4;     { SN0 SN1 SN2 SN3 - save addres to EEPROM  }
     ULNCS_BOOT_ACT = $C5;      { SN0 SN1 SN2 SN3  }
     ULNCS_BOOT_ACK = $C6;      { SN0 SN1 SN2 SN3  }

  { UL_CMD_RES	Reinitialize RS485 or connected module }

     ULRES_LINK = $10;
     ULRES_BAUD = $12;
     ULRES_CPU = $21;    { password - default 0x55 0xAA }

type
  TuMsg = procedure(FRcvMessage:ul_msginfo;BuffRx:pchar) of object;

  TuLan = class;                          //forward declaration

  TComThread = class (TThread)
    FuLan:TuLan;
    FRcvMessage:ul_msginfo;
    Buffer: Pchar;
  private
  protected
    procedure DispatchComMsg;
    procedure Execute;override;
  public
    constructor Create(uLan:TuLan);
  end;

  TuLan = class(TComponent)
  private
    FComThread: TComThread;
    FuMsg: TuMsg;
    FD: ul_fd_t;                         { Handle to uULan device driver. }
    FD1: ul_fd_t;                        { Handle to uULan device driver. }
    FOSDeviceName: string;
    procedure FlushMessages;
    function MessageAvailable: boolean;
    function MessageOpen: integer;
  protected
    { Protected declarations }
  public
    FRcvMessage:ul_msginfo;
    FSndMessage:ul_msginfo;
    constructor Create(AOwner: TComponent); override;
    destructor Destroy; override;
    procedure SetActive(OnOff: boolean);
    function GetActive: boolean;
    function GetDrvVersion: integer;
    function FilterAdd(ASrcAddr: integer; ACommand: integer):integer;
    function MessageCreate(ADestAddr: integer; ACommand: integer; AMessageFlags: integer): integer;
    function MessageTailCreate(ADestAddr: integer; ACommand: integer; AMessageFlags: integer): integer;
    function MessageWriteBuf(const ABuf; ABufSize: integer): integer;
    function MessageClose: integer;
    function MessageAbort: integer;

    function CommandSend(ADestAddr: integer; ACommand: integer;
                 AMessageFlags: integer; OutBuf: pointer; OutBufSize: integer): integer;
    function CommandSendWait(ADestAddr: integer; ACommand: integer;
                 AMessageFlags: integer; OutBuf: pointer; OutBufSize: integer): integer;
    function QuerySend(ADestAddr: integer; ACommand: integer;
                 AMessageFlags: integer; OutBuf: pointer; OutBufSize: integer): integer;
    function QuerySendWait(ADestAddr: integer; ACommand: integer;
                 AMessageFlags: integer; OutBuf: pointer; OutBufSize: integer;
                 var InBuf:pchar; var InBufSize: integer): integer;
  published
    property OnMessage: TuMsg read FuMsg write FuMsg;
    property Active: boolean read GetActive write SetActive default False;
    property OSDeviceName: string read FOSDeviceName write FOSDeviceName;
  end;

procedure Register;

implementation

//Receive messages
constructor TComThread.Create(uLan:TuLan);
begin
  inherited Create(True);
  FuLan:=uLan;
end;

procedure TComThread.Execute;
var bytes_ret:longint;
    stamp:integer;
begin
  while not Terminated do begin
    if (ul_fd_wait(FuLan.FD1,1)>0) then begin