X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=src%2Fscpi%2Fscpi_serial.c;h=650f9711c386cf24a11d031c422847c895dea66f;hb=91219afc75c9aa1d0c5e2da5c03343c1e43eb6df;hp=feb3317651eb18f2d858b576bd242e4556c1e1d0;hpb=155b680da482cea2381becb73c51cfb838bff31e;p=libsigrok.git diff --git a/src/scpi/scpi_serial.c b/src/scpi/scpi_serial.c index feb33176..650f9711 100644 --- a/src/scpi/scpi_serial.c +++ b/src/scpi/scpi_serial.c @@ -79,8 +79,7 @@ static int scpi_serial_dev_inst_new(void *priv, struct drv_context *drvc, (void)drvc; (void)params; - if (!(sscpi->serial = sr_serial_dev_inst_new(resource, serialcomm))) - return SR_ERR; + sscpi->serial = sr_serial_dev_inst_new(resource, serialcomm); return SR_OK; } @@ -90,7 +89,7 @@ static int scpi_serial_open(void *priv) struct scpi_serial *sscpi = priv; struct sr_serial_dev_inst *serial = sscpi->serial; - if (serial_open(serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK) + if (serial_open(serial, SERIAL_RDWR) != SR_OK) return SR_ERR; if (serial_flush(serial) != SR_OK) @@ -130,7 +129,8 @@ static int scpi_serial_send(void *priv, const char *command) len = strlen(terminated_command); written = 0; while (written < len) { - result = serial_write(serial, terminated_command + written, len - written); + result = serial_write_nonblocking(serial, + terminated_command + written, len - written); if (result < 0) { sr_err("Error while sending SCPI command: '%s'.", command); g_free(terminated_command); @@ -162,7 +162,7 @@ static int scpi_serial_read_data(void *priv, char *buf, int maxlen) /* Try to read new data into the buffer if there is space. */ if (len > 0) { - ret = serial_read(sscpi->serial, sscpi->buffer + sscpi->read, + ret = serial_read_nonblocking(sscpi->serial, sscpi->buffer + sscpi->read, BUFFER_SIZE - sscpi->count); if (ret < 0)