NeroReflex/ROGueENEMY
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Do not spam errors!

Browse source
This commit is contained in:
Denis 2023-12-13 02:15:46 +01:00
parent 385301f5cf
commit 29f67daddd
No known key found for this signature in database
GPG key ID: DD9B63F805CF5C03
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
dev_out.c
View file

@ -316,11 +316,13 @@ void *dev_out_thread_func(void *ptr) {
} else if (dev_out->communication.type == ipc_server_sockets) {
if (pthread_mutex_lock(&dev_out->communication.endpoint.ssocket.mutex) == 0) {
for (int i = 0; i < MAX_CONNECTED_CLIENTS; ++i) {
const int write_res = write(dev_out->communication.endpoint.ssocket.clients[i], (void*)&out_msgs, bytes_to_send);
if (write_res != bytes_to_send) {
fprintf(stderr, "Error in writing out_message to socket number %d: %d\n", i, write_res);
close(dev_out->communication.endpoint.ssocket.clients[i]);
dev_out->communication.endpoint.ssocket.clients[i] = -1;
if (dev_out->communication.endpoint.ssocket.clients[i] > 0) {
const int write_res = write(dev_out->communication.endpoint.ssocket.clients[i], (void*)&out_msgs, bytes_to_send);
if (write_res != bytes_to_send) {
fprintf(stderr, "Error in writing out_message to socket number %d: %d\n", i, write_res);
close(dev_out->communication.endpoint.ssocket.clients[i]);
dev_out->communication.endpoint.ssocket.clients[i] = -1;
}
}
}