hardware/norma-dmm/api.c

   1 /*
   2  * This file is part of the libsigrok project.
   3  *
   4  * Copyright (C) 2013 Matthias Heidbrink <m-sigrok@heidbrink.biz>
   5  *
   6  * This program is free software: you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License as published by
   8  * the Free Software Foundation, either version 3 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18  */
  19
  20 #include "protocol.h"
  21
  22 static const int32_t hwopts[] = {
  23         SR_CONF_CONN,
  24         SR_CONF_SERIALCOMM,
  25 };
  26
  27 static const int32_t hwcaps[] = {
  28         SR_CONF_MULTIMETER,
  29         SR_CONF_LIMIT_SAMPLES,
  30         SR_CONF_LIMIT_MSEC,
  31         SR_CONF_CONTINUOUS,
  32 };
  33
  34 #define BUF_MAX 50
  35
  36 #define SERIALCOMM "4800/8n1/dtr=1/rts=0/flow=1"
  37
  38 SR_PRIV struct sr_dev_driver norma_dmm_driver_info;
  39 static struct sr_dev_driver *di = &norma_dmm_driver_info;
  40
  41 static int init(struct sr_context *sr_ctx)
  42 {
  43         return std_init(sr_ctx, di, LOG_PREFIX);
  44 }
  45
  46 static GSList *scan(GSList *options)
  47 {
  48         struct sr_dev_inst *sdi;
  49         struct drv_context *drvc;
  50         struct dev_context *devc;
  51         struct sr_config *src;
  52         struct sr_probe *probe;
  53         struct sr_serial_dev_inst *serial;
  54         GSList *l, *devices;
  55         int len, cnt;
  56         const char *conn, *serialcomm;
  57         char *buf;
  58         char fmttype[10];
  59         char req[10];
  60         int auxtype;
  61
  62         devices = NULL;
  63         drvc = di->priv;
  64         drvc->instances = NULL;
  65         conn = serialcomm = NULL;
  66
  67         for (l = options; l; l = l->next) {
  68                 src = l->data;
  69                 switch (src->key) {
  70                 case SR_CONF_CONN:
  71                         conn = g_variant_get_string(src->data, NULL);
  72                         break;
  73                 case SR_CONF_SERIALCOMM:
  74                         serialcomm = g_variant_get_string(src->data, NULL);
  75                         break;
  76                 }
  77         }
  78         if (!conn)
  79                 return NULL;
  80         if (!serialcomm)
  81                 serialcomm = SERIALCOMM;
  82
  83         if (!(serial = sr_serial_dev_inst_new(conn, serialcomm)))
  84                 return NULL;
  85
  86         if (serial_open(serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK)
  87                 return NULL;
  88
  89         serial_flush(serial);
  90
  91         if (!(buf = g_try_malloc(BUF_MAX))) {
  92                 sr_err("Serial buffer malloc failed.");
  93                 return NULL;
  94         }
  95
  96         snprintf(req, sizeof(req), "%s\r\n",
  97                  nmadmm_requests[NMADMM_REQ_IDN].req_str);
  98         for (cnt = 0; cnt < 7; cnt++) {
  99                 if (serial_write(serial, req, strlen(req)) == -1) {
 100                         sr_err("Unable to send identification request: %d %s.",
 101                                errno, strerror(errno));
 102                         return NULL;
 103                 }
 104                 len = BUF_MAX;
 105                 serial_readline(serial, &buf, &len, 1500);
 106                 if (!len)
 107                         continue;
 108                 buf[BUF_MAX - 1] = '\0';
 109
 110                 /* Match ID string, e.g. "1834 065 V1.06,IF V1.02" (DM950) */
 111                 if (g_regex_match_simple("^1834 [^,]*,IF V*", (char *)buf, 0, 0)) {
 112                         auxtype = xgittoint(buf[7]);
 113                                 // TODO: Will this work with non-DM950?
 114                         snprintf(fmttype, sizeof(fmttype), "DM9%d0", auxtype);
 115                         sr_spew("Norma %s DMM %s detected!", fmttype, &buf[9]);
 116
 117                         if (!(sdi = sr_dev_inst_new(0, SR_ST_INACTIVE,
 118                                                 "Norma", fmttype, buf + 9)))
 119                                 return NULL;
 120                         if (!(devc = g_try_malloc0(sizeof(struct dev_context)))) {
 121                                 sr_err("Device context malloc failed.");
 122                                 return NULL;
 123                         }
 124                         devc->type = auxtype;
 125                         devc->version = g_strdup(&buf[9]);
 126                         devc->elapsed_msec = g_timer_new();
 127
 128                         sdi->conn = serial;
 129                         sdi->priv = devc;
 130                         sdi->driver = di;
 131                         if (!(probe = sr_probe_new(0, SR_PROBE_ANALOG, TRUE,
 132                                 "P1")))
 133                                 return NULL;
 134                         sdi->probes = g_slist_append(sdi->probes, probe);
 135                         drvc->instances = g_slist_append(drvc->instances, sdi);
 136                         devices = g_slist_append(devices, sdi);
 137                         break;
 138                 }
 139
 140                 /*
 141                  * The interface of the DM9x0 contains a cap that needs to
 142                  * charge for up to 10s before the interface works, if not
 143                  * powered externally. Therefore wait a little to improve
 144                  * chances.
 145                  */
 146                 if (cnt == 3) {
 147                         sr_info("Waiting 5s to allow interface to settle.");
 148                         g_usleep(5 * 1000 * 1000);
 149                 }
 150         }
 151
 152         g_free(buf);
 153
 154         serial_close(serial);
 155         if (!devices)
 156                 sr_serial_dev_inst_free(serial);
 157
 158         return devices;
 159 }
 160
 161 static GSList *dev_list(void)
 162 {
 163         return ((struct drv_context *)(di->priv))->instances;
 164 }
 165
 166 static int dev_clear(void)
 167 {
 168         return std_dev_clear(di, NULL);
 169 }
 170
 171 static int dev_open(struct sr_dev_inst *sdi)
 172 {
 173         struct sr_serial_dev_inst *serial;
 174
 175         serial = sdi->conn;
 176         if (serial_open(serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK)
 177                 return SR_ERR;
 178
 179         sdi->status = SR_ST_ACTIVE;
 180
 181         return SR_OK;
 182 }
 183
 184 static int dev_close(struct sr_dev_inst *sdi)
 185 {
 186         struct dev_context *devc;
 187
 188         std_serial_dev_close(sdi);
 189
 190         /* Free dynamically allocated resources. */
 191         if ((devc = sdi->priv) && devc->version) {
 192                 g_free(devc->version);
 193                 devc->version = NULL;
 194                 g_timer_destroy(devc->elapsed_msec);
 195         }
 196
 197         return SR_OK;
 198 }
 199
 200 static int cleanup(void)
 201 {
 202         return dev_clear();
 203 }
 204
 205 static int config_set(int key, GVariant *data, const struct sr_dev_inst *sdi,
 206                 const struct sr_probe_group *probe_group)
 207 {
 208         struct dev_context *devc;
 209
 210         (void)probe_group;
 211
 212         if (sdi->status != SR_ST_ACTIVE)
 213                 return SR_ERR_DEV_CLOSED;
 214
 215         if (!(devc = sdi->priv)) {
 216                 sr_err("sdi->priv was NULL.");
 217                 return SR_ERR_BUG;
 218         }
 219
 220         switch (key) {
 221         case SR_CONF_LIMIT_MSEC:
 222                 /* TODO: not yet implemented */
 223                 if (g_variant_get_uint64(data) == 0) {
 224                         sr_err("LIMIT_MSEC can't be 0.");
 225                         return SR_ERR;
 226                 }
 227                 devc->limit_msec = g_variant_get_uint64(data);
 228                 sr_dbg("Setting time limit to %" PRIu64 "ms.",
 229                        devc->limit_msec);
 230                 break;
 231         case SR_CONF_LIMIT_SAMPLES:
 232                 devc->limit_samples = g_variant_get_uint64(data);
 233                 sr_dbg("Setting sample limit to %" PRIu64 ".",
 234                        devc->limit_samples);
 235                 break;
 236         default:
 237                 return SR_ERR_NA;
 238         }
 239
 240         return SR_OK;
 241 }
 242
 243 static int config_list(int key, GVariant **data, const struct sr_dev_inst *sdi,
 244                 const struct sr_probe_group *probe_group)
 245 {
 246         (void)sdi;
 247         (void)probe_group;
 248
 249         switch (key) {
 250         case SR_CONF_SCAN_OPTIONS:
 251                 *data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
 252                                 hwopts, ARRAY_SIZE(hwopts), sizeof(int32_t));
 253                 break;
 254         case SR_CONF_DEVICE_OPTIONS:
 255                 *data = g_variant_new_fixed_array(G_VARIANT_TYPE_INT32,
 256                                 hwcaps, ARRAY_SIZE(hwcaps), sizeof(int32_t));
 257                 break;
 258         default:
 259                 return SR_ERR_NA;
 260         }
 261
 262         return SR_OK;
 263 }
 264
 265 static int dev_acquisition_start(const struct sr_dev_inst *sdi,
 266                                     void *cb_data)
 267 {
 268         struct dev_context *devc;
 269         struct sr_serial_dev_inst *serial;
 270
 271         (void)sdi;
 272         (void)cb_data;
 273
 274         if (!sdi || !cb_data || !(devc = sdi->priv))
 275                 return SR_ERR_BUG;
 276
 277         if (sdi->status != SR_ST_ACTIVE)
 278                 return SR_ERR_DEV_CLOSED;
 279
 280         devc->cb_data = cb_data;
 281
 282         /* Send header packet to the session bus. */
 283         std_session_send_df_header(cb_data, LOG_PREFIX);
 284
 285         /* Start timer, if required. */
 286         if (devc->limit_msec)
 287                 g_timer_start(devc->elapsed_msec);
 288
 289         /* Poll every 100ms, or whenever some data comes in. */
 290         serial = sdi->conn;
 291         serial_source_add(serial, G_IO_IN, 100, norma_dmm_receive_data,
 292                       (void *)sdi);
 293
 294         return SR_OK;
 295 }
 296
 297 static int dev_acquisition_stop(struct sr_dev_inst *sdi, void *cb_data)
 298 {
 299         struct dev_context *devc;
 300
 301         /* Stop timer, if required. */
 302         if (sdi && (devc = sdi->priv) && devc->limit_msec)
 303                 g_timer_stop(devc->elapsed_msec);
 304
 305         return std_dev_acquisition_stop_serial(sdi, cb_data, dev_close,
 306                         sdi->conn, LOG_PREFIX);
 307 }
 308
 309 SR_PRIV struct sr_dev_driver norma_dmm_driver_info = {
 310         .name = "norma-dmm",
 311         .longname = "Norma DM9x0 / Siemens B102x DMMs",
 312         .api_version = 1,
 313         .init = init,
 314         .cleanup = cleanup,
 315         .scan = scan,
 316         .dev_list = dev_list,
 317         .dev_clear = dev_clear,
 318         .config_get = NULL,
 319         .config_set = config_set,
 320         .config_list = config_list,
 321         .dev_open = dev_open,
 322         .dev_close = dev_close,
 323         .dev_acquisition_start = dev_acquisition_start,
 324         .dev_acquisition_stop = dev_acquisition_stop,
 325         .priv = NULL,
 326 };