* FIX nanomq/nanomq#1153

emqx · Apr 15, 2023 · c5c93a9 · c5c93a9
1 parent fadc89e
commit c5c93a9
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/core/message.c b/src/core/message.c
@@ -697,6 +697,10 @@ nni_msg_get_pub_pid(nni_msg *m)
 
 	pos = nni_msg_body(m);
 	NNI_GET16(pos, len);
-	NNI_GET16(pos + len + 2, pid);
-	return pid;
+	if (len > nni_msg_remaining_len(m) - 2)
+		return 0;
+	else {
+		NNI_GET16(pos + len + 2, pid);
+		return pid;
+	}
 }