X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=libdivecomputer.c;h=a10243dd4d594801f6574e0c9284c8f44dc2458c;hb=5c8305588b9b47805226ee50ffcb069fd9a6b251;hp=806ea651f108497f748e4b56f6d6252fdc821817;hpb=a1a4392e8d0b437ff6f9f79bedbdc7fa14517ec1;p=ext%2Fsubsurface.git

diff --git a/libdivecomputer.c b/libdivecomputer.c
index 806ea65..a10243d 100644
--- a/libdivecomputer.c
+++ b/libdivecomputer.c
@@ -216,6 +216,23 @@ static int parse_samples(struct dive **divep, parser_t *parser)
 	return parser_samples_foreach(parser, sample_cb, divep);
 }
 
+/*
+ * Check if this dive already existed before the import
+ */
+static int find_dive(struct dive *dive, device_data_t *devdata)
+{
+	int i;
+
+	for (i = 0; i < devdata->preexisting; i++) {
+		struct dive *old = dive_table.dives[i];
+
+		if (dive->when != old->when)
+			continue;
+		return 1;
+	}
+	return 0;
+}
+
 static int dive_cb(const unsigned char *data, unsigned int size,
 	const unsigned char *fingerprint, unsigned int fsize,
 	void *userdata)
@@ -302,15 +319,21 @@ static int dive_cb(const unsigned char *data, unsigned int size,
 		parser_destroy(parser);
 		return rc;
 	}
-	record_dive(dive);
 
 	parser_destroy(parser);
+
+	/* If we already saw this dive, abort. */
+	if (find_dive(dive, devdata))
+		return 0;
+
+	record_dive(dive);
 	return 1;
 }
 
 
 static device_status_t import_device_data(device_t *device, device_data_t *devicedata)
 {
+	devicedata->preexisting = dive_table.nr;
 	return device_foreach(device, dive_cb, devicedata);
 }