aboutsummaryrefslogtreecommitdiff
path: root/src/psycstore/plugin_psycstore_postgres.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/psycstore/plugin_psycstore_postgres.c')
-rw-r--r--src/psycstore/plugin_psycstore_postgres.c30
1 files changed, 15 insertions, 15 deletions
diff --git a/src/psycstore/plugin_psycstore_postgres.c b/src/psycstore/plugin_psycstore_postgres.c
index de4b6e43f..b8010af0a 100644
--- a/src/psycstore/plugin_psycstore_postgres.c
+++ b/src/psycstore/plugin_psycstore_postgres.c
@@ -391,7 +391,7 @@ exec_channel (struct Plugin *plugin, const char *stmt,
391 GNUNET_PQ_query_param_end 391 GNUNET_PQ_query_param_end
392 }; 392 };
393 393
394 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 394 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
395 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, stmt, params)) 395 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, stmt, params))
396 return GNUNET_SYSERR; 396 return GNUNET_SYSERR;
397 397
@@ -409,7 +409,7 @@ transaction_begin (struct Plugin *plugin, enum Transactions transaction)
409 GNUNET_PQ_query_param_end 409 GNUNET_PQ_query_param_end
410 }; 410 };
411 411
412 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 412 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
413 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "transaction_begin", params)) 413 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "transaction_begin", params))
414 return GNUNET_SYSERR; 414 return GNUNET_SYSERR;
415 415
@@ -428,7 +428,7 @@ transaction_commit (struct Plugin *plugin)
428 GNUNET_PQ_query_param_end 428 GNUNET_PQ_query_param_end
429 }; 429 };
430 430
431 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 431 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
432 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "transaction_commit", params)) 432 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "transaction_commit", params))
433 return GNUNET_SYSERR; 433 return GNUNET_SYSERR;
434 434
@@ -447,7 +447,7 @@ transaction_rollback (struct Plugin *plugin)
447 GNUNET_PQ_query_param_end 447 GNUNET_PQ_query_param_end
448 }; 448 };
449 449
450 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 450 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
451 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "transaction_rollback", params)) 451 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "transaction_rollback", params))
452 return GNUNET_SYSERR; 452 return GNUNET_SYSERR;
453 453
@@ -465,7 +465,7 @@ channel_key_store (struct Plugin *plugin,
465 GNUNET_PQ_query_param_end 465 GNUNET_PQ_query_param_end
466 }; 466 };
467 467
468 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 468 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
469 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_channel_key", params)) 469 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_channel_key", params))
470 return GNUNET_SYSERR; 470 return GNUNET_SYSERR;
471 471
@@ -482,7 +482,7 @@ slave_key_store (struct Plugin *plugin,
482 GNUNET_PQ_query_param_end 482 GNUNET_PQ_query_param_end
483 }; 483 };
484 484
485 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 485 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
486 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_slave_key", params)) 486 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_slave_key", params))
487 return GNUNET_SYSERR; 487 return GNUNET_SYSERR;
488 488
@@ -535,7 +535,7 @@ postgres_membership_store (void *cls,
535 GNUNET_PQ_query_param_end 535 GNUNET_PQ_query_param_end
536 }; 536 };
537 537
538 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 538 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
539 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_membership", params)) 539 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_membership", params))
540 return GNUNET_SYSERR; 540 return GNUNET_SYSERR;
541 541
@@ -572,7 +572,7 @@ membership_test (void *cls,
572 GNUNET_PQ_result_spec_end 572 GNUNET_PQ_result_spec_end
573 }; 573 };
574 574
575 if (GNUNET_PQ_STATUS_SUCCESS_ONE_RESULT != 575 if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
576 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, "select_membership", 576 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, "select_membership",
577 params_select, results_select)) 577 params_select, results_select))
578 return GNUNET_SYSERR; 578 return GNUNET_SYSERR;
@@ -635,7 +635,7 @@ fragment_store (void *cls,
635 GNUNET_PQ_query_param_end 635 GNUNET_PQ_query_param_end
636 }; 636 };
637 637
638 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 638 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
639 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_fragment", params_insert)) 639 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "insert_fragment", params_insert))
640 return GNUNET_SYSERR; 640 return GNUNET_SYSERR;
641 641
@@ -664,7 +664,7 @@ message_add_flags (void *cls,
664 GNUNET_PQ_query_param_end 664 GNUNET_PQ_query_param_end
665 }; 665 };
666 666
667 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 667 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
668 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "update_message_flags", params_update)) 668 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, "update_message_flags", params_update))
669 return GNUNET_SYSERR; 669 return GNUNET_SYSERR;
670 670
@@ -994,7 +994,7 @@ counters_message_get (void *cls,
994 GNUNET_PQ_result_spec_end 994 GNUNET_PQ_result_spec_end
995 }; 995 };
996 996
997 if (GNUNET_PQ_STATUS_SUCCESS_ONE_RESULT != 997 if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
998 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, stmt, 998 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, stmt,
999 params_select, results_select)) 999 params_select, results_select))
1000 return GNUNET_SYSERR; 1000 return GNUNET_SYSERR;
@@ -1028,7 +1028,7 @@ counters_state_get (void *cls,
1028 GNUNET_PQ_result_spec_end 1028 GNUNET_PQ_result_spec_end
1029 }; 1029 };
1030 1030
1031 if (GNUNET_PQ_STATUS_SUCCESS_ONE_RESULT != 1031 if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
1032 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, stmt, 1032 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, stmt,
1033 params_select, results_select)) 1033 params_select, results_select))
1034 return GNUNET_SYSERR; 1034 return GNUNET_SYSERR;
@@ -1054,7 +1054,7 @@ state_assign (struct Plugin *plugin, const char *stmt,
1054 GNUNET_PQ_query_param_end 1054 GNUNET_PQ_query_param_end
1055 }; 1055 };
1056 1056
1057 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 1057 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
1058 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, stmt, params)) 1058 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, stmt, params))
1059 return GNUNET_SYSERR; 1059 return GNUNET_SYSERR;
1060 1060
@@ -1074,7 +1074,7 @@ update_message_id (struct Plugin *plugin,
1074 GNUNET_PQ_query_param_end 1074 GNUNET_PQ_query_param_end
1075 }; 1075 };
1076 1076
1077 if (GNUNET_PQ_STATUS_SUCCESS_NO_RESULTS != 1077 if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS !=
1078 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, stmt, params)) 1078 GNUNET_PQ_eval_prepared_non_select (plugin->dbh, stmt, params))
1079 return GNUNET_SYSERR; 1079 return GNUNET_SYSERR;
1080 1080
@@ -1305,7 +1305,7 @@ state_get (void *cls, const struct GNUNET_CRYPTO_EddsaPublicKey *channel_key,
1305 GNUNET_PQ_result_spec_end 1305 GNUNET_PQ_result_spec_end
1306 }; 1306 };
1307 1307
1308 if (GNUNET_PQ_STATUS_SUCCESS_ONE_RESULT != 1308 if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT !=
1309 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, stmt, 1309 GNUNET_PQ_eval_prepared_singleton_select (plugin->dbh, stmt,
1310 params_select, results_select)) 1310 params_select, results_select))
1311 return GNUNET_SYSERR; 1311 return GNUNET_SYSERR;