From 7c75d3358b1a54ca9b47bc676791dc7ff3844320 Mon Sep 17 00:00:00 2001
From: Yota Toyama <raviqqe@gmail.com>
Date: Tue, 30 Jul 2024 17:45:51 +0900
Subject: [PATCH] Revert socket options

---
 src/prime_server.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/prime_server.cpp b/src/prime_server.cpp
index 3231675..8d5d9e8 100644
--- a/src/prime_server.cpp
+++ b/src/prime_server.cpp
@@ -158,6 +158,7 @@ server_t<request_container_t, request_info_t>::server_t(
   proxy.setsockopt(ZMQ_SNDHWM, &disabled, sizeof(disabled));
   proxy.connect(proxy_endpoint.c_str());
 
+  loopback.setsockopt(ZMQ_RCVHWM, &disabled, sizeof(disabled));
   loopback.bind(result_endpoint.c_str());
 
   interrupt.setsockopt(ZMQ_SNDHWM, &disabled, sizeof(disabled));
@@ -479,6 +480,7 @@ worker_t::worker_t(zmq::context_t& context,
   downstream_proxy.setsockopt(ZMQ_SNDHWM, &disabled, sizeof(disabled));
   downstream_proxy.connect(downstream_proxy_endpoint.c_str());
 
+  loopback.setsockopt(ZMQ_SNDHWM, &disabled, sizeof(disabled));
   loopback.connect(result_endpoint.c_str());
 
   interrupt.setsockopt(ZMQ_RCVHWM, &disabled, sizeof(disabled));