accept() can return an error

This commit is contained in:
folkert van heusden 2024-05-04 20:11:37 +02:00
parent 8cd6eed238
commit d1cd336ccd
Signed by untrusted user who does not match committer: folkert
GPG key ID: 6B6455EDFEED3BD1

View file

@ -117,6 +117,7 @@ void dc11::operator()()
} }
pfds[client_i].fd = accept(pfds[i].fd, nullptr, nullptr); pfds[client_i].fd = accept(pfds[i].fd, nullptr, nullptr);
if (pfds[client_i].fd != -1) {
set_nodelay(pfds[client_i].fd); set_nodelay(pfds[client_i].fd);
std::unique_lock<std::mutex> lck(input_lock[i]); std::unique_lock<std::mutex> lck(input_lock[i]);
@ -125,6 +126,7 @@ void dc11::operator()()
if (is_rx_interrupt_enabled(i)) if (is_rx_interrupt_enabled(i))
trigger_interrupt(i); trigger_interrupt(i);
} }
}
// receive data // receive data
for(int i=dc11_n_lines; i<dc11_n_lines * 2; i++) { for(int i=dc11_n_lines; i<dc11_n_lines * 2; i++) {