X-Git-Url: https://sigrok.org/gitweb/?p=libsigrokdecode.git;a=blobdiff_plain;f=session.c;h=8b8866046b3224f3b39542f65f63049acb5205d4;hp=109ede10516251c8079d40ce67575532013867f4;hb=fbff319f0a65e2d87a609f77a32b26ef200a5215;hpb=fe9d91a88a8896ef04d12682720943b237c0a295 diff --git a/session.c b/session.c index 109ede1..8b88660 100644 --- a/session.c +++ b/session.c @@ -18,9 +18,10 @@ * along with this program. If not, see . */ -#include "libsigrokdecode.h" /* First, so we avoid a _POSIX_C_SOURCE warning. */ -#include "libsigrokdecode-internal.h" +#include "libsigrokdecode-internal.h" /* First, so we avoid a _POSIX_C_SOURCE warning. */ +#include "libsigrokdecode.h" #include "config.h" +#include #include /** @@ -40,7 +41,7 @@ /** @cond PRIVATE */ SRD_PRIV GSList *sessions = NULL; -int max_session_id = -1; +SRD_PRIV int max_session_id = -1; /** @endcond */ @@ -75,8 +76,7 @@ SRD_API int srd_session_new(struct srd_session **sess) return SRD_ERR_ARG; } - if (!(*sess = g_try_malloc(sizeof(struct srd_session)))) - return SRD_ERR_MALLOC; + *sess = g_malloc(sizeof(struct srd_session)); (*sess)->session_id = ++max_session_id; (*sess)->di_list = (*sess)->callbacks = NULL; @@ -124,8 +124,7 @@ SRD_API int srd_session_start(struct srd_session *sess) return ret; } -/** @private */ -SRD_PRIV int srd_inst_send_meta(struct srd_decoder_inst *di, int key, +static int srd_inst_send_meta(struct srd_decoder_inst *di, int key, GVariant *data) { PyObject *py_ret; @@ -170,10 +169,27 @@ SRD_API int srd_session_metadata_set(struct srd_session *sess, int key, return SRD_ERR_ARG; } + if (!key) { + srd_err("Invalid key."); + return SRD_ERR_ARG; + } + + if (!data) { + srd_err("Invalid value."); + return SRD_ERR_ARG; + } + + /* Hardcoded to samplerate/uint64 for now. */ + if (key != SRD_CONF_SAMPLERATE) { srd_err("Unknown config key %d.", key); return SRD_ERR_ARG; } + if (!g_variant_is_of_type(data, G_VARIANT_TYPE_UINT64)) { + srd_err("Invalid value type: expected uint64, got %s", + g_variant_get_type_string(data)); + return SRD_ERR_ARG; + } srd_dbg("Setting session %d samplerate to %"PRIu64".", sess->session_id, g_variant_get_uint64(data)); @@ -192,12 +208,13 @@ SRD_API int srd_session_metadata_set(struct srd_session *sess, int key, /** * Send a chunk of logic sample data to a running decoder session. * - * The logic samples must be arranged in probe order, in the least - * amount of space possible. If no probes were configured, the default - * probe set consists of all required probes + all optional probes. + * If no channel map has been set up, the logic samples must be arranged + * in channel order, in the least amount of space possible. The default + * channel set consists of all required channels + all optional channels. * - * The size of a sample in inbuf is the minimum number of bytes needed - * to store the configured (or default) probes. + * The size of a sample in inbuf is the unit size passed to + * srd_inst_channel_set_all(). If no channel map has been configured, it is + * the minimum number of bytes needed to store the default channels. * * @param sess The session to use. * @param start_samplenum The sample number of the first sample in this chunk. @@ -221,10 +238,6 @@ SRD_API int srd_session_send(struct srd_session *sess, return SRD_ERR_ARG; } - srd_dbg("Calling decode() on all instances with starting sample " - "number %" PRIu64 ", %" PRIu64 " bytes at 0x%p", - start_samplenum, inbuflen, inbuf); - for (d = sess->di_list; d; d = d->next) { if ((ret = srd_inst_decode(d->data, start_samplenum, end_samplenum, inbuf, inbuflen)) != SRD_OK) @@ -283,7 +296,7 @@ SRD_API int srd_session_destroy(struct srd_session *sess) * @since 0.3.0 */ SRD_API int srd_pd_output_callback_add(struct srd_session *sess, - int output_type, srd_pd_output_callback_t cb, void *cb_data) + int output_type, srd_pd_output_callback cb, void *cb_data) { struct srd_pd_callback *pd_cb; @@ -294,11 +307,7 @@ SRD_API int srd_pd_output_callback_add(struct srd_session *sess, srd_dbg("Registering new callback for output type %d.", output_type); - if (!(pd_cb = g_try_malloc(sizeof(struct srd_pd_callback)))) { - srd_err("Failed to g_malloc() struct srd_pd_callback."); - return SRD_ERR_MALLOC; - } - + pd_cb = g_malloc(sizeof(struct srd_pd_callback)); pd_cb->output_type = output_type; pd_cb->cb = cb; pd_cb->cb_data = cb_data;