Skip to content

Commit 6392b5f

Browse files
authored
[Geneva] Send data to socket with MSG_NOSIGNAL (#546)
1 parent 12a60a7 commit 6392b5f

File tree

2 files changed

+14
-2
lines changed
  • exporters

2 files changed

+14
-2
lines changed

Diff for: exporters/fluentd/include/opentelemetry/exporters/fluentd/common/socket_tools.h

+7-1
Original file line numberDiff line numberDiff line change
@@ -585,8 +585,14 @@ struct Socket {
585585
assert(m_sock != Invalid);
586586
if ((m_sock == Invalid) || (buffer == nullptr) || (size == 0))
587587
return 0;
588+
int flags =
589+
#ifdef _WIN32
590+
0;
591+
#else
592+
MSG_NOSIGNAL;
593+
#endif
588594
return static_cast<int>(
589-
::send(m_sock, reinterpret_cast<char const *>(buffer), size, 0));
595+
::send(m_sock, reinterpret_cast<char const *>(buffer), size, flags));
590596
}
591597

592598
int sendto(void const *buffer, size_t size, int flags, SocketAddr &destAddr) {

Diff for: exporters/geneva/include/opentelemetry/exporters/geneva/metrics/socket_tools.h

+7-1
Original file line numberDiff line numberDiff line change
@@ -570,8 +570,14 @@ struct Socket {
570570
assert(m_sock != Invalid);
571571
if ((m_sock == Invalid) || (buffer == nullptr) || (size == 0))
572572
return 0;
573+
int flags =
574+
#ifdef _WIN32
575+
0;
576+
#else
577+
MSG_NOSIGNAL;
578+
#endif
573579
return static_cast<int>(
574-
::send(m_sock, reinterpret_cast<char const *>(buffer), size, 0));
580+
::send(m_sock, reinterpret_cast<char const *>(buffer), size, flags));
575581
}
576582

577583
int sendto(void const *buffer, size_t size, int flags, SocketAddr &destAddr) {

0 commit comments

Comments
 (0)