diff --git a/exporters/fluentd/include/opentelemetry/exporters/fluentd/common/socket_tools.h b/exporters/fluentd/include/opentelemetry/exporters/fluentd/common/socket_tools.h index a8e1d3fbe..f33d1a352 100644 --- a/exporters/fluentd/include/opentelemetry/exporters/fluentd/common/socket_tools.h +++ b/exporters/fluentd/include/opentelemetry/exporters/fluentd/common/socket_tools.h @@ -585,8 +585,14 @@ struct Socket { assert(m_sock != Invalid); if ((m_sock == Invalid) || (buffer == nullptr) || (size == 0)) return 0; + int flags = +#ifdef _WIN32 + 0; +#else + MSG_NOSIGNAL; +#endif return static_cast( - ::send(m_sock, reinterpret_cast(buffer), size, 0)); + ::send(m_sock, reinterpret_cast(buffer), size, flags)); } int sendto(void const *buffer, size_t size, int flags, SocketAddr &destAddr) { diff --git a/exporters/geneva/include/opentelemetry/exporters/geneva/metrics/socket_tools.h b/exporters/geneva/include/opentelemetry/exporters/geneva/metrics/socket_tools.h index e8fddb5fc..64a541e73 100644 --- a/exporters/geneva/include/opentelemetry/exporters/geneva/metrics/socket_tools.h +++ b/exporters/geneva/include/opentelemetry/exporters/geneva/metrics/socket_tools.h @@ -570,8 +570,14 @@ struct Socket { assert(m_sock != Invalid); if ((m_sock == Invalid) || (buffer == nullptr) || (size == 0)) return 0; + int flags = +#ifdef _WIN32 + 0; +#else + MSG_NOSIGNAL; +#endif return static_cast( - ::send(m_sock, reinterpret_cast(buffer), size, 0)); + ::send(m_sock, reinterpret_cast(buffer), size, flags)); } int sendto(void const *buffer, size_t size, int flags, SocketAddr &destAddr) {