diff options
Diffstat (limited to 'libdivecomputer.c')
| -rw-r--r-- | libdivecomputer.c | 50 |
1 files changed, 31 insertions, 19 deletions
diff --git a/libdivecomputer.c b/libdivecomputer.c index 4495b1716..bd31eb04e 100644 --- a/libdivecomputer.c +++ b/libdivecomputer.c @@ -104,7 +104,7 @@ static parser_status_t create_parser(device_data_t *devdata, parser_t **parser) } } -static int parse_gasmixes(struct dive *dive, parser_t *parser, int ngases) +static int parse_gasmixes(device_data_t *devdata, struct dive *dive, parser_t *parser, int ngases) { int i; @@ -225,11 +225,22 @@ sample_cb(parser_sample_type_t type, parser_sample_value_t value, void *userdata } } +static void dev_info(device_data_t *devdata, const char *fmt, ...) +{ + char buffer[32]; + va_list ap; + + va_start(ap, fmt); + vsnprintf(buffer, sizeof(buffer), fmt, ap); + va_end(ap); + update_progressbar_text(&devdata->progress, buffer); +} -static int parse_samples(struct dive **divep, parser_t *parser) +static int import_dive_number = 0; + +static int parse_samples(device_data_t *devdata, struct dive **divep, parser_t *parser) { // Parse the sample data. - printf("Parsing the sample data.\n"); return parser_samples_foreach(parser, sample_cb, divep); } @@ -263,21 +274,22 @@ static int dive_cb(const unsigned char *data, unsigned int size, rc = create_parser(devdata, &parser); if (rc != PARSER_STATUS_SUCCESS) { - fprintf(stderr, "Unable to create parser for %s", devdata->name); + dev_info(devdata, "Unable to create parser for %s", devdata->name); return rc; } rc = parser_set_data(parser, data, size); if (rc != PARSER_STATUS_SUCCESS) { - fprintf(stderr, "Error registering the data."); + dev_info(devdata, "Error registering the data"); parser_destroy(parser); return rc; } + import_dive_number++; dive = alloc_dive(); rc = parser_get_datetime(parser, &dt); if (rc != PARSER_STATUS_SUCCESS && rc != PARSER_STATUS_UNSUPPORTED) { - fprintf(stderr, "Error parsing the datetime."); + dev_info(devdata, "Error parsing the datetime"); parser_destroy (parser); return rc; } @@ -291,48 +303,46 @@ static int dive_cb(const unsigned char *data, unsigned int size, dive->when = utc_mktime(&tm); // Parse the divetime. - printf("Parsing the divetime.\n"); + dev_info(devdata, "Parsing dive %d", import_dive_number); unsigned int divetime = 0; rc = parser_get_field (parser, FIELD_TYPE_DIVETIME, 0, &divetime); if (rc != PARSER_STATUS_SUCCESS && rc != PARSER_STATUS_UNSUPPORTED) { - fprintf(stderr, "Error parsing the divetime."); + dev_info(devdata, "Error parsing the divetime"); parser_destroy(parser); return rc; } dive->duration.seconds = divetime; // Parse the maxdepth. - printf("Parsing the maxdepth.\n"); double maxdepth = 0.0; rc = parser_get_field(parser, FIELD_TYPE_MAXDEPTH, 0, &maxdepth); if (rc != PARSER_STATUS_SUCCESS && rc != PARSER_STATUS_UNSUPPORTED) { - fprintf(stderr, "Error parsing the maxdepth."); + dev_info(devdata, "Error parsing the maxdepth"); parser_destroy(parser); return rc; } dive->maxdepth.mm = maxdepth * 1000 + 0.5; // Parse the gas mixes. - printf("Parsing the gas mixes.\n"); unsigned int ngases = 0; rc = parser_get_field(parser, FIELD_TYPE_GASMIX_COUNT, 0, &ngases); if (rc != PARSER_STATUS_SUCCESS && rc != PARSER_STATUS_UNSUPPORTED) { - fprintf(stderr, "Error parsing the gas mix count."); + dev_info(devdata, "Error parsing the gas mix count"); parser_destroy(parser); return rc; } - rc = parse_gasmixes(dive, parser, ngases); + rc = parse_gasmixes(devdata, dive, parser, ngases); if (rc != PARSER_STATUS_SUCCESS) { - fprintf(stderr, "Error parsing the gas mix."); + dev_info(devdata, "Error parsing the gas mix"); parser_destroy(parser); return rc; } // Initialize the sample data. - rc = parse_samples(&dive, parser); + rc = parse_samples(devdata, &dive, parser); if (rc != PARSER_STATUS_SUCCESS) { - fprintf(stderr, "Error parsing the samples."); + dev_info(devdata, "Error parsing the samples"); parser_destroy(parser); return rc; } @@ -429,6 +439,7 @@ static device_status_t device_open(const char *devname, } } + static void event_cb(device_t *device, device_event_t event, const void *data, void *userdata) { const device_progress_t *progress = data; @@ -438,7 +449,7 @@ static void event_cb(device_t *device, device_event_t event, const void *data, v switch (event) { case DEVICE_EVENT_WAITING: - printf("Event: waiting for user action\n"); + dev_info(devdata, "Event: waiting for user action"); break; case DEVICE_EVENT_PROGRESS: update_progressbar(&devdata->progress, @@ -446,14 +457,14 @@ static void event_cb(device_t *device, device_event_t event, const void *data, v break; case DEVICE_EVENT_DEVINFO: devdata->devinfo = *devinfo; - printf("Event: model=%u (0x%08x), firmware=%u (0x%08x), serial=%u (0x%08x)\n", + dev_info(devdata, "model=%u (0x%08x), firmware=%u (0x%08x), serial=%u (0x%08x)", devinfo->model, devinfo->model, devinfo->firmware, devinfo->firmware, devinfo->serial, devinfo->serial); break; case DEVICE_EVENT_CLOCK: devdata->clock = *clock; - printf("Event: systime=%"PRId64", devtime=%u\n", + dev_info(devdata, "Event: systime=%"PRId64", devtime=%u\n", (uint64_t)clock->systime, clock->devtime); break; default: @@ -474,6 +485,7 @@ static const char *do_libdivecomputer_import(device_data_t *data) device_t *device = NULL; device_status_t rc; + import_dive_number = 0; rc = device_open(data->devname, data->type, &device); if (rc != DEVICE_STATUS_SUCCESS) return "Unable to open %s (%s)"; |