Ignore exceptions when publishing messages to some subscriber. (#810)

microsoft · Nov 18, 2024 · ec54e3e · ec54e3e
1 parent 7360073
commit ec54e3e
Showing 1 changed file with 13 additions and 6 deletions.
diff --git a/libs/server/Resp/PubSubCommands.cs b/libs/server/Resp/PubSubCommands.cs
@@ -44,6 +44,10 @@ public override unsafe void Publish(ref byte* keyPtr, int keyLength, ref byte* v
                 if (dcurr > networkSender.GetResponseObjectHead())
                     Send(networkSender.GetResponseObjectHead());
             }
+            catch
+            {
+                // Ignore exceptions
+            }
             finally
             {
                 networkSender.ExitAndReturnResponseObject();
@@ -68,16 +72,19 @@ public override unsafe void PrefixPublish(byte* patternPtr, int patternLength, r
                 }
                 while (!RespWriteUtils.WriteBulkString("pmessage"u8, ref dcurr, dend))
                     SendAndReset();
-                while (!RespWriteUtils.WriteBulkString(new Span<byte>(patternPtr + sizeof(int), patternLength - sizeof(int)), ref dcurr, dend))
-                    SendAndReset();
-                while (!RespWriteUtils.WriteBulkString(new Span<byte>(keyPtr + sizeof(int), keyLength - sizeof(int)), ref dcurr, dend))
-                    SendAndReset();
-                while (!RespWriteUtils.WriteBulkString(new Span<byte>(valPtr + sizeof(int), valLength - sizeof(int)), ref dcurr, dend))
-                    SendAndReset();
+
+                // Write pattern, key, and value to the network
+                WriteDirectLargeRespString(new Span<byte>(patternPtr + sizeof(int), patternLength - sizeof(int)));
+                WriteDirectLargeRespString(new Span<byte>(keyPtr + sizeof(int), keyLength - sizeof(int)));
+                WriteDirectLargeRespString(new Span<byte>(valPtr + sizeof(int), valLength - sizeof(int)));
 
                 if (dcurr > networkSender.GetResponseObjectHead())
                     Send(networkSender.GetResponseObjectHead());
             }
+            catch
+            {
+                // Ignore exceptions
+            }
             finally
             {
                 networkSender.ExitAndReturnResponseObject();