From 392cd9d7592ee5d6b215cf88fc97b73f697d2286 Mon Sep 17 00:00:00 2001 From: Richard Fuchs Date: Thu, 3 Jul 2025 15:06:43 -0400 Subject: [PATCH] MT#63171 StatsUDPServer: facilitate shutdown Wake up thread from blocking on recvfrom() so that it can shut down when requested to. Change-Id: Iaa05caf93877363c162d56791a6e24bdfb809094 --- core/plug-in/stats/StatsUDPServer.cpp | 6 ++++++ core/plug-in/stats/StatsUDPServer.h | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/core/plug-in/stats/StatsUDPServer.cpp b/core/plug-in/stats/StatsUDPServer.cpp index 8286ee2a..3b57d0bd 100644 --- a/core/plug-in/stats/StatsUDPServer.cpp +++ b/core/plug-in/stats/StatsUDPServer.cpp @@ -233,6 +233,12 @@ void StatsUDPServer::run() } +void StatsUDPServer::on_stop() +{ + if (sd != -1) + shutdown(sd, SHUT_RD); +} + static int msg_get_line(char*& msg_c, char* str, size_t len) { size_t l; diff --git a/core/plug-in/stats/StatsUDPServer.h b/core/plug-in/stats/StatsUDPServer.h index d58443d9..81c77a2b 100644 --- a/core/plug-in/stats/StatsUDPServer.h +++ b/core/plug-in/stats/StatsUDPServer.h @@ -55,7 +55,7 @@ class StatsUDPServer: public AmThread const struct sockaddr_in& reply_addr); void run(); - void on_stop(){} + void on_stop(); public: static StatsUDPServer* instance();