[C] Fix potential memory leak. Use correct action with publication notification.

mikeb01 · mikeb01 · commit bf349b6a009d · 2023-05-05T15:28:48.000+12:00
diff --git a/aeron-driver/src/main/c/aeron_driver_sender.c b/aeron-driver/src/main/c/aeron_driver_sender.c
@@ -322,7 +322,7 @@ void aeron_driver_sender_on_remove_publication(void *clientd, void *command)
     }
 
     if (aeron_udp_channel_interceptors_publication_notifications(
-        transport->data_paths, transport, publication, AERON_UDP_CHANNEL_INTERCEPTOR_ADD_NOTIFICATION) < 0)
+        transport->data_paths, transport, publication, AERON_UDP_CHANNEL_INTERCEPTOR_REMOVE_NOTIFICATION) < 0)
     {
         AERON_APPEND_ERR("%s", "sender on_remove_publication interceptors publication notifications");
         aeron_driver_sender_log_error(sender);

Original file line number	Diff line number	Diff line change
`@@ -322,7 +322,7 @@ void aeron_driver_sender_on_remove_publication(void clientd, void command)`
`322`	`322`	`}`
`323`	`323`
`324`	`324`	`if (aeron_udp_channel_interceptors_publication_notifications(`
`325`		`- transport->data_paths, transport, publication, AERON_UDP_CHANNEL_INTERCEPTOR_ADD_NOTIFICATION) < 0)`
	`325`	`+ transport->data_paths, transport, publication, AERON_UDP_CHANNEL_INTERCEPTOR_REMOVE_NOTIFICATION) < 0)`
`326`	`326`	`{`
`327`	`327`	`AERON_APPEND_ERR("%s", "sender on_remove_publication interceptors publication notifications");`
`328`	`328`	`aeron_driver_sender_log_error(sender);`