]> sigrok.org Git - libsigrok.git/blame - hardware/agilent-dmm/api.c
Add and use std_session_send_df_header().
[libsigrok.git] / hardware / agilent-dmm / api.c
CommitLineData
e93cdf42
BV
1/*
2 * This file is part of the sigrok project.
3 *
4 * Copyright (C) 2012 Bert Vermeulen <bert@biot.com>
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 <glib.h>
e93cdf42
BV
21#include <sys/types.h>
22#include <sys/stat.h>
23#include <fcntl.h>
24#include <string.h>
25#include <errno.h>
6f22a8ef
UH
26#include "libsigrok.h"
27#include "libsigrok-internal.h"
28#include "agilent-dmm.h"
e93cdf42
BV
29
30static const int hwopts[] = {
1953564a
BV
31 SR_CONF_CONN,
32 SR_CONF_SERIALCOMM,
e93cdf42
BV
33 0,
34};
35
36static const int hwcaps[] = {
1953564a
BV
37 SR_CONF_MULTIMETER,
38 SR_CONF_LIMIT_SAMPLES,
39 SR_CONF_LIMIT_MSEC,
40 SR_CONF_CONTINUOUS,
e93cdf42
BV
41 0,
42};
43
8c0152f2
BV
44extern const struct agdmm_job agdmm_jobs_u123x[];
45extern const struct agdmm_recv agdmm_recvs_u123x[];
46extern const struct agdmm_job agdmm_jobs_u125x[];
47extern const struct agdmm_recv agdmm_recvs_u125x[];
e93cdf42 48
74ac7d7f
BV
49/* This works on all the Agilent U12xxA series, although the
50 * U127xA can apparently also run at 19200/8n1. */
51#define SERIALCOMM "9600/8n1"
52
e93cdf42 53static const struct agdmm_profile supported_agdmm[] = {
74ac7d7f
BV
54 { AGILENT_U1231A, "U1231A", agdmm_jobs_u123x, agdmm_recvs_u123x },
55 { AGILENT_U1232A, "U1232A", agdmm_jobs_u123x, agdmm_recvs_u123x },
56 { AGILENT_U1233A, "U1233A", agdmm_jobs_u123x, agdmm_recvs_u123x },
57 { AGILENT_U1251A, "U1251A", agdmm_jobs_u125x, agdmm_recvs_u125x },
58 { AGILENT_U1252A, "U1252A", agdmm_jobs_u125x, agdmm_recvs_u125x },
59 { AGILENT_U1253A, "U1253A", agdmm_jobs_u125x, agdmm_recvs_u125x },
60 { 0, NULL, NULL, NULL }
e93cdf42
BV
61};
62
63SR_PRIV struct sr_dev_driver agdmm_driver_info;
64static struct sr_dev_driver *di = &agdmm_driver_info;
65
66/* Properly close and free all devices. */
67static int clear_instances(void)
68{
69 struct sr_dev_inst *sdi;
70 struct drv_context *drvc;
71 struct dev_context *devc;
72 GSList *l;
73
74 if (!(drvc = di->priv))
75 return SR_OK;
76
77 drvc = di->priv;
78 for (l = drvc->instances; l; l = l->next) {
79 if (!(sdi = l->data))
80 continue;
81 if (!(devc = sdi->priv))
82 continue;
83 sr_serial_dev_inst_free(devc->serial);
84 sr_dev_inst_free(sdi);
85 }
86 g_slist_free(drvc->instances);
87 drvc->instances = NULL;
88
89 return SR_OK;
90}
91
34f06b90 92static int hw_init(struct sr_context *sr_ctx)
e93cdf42 93{
063e7aef 94 return std_hw_init(sr_ctx, di, DRIVER_LOG_DOMAIN);
e93cdf42
BV
95}
96
e93cdf42
BV
97static GSList *hw_scan(GSList *options)
98{
99 struct sr_dev_inst *sdi;
100 struct drv_context *drvc;
101 struct dev_context *devc;
1987b8d6 102 struct sr_config *src;
e93cdf42 103 struct sr_probe *probe;
109a3ba4 104 struct sr_serial_dev_inst *serial;
e93cdf42 105 GSList *l, *devices;
109a3ba4 106 int len, i;
e93cdf42
BV
107 const char *conn, *serialcomm;
108 char *buf, **tokens;
109
110 drvc = di->priv;
111 drvc->instances = NULL;
112
113 devices = NULL;
114 conn = serialcomm = NULL;
115 for (l = options; l; l = l->next) {
1987b8d6
BV
116 src = l->data;
117 switch (src->key) {
1953564a 118 case SR_CONF_CONN:
1987b8d6 119 conn = src->value;
e93cdf42 120 break;
1953564a 121 case SR_CONF_SERIALCOMM:
1987b8d6 122 serialcomm = src->value;
e93cdf42
BV
123 break;
124 }
125 }
74ac7d7f 126 if (!conn)
e93cdf42 127 return NULL;
109a3ba4
BV
128 if (!serialcomm)
129 serialcomm = SERIALCOMM;
e93cdf42 130
109a3ba4 131 if (!(serial = sr_serial_dev_inst_new(conn, serialcomm)))
e93cdf42 132 return NULL;
e93cdf42 133
a54dd31e 134 if (serial_open(serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK)
e93cdf42 135 return NULL;
e93cdf42 136
109a3ba4
BV
137 serial_flush(serial);
138 if (serial_write(serial, "*IDN?\r\n", 7) == -1) {
38d326e8
UH
139 sr_err("Unable to send identification string: %s.",
140 strerror(errno));
e93cdf42
BV
141 return NULL;
142 }
143
144 len = 128;
886a52b6
UH
145 if (!(buf = g_try_malloc(len))) {
146 sr_err("Serial buffer malloc failed.");
147 return NULL;
148 }
109a3ba4 149 serial_readline(serial, &buf, &len, 150);
e93cdf42
BV
150 if (!len)
151 return NULL;
152
153 tokens = g_strsplit(buf, ",", 4);
154 if (!strcmp("Agilent Technologies", tokens[0])
155 && tokens[2] && tokens[3]) {
156 for (i = 0; supported_agdmm[i].model; i++) {
157 if (strcmp(supported_agdmm[i].modelname, tokens[1]))
158 continue;
159 if (!(sdi = sr_dev_inst_new(0, SR_ST_INACTIVE, tokens[0],
160 tokens[1], tokens[3])))
161 return NULL;
162 if (!(devc = g_try_malloc0(sizeof(struct dev_context)))) {
886a52b6 163 sr_err("Device context malloc failed.");
e93cdf42
BV
164 return NULL;
165 }
166 devc->profile = &supported_agdmm[i];
109a3ba4 167 devc->serial = serial;
e93cdf42
BV
168 devc->cur_mq = -1;
169 sdi->priv = devc;
170 sdi->driver = di;
171 if (!(probe = sr_probe_new(0, SR_PROBE_ANALOG, TRUE, "P1")))
172 return NULL;
173 sdi->probes = g_slist_append(sdi->probes, probe);
174 drvc->instances = g_slist_append(drvc->instances, sdi);
175 devices = g_slist_append(devices, sdi);
176 break;
177 }
178 }
179 g_strfreev(tokens);
180 g_free(buf);
181
109a3ba4
BV
182 serial_close(serial);
183 if (!devices)
184 sr_serial_dev_inst_free(serial);
e93cdf42
BV
185
186 return devices;
187}
188
189static GSList *hw_dev_list(void)
190{
0e94d524 191 return ((struct drv_context *)(di->priv))->instances;
e93cdf42
BV
192}
193
194static int hw_dev_open(struct sr_dev_inst *sdi)
195{
196 struct dev_context *devc;
197
198 if (!(devc = sdi->priv)) {
38d326e8 199 sr_err("sdi->priv was NULL.");
e93cdf42
BV
200 return SR_ERR_BUG;
201 }
202
a54dd31e 203 if (serial_open(devc->serial, SERIAL_RDWR | SERIAL_NONBLOCK) != SR_OK)
e93cdf42 204 return SR_ERR;
109a3ba4 205
e93cdf42
BV
206 sdi->status = SR_ST_ACTIVE;
207
208 return SR_OK;
209}
210
211static int hw_dev_close(struct sr_dev_inst *sdi)
212{
213 struct dev_context *devc;
214
961009b0 215 devc = sdi->priv;
e93cdf42
BV
216
217 if (devc->serial && devc->serial->fd != -1) {
109a3ba4 218 serial_close(devc->serial);
e93cdf42
BV
219 sdi->status = SR_ST_INACTIVE;
220 }
221
222 return SR_OK;
223}
224
225static int hw_cleanup(void)
226{
227
228 clear_instances();
229
230 return SR_OK;
231}
232
035a1078 233static int config_set(int id, const void *value, const struct sr_dev_inst *sdi)
e93cdf42
BV
234{
235 struct dev_context *devc;
236
237 if (sdi->status != SR_ST_ACTIVE)
238 return SR_ERR;
239
240 if (!(devc = sdi->priv)) {
38d326e8 241 sr_err("sdi->priv was NULL.");
e93cdf42
BV
242 return SR_ERR_BUG;
243 }
244
035a1078 245 switch (id) {
1953564a 246 case SR_CONF_LIMIT_MSEC:
e93cdf42
BV
247 /* TODO: not yet implemented */
248 if (*(const uint64_t *)value == 0) {
38d326e8 249 sr_err("LIMIT_MSEC can't be 0.");
e93cdf42
BV
250 return SR_ERR;
251 }
252 devc->limit_msec = *(const uint64_t *)value;
38d326e8 253 sr_dbg("Setting time limit to %" PRIu64 "ms.",
e93cdf42
BV
254 devc->limit_msec);
255 break;
1953564a 256 case SR_CONF_LIMIT_SAMPLES:
e93cdf42 257 devc->limit_samples = *(const uint64_t *)value;
38d326e8 258 sr_dbg("Setting sample limit to %" PRIu64 ".",
e93cdf42
BV
259 devc->limit_samples);
260 break;
261 default:
035a1078 262 sr_err("Unknown capability: %d.", id);
e93cdf42
BV
263 return SR_ERR;
264 break;
265 }
266
267 return SR_OK;
268}
269
a1c743fc
BV
270static int config_list(int key, const void **data, const struct sr_dev_inst *sdi)
271{
272
273 (void)sdi;
274
275 switch (key) {
0d485e30
BV
276 case SR_CONF_SCAN_OPTIONS:
277 *data = hwopts;
278 break;
9a6517d1
BV
279 case SR_CONF_DEVICE_OPTIONS:
280 *data = hwcaps;
281 break;
a1c743fc
BV
282 default:
283 return SR_ERR_ARG;
284 }
285
286 return SR_OK;
287}
288
e93cdf42
BV
289static int hw_dev_acquisition_start(const struct sr_dev_inst *sdi,
290 void *cb_data)
291{
e93cdf42
BV
292 struct dev_context *devc;
293
294 if (!(devc = sdi->priv)) {
38d326e8 295 sr_err("sdi->priv was NULL.");
e93cdf42
BV
296 return SR_ERR_BUG;
297 }
298
e93cdf42
BV
299 devc->cb_data = cb_data;
300
301 /* Send header packet to the session bus. */
4afdfd46 302 std_session_send_df_header(cb_data, DRIVER_LOG_DOMAIN);
e93cdf42 303
e93cdf42
BV
304 /* Poll every 100ms, or whenever some data comes in. */
305 sr_source_add(devc->serial->fd, G_IO_IN, 100, agdmm_receive_data, (void *)sdi);
306
307 return SR_OK;
308}
309
69b07d14 310static int hw_dev_acquisition_stop(struct sr_dev_inst *sdi, void *cb_data)
e93cdf42
BV
311{
312 struct sr_datafeed_packet packet;
313 struct dev_context *devc;
314
315 if (sdi->status != SR_ST_ACTIVE)
316 return SR_ERR;
317
318 if (!(devc = sdi->priv)) {
38d326e8 319 sr_err("sdi->priv was NULL.");
e93cdf42
BV
320 return SR_ERR_BUG;
321 }
322
38d326e8 323 sr_dbg("Stopping acquisition.");
e93cdf42
BV
324
325 sr_source_remove(devc->serial->fd);
326 hw_dev_close((struct sr_dev_inst *)sdi);
327
328 /* Send end packet to the session bus. */
38d326e8 329 sr_dbg("Sending SR_DF_END.");
e93cdf42
BV
330 packet.type = SR_DF_END;
331 sr_session_send(cb_data, &packet);
332
333
334 return SR_OK;
335}
336
337SR_PRIV struct sr_dev_driver agdmm_driver_info = {
338 .name = "agilent-dmm",
339 .longname = "Agilent U12xx series DMMs",
340 .api_version = 1,
341 .init = hw_init,
342 .cleanup = hw_cleanup,
343 .scan = hw_scan,
344 .dev_list = hw_dev_list,
345 .dev_clear = clear_instances,
035a1078 346 .config_set = config_set,
a1c743fc 347 .config_list = config_list,
e93cdf42
BV
348 .dev_open = hw_dev_open,
349 .dev_close = hw_dev_close,
e93cdf42
BV
350 .dev_acquisition_start = hw_dev_acquisition_start,
351 .dev_acquisition_stop = hw_dev_acquisition_stop,
352 .priv = NULL,
353};