aboutsummaryrefslogtreecommitdiffstats
path: root/src/app_osmo_gapk.c
diff options
context:
space:
mode:
authorVadim Yanitskiy <axilirator@gmail.com>2017-09-10 16:00:43 +0300
committerVadim Yanitskiy <axilirator@gmail.com>2017-12-31 12:20:59 +0100
commit3839a88ea681024752048c902b23144c42f4fa42 (patch)
treebcffa10e18bdcbd97007ed670d78e5798134abc8 /src/app_osmo_gapk.c
parent459791c488c6b66a5cd0d7cff9392a7a0b8ca733 (diff)
procqueue: separate queue check function
In order to give advanced control over a processing queue, it would be better to have the checking function separated from the osmo_gapk_pq_prepare(). Moreover, this change introduces an additional 'strict' checking mode that requires a queue to have a source item first and a sink item in the last position.
Diffstat (limited to 'src/app_osmo_gapk.c')
-rw-r--r--src/app_osmo_gapk.c6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/app_osmo_gapk.c b/src/app_osmo_gapk.c
index 6543eef..2aac0aa 100644
--- a/src/app_osmo_gapk.c
+++ b/src/app_osmo_gapk.c
@@ -521,6 +521,7 @@ make_processing_chain(struct gapk_state *gs)
const struct osmo_gapk_codec_desc *codec_in, *codec_out;
int need_dec, need_enc;
+ int rc;
LOGP(DAPP, LOGL_NOTICE, "Creating a processing queue\n");
@@ -627,6 +628,11 @@ make_processing_chain(struct gapk_state *gs)
return -1;
}
+ /* Check the processing queue in strict mode */
+ rc = osmo_gapk_pq_check(gs->pq, 1);
+ if (rc)
+ return rc;
+
return 0;
}