folkert/KEK
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

logging

Browse source
This commit is contained in:
folkert van heusden 2024-05-17 10:04:32 +02:00
parent abdf3eeb23
commit f37ed538e2
Signed by untrusted user who does not match committer: folkert
GPG key ID: 6B6455EDFEED3BD1
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
comm_tcp_socket_server.cpp
View file

@ -115,6 +115,7 @@ uint8_t comm_tcp_socket_server::get_byte()
uint8_t c = 0; uint8_t c = 0;
if (read(use_fd, &c, 1) <= 0) { if (read(use_fd, &c, 1) <= 0) {
DOLOG(warning, false, " comm_tcp_socket_server::get_byte failed");
std::unique_lock<std::mutex> lck(cfd_lock); std::unique_lock<std::mutex> lck(cfd_lock);
close(cfd); close(cfd);
cfd = INVALID_SOCKET; cfd = INVALID_SOCKET;
@ -132,6 +133,7 @@ void comm_tcp_socket_server::send_data(const uint8_t *const in, const size_t n)
std::unique_lock<std::mutex> lck(cfd_lock); std::unique_lock<std::mutex> lck(cfd_lock);
int rc = write(cfd, p, len); int rc = write(cfd, p, len);
if (rc <= 0) { // TODO error checking if (rc <= 0) { // TODO error checking
DOLOG(warning, false, " comm_tcp_socket_server::send_data failed");
close(cfd); close(cfd);
cfd = INVALID_SOCKET; cfd = INVALID_SOCKET;
break; break;
@ -144,7 +146,7 @@ void comm_tcp_socket_server::send_data(const uint8_t *const in, const size_t n)
void comm_tcp_socket_server::operator()() void comm_tcp_socket_server::operator()()
{ {
set_thread_name("kek:COMMTCP"); set_thread_name("kek:COMMTCPS");
DOLOG(info, true, "TCP comm thread started for port %d", port); DOLOG(info, true, "TCP comm thread started for port %d", port);
@ -171,7 +173,7 @@ void comm_tcp_socket_server::operator()()
close(fd); close(fd);
fd = INVALID_SOCKET; fd = INVALID_SOCKET;
DOLOG(warning, true, "Cannot bind to port %d (comm_tcp_socket_server)", port); DOLOG(warning, true, "Cannot bind to port %d (send_datacomm_tcp_socket_server)", port);
return; return;
} }
@ -218,7 +220,7 @@ void comm_tcp_socket_server::operator()()
set_nodelay(cfd); set_nodelay(cfd);
} }
DOLOG(info, true, "DC11 thread terminating"); DOLOG(info, true, "comm_tcp_socket_server thread terminating");
close(cfd); close(cfd);
close(fd); close(fd);