libctrl: Add support for 'deferred control commands'
Sometimes a control interface command cannot be processed
and responded immediately, but we need to process it asynchronously.
In order to support this, we introduce the 'ctrl_cmd_def', which
represents such a deferred command. It is created by the service
implementing the command using ctrl_cmd_def_make(), and a response is
later sent using ctrl_cmd_def_send().
ctrl_cmd_def_is_zombie() must be called to handle the case where
the control connection has disconnected/died between receiving the
command and sending the response.
diff --git a/src/ctrl/control_if.c b/src/ctrl/control_if.c
index 59cf255..c20c1e0 100644
--- a/src/ctrl/control_if.c
+++ b/src/ctrl/control_if.c
@@ -128,6 +128,8 @@
static void control_close_conn(struct ctrl_connection *ccon)
{
+ struct ctrl_cmd_def *cd, *cd2;
+
osmo_wqueue_clear(&ccon->write_queue);
close(ccon->write_queue.bfd.fd);
osmo_fd_unregister(&ccon->write_queue.bfd);
@@ -135,6 +137,19 @@
if (ccon->closed_cb)
ccon->closed_cb(ccon);
msgb_free(ccon->pending_msg);
+
+ /* clean up deferred commands */
+ llist_for_each_entry_safe(cd, cd2, &ccon->def_cmds, list) {
+ /* delete from list of def_cmds for this ccon */
+ llist_del(&cd->list);
+ /* not strictly needed as this is a slave to the ccon which we
+ * are about to free anyway */
+ talloc_free(cd->cmd);
+ /* set the CMD to null, this is the indication to the user that
+ * the connection for this command has gone */
+ cd->cmd = NULL;
+ }
+
talloc_free(ccon);
}
@@ -338,6 +353,8 @@
/* Error handling here? */
INIT_LLIST_HEAD(&ccon->cmds);
+ INIT_LLIST_HEAD(&ccon->def_cmds);
+
return ccon;
}