GArray *match_array;
/** Absolute start sample number. */
- uint64_t start_samplenum;
+ uint64_t abs_start_samplenum;
/** Absolute end sample number. */
- uint64_t end_samplenum;
+ uint64_t abs_end_samplenum;
/** Pointer to the buffer/chunk of input samples. */
const uint8_t *inbuf;
uint64_t inbuflen;
/** Absolute current samplenumber. */
- uint64_t cur_samplenum;
+ uint64_t abs_cur_samplenum;
/** Array of "old" (previous sample) pin values. */
GArray *old_pins_array;
/** Indicates whether the worker thread has handled all samples. */
gboolean handled_all_samples;
+ /** Requests termination of wait() and decode(). */
+ gboolean want_wait_terminate;
+
GCond got_new_samples_cond;
GCond handled_all_samples_cond;
GMutex data_mutex;
SRD_API int srd_session_metadata_set(struct srd_session *sess, int key,
GVariant *data);
SRD_API int srd_session_send(struct srd_session *sess,
- uint64_t start_samplenum, uint64_t end_samplenum,
+ uint64_t abs_start_samplenum, uint64_t abs_end_samplenum,
const uint8_t *inbuf, uint64_t inbuflen, uint64_t unitsize);
SRD_API int srd_session_destroy(struct srd_session *sess);
SRD_API int srd_pd_output_callback_add(struct srd_session *sess,