+static int zip_append_analog(const struct sr_output *o,
+ const struct sr_datafeed_analog *analog)
+{
+ struct out_context *outc;
+ struct zip *archive;
+ struct zip_source *analogsrc;
+ int64_t i, num_files;
+ struct zip_stat zs;
+ uint64_t chunk_num;
+ const char *entry_name;
+ char *basename;
+ gsize baselen;
+ struct sr_channel *channel;
+ float *chunkbuf;
+ gsize chunksize;
+ char *chunkname;
+ unsigned int next_chunk_num, index;
+
+ outc = o->priv;
+
+ /* TODO: support packets covering multiple channels */
+ if (g_slist_length(analog->meaning->channels) != 1) {
+ sr_err("Analog packets covering multiple channels not supported yet");
+ return SR_ERR;
+ }
+ channel = analog->meaning->channels->data;
+
+ /* When reading the file, analog channels must be consecutive.
+ * Thus we need a global channel index map as we don't know in
+ * which order the channel data comes in. */
+ for (index = 0; outc->analog_index_map[index] != -1; index++)
+ if (outc->analog_index_map[index] == channel->index)
+ break;
+ if (outc->analog_index_map[index] == -1)
+ return SR_ERR_ARG; /* Channel index was not in the list */
+
+ index += outc->first_analog_index;
+
+ if (!(archive = zip_open(outc->filename, 0, NULL)))
+ return SR_ERR;
+
+ if (zip_stat(archive, "metadata", 0, &zs) < 0) {
+ sr_err("Failed to open metadata: %s", zip_strerror(archive));
+ goto err_zip_discard;
+ }
+
+ basename = g_strdup_printf("analog-1-%u", index);
+ baselen = strlen(basename);
+ next_chunk_num = 1;
+ num_files = zip_get_num_entries(archive, 0);
+ for (i = 0; i < num_files; i++) {
+ entry_name = zip_get_name(archive, i, 0);
+ if (!entry_name || strncmp(entry_name, basename, baselen) != 0) {
+ continue;
+ } else if (entry_name[baselen] == '-') {
+ chunk_num = g_ascii_strtoull(entry_name + baselen + 1, NULL, 10);
+ if (chunk_num < G_MAXINT && chunk_num >= next_chunk_num)
+ next_chunk_num = chunk_num + 1;
+ }
+ }
+
+ chunksize = sizeof(float) * analog->num_samples;
+ if (!(chunkbuf = g_try_malloc(chunksize)))
+ goto err_free_basename;
+
+ if (sr_analog_to_float(analog, chunkbuf) != SR_OK)
+ goto err_free_chunkbuf;
+
+ analogsrc = zip_source_buffer(archive, chunkbuf, chunksize, FALSE);
+ chunkname = g_strdup_printf("%s-%u", basename, next_chunk_num);
+ i = zip_add(archive, chunkname, analogsrc);
+ g_free(chunkname);
+ if (i < 0) {
+ sr_err("Failed to add chunk '%s': %s", chunkname, zip_strerror(archive));
+ zip_source_free(analogsrc);
+ goto err_free_chunkbuf;
+ }
+ if (zip_close(archive) < 0) {
+ sr_err("Error saving session file: %s", zip_strerror(archive));
+ goto err_free_chunkbuf;
+ }
+
+ g_free(basename);
+ g_free(chunkbuf);
+
+ return SR_OK;
+
+err_free_chunkbuf:
+ g_free(chunkbuf);
+err_free_basename:
+ g_free(basename);
+err_zip_discard:
+ zip_discard(archive);
+
+ return SR_ERR;
+}
+