X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=udpinput.cpp;h=3a8beffeabcc8fcfd4aff48e2694f5aaa79603dd;hp=fc0779cebdf25be2eb115b92ce3da73f543ec9eb;hb=4d354ff76f26c47c090f8d095ef47a6199c24336;hpb=488f28bf7070f44469a006ed4a9d4c423788d175 diff --git a/udpinput.cpp b/udpinput.cpp index fc0779c..3a8beff 100644 --- a/udpinput.cpp +++ b/udpinput.cpp @@ -8,6 +8,7 @@ #include #include "acceptor.h" +#include "log.h" #include "serverpool.h" #include "state.pb.h" #include "udpinput.h" @@ -60,7 +61,7 @@ void UDPInput::close_socket() } while (ret == -1 && errno == EINTR); if (ret == -1) { - perror("close()"); + log_perror("close()"); } sock = -1; @@ -84,7 +85,7 @@ void UDPInput::do_work() int port_num = atoi(port.c_str()); sock = create_server_socket(port_num, UDP_SOCKET); if (sock == -1) { - fprintf(stderr, "WARNING: UDP socket creation failed. Waiting 0.2 seconds and trying again...\n"); + log(WARNING, "UDP socket creation failed. Waiting 0.2 seconds and trying again..."); usleep(200000); continue; } @@ -101,7 +102,7 @@ void UDPInput::do_work() continue; } if (nfds == -1) { - perror("poll"); + log_perror("poll"); close_socket(); continue; } @@ -113,7 +114,7 @@ void UDPInput::do_work() } while (ret == -1 && errno == EINTR); if (ret <= 0) { - perror("recv"); + log_perror("recv"); close_socket(); continue; }