Changeset: 9d23c00aac8e for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=9d23c00aac8e
Modified Files:
sql/storage/bat/bat_storage.c
Branch: Oct2014
Log Message:
properly cleanup no longer active delta's
diffs (45 lines):
diff --git a/sql/storage/bat/bat_storage.c b/sql/storage/bat/bat_storage.c
--- a/sql/storage/bat/bat_storage.c
+++ b/sql/storage/bat/bat_storage.c
@@ -1763,11 +1763,11 @@ update_table(sql_trans *tr, sql_table *f
b->next = tt->data;
tt->data = b;
- while (b && b->wtime > oldest->stime) {
+ while (b && b->wtime >= oldest->stime) {
p = b;
b = b->next;
}
- if (b && b->wtime <= oldest->stime && p) {
+ if (b && b->wtime < oldest->stime && p) {
p->next = NULL;
destroy_dbat(tr, b);
}
@@ -1788,11 +1788,11 @@ update_table(sql_trans *tr, sql_table *f
cc->data = NULL;
b->next = oc->data;
oc->data = b;
- while (b && b->wtime > oldest->stime) {
+ while (b && b->wtime >= oldest->stime) {
p = b;
b = b->next;
}
- if (b && b->wtime <= oldest->stime && p) {
+ if (b && b->wtime < oldest->stime && p) {
p->next = NULL;
destroy_bat(tr, b);
}
@@ -1838,11 +1838,11 @@ update_table(sql_trans *tr, sql_table *f
ci->data = NULL;
b->next = oi->data;
oi->data = b;
- while (b && b->wtime > oldest->stime) {
+ while (b && b->wtime >= oldest->stime) {
p = b;
b = b->next;
}
- if (b && b->wtime <= oldest->stime && p) {
+ if (b && b->wtime < oldest->stime && p) {
p->next = NULL;
destroy_bat(tr, b);
}
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list