Fix pub sub bug from recent PR

microsoft · Oct 13, 2021 · 59b316e · 59b316e
1 parent a237e4a
commit 59b316e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cs/remote/src/FASTER.server/PubSub/SubscribeBroker.cs b/cs/remote/src/FASTER.server/PubSub/SubscribeBroker.cs
@@ -155,7 +155,9 @@ private async Task Start(CancellationToken cancellationToken = default)
                         {
                             fixed (byte* subscriptionKeyValueAsciiPtr = &subscriptionKeyValueAscii[0])
                             {
-                                int subscriptionKeyLength = *(int*)subscriptionKeyValueAsciiPtr + sizeof(int);
+                                var keyPtr = subscriptionKeyValueAsciiPtr;
+                                keySerializer.ReadKeyByRef(ref keyPtr);
+                                int subscriptionKeyLength = (int)(keyPtr - subscriptionKeyValueAsciiPtr);
                                 int subscriptionValueLength = subscriptionKeyValueAscii.Length - (subscriptionKeyLength + sizeof(bool));
                                 subscriptionKey = new byte[subscriptionKeyLength];
                                 subscriptionValue = new byte[subscriptionValueLength];