1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
| uint8_t input_buffer[18];
//---------------------------------------------------------------------------
#define BUFSIZE 18 //ёмкость буферов
unsigned char bufrd[BUFSIZE], bufwr[BUFSIZE]; // приёмный и передающий буферы
//---------------------------------------------------------------------------
HANDLE COMport; //дескриптор порта
//структура OVERLAPPED необходима для асинхронных операций
OVERLAPPED overlapped; //для операций чтения (поток ReadThread)
OVERLAPPED overlappedwr; //для операций записи (поток WriteThread)
int handle; //дескриптор для работы с файлом с помощью библиотеки <io.h>
String SetInitStr;
bool ConnectActive = false;
HANDLE reader; //дескриптор потока чтения из порта
HANDLE writer; //дескриптор потока записи в порт
DWORD WINAPI ReadThread(LPVOID);
DWORD WINAPI WriteThread(LPVOID);
char stop = 0, parity = 0;
DWORD Flag = FILE_FLAG_OVERLAPPED;
//---------------------------------------------------------------------------
__fastcall TForm1::TForm1(TComponent* Owner)
: TForm(Owner)
{
}
//---------------------------------------------------------------------------
//главная функция потока, реализует приём байтов из COM-порта
DWORD WINAPI ReadThread(LPVOID)
{
COMSTAT comstat;
DWORD btr, temp, mask, signal;
overlapped.hEvent = CreateEvent(NULL, true, true, NULL);
SetCommMask(COMport, EV_RXCHAR);
while(1){
WaitCommEvent(COMport, &mask, &overlapped);
signal = WaitForSingleObject(overlapped.hEvent, INFINITE);
if(signal == WAIT_OBJECT_0){
if(GetOverlappedResult(COMport, &overlapped, &temp, true)){
if((mask & EV_RXCHAR)!=0){
ClearCommError(COMport, &temp, &comstat);
btr = comstat.cbInQue;
if(btr){
ReadFile(COMport, bufrd, 18, &temp, &overlapped);
for(int n = 0; n < 18; n++){
input_buffer[n] = bufrd[n];
bufrd[n] = 0;
}
Form1->Timer2->Enabled = true;
}
}
}
}
}
CloseHandle(overlapped.hEvent);
}
//---------------------------------------------------------------------------
// функция записи данных в СОМ порт
DWORD WINAPI WriteThread(LPVOID)
{
DWORD temp, signal;
COMSTAT comstat;
overlappedwr.hEvent = CreateEvent(NULL, true, true, NULL);
while(1){
WriteFile(COMport, bufwr, strlen(bufwr), &temp, &overlappedwr);
signal = WaitForSingleObject(overlappedwr.hEvent, INFINITE);
if((signal == WAIT_OBJECT_0) && (GetOverlappedResult(COMport, &overlappedwr, &temp, true))){
ClearCommError(COMport, &temp, &comstat);
}
memset(bufwr, 0, BUFSIZE);
SuspendThread(writer);
}
}
//---------------------------------------------------------------------------
//функция открытия и инициализации порта
void __fastcall TForm1::COMOpen()
{
String portname; //имя порта (например, "COM1", "COM2" и т.д.)
DCB dcb; //структура для общей инициализации порта DCB
COMMTIMEOUTS timeouts; //структура для установки таймаутов
portname = ComboBox1->Text; //получить имя выбранного порта
//открыть порт, для асинхронных операций обязательно нужно указать флаг FILE_FLAG_OVERLAPPED
COMport = CreateFile(portname.c_str(), GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, Flag, NULL);
// - portname.c_str() - имя порта в качестве имени файла, c_str() преобразует строку типа String в строку в виде массива типа char, иначе функция не примет
// - GENERIC_READ | GENERIC_WRITE - доступ к порту на чтение/записть
// - 0 - порт не может быть общедоступным (shared)
// - NULL - дескриптор порта не наследуется, используется дескриптор безопасности по умолчанию
// - OPEN_EXISTING - порт должен открываться как уже существующий файл
// - FILE_FLAG_OVERLAPPED - этот флаг указывает на использование асинхронных операций
// - NULL - указатель на файл шаблона не используется при работе с портами
if(COMport == INVALID_HANDLE_VALUE){
COMClose();
ShowMessage("Error: Can not open port");
ConnectActive = false;
return;
}
//инициализация порта
dcb.DCBlength = sizeof(DCB); //в первое поле структуры DCB необходимо занести её длину, она будет использоваться функциями настройки порта для контроля корректности структуры
//считать структуру DCB из порта
if(!GetCommState(COMport, &dcb)){ //если не удалось - закрыть порт и вывести сообщение об ошибке в строке состояния
COMClose();
ShowMessage("Error: Can not read DCB");
ConnectActive = false;
return;
}
//инициализация структуры DCB
dcb.BaudRate = StrToInt(ComboBox2->Text); //задаём скорость передачи 9600 бод
dcb.fBinary = TRUE; //включаем двоичный режим обмена
dcb.fOutxCtsFlow = FALSE; //выключаем режим слежения за сигналом CTS
dcb.fOutxDsrFlow = FALSE; //выключаем режим слежения за сигналом DSR
dcb.fDtrControl = DTR_CONTROL_DISABLE; //отключаем использование линии DTR
dcb.fDsrSensitivity = FALSE; //отключаем восприимчивость драйвера к состоянию линии DSR
dcb.fNull = FALSE; //запретить приём нулевых байтов
dcb.fRtsControl = RTS_CONTROL_DISABLE; //отключаем использование линии RTS
dcb.fAbortOnError = FALSE; //отключаем остановку всех операций чтения/записи при ошибке
dcb.ByteSize = StrToInt(ComboBox3->Text); //задаём 8 бит в байте
dcb.Parity = 0; //отключаем проверку чётности
dcb.StopBits = stop; //задаём один стоп-бит
//загрузить структуру DCB в порт
if(!SetCommState(COMport, &dcb)){ //если не удалось - закрыть порт и вывести сообщение об ошибке в строке состояния
COMClose();
ShowMessage("Error: Can not set DCB");
ConnectActive = false;
return;
}
//установить таймауты
timeouts.ReadIntervalTimeout = 0; //таймаут между двумя символами
timeouts.ReadTotalTimeoutMultiplier = 0; //общий таймаут операции чтения
timeouts.ReadTotalTimeoutConstant = 0; //константа для общего таймаута операции чтения
timeouts.WriteTotalTimeoutMultiplier = 0; //общий таймаут операции записи
timeouts.WriteTotalTimeoutConstant = 0; //константа для общего таймаута операции записи
//записать структуру таймаутов в порт
if(!SetCommTimeouts(COMport, &timeouts)){ //если не удалось - закрыть порт и вывести сообщение об ошибке в строке состояния
COMClose();
ShowMessage("Error: Can not set timeout");
ConnectActive = false;
return;
}
//установить размеры очередей приёма и передачи
SetupComm(COMport, 0, 0);
reader = CreateThread(NULL, 0, ReadThread, NULL, 0, NULL); //создаём поток чтения, который сразу начнёт выполняться (предпоследний параметр = 0)
writer = CreateThread(NULL, 0, WriteThread, NULL, CREATE_SUSPENDED, NULL); //создаём поток записи в остановленном состоянии (предпоследний параметр = CREATE_SUSPENDED)
ConnectActive = true;
}
//---------------------------------------------------------------------------
//функция закрытия порта
void __fastcall TForm1::COMClose()
{
if(writer){ //если поток записи работает, завершить его; проверка if(writer) обязательна, иначе возникают ошибки
TerminateThread(writer, 0);
CloseHandle(overlappedwr.hEvent); //нужно закрыть объект-событие
CloseHandle(writer);
}
if(reader){ //если поток чтения работает, завершить его; проверка if(reader) обязательна, иначе возникают ошибки
TerminateThread(reader, 0);
CloseHandle(overlapped.hEvent); //нужно закрыть объект-событие
CloseHandle(reader);
}
CloseHandle(COMport); //закрыть порт
COMport = 0; //обнулить переменную для дескриптора порта
ConnectActive = false;
} |
(
