diff options
Diffstat (limited to 'src/exchangedb')
-rw-r--r-- | src/exchangedb/pg_iterate_active_auditors.c | 9 | ||||
-rw-r--r-- | src/exchangedb/pg_iterate_active_signkeys.c | 9 | ||||
-rw-r--r-- | src/exchangedb/pg_iterate_auditor_denominations.c | 6 | ||||
-rw-r--r-- | src/exchangedb/pg_iterate_denomination_info.c | 16 | ||||
-rw-r--r-- | src/exchangedb/pg_iterate_denominations.c | 10 | ||||
-rw-r--r-- | src/exchangedb/pg_lookup_global_fee_by_time.c | 6 | ||||
-rw-r--r-- | src/exchangedb/pg_lookup_wire_fee_by_time.c | 4 | ||||
-rw-r--r-- | src/exchangedb/pg_lookup_wire_transfer.c | 7 | ||||
-rw-r--r-- | src/exchangedb/pg_lookup_wire_transfer.h | 4 | ||||
-rw-r--r-- | src/exchangedb/pg_preflight.c | 4 | ||||
-rw-r--r-- | src/exchangedb/pg_preflight.h | 9 | ||||
-rw-r--r-- | src/exchangedb/pg_start_read_committed.c | 6 | ||||
-rw-r--r-- | src/exchangedb/pg_start_read_committed.h | 4 |
13 files changed, 40 insertions, 54 deletions
diff --git a/src/exchangedb/pg_iterate_active_auditors.c b/src/exchangedb/pg_iterate_active_auditors.c index 11b10cb48..4f1c6ec66 100644 --- a/src/exchangedb/pg_iterate_active_auditors.c +++ b/src/exchangedb/pg_iterate_active_auditors.c @@ -45,7 +45,7 @@ struct AuditorsIteratorContext /** - * Helper function for #postgres_iterate_active_auditors(). + * Helper function for #TEH_PG_iterate_active_auditors(). * Calls the callback with each auditor. * * @param cls a `struct SignkeysIteratorContext` @@ -91,11 +91,10 @@ auditors_cb_helper (void *cls, } - enum GNUNET_DB_QueryStatus TEH_PG_iterate_active_auditors (void *cls, - TALER_EXCHANGEDB_AuditorsCallback cb, - void *cb_cls) + TALER_EXCHANGEDB_AuditorsCallback cb, + void *cb_cls) { struct PostgresClosure *pg = cls; struct GNUNET_PQ_QueryParam params[] = { @@ -105,7 +104,7 @@ TEH_PG_iterate_active_auditors (void *cls, .cb = cb, .cb_cls = cb_cls, }; - /* Used in #postgres_iterate_active_auditors() */ + PREPARE (pg, "select_auditors", "SELECT" diff --git a/src/exchangedb/pg_iterate_active_signkeys.c b/src/exchangedb/pg_iterate_active_signkeys.c index b6dac230e..9c280c95d 100644 --- a/src/exchangedb/pg_iterate_active_signkeys.c +++ b/src/exchangedb/pg_iterate_active_signkeys.c @@ -26,7 +26,6 @@ #include "pg_helper.h" - /** * Closure for #signkeys_cb_helper() */ @@ -46,7 +45,7 @@ struct SignkeysIteratorContext /** - * Helper function for #postgres_iterate_active_signkeys(). + * Helper function for #TEH_PG_iterate_active_signkeys(). * Calls the callback with each signkey. * * @param cls a `struct SignkeysIteratorContext` @@ -107,8 +106,8 @@ signkeys_cb_helper (void *cls, */ enum GNUNET_DB_QueryStatus TEH_PG_iterate_active_signkeys (void *cls, - TALER_EXCHANGEDB_ActiveSignkeysCallback cb, - void *cb_cls) + TALER_EXCHANGEDB_ActiveSignkeysCallback cb, + void *cb_cls) { struct PostgresClosure *pg = cls; struct GNUNET_TIME_Absolute now = {0}; @@ -120,7 +119,7 @@ TEH_PG_iterate_active_signkeys (void *cls, .cb = cb, .cb_cls = cb_cls, }; - + PREPARE (pg, "select_signkeys", "SELECT" diff --git a/src/exchangedb/pg_iterate_auditor_denominations.c b/src/exchangedb/pg_iterate_auditor_denominations.c index 6456ed1d4..1fd4cdea6 100644 --- a/src/exchangedb/pg_iterate_auditor_denominations.c +++ b/src/exchangedb/pg_iterate_auditor_denominations.c @@ -43,7 +43,7 @@ struct AuditorDenomsIteratorContext /** - * Helper function for #postgres_iterate_auditor_denominations(). + * Helper function for #TEH_PG_iterate_auditor_denominations(). * Calls the callback with each auditor and denomination pair. * * @param cls a `struct AuditorDenomsIteratorContext` @@ -102,7 +102,7 @@ TEH_PG_iterate_auditor_denominations ( .cb = cb, .cb_cls = cb_cls, }; - /* Used in #postgres_iterate_auditor_denominations() */ + /* Used in #postgres_iterate_auditor_denominations() */ PREPARE (pg, "select_auditor_denoms", "SELECT" @@ -113,7 +113,7 @@ TEH_PG_iterate_auditor_denominations ( " JOIN auditors USING (auditor_uuid)" " JOIN denominations USING (denominations_serial)" " WHERE auditors.is_active;"); - return GNUNET_PQ_eval_prepared_multi_select (pg->conn, + return GNUNET_PQ_eval_prepared_multi_select (pg->conn, "select_auditor_denoms", params, &auditor_denoms_cb_helper, diff --git a/src/exchangedb/pg_iterate_denomination_info.c b/src/exchangedb/pg_iterate_denomination_info.c index bf39a65af..ba7026ebc 100644 --- a/src/exchangedb/pg_iterate_denomination_info.c +++ b/src/exchangedb/pg_iterate_denomination_info.c @@ -49,7 +49,7 @@ struct DenomIteratorContext /** - * Helper function for #postgres_iterate_denomination_info(). + * Helper function for #TEH_PG_iterate_denomination_info(). * Calls the callback with each denomination key. * * @param cls a `struct DenomIteratorContext` @@ -132,14 +132,6 @@ domination_cb_helper (void *cls, } - - - - - - - - /** * Fetch information about all known denomination keys. * @@ -150,8 +142,8 @@ domination_cb_helper (void *cls, */ enum GNUNET_DB_QueryStatus TEH_PG_iterate_denomination_info (void *cls, - TALER_EXCHANGEDB_DenominationCallback cb, - void *cb_cls) + TALER_EXCHANGEDB_DenominationCallback cb, + void *cb_cls) { struct PostgresClosure *pg = cls; struct GNUNET_PQ_QueryParam params[] = { @@ -163,7 +155,7 @@ TEH_PG_iterate_denomination_info (void *cls, .pg = pg }; - /* Used in #postgres_iterate_denomination_info() */ + /* Used in #postgres_iterate_denomination_info() */ PREPARE (pg, "denomination_iterate", "SELECT" diff --git a/src/exchangedb/pg_iterate_denominations.c b/src/exchangedb/pg_iterate_denominations.c index d8a91f558..a38257689 100644 --- a/src/exchangedb/pg_iterate_denominations.c +++ b/src/exchangedb/pg_iterate_denominations.c @@ -26,8 +26,6 @@ #include "pg_helper.h" - - /** * Closure for #dominations_cb_helper() */ @@ -51,7 +49,7 @@ struct DenomsIteratorContext /** - * Helper function for #postgres_iterate_denominations(). + * Helper function for #TEH_PG_iterate_denominations(). * Calls the callback with each denomination key. * * @param cls a `struct DenomsIteratorContext` @@ -130,8 +128,8 @@ dominations_cb_helper (void *cls, enum GNUNET_DB_QueryStatus TEH_PG_iterate_denominations (void *cls, - TALER_EXCHANGEDB_DenominationsCallback cb, - void *cb_cls) + TALER_EXCHANGEDB_DenominationsCallback cb, + void *cb_cls) { struct PostgresClosure *pg = cls; struct GNUNET_PQ_QueryParam params[] = { @@ -143,7 +141,7 @@ TEH_PG_iterate_denominations (void *cls, .pg = pg }; - /* Used in #postgres_iterate_denominations() */ + /* Used in #postgres_iterate_denominations() */ PREPARE (pg, "select_denominations", "SELECT" diff --git a/src/exchangedb/pg_lookup_global_fee_by_time.c b/src/exchangedb/pg_lookup_global_fee_by_time.c index 895db22b1..0119c2cd1 100644 --- a/src/exchangedb/pg_lookup_global_fee_by_time.c +++ b/src/exchangedb/pg_lookup_global_fee_by_time.c @@ -60,7 +60,7 @@ struct GlobalFeeLookupContext /** - * Helper function for #postgres_lookup_global_fee_by_time(). + * Helper function for #TEH_PG_lookup_global_fee_by_time(). * Calls the callback with each denomination key. * * @param cls a `struct GlobalFeeLookupContext` @@ -138,9 +138,6 @@ global_fee_by_time_helper (void *cls, } - - - enum GNUNET_DB_QueryStatus TEH_PG_lookup_global_fee_by_time ( void *cls, @@ -186,4 +183,3 @@ TEH_PG_lookup_global_fee_by_time ( &global_fee_by_time_helper, &wlc); } - diff --git a/src/exchangedb/pg_lookup_wire_fee_by_time.c b/src/exchangedb/pg_lookup_wire_fee_by_time.c index fdd6f8827..89be4087a 100644 --- a/src/exchangedb/pg_lookup_wire_fee_by_time.c +++ b/src/exchangedb/pg_lookup_wire_fee_by_time.c @@ -46,7 +46,7 @@ struct WireFeeLookupContext /** - * Helper function for #postgres_lookup_wire_fee_by_time(). + * Helper function for #TEH_PG_lookup_wire_fee_by_time(). * Calls the callback with the wire fee structure. * * @param cls a `struct WireFeeLookupContext` @@ -138,7 +138,7 @@ TEH_PG_lookup_wire_fee_by_time ( .fees = fees, .pg = pg }; - /* used in #postgres_lookup_wire_fee_by_time() */ + /* used in #postgres_lookup_wire_fee_by_time() */ PREPARE (pg, "lookup_wire_fee_by_time", "SELECT" diff --git a/src/exchangedb/pg_lookup_wire_transfer.c b/src/exchangedb/pg_lookup_wire_transfer.c index 394251702..c5f63a070 100644 --- a/src/exchangedb/pg_lookup_wire_transfer.c +++ b/src/exchangedb/pg_lookup_wire_transfer.c @@ -14,8 +14,8 @@ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> */ /** - * @file exchangedb/pg_lookup_wire_tranfer.c - * @brief Implementation of the lookup_wire_tranfer function for Postgres + * @file exchangedb/pg_lookup_wire_transfer.c + * @brief Implementation of the lookup_wire_transfer function for Postgres * @author Christian Grothoff */ #include "platform.h" @@ -128,6 +128,7 @@ handle_wt_result (void *cls, } } + enum GNUNET_DB_QueryStatus TEH_PG_lookup_wire_transfer ( void *cls, @@ -148,7 +149,7 @@ TEH_PG_lookup_wire_transfer ( ctx.pg = pg; ctx.status = GNUNET_OK; /* check if the melt record exists and get it */ - /* Used in #postgres_lookup_wire_transfer */ + /* Used in #postgres_lookup_wire_transfer */ PREPARE (pg, "lookup_transactions", "SELECT" diff --git a/src/exchangedb/pg_lookup_wire_transfer.h b/src/exchangedb/pg_lookup_wire_transfer.h index 1d66a2119..ae5355f40 100644 --- a/src/exchangedb/pg_lookup_wire_transfer.h +++ b/src/exchangedb/pg_lookup_wire_transfer.h @@ -14,8 +14,8 @@ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> */ /** - * @file exchangedb/pg_lookup_wire_tranfer.h - * @brief implementation of the lookup_wire_tranfer function for Postgres + * @file exchangedb/pg_lookup_wire_transfer.h + * @brief implementation of the lookup_wire_transfer function for Postgres * @author Christian Grothoff */ #ifndef PG_LOOKUP_WIRE_TRANSFER_H diff --git a/src/exchangedb/pg_preflight.c b/src/exchangedb/pg_preflight.c index 1961265d1..cc4de6f76 100644 --- a/src/exchangedb/pg_preflight.c +++ b/src/exchangedb/pg_preflight.c @@ -14,8 +14,8 @@ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> */ /** - * @file exchangedb/pg_prefligth.c - * @brief Implementation of the prefligth function for Postgres + * @file exchangedb/pg_preflight.c + * @brief Implementation of the preflight function for Postgres * @author Christian Grothoff */ #include "platform.h" diff --git a/src/exchangedb/pg_preflight.h b/src/exchangedb/pg_preflight.h index d2b20493f..ba994f1e6 100644 --- a/src/exchangedb/pg_preflight.h +++ b/src/exchangedb/pg_preflight.h @@ -14,12 +14,12 @@ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> */ /** - * @file exchangedb/pg_prefligth.h - * @brief implementation of the prefligth function for Postgres + * @file exchangedb/pg_preflight.h + * @brief implementation of the preflight function for Postgres * @author Christian Grothoff */ -#ifndef PG_PREFLIGHT_H -#define PG_PREFLIGHT_H +#ifndef PG_PREFLIGTH_H +#define PG_PREFLIGTH_H #include "taler_util.h" #include "taler_json_lib.h" @@ -40,4 +40,5 @@ enum GNUNET_GenericReturnValue TEH_PG_preflight (void *cls); + #endif diff --git a/src/exchangedb/pg_start_read_committed.c b/src/exchangedb/pg_start_read_committed.c index ec207f0ce..1c8248ab0 100644 --- a/src/exchangedb/pg_start_read_committed.c +++ b/src/exchangedb/pg_start_read_committed.c @@ -14,8 +14,8 @@ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> */ /** - * @file exchangedb/pg_start_read_commited.c - * @brief Implementation of the start_read_commited function for Postgres + * @file exchangedb/pg_start_read_committed.c + * @brief Implementation of the start_read_committed function for Postgres * @author Christian Grothoff */ #include "platform.h" @@ -28,7 +28,7 @@ enum GNUNET_GenericReturnValue TEH_PG_start_read_committed (void *cls, - const char *name) + const char *name) { struct PostgresClosure *pg = cls; struct GNUNET_PQ_ExecuteStatement es[] = { diff --git a/src/exchangedb/pg_start_read_committed.h b/src/exchangedb/pg_start_read_committed.h index 6330a1382..08b60e688 100644 --- a/src/exchangedb/pg_start_read_committed.h +++ b/src/exchangedb/pg_start_read_committed.h @@ -14,8 +14,8 @@ TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/> */ /** - * @file exchangedb/pg_start_read_commited.h - * @brief implementation of the start_read_commited function for Postgres + * @file exchangedb/pg_start_read_committed.h + * @brief implementation of the start_read_committed function for Postgres * @author Christian Grothoff */ #ifndef PG_START_READ_COMMITTED_H |