]> sigrok.org Git - libsigrok.git/blobdiff - hardware/openbench-logic-sniffer/protocol.c
build: Portability fixes.
[libsigrok.git] / hardware / openbench-logic-sniffer / protocol.c
index 5e8dc76ace37667b50a3dbc9a60f7402f81494bb..1c94b7ff6948e9103d7caa7cb66878b0f6a76bdd 100644 (file)
@@ -54,56 +54,61 @@ SR_PRIV int send_longcommand(struct sr_serial_dev_inst *serial,
        return SR_OK;
 }
 
-SR_PRIV int ols_configure_probes(const struct sr_dev_inst *sdi)
+/* Configures the channel mask based on which channels are enabled. */
+SR_PRIV void ols_channel_mask(const struct sr_dev_inst *sdi)
 {
        struct dev_context *devc;
-       const struct sr_probe *probe;
+       struct sr_channel *channel;
        const GSList *l;
-       int probe_bit, stage, i;
-       char *tc;
 
        devc = sdi->priv;
 
-       devc->probe_mask = 0;
+       devc->channel_mask = 0;
+       for (l = sdi->channels; l; l = l->next) {
+               channel = l->data;
+               if (channel->enabled)
+                       devc->channel_mask |= 1 << channel->index;
+       }
+}
+
+SR_PRIV int ols_convert_trigger(const struct sr_dev_inst *sdi)
+{
+       struct dev_context *devc;
+       struct sr_trigger *trigger;
+       struct sr_trigger_stage *stage;
+       struct sr_trigger_match *match;
+       const GSList *l, *m;
+       int i;
+
+       devc = sdi->priv;
+
+       devc->num_stages = 0;
        for (i = 0; i < NUM_TRIGGER_STAGES; i++) {
                devc->trigger_mask[i] = 0;
                devc->trigger_value[i] = 0;
        }
 
-       devc->num_stages = 0;
-       for (l = sdi->probes; l; l = l->next) {
-               probe = (const struct sr_probe *)l->data;
-               if (!probe->enabled)
-                       continue;
-
-               if (probe->index >= devc->max_probes) {
-                       sr_err("Channels over the limit of %d\n", devc->max_probes);
-                       return SR_ERR;
-               }
+       if (!(trigger = sr_session_trigger_get(sdi->session)))
+               return SR_OK;
 
-               /*
-                * Set up the probe mask for later configuration into the
-                * flag register.
-                */
-               probe_bit = 1 << (probe->index);
-               devc->probe_mask |= probe_bit;
-
-               if (!probe->trigger)
-                       continue;
-
-               /* Configure trigger mask and value. */
-               stage = 0;
-               for (tc = probe->trigger; tc && *tc; tc++) {
-                       devc->trigger_mask[stage] |= probe_bit;
-                       if (*tc == '1')
-                               devc->trigger_value[stage] |= probe_bit;
-                       stage++;
-                       /* Only supporting parallel mode, with up to 4 stages. */
-                       if (stage > 4)
-                               return SR_ERR;
+       devc->num_stages = g_slist_length(trigger->stages);
+       if (devc->num_stages > NUM_TRIGGER_STAGES) {
+               sr_err("This device only supports %d trigger stages.",
+                               NUM_TRIGGER_STAGES);
+               return SR_ERR;
+       }
+
+       for (l = trigger->stages; l; l = l->next) {
+               stage = l->data;
+               for (m = stage->matches; m; m = m->next) {
+                       match = m->data;
+                       if (!match->channel->enabled)
+                               /* Ignore disabled channels with a trigger. */
+                               continue;
+                       devc->trigger_mask[stage->stage] |= 1 << match->channel->index;
+                       if (match->match == SR_TRIGGER_ONE)
+                               devc->trigger_value[stage->stage] |= 1 << match->channel->index;
                }
-               if (stage > devc->num_stages)
-                       devc->num_stages = stage - 1;
        }
 
        return SR_OK;
@@ -124,7 +129,7 @@ SR_PRIV struct dev_context *ols_dev_new(void)
        /* Acquisition settings */
        devc->limit_samples = devc->capture_ratio = 0;
        devc->trigger_at = -1;
-       devc->probe_mask = 0xffffffff;
+       devc->channel_mask = 0xffffffff;
        devc->flag_reg = 0;
 
        return devc;
@@ -134,7 +139,7 @@ SR_PRIV struct sr_dev_inst *get_metadata(struct sr_serial_dev_inst *serial)
 {
        struct sr_dev_inst *sdi;
        struct dev_context *devc;
-       struct sr_probe *probe;
+       struct sr_channel *ch;
        uint32_t tmp_int, ui;
        uint8_t key, type, token;
        GString *tmp_str, *devname, *version;
@@ -201,12 +206,12 @@ SR_PRIV struct sr_dev_inst *get_metadata(struct sr_serial_dev_inst *serial)
                               key, tmp_int);
                        switch (token) {
                        case 0x00:
-                               /* Number of usable probes */
+                               /* Number of usable channels */
                                for (ui = 0; ui < tmp_int; ui++) {
-                                       if (!(probe = sr_probe_new(ui, SR_PROBE_LOGIC, TRUE,
-                                                       ols_probe_names[ui])))
+                                       if (!(ch = sr_channel_new(ui, SR_CHANNEL_LOGIC, TRUE,
+                                                       ols_channel_names[ui])))
                                                return 0;
-                                       sdi->probes = g_slist_append(sdi->probes, probe);
+                                       sdi->channels = g_slist_append(sdi->channels, ch);
                                }
                                break;
                        case 0x01:
@@ -239,12 +244,12 @@ SR_PRIV struct sr_dev_inst *get_metadata(struct sr_serial_dev_inst *serial)
                               key, tmp_c);
                        switch (token) {
                        case 0x00:
-                               /* Number of usable probes */
+                               /* Number of usable channels */
                                for (ui = 0; ui < tmp_c; ui++) {
-                                       if (!(probe = sr_probe_new(ui, SR_PROBE_LOGIC, TRUE,
-                                                       ols_probe_names[ui])))
+                                       if (!(ch = sr_channel_new(ui, SR_CHANNEL_LOGIC, TRUE,
+                                                       ols_channel_names[ui])))
                                                return 0;
-                                       sdi->probes = g_slist_append(sdi->probes, probe);
+                                       sdi->channels = g_slist_append(sdi->channels, ch);
                                }
                                break;
                        case 0x01:
@@ -284,13 +289,13 @@ SR_PRIV int ols_set_samplerate(const struct sr_dev_inst *sdi,
                sr_info("Enabling demux mode.");
                devc->flag_reg |= FLAG_DEMUX;
                devc->flag_reg &= ~FLAG_FILTER;
-               devc->max_probes = NUM_PROBES / 2;
+               devc->max_channels = NUM_CHANNELS / 2;
                devc->cur_samplerate_divider = (CLOCK_RATE * 2 / samplerate) - 1;
        } else {
                sr_info("Disabling demux mode.");
                devc->flag_reg &= ~FLAG_DEMUX;
                devc->flag_reg |= FLAG_FILTER;
-               devc->max_probes = NUM_PROBES;
+               devc->max_channels = NUM_CHANNELS;
                devc->cur_samplerate_divider = (CLOCK_RATE / samplerate) - 1;
        }
 
@@ -313,7 +318,7 @@ SR_PRIV void abort_acquisition(const struct sr_dev_inst *sdi)
        struct sr_serial_dev_inst *serial;
 
        serial = sdi->conn;
-       serial_source_remove(serial);
+       serial_source_remove(sdi->session, serial);
 
        /* Terminate session */
        packet.type = SR_DF_END;
@@ -328,7 +333,7 @@ SR_PRIV int ols_receive_data(int fd, int revents, void *cb_data)
        struct sr_datafeed_packet packet;
        struct sr_datafeed_logic logic;
        uint32_t sample;
-       int num_channels, offset, j;
+       int num_ols_changrp, offset, j;
        unsigned int i;
        unsigned char byte;
 
@@ -345,8 +350,9 @@ SR_PRIV int ols_receive_data(int fd, int revents, void *cb_data)
                 * longer than it takes to send a byte, that means it's
                 * finished. We'll double that to 30ms to be sure...
                 */
-               serial_source_remove(serial);
-               serial_source_add(serial, G_IO_IN, 30, ols_receive_data, cb_data);
+               serial_source_remove(sdi->session, serial);
+               serial_source_add(sdi->session, serial, G_IO_IN, 30,
+                               ols_receive_data, cb_data);
                devc->raw_sample_buf = g_try_malloc(devc->limit_samples * 4);
                if (!devc->raw_sample_buf) {
                        sr_err("Sample buffer malloc failed.");
@@ -356,10 +362,10 @@ SR_PRIV int ols_receive_data(int fd, int revents, void *cb_data)
                memset(devc->raw_sample_buf, 0x82, devc->limit_samples * 4);
        }
 
-       num_channels = 0;
-       for (i = NUM_PROBES; i > 0x02; i /= 2) {
+       num_ols_changrp = 0;
+       for (i = NUM_CHANNELS; i > 0x02; i /= 2) {
                if ((devc->flag_reg & i) == 0) {
-                       num_channels++;
+                       num_ols_changrp++;
                }
        }
 
@@ -374,7 +380,7 @@ SR_PRIV int ols_receive_data(int fd, int revents, void *cb_data)
 
                devc->sample[devc->num_bytes++] = byte;
                sr_spew("Received byte 0x%.2x.", byte);
-               if (devc->num_bytes == num_channels) {
+               if (devc->num_bytes == num_ols_changrp) {
                        devc->cnt_samples++;
                        devc->cnt_samples_rle++;
                        /*
@@ -407,7 +413,7 @@ SR_PRIV int ols_receive_data(int fd, int revents, void *cb_data)
                                devc->num_samples = devc->limit_samples;
                        }
 
-                       if (num_channels < 4) {
+                       if (num_ols_changrp < 4) {
                                /*
                                 * Some channel groups may have been turned
                                 * off, to speed up transfer between the
@@ -415,7 +421,7 @@ SR_PRIV int ols_receive_data(int fd, int revents, void *cb_data)
                                 * submitting it over the session bus --
                                 * whatever is listening on the bus will be
                                 * expecting a full 32-bit sample, based on
-                                * the number of probes.
+                                * the number of channels.
                                 */
                                j = 0;
                                memset(devc->tmp_sample, 0, 4);