?? tserial_event.cpp
字號:
/* ------------------------------------------------------------------------ --
-- --
-- PC serial port connection object --
-- for event-driven programs --
-- --
-- --
-- --
-- Copyright @ 2001 Thierry Schneider --
-- thierry@tetraedre.com --
-- --
-- --
-- --
-- ------------------------------------------------------------------------ --
-- --
-- Filename : sertest2.cpp --
-- Author : Thierry Schneider --
-- Created : April 4th 2000 --
-- Modified : April 24th 2001 --
-- Plateform: Windows 95, 98, NT, 2000 (Win32) --
-- ------------------------------------------------------------------------ --
-- --
-- This software is given without any warranty. It can be distributed --
-- free of charge as long as this header remains, unchanged. --
-- --
-- ------------------------------------------------------------------------ --
-- --
-- 01.04.24 Comments added --
-- 01.04.28 Bug 010427 corrected. OnDisconnectedManager was not --
-- initialized --
-- 01.04.28 connect() function prototype modified to handle 7-bit --
-- communication --
-- 01.04.29 "ready" field added to remove a bug that occured during --
-- reconnect (event manager pointers cleared) --
-- I removed the "delete" in Tserial_event_thread_start --
-- because it was destroying the object even if we would --
-- use it again --
-- --
-- --
-- ------------------------------------------------------------------------ --
-- --
-- Note to Visual C++ users: Don't forget to compile with the --
-- "Multithreaded" option in your project settings --
-- --
-- See Project settings --
-- | --
-- *--- C/C++ --
-- | --
-- *--- Code generation --
-- | --
-- *---- Use run-time library --
-- | --
-- *---- Multithreaded --
-- --
-- --
-- --
-- ------------------------------------------------------------------------ */
/* ---------------------------------------------------------------------- */
#define STRICT
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <process.h>
#include <conio.h>
#include <windows.h>
#include "Tserial_event.h"
#define SIG_POWER_ON 0 // signals definition for external threads
#define SIG_POWER_DOWN 1
#define SIG_COM_READER 3
#define SIG_COM_WRITER 4
#define SIG_DATA_IN 5 // for byte by byte operation
void Tserial_event_thread_start(void *arg);
typedef unsigned (WINAPI *PBEGINTHREADEX_THREADFUNC) (LPVOID lpThreadParameter);
typedef unsigned *PBEGINTHREADEX_THREADID;
/* ---------------------------------------------------------------------- */
/* --------------------- Tserial_event_thread_start ------------------- */
/* ---------------------------------------------------------------------- */
/**
This function is not part of the Tserial_event object. It is simply used
to start the thread from an external point of the object.
*/
void Tserial_event_thread_start(void *arg)
{
class Tserial_event *serial_unit;
serial_unit = (Tserial_event *) arg;
if (serial_unit!=0)
serial_unit->Run();
}
/* -------------------------------------------------------------------- */
/* ------------------------- Tserial_event ------------------------- */
/* -------------------------------------------------------------------- */
Tserial_event::Tserial_event()
{
int i;
ready = false;
parityMode = spNONE;
port[0] = 0;
rate = 0;
threadid = 0;
serial_handle = INVALID_HANDLE_VALUE;
tx_in_progress = 0;
rx_in_progress = 0;
OnConnectedManager = 0;
OnCharSentManager = 0;
OnCharArrivalManager = 0;
OnDisconnectedManager= 0; // bug 010427 correction
/* -------------------------------------------------------------- */
// creating Events for the different sources
for (i=0; i<TSERIAL_SIGNAL_NBR; i++)
{
if ((i==SIG_COM_READER) || (i==SIG_COM_WRITER) )
serial_events[i] = CreateEvent(NULL, TRUE, FALSE, NULL); // Manual Reset
else
serial_events[i] = CreateEvent(NULL, FALSE, FALSE, NULL); // Auto reset
}
}
/* -------------------------------------------------------------------- */
/* -------------------------- ~Tserial_event ----------------------- */
/* -------------------------------------------------------------------- */
Tserial_event::~Tserial_event()
{
int i;
/* -------------------------------------------------------- */
for (i=0; i<TSERIAL_SIGNAL_NBR; i++) // deleting the events
{
if (serial_events[i]!=INVALID_HANDLE_VALUE)
CloseHandle(serial_events[i]);
serial_events[i] = INVALID_HANDLE_VALUE;
}
if (serial_handle!=INVALID_HANDLE_VALUE)
CloseHandle(serial_handle);
serial_handle = INVALID_HANDLE_VALUE;
}
/* ---------------------------------------------------------------------- */
/* ------------------------ Start_thread --------------------- */
/* ---------------------------------------------------------------------- */
void Tserial_event::Start_thread(void)
{
SetSignal(SIG_POWER_ON); // sending a power on signal to myself
_beginthreadex(NULL,0,(PBEGINTHREADEX_THREADFUNC) Tserial_event_thread_start,
(void *) this, 0, &threadid);
}
/* -------------------------------------------------------------------- */
/* -------------------------- SetSignal ------------------------- */
/* -------------------------------------------------------------------- */
void Tserial_event::SetSignal(long mask)
{
if ((mask<TSERIAL_SIGNAL_NBR) && (mask>=0))
{
if (serial_events[mask]!=INVALID_HANDLE_VALUE)
SetEvent(serial_events[mask]);
}
}
/* -------------------------------------------------------------------- */
/* -------------------------- disconnect ------------------------- */
/* -------------------------------------------------------------------- */
void Tserial_event::disconnect(void)
{
ready = false;
SetSignal(SIG_POWER_DOWN);
}
/* -------------------------------------------------------------------- */
/* -------------------------- powerDown ------------------------- */
/* -------------------------------------------------------------------- */
void Tserial_event::powerDown(void)
{
ready = false;
if (serial_handle!=INVALID_HANDLE_VALUE)
CloseHandle(serial_handle);
serial_handle = INVALID_HANDLE_VALUE;
OnDisconnected();
}
/* -------------------------------------------------------------------- */
/* -------------------------- connect ------------------------- */
/* -------------------------------------------------------------------- */
/**
Serial port, file and overlapped structures initialization
*/
int Tserial_event::connect (char *port_arg, int rate_arg,
serial_parity parity_arg, char ByteSize)
{
int erreur;
DCB dcb;
COMMTIMEOUTS cto = { 0, 0, 0, 0, 0 };
/* --------------------------------------------- */
if (serial_handle!=INVALID_HANDLE_VALUE)
CloseHandle(serial_handle);
serial_handle = INVALID_HANDLE_VALUE;
if (port_arg!=0)
{
strncpy(port, port_arg, 10);
rate = rate_arg;
parityMode= parity_arg;
erreur = 0;
ZeroMemory(&ovReader,sizeof(ovReader)); // clearing the overlapped
ZeroMemory(&ovWriter,sizeof(ovWriter));
memset(&dcb,0,sizeof(dcb));
/* -------------------------------------------------------------------- */
// set DCB to configure the serial port
dcb.DCBlength = sizeof(dcb);
/* ---------- Serial Port Config ------- */
dcb.BaudRate = rate;
switch(parityMode)
{
case spNONE:
dcb.Parity = NOPARITY;
dcb.fParity = 0;
break;
case spEVEN:
dcb.Parity = EVENPARITY;
dcb.fParity = 1;
break;
case spODD:
dcb.Parity = ODDPARITY;
dcb.fParity = 1;
break;
}
dcb.StopBits = ONESTOPBIT;
dcb.ByteSize = (BYTE) ByteSize;
dcb.fOutxCtsFlow = 0;
dcb.fOutxDsrFlow = 0;
dcb.fDtrControl = DTR_CONTROL_DISABLE;
dcb.fDsrSensitivity = 0;
dcb.fRtsControl = RTS_CONTROL_DISABLE;
dcb.fOutX = 0;
dcb.fInX = 0;
/* ----------------- misc parameters ----- */
dcb.fErrorChar = 0;
dcb.fBinary = 1;
dcb.fNull = 0;
dcb.fAbortOnError = 0;
dcb.wReserved = 0;
dcb.XonLim = 2;
dcb.XoffLim = 4;
dcb.XonChar = 0x13;
dcb.XoffChar = 0x19;
dcb.EvtChar = 0;
/* -------------------------------------------------------------------- */
serial_handle = CreateFile(port, GENERIC_READ | GENERIC_WRITE,
0, NULL, OPEN_EXISTING,FILE_FLAG_OVERLAPPED,NULL);
// opening serial port
ovReader.hEvent = serial_events[SIG_COM_READER];
ovWriter.hEvent = serial_events[SIG_COM_WRITER];
if (serial_handle != INVALID_HANDLE_VALUE)
{
if(!SetCommMask(serial_handle, 0))
erreur = 1;
// set timeouts
if(!SetCommTimeouts(serial_handle,&cto))
erreur = 2;
// set DCB
if(!SetCommState(serial_handle,&dcb))
erreur = 4;
}
else
erreur = 8;
}
else
erreur = 16;
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -