From aa96b4fc589d30dd688f1a2d0baa786b5c3fb5be Mon Sep 17 00:00:00 2001 From: Pierre Rognant Date: Mon, 13 Jul 2020 15:19:28 +0200 Subject: [PATCH 1/2] [dogstatsd] sock.setblocking(0) for UDP socket --- datadog/dogstatsd/base.py | 1 + 1 file changed, 1 insertion(+) diff --git a/datadog/dogstatsd/base.py b/datadog/dogstatsd/base.py index 750771f28..8f1d21fff 100644 --- a/datadog/dogstatsd/base.py +++ b/datadog/dogstatsd/base.py @@ -246,6 +246,7 @@ def get_socket(self): self.socket = sock else: sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) + sock.setblocking(0) sock.connect((self.host, self.port)) self.socket = sock From 6b3b54b726a84162904ea36b2606e7d1a2f1fb77 Mon Sep 17 00:00:00 2001 From: Pierre Rognant Date: Wed, 15 Jul 2020 17:41:33 +0200 Subject: [PATCH 2/2] Consistency udp vs. af_unix --- datadog/dogstatsd/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datadog/dogstatsd/base.py b/datadog/dogstatsd/base.py index 8f1d21fff..f52bc5cf5 100644 --- a/datadog/dogstatsd/base.py +++ b/datadog/dogstatsd/base.py @@ -241,8 +241,8 @@ def get_socket(self): if not self.socket: if self.socket_path is not None: sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) - sock.connect(self.socket_path) sock.setblocking(0) + sock.connect(self.socket_path) self.socket = sock else: sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)