Исходящий сигнал, когда байты принимаются в последовательном порту

Question

Я пытаюсь подключить сигнал и слот на C++, используя библиотеки boost. Мой код в настоящее время открывает файл и считывает данные с него. Тем не менее, я пытаюсь улучшить код, чтобы он мог читать и анализировать данные в реальном времени с помощью последовательного порта. Я бы хотел, чтобы функции анализа вызывались только один раз, когда есть данные, доступные в последовательном порту.

Как бы я это сделал? Я делал это в Qt раньше, однако я не могу использовать сигналы и слоты в Qt, потому что этот код не использует их moc-инструмент.

Answer 1

Ваша ОС (Linux) предоставляет вам следующий механизм при работе с последовательным портом.

Вы можете установить свой последовательный порт в неканонический режим (путем снятия отметки ICANON с флагом в структуре termios). Затем, если параметры MIN и TIME в c_cc[] равны нулю, функция read() будет возвращать тогда и только тогда, когда в буфере ввода последовательного порта есть новые данные (подробности см. В справочной странице termios). Таким образом, вы можете запустить отдельный поток, отвечающий за получение входящего последовательных данных:

ssize_t count, bytesReceived = 0; 
char myBuffer[1024]; 
while(1) 
{ 
    if (count = read(portFD, 
     myBuffer + bytesReceived, 
     sizeof(myBuffer)-bytesReceived) > 0) 
    { 
    /* 
     Here we check the arrived bytes. If they can be processed as a complete message, 
     you can alert other thread in a way you choose, put them to some kind of 
     queue etc. The details depend greatly on communication protocol being used. 
     If there is not enough bytes to process, you just store them in buffer 
     */ 
     bytesReceived += count; 
     if (MyProtocolMessageComplete(myBuffer, bytesReceived)) 
     { 
       ProcessMyData(myBuffer, bytesReceived); 
       AlertOtherThread(); //emit your 'signal' here 
       bytesReceived = 0; //going to wait for next message 
     } 
    } 
    else 
    { 
    //process read() error 
    } 
} 

Основная идея здесь заключается в том, что поток вызова read() будет активна только при поступлении новых данных. В остальное время ОС сохранит этот поток в состоянии ожидания. Таким образом, он не будет потреблять процессорное время. Это зависит от вас, как реализовать фактическую часть signal.

В приведенном выше примере используется регулярный read системный вызов для получения данных из порта, но вы можете использовать класс boost таким же образом. Просто используйте функцию синхронного чтения, и результат будет таким же.