summaryrefslogtreecommitdiff
path: root/src/stasis/plugin_anastasis_postgres.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/stasis/plugin_anastasis_postgres.c')
-rw-r--r--src/stasis/plugin_anastasis_postgres.c8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/stasis/plugin_anastasis_postgres.c b/src/stasis/plugin_anastasis_postgres.c
index 4aba97c..4d95c8f 100644
--- a/src/stasis/plugin_anastasis_postgres.c
+++ b/src/stasis/plugin_anastasis_postgres.c
@@ -329,6 +329,7 @@ postgres_store_recovery_document (
switch (qs)
{
case GNUNET_DB_STATUS_HARD_ERROR:
+ GNUNET_break (0);
rollback (pg);
return ANASTASIS_DB_STORE_STATUS_HARD_ERROR;
case GNUNET_DB_STATUS_SOFT_ERROR:
@@ -348,8 +349,9 @@ postgres_store_recovery_document (
(*version)++;
break;
default:
+ GNUNET_break (0);
rollback (pg);
- return qs;
+ return ANASTASIS_DB_STORE_STATUS_HARD_ERROR;
}
}
@@ -441,6 +443,7 @@ postgres_store_recovery_document (
switch (qs)
{
case GNUNET_DB_STATUS_HARD_ERROR:
+ GNUNET_break (0);
rollback (pg);
return ANASTASIS_DB_STORE_STATUS_HARD_ERROR;
case GNUNET_DB_STATUS_SOFT_ERROR:
@@ -452,8 +455,9 @@ postgres_store_recovery_document (
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
break;
default:
+ GNUNET_break (0);
rollback (pg);
- return qs;
+ return ANASTASIS_DB_STORE_STATUS_HARD_ERROR;
}
}
}