* FIX remove unexist API

emqx · Apr 15, 2023 · 67a5d54 · 67a5d54
1 parent c5c93a9
commit 67a5d54
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/core/message.c b/src/core/message.c
@@ -697,7 +697,8 @@ nni_msg_get_pub_pid(nni_msg *m)
 
 	pos = nni_msg_body(m);
 	NNI_GET16(pos, len);
-	if (len > nni_msg_remaining_len(m) - 2)
+	// assume a min pub packet here
+	if (len > nni_msg_len(m) - 3)
 		return 0;
 	else {
 		NNI_GET16(pos + len + 2, pid);