system/uorb: uorb_listener flush functionality optimization.

Otpvondoiats · xiaoxiang781216 · commit a454cf4d9428 · 2026-01-23T10:01:33.000+08:00
uorb/listener:Added flush failure prompt information.

Signed-off-by: likun17 &lt;likun17@xiaomi.com&gt;
diff --git a/system/uorb/listener.c b/system/uorb/listener.c
@@ -559,13 +559,13 @@ static void listener_flush_topic(FAR const struct listen_list_s *objlist,
   int ret;
 
   fds = calloc(nb_objects, sizeof(struct pollfd));
-  if (!fds)
+  if (fds == NULL)
     {
       return;
     }
 
   result = calloc(nb_objects, sizeof(int8_t));
-  if (!result)
+  if (result == NULL)
     {
       free(fds);
       return;
@@ -598,6 +598,8 @@ static void listener_flush_topic(FAR const struct listen_list_s *objlist,
       if (ret < 0)
         {
           result[i] = ret;
+          uorbinfo_raw("topic [%s%d] call flush failed! return:%d\n",
+                       tmp->object.meta->o_name, tmp->object.instance, ret);
         }
       else
         {

Original file line number	Diff line number	Diff line change
`@@ -559,13 +559,13 @@ static void listener_flush_topic(FAR const struct listen_list_s *objlist,`
`559`	`559`	`int ret;`
`560`	`560`
`561`	`561`	`fds = calloc(nb_objects, sizeof(struct pollfd));`
`562`		`- if (!fds)`
	`562`	`+ if (fds == NULL)`
`563`	`563`	`{`
`564`	`564`	`return;`
`565`	`565`	`}`
`566`	`566`
`567`	`567`	`result = calloc(nb_objects, sizeof(int8_t));`
`568`		`- if (!result)`
	`568`	`+ if (result == NULL)`
`569`	`569`	`{`
`570`	`570`	`free(fds);`
`571`	`571`	`return;`
`@@ -598,6 +598,8 @@ static void listener_flush_topic(FAR const struct listen_list_s *objlist,`
`598`	`598`	`if (ret < 0)`
`599`	`599`	`{`
`600`	`600`	`result[i] = ret;`
	`601`	`+ uorbinfo_raw("topic [%s%d] call flush failed! return:%d\n",`
	`602`	`+ tmp->object.meta->o_name, tmp->object.instance, ret);`
`601`	`603`	`}`
`602`	`604`	`else`
`603`	`605`	`{`