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_cmd.c b/src/ctrl/control_cmd.c
index 88a30a2..4e156b8 100644
--- a/src/ctrl/control_cmd.c
+++ b/src/ctrl/control_cmd.c
@@ -487,3 +487,63 @@
msgb_free(msg);
return NULL;
}
+
+struct ctrl_cmd_def *
+ctrl_cmd_def_make(const void *ctx, struct ctrl_cmd *cmd, void *data, unsigned int secs)
+{
+ struct ctrl_cmd_def *cd;
+
+ if (!cmd->ccon)
+ return NULL;
+
+ cd = talloc_zero(ctx, struct ctrl_cmd_def);
+
+ cd->cmd = cmd;
+ cd->data = data;
+
+ /* add to per-connection list of deferred commands */
+ llist_add(&cd->list, &cmd->ccon->def_cmds);
+
+ return cd;
+}
+
+int ctrl_cmd_def_is_zombie(struct ctrl_cmd_def *cd)
+{
+ /* luckily we're still alive */
+ if (cd->cmd)
+ return 0;
+
+ /* if we are a zombie, make sure we really die */
+ llist_del(&cd->list);
+ talloc_free(cd);
+
+ return 1;
+}
+
+int ctrl_cmd_def_send(struct ctrl_cmd_def *cd)
+{
+ struct ctrl_cmd *cmd = cd->cmd;
+
+ int rc;
+
+ /* Deferred commands can only be responses to GET/SET or ERROR, but
+ * never TRAP or anything else */
+ switch (cmd->type) {
+ case CTRL_TYPE_GET:
+ cmd->type = CTRL_TYPE_GET_REPLY;
+ break;
+ case CTRL_TYPE_SET:
+ cmd->type = CTRL_TYPE_SET_REPLY;
+ break;
+ default:
+ cmd->type = CTRL_TYPE_ERROR;
+ }
+
+ rc = ctrl_cmd_send(&cmd->ccon->write_queue, cmd);
+
+ talloc_free(cmd);
+ llist_del(&cd->list);
+ talloc_free(cd);
+
+ return rc;
+}