+ srd_dbg("Calling start() on all instances in session %d.", sess->session_id);
+
+ /* Run the start() method on all decoders receiving frontend data. */
+ ret = SRD_OK;
+ for (d = sess->di_list; d; d = d->next) {
+ di = d->data;
+ if ((ret = srd_inst_start(di)) != SRD_OK)
+ break;
+ }
+
+ return ret;
+}
+
+SRD_PRIV int srd_inst_send_meta(struct srd_decoder_inst *di, int key,
+ GVariant *data)
+{
+ PyObject *py_ret;
+
+ if (key != SRD_CONF_SAMPLERATE)
+ /* This is the only key we pass on to the decoder for now. */
+ return SRD_OK;
+
+ if (!PyObject_HasAttrString(di->py_inst, "metadata"))
+ /* This decoder doesn't want metadata, that's fine. */
+ return SRD_OK;
+
+ py_ret = PyObject_CallMethod(di->py_inst, "metadata", "lK",
+ (long)SRD_CONF_SAMPLERATE,
+ (unsigned long long)g_variant_get_uint64(data));
+ Py_XDECREF(py_ret);
+
+ return SRD_OK;
+}
+
+/**
+ * Set a metadata 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_metadata_set(struct srd_session *sess, int key,
+ GVariant *data)
+{
+ GSList *l;
+ int ret;
+
+ if (session_is_valid(sess) != SRD_OK) {
+ srd_err("Invalid session.");
+ return SRD_ERR_ARG;
+ }
+
+ if (key != SRD_CONF_SAMPLERATE) {
+ srd_err("Unknown config key %d.", key);
+ return SRD_ERR_ARG;
+ }
+
+ srd_dbg("Setting session %d samplerate to %"PRIu64".",
+ sess->session_id, g_variant_get_uint64(data));
+
+ ret = SRD_OK;
+ for (l = sess->di_list; l; l = l->next) {
+ if ((ret = srd_inst_send_meta(l->data, key, data)) != SRD_OK)
+ break;
+ }
+
+ g_variant_unref(data);
+
+ return ret;
+}
+
+/**
+ * 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.
+ *
+ * The size of a sample in inbuf is the minimum number of bytes needed
+ * to store the configured (or default) probes.
+ *
+ * @param sess The session to use.
+ * @param start_samplenum The sample number of the first sample in this chunk.
+ * @param end_samplenum The sample number of the last 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.3.0
+ */
+SRD_API int srd_session_send(struct srd_session *sess,
+ uint64_t start_samplenum, uint64_t end_samplenum,
+ const uint8_t *inbuf, uint64_t inbuflen)
+{
+ GSList *d;
+ int ret;
+
+ if (session_is_valid(sess) != SRD_OK) {
+ srd_err("Invalid session.");
+ 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)