From: Bert Vermeulen Date: Mon, 23 Jul 2012 13:06:49 +0000 (+0200) Subject: sr: sr_session_save() now takes sdi and datastore parameters X-Git-Tag: dsupstream~763 X-Git-Url: https://sigrok.org/gitaction?a=commitdiff_plain;h=056be0719f0c1a05cde6fc2483b50e024708fdac;p=libsigrok.git sr: sr_session_save() now takes sdi and datastore parameters This means it's restricted to saving one device's capture per file, for now. --- diff --git a/proto.h b/proto.h index 5b30cf05..d79e017b 100644 --- a/proto.h +++ b/proto.h @@ -94,7 +94,8 @@ SR_API int sr_session_start(void); SR_API int sr_session_run(void); SR_API int sr_session_halt(void); SR_API int sr_session_stop(void); -SR_API int sr_session_save(const char *filename); +SR_API int sr_session_save(const char *filename, + const struct sr_dev_inst *sdi, struct sr_datastore *ds); SR_API int sr_session_source_add(int fd, int events, int timeout, sr_receive_data_callback_t cb, void *cb_data); SR_API int sr_session_source_add_pollfd(GPollFD *pollfd, int timeout, diff --git a/session_file.c b/session_file.c index 90f671e9..33364a29 100644 --- a/session_file.c +++ b/session_file.c @@ -169,21 +169,22 @@ SR_API int sr_session_load(const char *filename) * * @param filename The name of the file where to save the current session. * Must not be NULL. + * @param sdi The device instance from which the data was captured. + * @param ds The datastore where the session's captured data was stored. * * @return SR_OK upon success, SR_ERR_ARG upon invalid arguments, or SR_ERR * upon other errors. */ -int sr_session_save(const char *filename) +SR_API int sr_session_save(const char *filename, + const struct sr_dev_inst *sdi, struct sr_datastore *ds) { - GSList *l, *p, *d; + GSList *l, *d; FILE *meta; - struct sr_dev_inst *sdi; struct sr_probe *probe; - struct sr_datastore *ds; struct zip *zipfile; struct zip_source *versrc, *metasrc, *logicsrc; - int bufcnt, devcnt, tmpfile, ret, probecnt; - uint64_t samplerate; + int bufcnt, tmpfile, ret, probecnt; + uint64_t *samplerate; char version[1], rawname[16], metafile[32], *buf, *s; if (!filename) { @@ -214,66 +215,57 @@ int sr_session_save(const char *filename) meta = g_fopen(metafile, "wb"); fprintf(meta, "[global]\n"); fprintf(meta, "sigrok version = %s\n", PACKAGE_VERSION); - /* TODO: save protocol decoders used */ - /* all datastores in all devices */ - devcnt = 1; - for (l = session->devs; l; l = l->next) { - dev = l->data; - /* metadata */ - fprintf(meta, "[device %d]\n", devcnt); - if (dev->driver) - fprintf(meta, "driver = %s\n", dev->driver->name); + /* metadata */ + fprintf(meta, "[device 1]\n"); + if (sdi->driver) + fprintf(meta, "driver = %s\n", sdi->driver->name); - ds = dev->datastore; - if (ds) { - /* metadata */ - fprintf(meta, "capturefile = logic-%d\n", devcnt); - fprintf(meta, "unitsize = %d\n", ds->ds_unitsize); - fprintf(meta, "total probes = %d\n", g_slist_length(dev->probes)); - if (sr_dev_has_hwcap(dev, SR_HWCAP_SAMPLERATE)) { - samplerate = *((uint64_t *) dev->driver->dev_info_get( - dev->driver_index, SR_DI_CUR_SAMPLERATE)); - s = sr_samplerate_string(samplerate); - fprintf(meta, "samplerate = %s\n", s); - g_free(s); - } - probecnt = 1; - for (p = dev->probes; p; p = p->next) { - probe = p->data; - if (probe->enabled) { - if (probe->name) - fprintf(meta, "probe%d = %s\n", probecnt, probe->name); - if (probe->trigger) - fprintf(meta, " trigger%d = %s\n", probecnt, probe->trigger); - probecnt++; - } - } + /* metadata */ + fprintf(meta, "capturefile = logic-1\n"); + fprintf(meta, "unitsize = %d\n", ds->ds_unitsize); + fprintf(meta, "total probes = %d\n", g_slist_length(sdi->probes)); + if (sr_dev_has_hwcap(sdi, SR_HWCAP_SAMPLERATE)) { + if (sr_info_get(sdi->driver, SR_DI_CUR_SAMPLERATE, + (const void **)&samplerate, sdi) == SR_OK) { + s = sr_samplerate_string(*samplerate); + fprintf(meta, "samplerate = %s\n", s); + g_free(s); + } + } + probecnt = 1; + for (l = sdi->probes; l; l = l->next) { + probe = l->data; + if (probe->enabled) { + if (probe->name) + fprintf(meta, "probe%d = %s\n", probecnt, probe->name); + if (probe->trigger) + fprintf(meta, " trigger%d = %s\n", probecnt, probe->trigger); + probecnt++; + } + } - /* dump datastore into logic-n */ - buf = g_try_malloc(ds->num_units * ds->ds_unitsize + - DATASTORE_CHUNKSIZE); - if (!buf) { - sr_err("session file: %s: buf malloc failed", - __func__); - return SR_ERR_MALLOC; - } + /* dump datastore into logic-n */ + buf = g_try_malloc(ds->num_units * ds->ds_unitsize + + DATASTORE_CHUNKSIZE); + if (!buf) { + sr_err("session file: %s: buf malloc failed", + __func__); + return SR_ERR_MALLOC; + } - bufcnt = 0; - for (d = ds->chunklist; d; d = d->next) { - memcpy(buf + bufcnt, d->data, - DATASTORE_CHUNKSIZE); - bufcnt += DATASTORE_CHUNKSIZE; - } - if (!(logicsrc = zip_source_buffer(zipfile, buf, - ds->num_units * ds->ds_unitsize, TRUE))) - return SR_ERR; - snprintf(rawname, 15, "logic-%d", devcnt); - if (zip_add(zipfile, rawname, logicsrc) == -1) - return SR_ERR; - } - devcnt++; + bufcnt = 0; + for (d = ds->chunklist; d; d = d->next) { + memcpy(buf + bufcnt, d->data, + DATASTORE_CHUNKSIZE); + bufcnt += DATASTORE_CHUNKSIZE; } + if (!(logicsrc = zip_source_buffer(zipfile, buf, + ds->num_units * ds->ds_unitsize, TRUE))) + return SR_ERR; + snprintf(rawname, 15, "logic-1"); + if (zip_add(zipfile, rawname, logicsrc) == -1) + return SR_ERR; fclose(meta); if (!(metasrc = zip_source_file(zipfile, metafile, 0, -1)))