From 9553e9622bb26dfbe6296ef6f330b1cf0f5b40e6 Mon Sep 17 00:00:00 2001 From: Gerhard Sittig Date: Sun, 17 Dec 2017 18:55:46 +0100 Subject: session: add "terminate and reset" support for protocol stacks Implement routines which terminate currently pending decoder operations and reset internal state (on the C and Python sides) for instances as well as sessions. This allows to re-use previously created stacks for new input data. --- session.c | 39 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 39 insertions(+) (limited to 'session.c') diff --git a/session.c b/session.c index 0c1ef82..4d794df 100644 --- a/session.c +++ b/session.c @@ -297,6 +297,45 @@ SRD_API int srd_session_send(struct srd_session *sess, return SRD_OK; } +/** + * Terminate currently executing decoders in a session, reset internal state. + * + * All decoder instances have their .wait() method terminated, which + * shall terminate .decode() as well. Afterwards the decoders' optional + * .reset() method gets executed. + * + * This routine allows callers to abort pending expensive operations, + * when they are no longer interested in the decoders' results. Note + * that the decoder state is lost and aborted work cannot resume. + * + * This routine also allows callers to re-use previously created decoder + * stacks to process new input data which is not related to previously + * processed input data. This avoids the necessity to re-construct the + * decoder stack. + * + * @param sess The session in which to terminate decoders. + * @return SRD_OK upon success, a (negative) error code otherwise. + * + * @since 0.6.0 + */ +SRD_API int srd_session_terminate_reset(struct srd_session *sess) +{ + GSList *d; + int ret; + + if (session_is_valid(sess) != SRD_OK) { + srd_err("Invalid session."); + return SRD_ERR_ARG; + } + + for (d = sess->di_list; d; d = d->next) { + ret = srd_inst_terminate_reset(d->data); + if (ret != SRD_OK) + return ret; + } + return SRD_OK; +} + /** * Destroy a decoding session. * -- cgit v1.2.3-70-g09d2