Merge pull request #9 from guzba/ryan

msg_nosignal
guzba · Jan 15, 2024 · ec92c48 · ec92c48
2 parents a7bce99 + 4f11a40
commit ec92c48
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/ready/connections.nim b/src/ready/connections.nim
@@ -82,7 +82,7 @@ proc send*(
     for arg in args:
       msg.add "$" & $arg.len & "\r\n" & arg & "\r\n"
 
-  if conn.socket.send(msg[0].addr, msg.len.cint, 0) < 0:
+  if conn.socket.send(msg[0].addr, msg.len.cint, MSG_NOSIGNAL) < 0:
     raise newException(RedisError, osErrorMsg(osLastError()))
 
 proc send*(
@@ -103,7 +103,7 @@ proc send*(
   for arg in args:
     msg.add "$" & $arg.len & "\r\n" & arg & "\r\n"
 
-  if conn.socket.send(msg[0].addr, msg.len.cint, 0) < 0:
+  if conn.socket.send(msg[0].addr, msg.len.cint, MSG_NOSIGNAL) < 0:
     raise newException(RedisError, osErrorMsg(osLastError()))
 
 proc recvBytes(conn: RedisConn) {.raises: [RedisError].} =