diff options
| author | Harald Welte <laforge@gnumonks.org> | 2014-08-22 00:28:51 +0200 | 
|---|---|---|
| committer | Harald Welte <laforge@gnumonks.org> | 2014-08-24 16:52:54 +0200 | 
| commit | 39c9e7b471f29ec1df8b4fc407bb3fe2ac96cb9e (patch) | |
| tree | de138b59f02a0d4d1a4a89dd59f125154eac3692 /include/osmocom/ctrl | |
| parent | 5e21131c8dd37a536ec7df968d602c2c85580c39 (diff) | |
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.
Diffstat (limited to 'include/osmocom/ctrl')
| -rw-r--r-- | include/osmocom/ctrl/control_cmd.h | 15 | 
1 files changed, 15 insertions, 0 deletions
diff --git a/include/osmocom/ctrl/control_cmd.h b/include/osmocom/ctrl/control_cmd.h index 9e949631..8f2eaa25 100644 --- a/include/osmocom/ctrl/control_cmd.h +++ b/include/osmocom/ctrl/control_cmd.h @@ -45,6 +45,9 @@ struct ctrl_connection {  	/* Pending commands for this connection */  	struct llist_head cmds; + +	/* Pending deferred commands for this connection */ +	struct llist_head def_cmds;  };  struct ctrl_cmd { @@ -75,6 +78,18 @@ struct ctrl_cmd_map {  	enum ctrl_type type;  }; +/* deferred control command, i.e. responded asynchronously */ +struct ctrl_cmd_def { +	struct llist_head list;		/* ctrl_connection.def_cmds */ +	struct ctrl_cmd *cmd; +	void *data;			/* opaque user data */ +}; + +struct ctrl_cmd_def * +ctrl_cmd_def_make(const void *ctx, struct ctrl_cmd *cmd, void *data, unsigned int secs); +int ctrl_cmd_def_is_zombie(struct ctrl_cmd_def *cd); +int ctrl_cmd_def_send(struct ctrl_cmd_def *cd); +  int ctrl_cmd_exec(vector vline, struct ctrl_cmd *command, vector node, void *data);  int ctrl_cmd_install(enum ctrl_node_type node, struct ctrl_cmd_element *cmd);  int ctrl_cmd_send(struct osmo_wqueue *queue, struct ctrl_cmd *cmd);  | 
