+ if (!sess) {
+ srd_err("Invalid session pointer.");
+ return SRD_ERR_ARG;
+ }
+
+ if (!(*sess = g_try_malloc(sizeof(struct srd_session))))
+ return SRD_ERR_MALLOC;
+ (*sess)->session_id = ++max_session_id;
+ (*sess)->num_probes = (*sess)->unitsize = (*sess)->samplerate = 0;
+ (*sess)->di_list = (*sess)->callbacks = NULL;
+
+ /* Keep a list of all sessions, so we can clean up as needed. */
+ sessions = g_slist_append(sessions, *sess);
+
+ srd_dbg("Created session %d.", (*sess)->session_id);
+
+ return SRD_OK;
+}
+
+/**
+ * Start a decoding session.
+ *
+ * Decoders, instances and stack must have been prepared beforehand,
+ * and all SRD_CONF parameters set.
+ *
+ * @param sess The session to start.
+ *
+ * @return SRD_OK upon success, a (negative) error code otherwise.
+ *
+ * @since 0.1.0 (the API changed in 0.3.0, though)
+ */
+SRD_API int srd_session_start(struct srd_session *sess)
+{
+ PyObject *args;
+ GSList *d;
+ struct srd_decoder_inst *di;
+ int ret;
+
+ if (session_is_valid(sess) != SRD_OK) {
+ srd_err("Invalid session pointer.");
+ return SRD_ERR;
+ }
+ if (sess->num_probes == 0) {
+ srd_err("Session has invalid number of probes.");
+ return SRD_ERR;
+ }
+ if (sess->unitsize == 0) {
+ srd_err("Session has invalid unitsize.");
+ return SRD_ERR;
+ }
+ if (sess->samplerate == 0) {
+ srd_err("Session has invalid samplerate.");
+ return SRD_ERR;
+ }
+
+ ret = SRD_OK;
+
+ srd_dbg("Calling start() on all instances in session %d with "
+ "%" PRIu64 " probes, unitsize %" PRIu64
+ ", samplerate %" PRIu64 ".", sess->session_id,
+ sess->num_probes, sess->unitsize, sess->samplerate);
+
+ /*
+ * Currently only one item of metadata is passed along to decoders,
+ * samplerate. This can be extended as needed.
+ */
+ if (!(args = Py_BuildValue("{s:l}", "samplerate", (long)sess->samplerate))) {
+ srd_err("Unable to build Python object for metadata.");
+ return SRD_ERR_PYTHON;
+ }
+
+ /* Run the start() method on all decoders receiving frontend data. */
+ for (d = sess->di_list; d; d = d->next) {
+ di = d->data;
+ di->data_num_probes = sess->num_probes;
+ di->data_unitsize = sess->unitsize;
+ di->data_samplerate = sess->samplerate;
+ if ((ret = srd_inst_start(di, args)) != SRD_OK)
+ break;
+ }
+
+ Py_DecRef(args);
+
+ return ret;
+}
+
+/**
+ * Set a configuration key in a session.
+ *
+ * @param sess The session to configure.
+ * @param key The configuration key (SRD_CONF_*).
+ * @param data The new value for the key, as a GVariant with GVariantType
+ * appropriate to that key. A floating reference can be passed
+ * in; its refcount will be sunk and unreferenced after use.
+ *
+ * @return SRD_OK upon success, a (negative) error code otherwise.
+ *
+ * @since 0.3.0
+ */
+SRD_API int srd_session_config_set(struct srd_session *sess, int key,
+ GVariant *data)
+{
+
+ if (session_is_valid(sess) != SRD_OK) {
+ srd_err("Invalid session.");
+ return SRD_ERR_ARG;
+ }
+
+ if (!data) {
+ srd_err("Invalid config data.");
+ return SRD_ERR_ARG;
+ }
+
+ if (!g_variant_is_of_type(data, G_VARIANT_TYPE_UINT64)) {
+ srd_err("Value for key %d should be of type uint64.", key);
+ return SRD_ERR_ARG;
+ }
+
+ switch (key) {
+ case SRD_CONF_NUM_PROBES:
+ sess->num_probes = g_variant_get_uint64(data);
+ break;
+ case SRD_CONF_UNITSIZE:
+ sess->unitsize = g_variant_get_uint64(data);
+ break;
+ case SRD_CONF_SAMPLERATE:
+ sess->samplerate = g_variant_get_uint64(data);
+ break;
+ default:
+ srd_err("Cannot set config for unknown key %d.", key);
+ return SRD_ERR_ARG;
+ }
+
+ g_variant_unref(data);
+
+ return SRD_OK;
+}
+
+/**
+ * Send a chunk of logic sample data to a running decoder session.
+ *
+ * @param sess The session to use.
+ * @param start_samplenum The sample number of the first sample in this chunk.
+ * @param inbuf Pointer to sample data.
+ * @param inbuflen Length in bytes of the buffer.
+ *
+ * @return SRD_OK upon success, a (negative) error code otherwise.
+ *
+ * @since 0.1.0
+ */
+SRD_API int srd_session_send(struct srd_session *sess, uint64_t start_samplenum,
+ const uint8_t *inbuf, uint64_t inbuflen)