gnunet_pq_lib.h File Reference

helper functions for Postgres DB interactions More...

#include <libpq-fe.h>
#include "gnunet_util_lib.h"
#include "gnunet_db_lib.h"

Include dependency graph for gnunet_pq_lib.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	GNUNET_PQ_QueryParam
	Description of a DB query parameter. More...
struct	GNUNET_PQ_ResultSpec
	Description of a DB result cell. More...
struct	GNUNET_PQ_PreparedStatement
	Information needed to prepare a list of SQL statements using GNUNET_PQ_prepare_statements(). More...
struct	GNUNET_PQ_ExecuteStatement
	Information needed to run a list of SQL statements using GNUNET_PQ_exec_statements(). More...
struct	GNUNET_PQ_EventHeaderP
	Header of a structure that describes an event channel we may subscribe to or notify on. More...

Macros
#define	GNUNET_PQ_query_param_end
	End of query parameter specification. More...
#define	GNUNET_PQ_query_param_auto_from_type(x)   GNUNET_PQ_query_param_fixed_size ((x), sizeof(*(x)))
	Generate fixed-size query parameter with size determined by variable type. More...
#define	GNUNET_PQ_result_spec_end
	End of result parameter specification. More...
#define	GNUNET_PQ_result_spec_auto_from_type(name, dst)   GNUNET_PQ_result_spec_fixed_size (name, (dst), sizeof(*(dst)))
	We expect a fixed-size result, with size determined by the type of * dst More...
#define	GNUNET_PQ_PREPARED_STATEMENT_END
	Terminator for prepared statement list. More...
#define	GNUNET_PQ_EXECUTE_STATEMENT_END
	Terminator for executable statement list. More...

Typedefs
typedef int(*	GNUNET_PQ_QueryConverter) (void *cls, const void *data, size_t data_len, void *param_values[], int param_lengths[], int param_formats[], unsigned int param_length, void *scratch[], unsigned int scratch_length)
	Function called to convert input argument into SQL parameters. More...
typedef enum GNUNET_GenericReturnValue(*	GNUNET_PQ_ResultConverter) (void *cls, PGresult *result, int row, const char *fname, size_t *dst_size, void *dst)
	Extract data from a Postgres database result at row row. More...
typedef void(*	GNUNET_PQ_ResultCleanup) (void *cls, void *rd)
	Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter. More...
typedef void(*	GNUNET_PQ_PostgresResultHandler) (void *cls, PGresult *result, unsigned int num_results)
	Function to be called with the results of a SELECT statement that has returned num_results results. More...
typedef void(*	GNUNET_PQ_SocketCallback) (void *cls, int fd)
	Function called whenever the socket needed for notifications from postgres changes. More...
typedef void(*	GNUNET_PQ_EventCallback) (void *cls, const void *extra, size_t extra_size)
	Function called on events received from Postgres. More...

Functions
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_null (void)
	Generate query parameter to create a NULL value. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_fixed_size (const void *ptr, size_t ptr_size)
	Generate query parameter for a buffer ptr of ptr_size bytes. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_string (const char *ptr)
	Generate query parameter for a string. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_rsa_public_key (const struct GNUNET_CRYPTO_RsaPublicKey *x)
	Generate query parameter for an RSA public key. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_rsa_signature (const struct GNUNET_CRYPTO_RsaSignature *x)
	Generate query parameter for an RSA signature. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_relative_time (const struct GNUNET_TIME_Relative *x)
	Generate query parameter for a relative time value. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_absolute_time (const struct GNUNET_TIME_Absolute *x)
	Generate query parameter for an absolute time value. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_absolute_time_nbo (const struct GNUNET_TIME_AbsoluteNBO *x)
	Generate query parameter for an absolute time value. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_uint16 (const uint16_t *x)
	Generate query parameter for an uint16_t in host byte order. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_uint32 (const uint32_t *x)
	Generate query parameter for an uint32_t in host byte order. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_uint64 (const uint64_t *x)
	Generate query parameter for an uint16_t in host byte order. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_allow_null (struct GNUNET_PQ_ResultSpec rs, bool *is_null)
	Allow NULL value to be found in the database for the given value. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_variable_size (const char *name, void **dst, size_t *sptr)
	Variable-size result expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_fixed_size (const char *name, void *dst, size_t dst_size)
	Fixed-size result expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_string (const char *name, char **dst)
	0-terminated string expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_rsa_public_key (const char *name, struct GNUNET_CRYPTO_RsaPublicKey **rsa)
	RSA public key expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_rsa_signature (const char *name, struct GNUNET_CRYPTO_RsaSignature **sig)
	RSA signature expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_absolute_time (const char *name, struct GNUNET_TIME_Absolute *at)
	Absolute time expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_relative_time (const char *name, struct GNUNET_TIME_Relative *rt)
	Relative time expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_absolute_time_nbo (const char *name, struct GNUNET_TIME_AbsoluteNBO *at)
	Absolute time expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_uint16 (const char *name, uint16_t *u16)
	uint16_t expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_uint32 (const char *name, uint32_t *u32)
	uint32_t expected. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_uint64 (const char *name, uint64_t *u64)
	uint64_t expected. More...
PGresult *	GNUNET_PQ_exec_prepared (struct GNUNET_PQ_Context *db, const char *name, const struct GNUNET_PQ_QueryParam *params)
	Execute a prepared statement. More...
enum GNUNET_GenericReturnValue	GNUNET_PQ_extract_result (PGresult *result, struct GNUNET_PQ_ResultSpec *rs, int row)
	Extract results from a query result according to the given specification. More...
void	GNUNET_PQ_cleanup_result (struct GNUNET_PQ_ResultSpec *rs)
	Free all memory that was allocated in rs during GNUNET_PQ_extract_result(). More...
enum GNUNET_DB_QueryStatus	GNUNET_PQ_eval_result (struct GNUNET_PQ_Context *db, const char *statement_name, PGresult *result)
	Check the result's error code to see what happened. More...
enum GNUNET_DB_QueryStatus	GNUNET_PQ_eval_prepared_non_select (struct GNUNET_PQ_Context *db, const char *statement_name, const struct GNUNET_PQ_QueryParam *params)
	Execute a named prepared statement that is NOT a SELECT statement in connection using the given params. More...
enum GNUNET_DB_QueryStatus	GNUNET_PQ_eval_prepared_multi_select (struct GNUNET_PQ_Context *db, const char *statement_name, const struct GNUNET_PQ_QueryParam *params, GNUNET_PQ_PostgresResultHandler rh, void *rh_cls)
	Execute a named prepared statement that is a SELECT statement which may return multiple results in connection using the given params. More...
enum GNUNET_DB_QueryStatus	GNUNET_PQ_eval_prepared_singleton_select (struct GNUNET_PQ_Context *db, const char *statement_name, const struct GNUNET_PQ_QueryParam *params, struct GNUNET_PQ_ResultSpec *rs)
	Execute a named prepared statement that is a SELECT statement which must return a single result in connection using the given params. More...
struct GNUNET_PQ_PreparedStatement	GNUNET_PQ_make_prepare (const char *name, const char *sql, unsigned int num_args)
	Create a struct GNUNET_PQ_PreparedStatement. More...
int	GNUNET_PQ_prepare_statements (struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_PreparedStatement *ps)
	Request creation of prepared statements ps from Postgres. More...
struct GNUNET_PQ_ExecuteStatement	GNUNET_PQ_make_execute (const char *sql)
	Create a struct GNUNET_PQ_ExecuteStatement where errors are fatal. More...
struct GNUNET_PQ_ExecuteStatement	GNUNET_PQ_make_try_execute (const char *sql)
	Create a struct GNUNET_PQ_ExecuteStatement where errors should be tolerated. More...
int	GNUNET_PQ_exec_statements (struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_ExecuteStatement *es)
	Request execution of an array of statements es from Postgres. More...
struct GNUNET_PQ_Context *	GNUNET_PQ_connect (const char *config_str, const char *load_path, const struct GNUNET_PQ_ExecuteStatement *es, const struct GNUNET_PQ_PreparedStatement *ps)
	Create a connection to the Postgres database using config_str for the configuration. More...
struct GNUNET_PQ_Context *	GNUNET_PQ_connect_with_cfg (const struct GNUNET_CONFIGURATION_Handle *cfg, const char *section, const char *load_path_suffix, const struct GNUNET_PQ_ExecuteStatement *es, const struct GNUNET_PQ_PreparedStatement *ps)
	Connect to a postgres database using the configuration option "CONFIG" in section. More...
void	GNUNET_PQ_reconnect_if_down (struct GNUNET_PQ_Context *db)
	Reinitialize the database db if the connection is down. More...
void	GNUNET_PQ_reconnect (struct GNUNET_PQ_Context *db)
	Reinitialize the database db. More...
void	GNUNET_PQ_event_set_socket_callback (struct GNUNET_PQ_Context *db, GNUNET_PQ_SocketCallback sc, void *sc_cls)
	Obtain the file descriptor to poll on for notifications. More...
void	GNUNET_PQ_event_do_poll (struct GNUNET_PQ_Context *db)
	Poll for database events now. More...
void	GNUNET_PQ_event_scheduler_start (struct GNUNET_PQ_Context *db)
	Run poll event loop using the GNUnet scheduler. More...
void	GNUNET_PQ_event_scheduler_stop (struct GNUNET_PQ_Context *db)
	Stop running poll event loop using the GNUnet scheduler. More...
struct GNUNET_PQ_EventHandler *	GNUNET_PQ_event_listen (struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_EventHeaderP *es, GNUNET_PQ_EventCallback cb, void *cb_cls)
	Register callback to be invoked on events of type es. More...
void	GNUNET_PQ_event_listen_cancel (struct GNUNET_PQ_EventHandler *eh)
	Stop notifications. More...
void	GNUNET_PQ_event_notify (struct GNUNET_PQ_Context *db, const struct GNUNET_PQ_EventHeaderP *es, const void *extra, size_t extra_size)
	Notify all that listen on es of an event. More...
enum GNUNET_GenericReturnValue	GNUNET_PQ_run_sql (struct GNUNET_PQ_Context *db, const char *load_path)
	Within the db context, run all the SQL files from the load_path from 0000-9999.sql (as long as the files exist contiguously). More...
void	GNUNET_PQ_disconnect (struct GNUNET_PQ_Context *db)
	Disconnect from the database, destroying the prepared statements and releasing other associated resources. More...

Detailed Description

helper functions for Postgres DB interactions

Author

Christian Grothoff

Definition in file gnunet_pq_lib.h.

Macro Definition Documentation

GNUNET_PQ_query_param_end

#define GNUNET_PQ_query_param_end

Value:

{                               \
    NULL, NULL, NULL, 0, 0        \
  }

End of query parameter specification.

Definition at line 97 of file gnunet_pq_lib.h.

Referenced by delete_old_block(), GNUNET_PQ_run_sql(), namecache_postgres_cache_block(), namecache_postgres_expire_blocks(), namecache_postgres_lookup_block(), namestore_postgres_iterate_records(), namestore_postgres_lookup_records(), namestore_postgres_store_records(), namestore_postgres_zone_to_name(), postgres_plugin_del(), postgres_plugin_estimate_size(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_expiration(), postgres_plugin_get_key(), postgres_plugin_get_keys(), postgres_plugin_get_random(), postgres_plugin_get_replication(), postgres_plugin_get_zero_anonymity(), postgres_plugin_put(), postgres_plugin_remove_key(), process_result(), and repl_proc().

GNUNET_PQ_query_param_auto_from_type

#define GNUNET_PQ_query_param_auto_from_type

(

x

)

GNUNET_PQ_query_param_fixed_size ((x), sizeof(*(x)))

Generate fixed-size query parameter with size determined by variable type.

Parameters

x	pointer to the query parameter to pass.

Returns

query parameter to use

Definition at line 142 of file gnunet_pq_lib.h.

Referenced by delete_old_block(), GNUNET_PQ_query_param_absolute_time_nbo(), namecache_postgres_cache_block(), namecache_postgres_lookup_block(), namestore_postgres_iterate_records(), namestore_postgres_lookup_records(), namestore_postgres_store_records(), namestore_postgres_zone_to_name(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_key(), postgres_plugin_put(), and postgres_plugin_remove_key().

GNUNET_PQ_result_spec_end

#define GNUNET_PQ_result_spec_end

Value:

{                                       \
    NULL, NULL, NULL, NULL, 0, NULL, NULL \
  }

End of result parameter specification.

Returns

array last entry for the result specification to use

Definition at line 336 of file gnunet_pq_lib.h.

Referenced by extract_result_cb(), GNUNET_PQ_run_sql(), handle_results(), namecache_postgres_lookup_block(), parse_result_call_iterator(), postgres_plugin_del(), postgres_plugin_estimate_size(), postgres_plugin_get_random(), process_keys(), and process_result().

GNUNET_PQ_result_spec_auto_from_type

#define GNUNET_PQ_result_spec_auto_from_type	(		name,
			dst
	)		GNUNET_PQ_result_spec_fixed_size (name, (dst), sizeof(*(dst)))

We expect a fixed-size result, with size determined by the type of * dst

Parameters

name	name of the field in the table
dst	point to where to store the result, type fits expected result size

Returns

array entry for the result specification to use

Definition at line 390 of file gnunet_pq_lib.h.

Referenced by extract_result_cb(), GNUNET_PQ_result_spec_absolute_time_nbo(), parse_result_call_iterator(), postgres_plugin_del(), postgres_plugin_get_random(), process_keys(), and process_result().

GNUNET_PQ_PREPARED_STATEMENT_END

#define GNUNET_PQ_PREPARED_STATEMENT_END

Value:

{                                      \
    NULL, NULL, 0                        \
  }

Terminator for prepared statement list.

Definition at line 681 of file gnunet_pq_lib.h.

Referenced by database_setup(), and init_connection().

GNUNET_PQ_EXECUTE_STATEMENT_END

#define GNUNET_PQ_EXECUTE_STATEMENT_END

Value:

{                                     \
    NULL, GNUNET_SYSERR                 \
  }

Terminator for executable statement list.

Definition at line 739 of file gnunet_pq_lib.h.

Referenced by database_setup(), init_connection(), and postgres_plugin_drop().

Typedef Documentation

GNUNET_PQ_QueryConverter

typedef int(* GNUNET_PQ_QueryConverter) (void *cls, const void *data, size_t data_len, void *param_values[], int param_lengths[], int param_formats[], unsigned int param_length, void *scratch[], unsigned int scratch_length)

Function called to convert input argument into SQL parameters.

Parameters

	cls	closure
	data	pointer to input argument
	data_len	number of bytes in data (if applicable)
[out]	param_values	SQL data to set
[out]	param_lengths	SQL length data to set
[out]	param_formats	SQL format data to set
	param_length	number of entries available in the param_values, param_lengths and param_formats arrays
[out]	scratch	buffer for dynamic allocations (to be done via GNUNET_malloc()
	scratch_length	number of entries left in scratch

Returns

-1 on error, number of offsets used in scratch otherwise

Definition at line 50 of file gnunet_pq_lib.h.

GNUNET_PQ_ResultConverter

typedef enum GNUNET_GenericReturnValue(* GNUNET_PQ_ResultConverter) (void *cls, PGresult *result, int row, const char *fname, size_t *dst_size, void *dst)

Extract data from a Postgres database result at row row.

Parameters

	cls	closure
	result	where to extract data from
	int	row to extract data from
	fname	name (or prefix) of the fields to extract from
[in,out]	dst_size	where to store size of result, may be NULL
[out]	dst	where to store the result

Returns

GNUNET_YES if all results could be extracted GNUNET_NO if the field was NULL GNUNET_SYSERR if a result was invalid (non-existing field)

Definition at line 252 of file gnunet_pq_lib.h.

GNUNET_PQ_ResultCleanup

typedef void(* GNUNET_PQ_ResultCleanup) (void *cls, void *rd)

Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter.

Parameters

cls	closure
rd	result data to clean up

Definition at line 268 of file gnunet_pq_lib.h.

GNUNET_PQ_PostgresResultHandler

typedef void(* GNUNET_PQ_PostgresResultHandler) (void *cls, PGresult *result, unsigned int num_results)

Function to be called with the results of a SELECT statement that has returned num_results results.

Parameters

cls	closure
result	the postgres result
num_result	the number of results in result

Definition at line 600 of file gnunet_pq_lib.h.

GNUNET_PQ_SocketCallback

typedef void(* GNUNET_PQ_SocketCallback) (void *cls, int fd)

Function called whenever the socket needed for notifications from postgres changes.

Parameters

cls	closure
fd	socket to listen on, -1 for none

Definition at line 863 of file gnunet_pq_lib.h.

GNUNET_PQ_EventCallback

typedef void(* GNUNET_PQ_EventCallback) (void *cls, const void *extra, size_t extra_size)

Function called on events received from Postgres.

Parameters

cls	closure
extra	additional event data provided
extra_size	number of bytes in extra

Definition at line 926 of file gnunet_pq_lib.h.

Function Documentation

GNUNET_PQ_query_param_null()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_null

(

void

)

Generate query parameter to create a NULL value.

Returns

query parameter to use to insert NULL into DB

Definition at line 70 of file pq_query_helper.c.

References qconv_null(), and res.

{
  struct GNUNET_PQ_QueryParam res = {
    &qconv_null, NULL, NULL, 0, 1
  };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_query_param_fixed_size()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_fixed_size	(	const void *	ptr,
		size_t	ptr_size
	)

Generate query parameter for a buffer ptr of ptr_size bytes.

Parameters

ptr	pointer to the query parameter to pass ptr_size number of bytes in ptr

Returns

query parameter to use

Definition at line 118 of file pq_query_helper.c.

References qconv_fixed(), and res.

Referenced by GNUNET_PQ_query_param_string(), namecache_postgres_cache_block(), namestore_postgres_store_records(), postgres_plugin_put(), and postgres_plugin_remove_key().

{
  struct GNUNET_PQ_QueryParam res = {
    &qconv_fixed, NULL, ptr, ptr_size, 1
  };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_query_param_string()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_string

(

const char *

ptr

)

Generate query parameter for a string.

Parameters

ptr	pointer to the string query parameter to pass

Returns

query parameter to use

Definition at line 130 of file pq_query_helper.c.

References GNUNET_PQ_query_param_fixed_size().

Referenced by GNUNET_PQ_run_sql(), namestore_postgres_lookup_records(), and namestore_postgres_store_records().

{
  return GNUNET_PQ_query_param_fixed_size (ptr,
                                           strlen (ptr));
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_query_param_rsa_public_key()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_rsa_public_key

(

const struct GNUNET_CRYPTO_RsaPublicKey *

x

)

Generate query parameter for an RSA public key.

The database must contain a BLOB type in the respective position.

Parameters

x	the query parameter to pass.

Returns

query parameter to use

Definition at line 339 of file pq_query_helper.c.

References qconv_rsa_public_key(), and res.

{
  struct GNUNET_PQ_QueryParam res =
  { &qconv_rsa_public_key, NULL, (x), 0, 1 };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_query_param_rsa_signature()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_rsa_signature

(

const struct GNUNET_CRYPTO_RsaSignature *

x

)

Generate query parameter for an RSA signature.

The database must contain a BLOB type in the respective position.

Parameters

x	the query parameter to pass

Returns

query parameter to use

Definition at line 392 of file pq_query_helper.c.

References qconv_rsa_signature(), and res.

{
  struct GNUNET_PQ_QueryParam res =
  { &qconv_rsa_signature, NULL, (x), 0, 1 };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_query_param_relative_time()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_relative_time

(

const struct GNUNET_TIME_Relative *

x

)

Generate query parameter for a relative time value.

The database must store a 64-bit integer.

Parameters

x	pointer to the query parameter to pass

Returns

query parameter to use

Definition at line 447 of file pq_query_helper.c.

References qconv_rel_time(), and res.

{
  struct GNUNET_PQ_QueryParam res =
  { &qconv_rel_time, NULL, x, sizeof(*x), 1 };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_query_param_absolute_time()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_absolute_time

(

const struct GNUNET_TIME_Absolute *

x

)

Generate query parameter for an absolute time value.

The database must store a 64-bit integer.

Parameters

x	pointer to the query parameter to pass

Returns

query parameter to use

Definition at line 502 of file pq_query_helper.c.

References qconv_abs_time(), and res.

Referenced by delete_old_block(), namecache_postgres_cache_block(), namecache_postgres_expire_blocks(), postgres_plugin_del(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_expiration(), postgres_plugin_get_random(), and postgres_plugin_put().

{
  struct GNUNET_PQ_QueryParam res = {
    &qconv_abs_time, NULL, x, sizeof(*x), 1
  };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_query_param_absolute_time_nbo()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_absolute_time_nbo

(

const struct GNUNET_TIME_AbsoluteNBO *

x

)

Generate query parameter for an absolute time value.

The database must store a 64-bit integer.

Parameters

x	pointer to the query parameter to pass

Returns

query parameter to use

Definition at line 513 of file pq_query_helper.c.

References GNUNET_PQ_query_param_auto_from_type.

{
  return GNUNET_PQ_query_param_auto_from_type (&x->abs_value_us__);
}

GNUNET_PQ_query_param_uint16()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_uint16

(

const uint16_t *

x

)

Generate query parameter for an uint16_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Returns

query parameter to use

Definition at line 181 of file pq_query_helper.c.

References qconv_uint16(), and res.

Referenced by postgres_plugin_get_key().

{
  struct GNUNET_PQ_QueryParam res =
  { &qconv_uint16, NULL, x, sizeof(*x), 1 };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_query_param_uint32()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_uint32

(

const uint32_t *

x

)

Generate query parameter for an uint32_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Returns

query parameter to use

Definition at line 234 of file pq_query_helper.c.

References qconv_uint32(), and res.

Referenced by namestore_postgres_store_records(), postgres_plugin_del(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_key(), postgres_plugin_get_random(), postgres_plugin_get_zero_anonymity(), postgres_plugin_put(), process_result(), and repl_proc().

{
  struct GNUNET_PQ_QueryParam res =
  { &qconv_uint32, NULL, x, sizeof(*x), 1 };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_query_param_uint64()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_uint64

(

const uint64_t *

x

)

Generate query parameter for an uint16_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Returns

query parameter to use

Definition at line 287 of file pq_query_helper.c.

References qconv_uint64(), and res.

Referenced by namestore_postgres_iterate_records(), namestore_postgres_store_records(), postgres_plugin_get_key(), postgres_plugin_get_zero_anonymity(), and postgres_plugin_put().

{
  struct GNUNET_PQ_QueryParam res =
  { &qconv_uint64, NULL, x, sizeof(*x), 1 };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_result_spec_allow_null()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_allow_null	(	struct GNUNET_PQ_ResultSpec	rs,
		bool *	is_null
	)

Allow NULL value to be found in the database for the given value.

Parameters

	rs	result spec entry to modify
[out]	is_null	location set to 'true' if the value was indeed NULL, set to 'false' if the value was non-NULL

Returns

array entry for the result specification to use

Definition at line 31 of file pq_result_helper.c.

References GNUNET_PQ_ResultSpec::is_null, and GNUNET_PQ_ResultSpec::is_nullable.

{
  struct GNUNET_PQ_ResultSpec rsr;

  rsr = rs;
  rsr.is_nullable = true;
  rsr.is_null = is_null;
  return rsr;
}

GNUNET_PQ_result_spec_variable_size()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_variable_size	(	const char *	name,
		void **	dst,
		size_t *	sptr
	)

Variable-size result expected.

Parameters

	name	name of the field in the table
[out]	dst	where to store the result, allocated
[out]	sptr	where to store the size of dst

Returns

array entry for the result specification to use

Definition at line 126 of file pq_result_helper.c.

References clean_varsize_blob(), GNUNET_PQ_ResultSpec::dst, extract_varsize_blob(), name, and res.

Referenced by extract_result_cb(), handle_results(), namecache_postgres_lookup_block(), parse_result_call_iterator(), postgres_plugin_get_random(), and process_result().

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_varsize_blob,
    &clean_varsize_blob, NULL,
    (void *) (dst), 0, name, sptr };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_result_spec_fixed_size()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_fixed_size	(	const char *	name,
		void *	dst,
		size_t	dst_size
	)

Fixed-size result expected.

Parameters

	name	name of the field in the table
[out]	dst	where to store the result
	dst_size	number of bytes in dst

Returns

array entry for the result specification to use

Definition at line 206 of file pq_result_helper.c.

References GNUNET_PQ_ResultSpec::dst, GNUNET_PQ_ResultSpec::dst_size, extract_fixed_blob(), and res.

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_fixed_blob,
    NULL, NULL,
    (dst), dst_size, name, NULL };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_result_spec_string()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_string	(	const char *	name,
		char **	dst
	)

0-terminated string expected.

Parameters

	name	name of the field in the table
[out]	dst	where to store the result, allocated

Returns

array entry for the result specification to use

Definition at line 489 of file pq_result_helper.c.

References clean_string(), GNUNET_PQ_ResultSpec::dst, extract_string(), and res.

Referenced by GNUNET_PQ_run_sql(), and parse_result_call_iterator().

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_string,
    &clean_string,
    NULL,
    (void *) dst, 0, (name), NULL };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_result_spec_rsa_public_key()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_rsa_public_key	(	const char *	name,
		struct GNUNET_CRYPTO_RsaPublicKey **	rsa
	)

RSA public key expected.

Parameters

	name	name of the field in the table
[out]	rsa	where to store the result

Returns

array entry for the result specification to use

Definition at line 301 of file pq_result_helper.c.

References clean_rsa_public_key(), extract_rsa_public_key(), and res.

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_rsa_public_key,
    &clean_rsa_public_key,
    NULL,
    (void *) rsa, 0, name, NULL };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_result_spec_rsa_signature()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_rsa_signature	(	const char *	name,
		struct GNUNET_CRYPTO_RsaSignature **	sig
	)

RSA signature expected.

Parameters

	name	name of the field in the table
[out]	sig	where to store the result;

Returns

array entry for the result specification to use

Definition at line 395 of file pq_result_helper.c.

References clean_rsa_signature(), extract_rsa_signature(), and res.

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_rsa_signature,
    &clean_rsa_signature,
    NULL,
    (void *) sig, 0, (name), NULL };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_result_spec_absolute_time()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_absolute_time	(	const char *	name,
		struct GNUNET_TIME_Absolute *	at
	)

Absolute time expected.

Parameters

	name	name of the field in the table
[out]	at	where to store the result

Returns

array entry for the result specification to use

Definition at line 645 of file pq_result_helper.c.

References extract_abs_time(), name, and res.

Referenced by extract_result_cb(), handle_results(), postgres_plugin_get_random(), and process_result().

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_abs_time,
    NULL,
    NULL,
    (void *) at, sizeof(*at), (name), NULL };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_result_spec_relative_time()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_relative_time	(	const char *	name,
		struct GNUNET_TIME_Relative *	rt
	)

Relative time expected.

Parameters

	name	name of the field in the table
[out]	rt	where to store the result

Returns

array entry for the result specification to use

Definition at line 565 of file pq_result_helper.c.

References extract_rel_time(), name, and res.

{
  struct GNUNET_PQ_ResultSpec res = {
    &extract_rel_time,
    NULL,
    NULL,
    (void *) rt,
    sizeof(*rt),
    name,
    NULL
  };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_result_spec_absolute_time_nbo()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_absolute_time_nbo	(	const char *	name,
		struct GNUNET_TIME_AbsoluteNBO *	at
	)

Absolute time expected.

Parameters

	name	name of the field in the table
[out]	at	where to store the result

Returns

array entry for the result specification to use

Definition at line 659 of file pq_result_helper.c.

References GNUNET_PQ_result_spec_auto_from_type, and res.

{
  struct GNUNET_PQ_ResultSpec res =
    GNUNET_PQ_result_spec_auto_from_type (name, &at->abs_value_us__);

  return res;
}

GNUNET_PQ_result_spec_uint16()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_uint16	(	const char *	name,
		uint16_t *	u16
	)

uint16_t expected.

Parameters

	name	name of the field in the table
[out]	u16	where to store the result

Returns

array entry for the result specification to use

Definition at line 729 of file pq_result_helper.c.

References extract_uint16(), name, and res.

{
  struct GNUNET_PQ_ResultSpec res =
  { &extract_uint16,
    NULL,
    NULL,
    (void *) u16, sizeof(*u16), (name), NULL };

  return res;
}

Here is the call graph for this function:

GNUNET_PQ_result_spec_uint32()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_uint32	(	const char *	name,
		uint32_t *	u32
	)

uint32_t expected.

Parameters

	name	name of the field in the table
[out]	u32	where to store the result

Returns

array entry for the result specification to use

Definition at line 802 of file pq_result_helper.c.

References extract_uint32(), name, and res.

Referenced by extract_result_cb(), handle_results(), parse_result_call_iterator(), postgres_plugin_del(), postgres_plugin_get_random(), and process_result().

{
  struct GNUNET_PQ_ResultSpec res = {
    &extract_uint32,
    NULL,
    NULL,
    (void *) u32,
    sizeof(*u32),
    (name),
    NULL
  };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_result_spec_uint64()

struct GNUNET_PQ_ResultSpec GNUNET_PQ_result_spec_uint64	(	const char *	name,
		uint64_t *	u64
	)

uint64_t expected.

Parameters

	name	name of the field in the table
[out]	u64	where to store the result

Returns

array entry for the result specification to use

Definition at line 883 of file pq_result_helper.c.

References extract_uint64(), name, and res.

Referenced by parse_result_call_iterator(), and postgres_plugin_estimate_size().

{
  struct GNUNET_PQ_ResultSpec res = {
    &extract_uint64,
    NULL,
    NULL,
    (void *) u64,
    sizeof(*u64),
    (name),
    NULL
  };

  return res;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_exec_prepared()

PGresult* GNUNET_PQ_exec_prepared	(	struct GNUNET_PQ_Context *	db,
		const char *	name,
		const struct GNUNET_PQ_QueryParam *	params
	)

Execute a prepared statement.

Parameters

db	database context
name	name of the prepared statement
params	parameters to the statement

Returns

postgres result

Deprecated:

(should become an internal API)

Definition at line 32 of file pq.c.

References GNUNET_PQ_Context::conn, GNUNET_PQ_QueryParam::conv, GNUNET_PQ_QueryParam::conv_cls, GNUNET_PQ_QueryParam::data, GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_log, GNUNET_log_from, GNUNET_PQ_reconnect(), len, GNUNET_PQ_QueryParam::num_params, res, ret, GNUNET_PQ_QueryParam::size, and status.

Referenced by GNUNET_PQ_eval_prepared_multi_select(), GNUNET_PQ_eval_prepared_non_select(), and GNUNET_PQ_eval_prepared_singleton_select().

{
  unsigned int len;

  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Running prepared statement `%s' on %p\n",
              name,
              db);
  /* count the number of parameters */
  len = 0;
  for (unsigned int i = 0; 0 != params[i].num_params; i++)
    len += params[i].num_params;

  /* new scope to allow stack allocation without alloca */
  {
    /* Scratch buffer for temporary storage */
    void *scratch[len];
    /* Parameter array we are building for the query */
    void *param_values[len];
    int param_lengths[len];
    int param_formats[len];
    unsigned int off;
    /* How many entries in the scratch buffer are in use? */
    unsigned int soff;
    PGresult *res;
    int ret;
    ConnStatusType status;

    off = 0;
    soff = 0;
    for (unsigned int i = 0; 0 != params[i].num_params; i++)
    {
      const struct GNUNET_PQ_QueryParam *x = &params[i];

      ret = x->conv (x->conv_cls,
                     x->data,
                     x->size,
                     &param_values[off],
                     &param_lengths[off],
                     &param_formats[off],
                     x->num_params,
                     &scratch[soff],
                     len - soff);
      if (ret < 0)
      {
        for (off = 0; off < soff; off++)
          GNUNET_free (scratch[off]);
        return NULL;
      }
      soff += ret;
      off += x->num_params;
    }
    GNUNET_assert (off == len);
    GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
                     "pq",
                     "Executing prepared SQL statement `%s'\n",
                     name);
    res = PQexecPrepared (db->conn,
                          name,
                          len,
                          (const char **) param_values,
                          param_lengths,
                          param_formats,
                          1);
    if ( (PGRES_COMMAND_OK != PQresultStatus (res)) &&
         (CONNECTION_OK != (status = PQstatus (db->conn))) )
    {
      GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
                       "pq",
                       "Database disconnected on SQL statement `%s' (reconnecting)\n",
                       name);
      GNUNET_PQ_reconnect (db);
      res = NULL;
    }

    for (off = 0; off < soff; off++)
      GNUNET_free (scratch[off]);
    return res;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_extract_result()

enum GNUNET_GenericReturnValue GNUNET_PQ_extract_result	(	PGresult *	result,
		struct GNUNET_PQ_ResultSpec *	rs,
		int	row
	)

Extract results from a query result according to the given specification.

Parameters

	result	result to process
[in,out]	rs	result specification to extract for
	row	row from the result to extract

Returns

GNUNET_YES if all results could be extracted GNUNET_SYSERR if a result was invalid (non-existing field)

Definition at line 127 of file pq.c.

References GNUNET_PQ_ResultSpec::cleaner, cleanup(), GNUNET_PQ_ResultSpec::cls, GNUNET_PQ_ResultSpec::conv, GNUNET_PQ_ResultSpec::dst, GNUNET_PQ_ResultSpec::dst_size, GNUNET_PQ_ResultSpec::fname, GNUNET_break, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_SYSERR, GNUNET_PQ_ResultSpec::is_null, GNUNET_PQ_ResultSpec::is_nullable, GNUNET_PQ_ResultSpec::result_size, and ret.

Referenced by extract_result_cb(), GNUNET_PQ_eval_prepared_singleton_select(), handle_results(), parse_result_call_iterator(), process_keys(), and process_result().

{
  unsigned int i;

  if (NULL == result)
    return GNUNET_SYSERR;
  for (i = 0; NULL != rs[i].conv; i++)
  {
    struct GNUNET_PQ_ResultSpec *spec;
    enum GNUNET_GenericReturnValue ret;

    spec = &rs[i];
    ret = spec->conv (spec->cls,
                      result,
                      row,
                      spec->fname,
                      &spec->dst_size,
                      spec->dst);
    switch (ret)
    {
    case GNUNET_OK:
      /* canonical case, continue below */
      if (NULL != spec->is_null)
        *spec->is_null = false;
      break;
    case GNUNET_NO:
      if (spec->is_nullable)
      {
        if (NULL != spec->is_null)
          *spec->is_null = true;
        continue;
      }
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "NULL field encountered for `%s' where non-NULL was required\n",
                  spec->fname);
      goto cleanup;
    case GNUNET_SYSERR:
      GNUNET_break (0);
      goto cleanup;
    }
    if (NULL != spec->result_size)
      *spec->result_size = spec->dst_size;
  }
  return GNUNET_OK;
cleanup:
  for (unsigned int j = 0; j < i; j++)
    if (NULL != rs[j].cleaner)
      rs[j].cleaner (rs[j].cls,
                     rs[j].dst);
  return GNUNET_SYSERR;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_cleanup_result()

void GNUNET_PQ_cleanup_result

(

struct GNUNET_PQ_ResultSpec *

rs

)

Free all memory that was allocated in rs during GNUNET_PQ_extract_result().

Parameters

rs	reult specification to clean up

Definition at line 117 of file pq.c.

References GNUNET_PQ_ResultSpec::cleaner, and GNUNET_PQ_ResultSpec::conv.

Referenced by extract_result_cb(), GNUNET_PQ_run_sql(), handle_results(), namecache_postgres_lookup_block(), parse_result_call_iterator(), postgres_plugin_del(), postgres_plugin_get_random(), process_keys(), and process_result().

{
  for (unsigned int i = 0; NULL != rs[i].conv; i++)
    if (NULL != rs[i].cleaner)
      rs[i].cleaner (rs[i].cls,
                     rs[i].dst);
}

Here is the caller graph for this function:

GNUNET_PQ_eval_result()

enum GNUNET_DB_QueryStatus GNUNET_PQ_eval_result	(	struct GNUNET_PQ_Context *	db,
		const char *	statement_name,
		PGresult *	result
	)

Check the result's error code to see what happened.

Also logs errors.

Parameters

db	database to execute the statement in
statement_name	name of the statement that created result
result	result to check

Returns

status code from the result, mapping PQ status codes to enum GNUNET_DB_QueryStatus. Never returns positive values as this function does not look at the result set.

Deprecated:

(low level, let's see if we can do with just the high-level functions)

Also logs errors.

Parameters

db	database to execute the statement with
statement_name	name of the statement that created result
result	result to check

Returns

status code from the result, mapping PQ status codes to enum GNUNET_DB_QueryStatus. Never returns positive values as this function does not look at the result set.

Deprecated:

(low level, let's see if we can do with just the high-level functions)

Definition at line 59 of file pq_eval.c.

References GNUNET_PQ_Context::conn, GNUNET_break, GNUNET_DB_STATUS_HARD_ERROR, GNUNET_DB_STATUS_SOFT_ERROR, GNUNET_DB_STATUS_SUCCESS_NO_RESULTS, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_log_from, GNUNET_PQ_reconnect(), PQ_DIAG_SQLSTATE_DEADLOCK, PQ_DIAG_SQLSTATE_SERIALIZATION_FAILURE, PQ_DIAG_SQLSTATE_UNIQUE_VIOLATION, and status.

Referenced by GNUNET_PQ_eval_prepared_multi_select(), GNUNET_PQ_eval_prepared_non_select(), and GNUNET_PQ_eval_prepared_singleton_select().

{
  ExecStatusType est;

  if (NULL == result)
    return GNUNET_DB_STATUS_SOFT_ERROR;
  est = PQresultStatus (result);
  if ((PGRES_COMMAND_OK != est) &&
      (PGRES_TUPLES_OK != est))
  {
    const char *sqlstate;
    ConnStatusType status;

    if (CONNECTION_OK != (status = PQstatus (db->conn)))
    {
      GNUNET_log_from (GNUNET_ERROR_TYPE_INFO,
                       "pq",
                       "Database connection failed during query `%s': %d (reconnecting)\n",
                       statement_name,
                       status);
      GNUNET_PQ_reconnect (db);
      return GNUNET_DB_STATUS_SOFT_ERROR;
    }

    sqlstate = PQresultErrorField (result,
                                   PG_DIAG_SQLSTATE);
    if (NULL == sqlstate)
    {
      /* very unexpected... */
      GNUNET_break (0);
      return GNUNET_DB_STATUS_HARD_ERROR;
    }
    if ((0 == strcmp (sqlstate,
                      PQ_DIAG_SQLSTATE_DEADLOCK)) ||
        (0 == strcmp (sqlstate,
                      PQ_DIAG_SQLSTATE_SERIALIZATION_FAILURE)))
    {
      /* These two can be retried and have a fair chance of working
         the next time */
      GNUNET_log_from (GNUNET_ERROR_TYPE_INFO,
                       "pq",
                       "Query `%s' failed with result: %s/%s/%s/%s/%s\n",
                       statement_name,
                       PQresultErrorField (result,
                                           PG_DIAG_MESSAGE_PRIMARY),
                       PQresultErrorField (result,
                                           PG_DIAG_MESSAGE_DETAIL),
                       PQresultErrorMessage (result),
                       PQresStatus (PQresultStatus (result)),
                       PQerrorMessage (db->conn));
      return GNUNET_DB_STATUS_SOFT_ERROR;
    }
    if (0 == strcmp (sqlstate,
                     PQ_DIAG_SQLSTATE_UNIQUE_VIOLATION))
    {
      /* Likely no need to retry, INSERT of "same" data. */
      GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
                       "pq",
                       "Query `%s' failed with unique violation: %s/%s/%s/%s/%s\n",
                       statement_name,
                       PQresultErrorField (result,
                                           PG_DIAG_MESSAGE_PRIMARY),
                       PQresultErrorField (result,
                                           PG_DIAG_MESSAGE_DETAIL),
                       PQresultErrorMessage (result),
                       PQresStatus (PQresultStatus (result)),
                       PQerrorMessage (db->conn));
      return GNUNET_DB_STATUS_SUCCESS_NO_RESULTS;
    }
    GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
                     "pq",
                     "Query `%s' failed with result: %s/%s/%s/%s/%s\n",
                     statement_name,
                     PQresultErrorField (result,
                                         PG_DIAG_MESSAGE_PRIMARY),
                     PQresultErrorField (result,
                                         PG_DIAG_MESSAGE_DETAIL),
                     PQresultErrorMessage (result),
                     PQresStatus (PQresultStatus (result)),
                     PQerrorMessage (db->conn));
    return GNUNET_DB_STATUS_HARD_ERROR;
  }
  return GNUNET_DB_STATUS_SUCCESS_NO_RESULTS;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_eval_prepared_non_select()

enum GNUNET_DB_QueryStatus GNUNET_PQ_eval_prepared_non_select	(	struct GNUNET_PQ_Context *	db,
		const char *	statement_name,
		const struct GNUNET_PQ_QueryParam *	params
	)

Execute a named prepared statement that is NOT a SELECT statement in connection using the given params.

Returns the resulting session state.

Parameters

db	database to execute the statement with
statement_name	name of the statement
params	parameters to give to the statement (GNUNET_PQ_query_param_end-terminated)

Returns

status code from the result, mapping PQ status codes to enum GNUNET_DB_QueryStatus. If the statement was a DELETE or UPDATE statement, the number of affected rows is returned; if the statement was an INSERT statement, and no row was added due to a UNIQUE violation, we return zero; if INSERT was successful, we return one.

Returns the resulting session state.

Parameters

db	database to execute the statement with
statement_name	name of the statement
params	parameters to give to the statement (GNUNET_PQ_query_param_end-terminated)

Returns

status code from the result, mapping PQ status codes to enum GNUNET_DB_QueryStatus. If the statement was a DELETE or UPDATE statement, the number of affected rows is returned.; if the statement was an INSERT statement, and no row was added due to a UNIQUE violation, we return zero; if INSERT was successful, we return one.

Definition at line 164 of file pq_eval.c.

References GNUNET_DB_STATUS_SOFT_ERROR, GNUNET_DB_STATUS_SUCCESS_NO_RESULTS, GNUNET_PQ_eval_result(), GNUNET_PQ_exec_prepared(), and result.

Referenced by delete_old_block(), namecache_postgres_cache_block(), namecache_postgres_expire_blocks(), namestore_postgres_store_records(), postgres_plugin_del(), postgres_plugin_put(), postgres_plugin_remove_key(), process_result(), and repl_proc().

{
  PGresult *result;
  enum GNUNET_DB_QueryStatus qs;

  result = GNUNET_PQ_exec_prepared (db,
                                    statement_name,
                                    params);
  if (NULL == result)
    return GNUNET_DB_STATUS_SOFT_ERROR;
  qs = GNUNET_PQ_eval_result (db,
                              statement_name,
                              result);
  if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs)
  {
    const char *tuples;

    /* What an awful API, this function really does return a string */
    tuples = PQcmdTuples (result);
    if (NULL != tuples)
      qs = strtol (tuples, NULL, 10);
  }
  PQclear (result);
  return qs;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_eval_prepared_multi_select()

enum GNUNET_DB_QueryStatus GNUNET_PQ_eval_prepared_multi_select	(	struct GNUNET_PQ_Context *	db,
		const char *	statement_name,
		const struct GNUNET_PQ_QueryParam *	params,
		GNUNET_PQ_PostgresResultHandler	rh,
		void *	rh_cls
	)

Execute a named prepared statement that is a SELECT statement which may return multiple results in connection using the given params.

Call rh with the results. Returns the query status including the number of results given to rh (possibly zero). rh will not have been called if the return value is negative.

Parameters

db	database to execute the statement with
statement_name	name of the statement
params	parameters to give to the statement (GNUNET_PQ_query_param_end-terminated)
rh	function to call with the result set, NULL to ignore
rh_cls	closure to pass to rh

Returns

status code from the result, mapping PQ status codes to enum GNUNET_DB_QueryStatus.

Definition at line 209 of file pq_eval.c.

References GNUNET_DB_STATUS_SOFT_ERROR, GNUNET_PQ_eval_result(), GNUNET_PQ_exec_prepared(), result, and ret.

Referenced by namestore_postgres_iterate_records(), namestore_postgres_lookup_records(), namestore_postgres_zone_to_name(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_expiration(), postgres_plugin_get_key(), postgres_plugin_get_keys(), postgres_plugin_get_replication(), and postgres_plugin_get_zero_anonymity().

{
  PGresult *result;
  enum GNUNET_DB_QueryStatus qs;
  unsigned int ret;

  result = GNUNET_PQ_exec_prepared (db,
                                    statement_name,
                                    params);
  if (NULL == result)
    return GNUNET_DB_STATUS_SOFT_ERROR;
  qs = GNUNET_PQ_eval_result (db,
                              statement_name,
                              result);
  if (qs < 0)
  {
    PQclear (result);
    return qs;
  }
  ret = PQntuples (result);
  if (NULL != rh)
    rh (rh_cls,
        result,
        ret);
  PQclear (result);
  return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_eval_prepared_singleton_select()

enum GNUNET_DB_QueryStatus GNUNET_PQ_eval_prepared_singleton_select	(	struct GNUNET_PQ_Context *	db,
		const char *	statement_name,
		const struct GNUNET_PQ_QueryParam *	params,
		struct GNUNET_PQ_ResultSpec *	rs
	)

Execute a named prepared statement that is a SELECT statement which must return a single result in connection using the given params.

Stores the result (if any) in rs, which the caller must then clean up using GNUNET_PQ_cleanup_result() if the return value was GNUNET_DB_STATUS_SUCCESS_ONE_RESULT. Returns the resulting session status.

Parameters

	db	database to execute the statement with
	statement_name	name of the statement
	params	parameters to give to the statement (GNUNET_PQ_query_param_end-terminated)
[in,out]	rs	result specification to use for storing the result of the query

Returns

status code from the result, mapping PQ status codes to enum GNUNET_DB_QueryStatus.

Definition at line 258 of file pq_eval.c.

References GNUNET_break, GNUNET_DB_STATUS_HARD_ERROR, GNUNET_DB_STATUS_SOFT_ERROR, GNUNET_DB_STATUS_SUCCESS_NO_RESULTS, GNUNET_DB_STATUS_SUCCESS_ONE_RESULT, GNUNET_OK, GNUNET_PQ_eval_result(), GNUNET_PQ_exec_prepared(), GNUNET_PQ_extract_result(), and result.

Referenced by GNUNET_PQ_run_sql(), namecache_postgres_lookup_block(), postgres_plugin_del(), postgres_plugin_estimate_size(), and postgres_plugin_get_random().

{
  PGresult *result;
  enum GNUNET_DB_QueryStatus qs;
  int ntuples;

  result = GNUNET_PQ_exec_prepared (db,
                                    statement_name,
                                    params);
  if (NULL == result)
    return GNUNET_DB_STATUS_SOFT_ERROR;
  qs = GNUNET_PQ_eval_result (db,
                              statement_name,
                              result);
  if (qs < 0)
  {
    PQclear (result);
    return qs;
  }
  ntuples = PQntuples (result);
  if (0 == ntuples)
  {
    PQclear (result);
    return GNUNET_DB_STATUS_SUCCESS_NO_RESULTS;
  }
  if (1 != ntuples)
  {
    /* more than one result, but there must be at most one */
    GNUNET_break (0);
    PQclear (result);
    return GNUNET_DB_STATUS_HARD_ERROR;
  }
  if (GNUNET_OK !=
      GNUNET_PQ_extract_result (result,
                                rs,
                                0))
  {
    PQclear (result);
    return GNUNET_DB_STATUS_HARD_ERROR;
  }
  PQclear (result);
  return GNUNET_DB_STATUS_SUCCESS_ONE_RESULT;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_make_prepare()

struct GNUNET_PQ_PreparedStatement GNUNET_PQ_make_prepare	(	const char *	name,
		const char *	sql,
		unsigned int	num_args
	)

Create a struct GNUNET_PQ_PreparedStatement.

Parameters

name	name of the statement
sql	actual SQL statement
num_args	number of arguments in the statement

Returns

initialized struct

Definition at line 38 of file pq_prepare.c.

References name, GNUNET_PQ_PreparedStatement::name, and GNUNET_PQ_PreparedStatement::sql.

Referenced by database_setup(), and init_connection().

{
  struct GNUNET_PQ_PreparedStatement ps = {
    .name = name,
    .sql = sql,
    .num_arguments = num_args
  };

  return ps;
}

Here is the caller graph for this function:

GNUNET_PQ_prepare_statements()

int GNUNET_PQ_prepare_statements	(	struct GNUNET_PQ_Context *	db,
		const struct GNUNET_PQ_PreparedStatement *	ps
	)

Request creation of prepared statements ps from Postgres.

Parameters

db	database to prepare the statements for
ps	GNUNET_PQ_PREPARED_STATEMENT_END-terminated array of prepared statements.

Returns

GNUNET_OK on success, GNUNET_SYSERR on error

Definition at line 62 of file pq_prepare.c.

References _, GNUNET_PQ_Context::conn, GNUNET_ERROR_TYPE_BULK, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log_from, GNUNET_new_array, GNUNET_OK, GNUNET_SYSERR, GNUNET_PQ_PreparedStatement::name, GNUNET_PQ_PreparedStatement::num_arguments, GNUNET_PQ_Context::ps, ret, and GNUNET_PQ_PreparedStatement::sql.

Referenced by GNUNET_PQ_reconnect().

{
  if (db->ps != ps)
  {
    /* add 'ps' to list db->ps of prepared statements to run on reconnect! */
    unsigned int olen = 0; /* length of existing 'db->ps' array */
    unsigned int nlen = 0; /* length of 'ps' array */
    struct GNUNET_PQ_PreparedStatement *rps; /* combined array */

    if (NULL != db->ps)
      while (NULL != db->ps[olen].name)
        olen++;
    while (NULL != ps[nlen].name)
      nlen++;
    rps = GNUNET_new_array (olen + nlen + 1,
                            struct GNUNET_PQ_PreparedStatement);
    if (NULL != db->ps)
      memcpy (rps,
              db->ps,
              olen * sizeof (struct GNUNET_PQ_PreparedStatement));
    memcpy (&rps[olen],
            ps,
            nlen * sizeof (struct GNUNET_PQ_PreparedStatement));
    GNUNET_free (db->ps);
    db->ps = rps;
  }

  /* actually prepare statements */
  for (unsigned int i = 0; NULL != ps[i].name; i++)
  {
    PGresult *ret;

    GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG,
                     "pq",
                     "Preparing SQL statement `%s' as `%s'\n",
                     ps[i].sql,
                     ps[i].name);
    ret = PQprepare (db->conn,
                     ps[i].name,
                     ps[i].sql,
                     ps[i].num_arguments,
                     NULL);
    if (PGRES_COMMAND_OK != PQresultStatus (ret))
    {
      GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
                       "pq",
                       _ ("PQprepare (`%s' as `%s') failed with error: %s\n"),
                       ps[i].sql,
                       ps[i].name,
                       PQerrorMessage (db->conn));
      PQclear (ret);
      return GNUNET_SYSERR;
    }
    PQclear (ret);
  }
  return GNUNET_OK;
}

Here is the caller graph for this function:

GNUNET_PQ_make_execute()

struct GNUNET_PQ_ExecuteStatement GNUNET_PQ_make_execute

(

const char *

sql

)

Create a struct GNUNET_PQ_ExecuteStatement where errors are fatal.

Parameters

sql	actual SQL statement

Returns

initialized struct

Definition at line 36 of file pq_exec.c.

References GNUNET_NO, and GNUNET_PQ_ExecuteStatement::sql.

Referenced by database_setup(), init_connection(), and postgres_plugin_drop().

{
  struct GNUNET_PQ_ExecuteStatement es = {
    .sql = sql,
    .ignore_errors = GNUNET_NO
  };

  return es;
}

Here is the caller graph for this function:

GNUNET_PQ_make_try_execute()

struct GNUNET_PQ_ExecuteStatement GNUNET_PQ_make_try_execute

(

const char *

sql

)

Create a struct GNUNET_PQ_ExecuteStatement where errors should be tolerated.

Parameters

sql	actual SQL statement

Returns

initialized struct

Definition at line 55 of file pq_exec.c.

References GNUNET_YES, and GNUNET_PQ_ExecuteStatement::sql.

Referenced by database_setup(), and init_connection().

{
  struct GNUNET_PQ_ExecuteStatement es = {
    .sql = sql,
    .ignore_errors = GNUNET_YES
  };

  return es;
}

Here is the caller graph for this function:

GNUNET_PQ_exec_statements()

int GNUNET_PQ_exec_statements	(	struct GNUNET_PQ_Context *	db,
		const struct GNUNET_PQ_ExecuteStatement *	es
	)

Request execution of an array of statements es from Postgres.

Parameters

pq	database to execute the statements in
es	GNUNET_PQ_PREPARED_STATEMENT_END-terminated array of prepared statements.

Returns

GNUNET_OK on success (modulo statements where errors can be ignored) GNUNET_SYSERR on error

Parameters

db	database to execute the statements with
es	GNUNET_PQ_PREPARED_STATEMENT_END-terminated array of prepared statements.

Returns

GNUNET_OK on success (modulo statements where errors can be ignored) GNUNET_SYSERR on error

Definition at line 76 of file pq_exec.c.

References GNUNET_PQ_Context::conn, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_log_from, GNUNET_NO, GNUNET_OK, GNUNET_SYSERR, GNUNET_PQ_ExecuteStatement::ignore_errors, result, and GNUNET_PQ_ExecuteStatement::sql.

Referenced by GNUNET_PQ_reconnect(), and postgres_plugin_drop().

{
  for (unsigned int i = 0; NULL != es[i].sql; i++)
  {
    PGresult *result;

    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                "Running statement `%s' on %p\n",
                es[i].sql,
                db);
    result = PQexec (db->conn,
                     es[i].sql);
    if ((GNUNET_NO == es[i].ignore_errors) &&
        (PGRES_COMMAND_OK != PQresultStatus (result)))
    {
      GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
                       "pq",
                       "Failed to execute `%s': %s/%s/%s/%s/%s",
                       es[i].sql,
                       PQresultErrorField (result,
                                           PG_DIAG_MESSAGE_PRIMARY),
                       PQresultErrorField (result,
                                           PG_DIAG_MESSAGE_DETAIL),
                       PQresultErrorMessage (result),
                       PQresStatus (PQresultStatus (result)),
                       PQerrorMessage (db->conn));
      PQclear (result);
      return GNUNET_SYSERR;
    }
    PQclear (result);
  }
  return GNUNET_OK;
}

Here is the caller graph for this function:

GNUNET_PQ_connect()

struct GNUNET_PQ_Context* GNUNET_PQ_connect	(	const char *	config_str,
		const char *	load_path,
		const struct GNUNET_PQ_ExecuteStatement *	es,
		const struct GNUNET_PQ_PreparedStatement *	ps
	)

Create a connection to the Postgres database using config_str for the configuration.

Initialize logging via GNUnet's log routines and disable Postgres's logger. Also ensures that the statements in load_path and es are executed whenever we (re)connect to the database, and that the prepared statements in ps are "ready". If statements in fail that were created with GNUNET_PQ_make_execute(), then the entire operation fails.

In load_path, a list of "$XXXX.sql" files is expected where $XXXX must be a sequence of contiguous integer values starting at 0000. These files are then loaded in sequence using "psql $config_str" before running statements from es. The directory is inspected again on reconnect.

Parameters

config_str	configuration to use
load_path	path to directory with SQL transactions to run, can be NULL
es	GNUNET_PQ_PREPARED_STATEMENT_END-terminated array of statements to execute upon EACH connection, can be NULL
ps	array of prepared statements to prepare, can be NULL

Returns

NULL on error

Definition at line 68 of file pq_connect.c.

References GNUNET_PQ_Context::channel_map, GNUNET_PQ_Context::config_str, GNUNET_PQ_Context::conn, db, GNUNET_PQ_Context::es, GNUNET_assert, GNUNET_CONTAINER_multishortmap_create(), GNUNET_free, GNUNET_new, GNUNET_new_array, GNUNET_PQ_reconnect(), GNUNET_strdup, GNUNET_YES, GNUNET_PQ_Context::load_path, name, GNUNET_PQ_Context::notify_lock, and GNUNET_PQ_Context::ps.

Referenced by GNUNET_PQ_connect_with_cfg().

{
  struct GNUNET_PQ_Context *db;
  unsigned int elen = 0;
  unsigned int plen = 0;

  if (NULL != es)
    while (NULL != es[elen].sql)
      elen++;
  if (NULL != ps)
    while (NULL != ps[plen].name)
      plen++;

  db = GNUNET_new (struct GNUNET_PQ_Context);
  db->config_str = GNUNET_strdup (config_str);
  if (NULL != load_path)
    db->load_path = GNUNET_strdup (load_path);
  if (0 != elen)
  {
    db->es = GNUNET_new_array (elen + 1,
                               struct GNUNET_PQ_ExecuteStatement);
    memcpy (db->es,
            es,
            elen * sizeof (struct GNUNET_PQ_ExecuteStatement));
  }
  if (0 != plen)
  {
    db->ps = GNUNET_new_array (plen + 1,
                               struct GNUNET_PQ_PreparedStatement);
    memcpy (db->ps,
            ps,
            plen * sizeof (struct GNUNET_PQ_PreparedStatement));
  }
  db->channel_map = GNUNET_CONTAINER_multishortmap_create (16,
                                                           GNUNET_YES);
  GNUNET_assert (0 ==
                 pthread_mutex_init (&db->notify_lock,
                                     NULL));
  GNUNET_PQ_reconnect (db);
  if (NULL == db->conn)
  {
    GNUNET_free (db->load_path);
    GNUNET_free (db->config_str);
    GNUNET_free (db);
    return NULL;
  }
  return db;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_connect_with_cfg()

struct GNUNET_PQ_Context* GNUNET_PQ_connect_with_cfg	(	const struct GNUNET_CONFIGURATION_Handle *	cfg,
		const char *	section,
		const char *	load_path_suffix,
		const struct GNUNET_PQ_ExecuteStatement *	es,
		const struct GNUNET_PQ_PreparedStatement *	ps
	)

Connect to a postgres database using the configuration option "CONFIG" in section.

Also ensures that the statements in es are executed whenever we (re)connect to the database, and that the prepared statements in ps are "ready".

The caller does not have to ensure that es and ps remain allocated and initialized in memory until GNUNET_PQ_disconnect() is called, as a copy will be made.

Parameters

cfg	configuration
section	configuration section to use to get Postgres configuration options
load_path_suffix	suffix to append to the SQL_DIR in the configuration
es	GNUNET_PQ_PREPARED_STATEMENT_END-terminated array of statements to execute upon EACH connection, can be NULL
ps	array of prepared statements to prepare, can be NULL

Returns

the postgres handle, NULL on error

Definition at line 428 of file pq_connect.c.

References db, GNUNET_asprintf(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_free, GNUNET_OK, GNUNET_PQ_connect(), and GNUNET_PQ_Context::load_path.

Referenced by database_setup(), and init_connection().

{
  struct GNUNET_PQ_Context *db;
  char *conninfo;
  char *load_path;
  char *sp;

  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_string (cfg,
                                             section,
                                             "CONFIG",
                                             &conninfo))
    conninfo = NULL;
  load_path = NULL;
  sp = NULL;
  if ( (NULL != load_path_suffix) &&
       (GNUNET_OK ==
        GNUNET_CONFIGURATION_get_value_filename (cfg,
                                                 section,
                                                 "SQL_DIR",
                                                 &sp)) )
    GNUNET_asprintf (&load_path,
                     "%s%s",
                     sp,
                     load_path_suffix);
  db = GNUNET_PQ_connect (conninfo == NULL ? "" : conninfo,
                          load_path,
                          es,
                          ps);
  GNUNET_free (load_path);
  GNUNET_free (sp);
  GNUNET_free (conninfo);
  return db;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_reconnect_if_down()

void GNUNET_PQ_reconnect_if_down

(

struct GNUNET_PQ_Context *

db

)

Reinitialize the database db if the connection is down.

Parameters

db	database connection to reinitialize

Definition at line 283 of file pq_connect.c.

References GNUNET_PQ_Context::conn, and GNUNET_PQ_reconnect().

{
  if (1 ==
      PQconsumeInput (db->conn))
    return;
  if (CONNECTION_BAD != PQstatus (db->conn))
    return;
  GNUNET_PQ_reconnect (db);
}

Here is the call graph for this function:

GNUNET_PQ_reconnect()

void GNUNET_PQ_reconnect

(

struct GNUNET_PQ_Context *

db

)

Reinitialize the database db.

Parameters

db	database connection to reinitialize

Definition at line 295 of file pq_connect.c.

References apply_patch(), GNUNET_PQ_Context::channel_map, GNUNET_PQ_Context::config_str, GNUNET_PQ_Context::conn, GNUNET_PQ_Context::es, GNUNET_CONTAINER_multishortmap_size(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_log_from, GNUNET_NO, GNUNET_OK, GNUNET_PQ_event_reconnect_(), GNUNET_PQ_exec_statements(), GNUNET_PQ_prepare_statements(), GNUNET_PQ_run_sql(), GNUNET_SYSERR, GNUNET_PQ_Context::load_path, pq_notice_processor_cb(), pq_notice_receiver_cb(), GNUNET_PQ_Context::ps, res, ret, GNUNET_PQ_Context::sc, and GNUNET_PQ_Context::sc_cls.

Referenced by GNUNET_PQ_connect(), GNUNET_PQ_eval_result(), GNUNET_PQ_exec_prepared(), and GNUNET_PQ_reconnect_if_down().

{
  if (NULL != db->sc) 
    db->sc (db->sc_cls,
            -1);
  if (NULL != db->conn)
    PQfinish (db->conn);
  db->conn = PQconnectdb (db->config_str);
  if ( (NULL == db->conn) ||
       (CONNECTION_OK != PQstatus (db->conn)) )
  {
    GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
                     "pq",
                     "Database connection to '%s' failed: %s\n",
                     db->config_str,
                     (NULL != db->conn) ?
                     PQerrorMessage (db->conn)
                     : "PQconnectdb returned NULL");
    if (NULL != db->conn)
    {
      PQfinish (db->conn);
      db->conn = NULL;
    }
    return;
  }
  PQsetNoticeReceiver (db->conn,
                       &pq_notice_receiver_cb,
                       db);
  PQsetNoticeProcessor (db->conn,
                        &pq_notice_processor_cb,
                        db);
  if (NULL != db->load_path)
  {
    PGresult *res;

    res = PQprepare (db->conn,
                     "gnunet_pq_check_patch",
                     "SELECT"
                     " applied_by"
                     " FROM _v.patches"
                     " WHERE patch_name = $1"
                     " LIMIT 1",
                     1,
                     NULL);
    if (PGRES_COMMAND_OK != PQresultStatus (res))
    {
      int ret;

      PQclear (res);
      GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                  "Failed to prepare statement to check patch level. Likely versioning schema does not exist yet, loading patch level 0000!\n");
      ret = apply_patch (db,
                         db->load_path,
                         0);
      if (GNUNET_NO == ret)
      {
        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                    "Failed to find SQL file to load database versioning logic\n");
        PQfinish (db->conn);
        db->conn = NULL;
        return;
      }
      if (GNUNET_SYSERR == ret)
      {
        GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                    "Failed to run SQL logic to setup database versioning logic\n");
        PQfinish (db->conn);
        db->conn = NULL;
        return;
      }
      /* try again to prepare our statement! */
      res = PQprepare (db->conn,
                       "gnunet_pq_check_patch",
                       "SELECT"
                       " applied_by"
                       " FROM _v.patches"
                       " WHERE patch_name = $1"
                       " LIMIT 1",
                       1,
                       NULL);
      if (PGRES_COMMAND_OK != PQresultStatus (res))
      {
        GNUNET_log (GNUNET_ERROR_TYPE_INFO,
                    "Failed to run SQL logic to setup database versioning logic: %s/%s\n",
                    PQresultErrorMessage (res),
                    PQerrorMessage (db->conn));
        PQclear (res);
        PQfinish (db->conn);
        db->conn = NULL;
        return;
      }
    }
    PQclear (res);

    if (GNUNET_SYSERR ==
        GNUNET_PQ_run_sql (db,
                           db->load_path))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Failed to load SQL statements from `%s*'\n",
                  db->load_path);
      PQfinish (db->conn);
      db->conn = NULL;
      return;
    }
  }
  if ( (NULL != db->es) &&
       (GNUNET_OK !=
        GNUNET_PQ_exec_statements (db,
                                   db->es)) )
  {
    PQfinish (db->conn);
    db->conn = NULL;
    return;
  }
  if ( (NULL != db->ps) &&
       (GNUNET_OK !=
        GNUNET_PQ_prepare_statements (db,
                                      db->ps)) )
  {
    PQfinish (db->conn);
    db->conn = NULL;
    return;
  }
  GNUNET_PQ_event_reconnect_ (db);
  if ( (NULL != db->sc) &&
       (0 != GNUNET_CONTAINER_multishortmap_size (db->channel_map)) )
    db->sc (db->sc_cls,
            PQsocket (db->conn));
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_event_set_socket_callback()

void GNUNET_PQ_event_set_socket_callback	(	struct GNUNET_PQ_Context *	db,
		GNUNET_PQ_SocketCallback	sc,
		void *	sc_cls
	)

Obtain the file descriptor to poll on for notifications.

Useful if the GNUnet scheduler is NOT to be used for such notifications.

Parameters

db	database handle
sc	function to call with the socket
sc_cls	closure for sc

Definition at line 168 of file pq_event.c.

References GNUNET_PQ_Context::channel_map, GNUNET_PQ_Context::conn, GNUNET_assert, GNUNET_CONTAINER_multishortmap_size(), GNUNET_PQ_Context::notify_lock, sc, GNUNET_PQ_Context::sc, and GNUNET_PQ_Context::sc_cls.

{
  int fd;

  db->sc = sc;
  db->sc_cls = sc_cls;
  if (NULL == sc)
    return;
  GNUNET_assert (0 ==
                 pthread_mutex_lock (&db->notify_lock));
  fd = PQsocket (db->conn);
  if ( (-1 != fd) &&
       (0 != GNUNET_CONTAINER_multishortmap_size (db->channel_map)) )
    sc (sc_cls,
        fd);
  GNUNET_assert (0 ==
                 pthread_mutex_unlock (&db->notify_lock));
}

Here is the call graph for this function:

GNUNET_PQ_event_do_poll()

void GNUNET_PQ_event_do_poll

(

struct GNUNET_PQ_Context *

db

)

Poll for database events now.

Used if the event FD is ready and the application wants to trigger applicable events. Useful if the GNUnet scheduler is NOT to be used for such notifications.

Parameters

db	database handle

Definition at line 191 of file pq_event.c.

References GNUNET_PQ_Context::channel_map, GNUNET_PQ_Context::conn, do_notify(), NotifyContext::extra, NotifyContext::extra_size, GNUNET_assert, GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_OK, GNUNET_STRINGS_string_to_data(), GNUNET_STRINGS_string_to_data_alloc(), GNUNET_PQ_Context::notify_lock, and scheduler_fd_cb().

Referenced by do_scheduler_notify().

{
  PGnotify *n;

  GNUNET_assert (0 ==
                 pthread_mutex_lock (&db->notify_lock));
  while (NULL != (n = PQnotifies (db->conn)))
  {
    struct GNUNET_ShortHashCode sh;
    struct NotifyContext ctx = {
      .extra = NULL
    };

    if (GNUNET_OK !=
        GNUNET_STRINGS_string_to_data (n->relname,
                                       strlen (n->relname),
                                       &sh,
                                       sizeof (sh)))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Ignoring notification for unsupported channel identifier `%s'\n",
                  n->relname);
      continue;
    }
    if ( (NULL != n->extra) &&
         (GNUNET_OK !=
          GNUNET_STRINGS_string_to_data_alloc (n->extra,
                                               strlen (n->extra),
                                               &ctx.extra,
                                               &ctx.extra_size)))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Ignoring notification for unsupported extra data `%s' on channel `%s'\n",
                  n->extra,
                  n->relname);
      continue;
    }
    GNUNET_CONTAINER_multishortmap_iterate (db->channel_map,
                                            &do_notify,
                                            &ctx);
    GNUNET_free (ctx.extra);
  }
  GNUNET_assert (0 ==
                 pthread_mutex_unlock (&db->notify_lock));
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_event_scheduler_start()

void GNUNET_PQ_event_scheduler_start

(

struct GNUNET_PQ_Context *

db

)

Run poll event loop using the GNUnet scheduler.

Parameters

db	database handle

Definition at line 305 of file pq_event.c.

References GNUNET_PQ_Context::conn, GNUNET_PQ_EventHandler::db, GNUNET_assert, GNUNET_PQ_Context::sc, GNUNET_PQ_Context::sc_cls, scheduler_fd_cb(), and GNUNET_PQ_Context::scheduler_on.

{
  int fd;
  
  GNUNET_assert (! db->scheduler_on);
  GNUNET_assert (NULL == db->sc);
  db->scheduler_on = true;
  db->sc = &scheduler_fd_cb;
  db->sc_cls = db;
  fd = PQsocket (db->conn);
  scheduler_fd_cb (db,
                   fd);
}

Here is the call graph for this function:

GNUNET_PQ_event_scheduler_stop()

void GNUNET_PQ_event_scheduler_stop

(

struct GNUNET_PQ_Context *

db

)

Stop running poll event loop using the GNUnet scheduler.

Parameters

db	database handle

Definition at line 321 of file pq_event.c.

References GNUNET_PQ_Context::event_task, GNUNET_assert, GNUNET_free, GNUNET_SCHEDULER_cancel(), GNUNET_PQ_Context::rfd, GNUNET_PQ_Context::sc, and GNUNET_PQ_Context::scheduler_on.

{
  GNUNET_assert (db->scheduler_on);
  GNUNET_free (db->rfd);
  db->sc = NULL;
  db->scheduler_on = false;
  if (NULL != db->event_task)
  {
    GNUNET_SCHEDULER_cancel (db->event_task);
    db->event_task = NULL;
  }
}

Here is the call graph for this function:

GNUNET_PQ_event_listen()

struct GNUNET_PQ_EventHandler* GNUNET_PQ_event_listen	(	struct GNUNET_PQ_Context *	db,
		const struct GNUNET_PQ_EventHeaderP *	es,
		GNUNET_PQ_EventCallback	cb,
		void *	cb_cls
	)

Register callback to be invoked on events of type es.

Unlike many other calls, this function is thread-safe and may be called from threads that are different from the one that setup db. However, the cb will always be called from the thread that runs GNUNET_PQ_event_do_poll() or the GNUnet scheduler.

Parameters

db	database context to use
es	specification of the event to listen for
cb	function to call when the event happens, possibly multiple times (until GNUNET_PQ_event_listen_cancel() is invoked)
cb_cls	closure for cb

Returns

handle useful to cancel the listener

Definition at line 405 of file pq_event.c.

References GNUNET_PQ_EventHandler::cb, GNUNET_PQ_EventHandler::cb_cls, GNUNET_PQ_Context::channel_map, GNUNET_PQ_Context::conn, GNUNET_PQ_EventHandler::db, es_to_sh(), GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE, GNUNET_CONTAINER_multishortmap_put(), GNUNET_CONTAINER_multishortmap_size(), GNUNET_new, GNUNET_OK, manage_subscribe(), GNUNET_PQ_Context::notify_lock, GNUNET_PQ_Context::sc, GNUNET_PQ_Context::sc_cls, and GNUNET_PQ_EventHandler::sh.

{
  struct GNUNET_PQ_EventHandler *eh;
  bool was_zero;

  eh = GNUNET_new (struct GNUNET_PQ_EventHandler);
  eh->db = db;
  es_to_sh (es,
            &eh->sh);
  eh->cb = cb;
  eh->cb_cls = cb_cls;
  GNUNET_assert (0 ==
                 pthread_mutex_lock (&db->notify_lock));
  was_zero = (0 == GNUNET_CONTAINER_multishortmap_size (db->channel_map));
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_CONTAINER_multishortmap_put (db->channel_map,
                                                         &eh->sh,
                                                         eh,
                                                         GNUNET_CONTAINER_MULTIHASHMAPOPTION_MULTIPLE));
  if ( (NULL != db->sc) &&
       was_zero)
  {
    int fd = PQsocket (db->conn);
    
    if (-1 != fd)
      db->sc (db->sc_cls,
              fd);
  }
  manage_subscribe (db,
                    "LISTEN ",
                    eh);
  GNUNET_assert (0 ==
                 pthread_mutex_unlock (&db->notify_lock));
  return eh;
}

Here is the call graph for this function:

GNUNET_PQ_event_listen_cancel()

void GNUNET_PQ_event_listen_cancel

(

struct GNUNET_PQ_EventHandler *

eh

)

Stop notifications.

Unlike many other calls, this function is thread-safe and may be called from threads that are different from the one that setup db. However, the cb will always be called from the thread that runs GNUNET_PQ_event_do_poll() or the GNUnet scheduler.

Parameters

eh	handle to unregister.

Definition at line 446 of file pq_event.c.

References GNUNET_PQ_Context::channel_map, GNUNET_PQ_EventHandler::db, GNUNET_assert, GNUNET_CONTAINER_multishortmap_remove(), GNUNET_CONTAINER_multishortmap_size(), GNUNET_free, GNUNET_OK, manage_subscribe(), GNUNET_PQ_Context::notify_lock, GNUNET_PQ_Context::sc, GNUNET_PQ_Context::sc_cls, and GNUNET_PQ_EventHandler::sh.

{
  struct GNUNET_PQ_Context *db = eh->db;

  GNUNET_assert (0 ==
                 pthread_mutex_lock (&db->notify_lock));
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_CONTAINER_multishortmap_remove (db->channel_map,
                                                    &eh->sh,
                                                    eh));
    
  manage_subscribe (db,
                    "UNLISTEN ",
                    eh);
  if ( (NULL != db->sc) &&
       (0 == GNUNET_CONTAINER_multishortmap_size (db->channel_map)) )
  {
    db->sc (db->sc_cls,
            -1);
  }
  GNUNET_assert (0 ==
                 pthread_mutex_unlock (&db->notify_lock));
  GNUNET_free (eh);
}

Here is the call graph for this function:

GNUNET_PQ_event_notify()

void GNUNET_PQ_event_notify	(	struct GNUNET_PQ_Context *	db,
		const struct GNUNET_PQ_EventHeaderP *	es,
		const void *	extra,
		size_t	extra_size
	)

Notify all that listen on es of an event.

Unlike many other calls, this function is thread-safe and may be called from threads that are different from the one that setup db. However, the cb will always be called from the thread that runs GNUNET_PQ_event_do_poll() or the GNUnet scheduler.

Parameters

db	database context to use
es	specification of the event to generate
extra	additional event data provided
extra_size	number of bytes in extra

Definition at line 473 of file pq_event.c.

References GNUNET_PQ_Context::conn, end, es_to_channel(), GNUNET_assert, GNUNET_ERROR_TYPE_ERROR, GNUNET_log_from, GNUNET_STRINGS_data_to_string(), and result.

{
  char sql[16 + 64 + extra_size * 8 / 5 + 8];
  char *end;
  PGresult *result;

  end = stpcpy (sql,
                "NOTIFY ");
  end = es_to_channel (es,
                       end);
  end = stpcpy (end,
                ", '");
  end = GNUNET_STRINGS_data_to_string (extra,
                                       extra_size,
                                       end,
                                       sizeof (sql) - (end - sql) - 1);
  GNUNET_assert (NULL != end);
  *end = '\0';
  end = stpcpy (end,
                "'");
  result = PQexec (db->conn,
                   sql);
  if (PGRES_COMMAND_OK != PQresultStatus (result))
  {
    GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
                     "pq",
                     "Failed to execute `%s': %s/%s/%s/%s/%s",
                     sql,
                     PQresultErrorField (result,
                                         PG_DIAG_MESSAGE_PRIMARY),
                     PQresultErrorField (result,
                                         PG_DIAG_MESSAGE_DETAIL),
                     PQresultErrorMessage (result),
                     PQresStatus (PQresultStatus (result)),
                     PQerrorMessage (db->conn));
  }
  PQclear (result);
}

Here is the call graph for this function:

GNUNET_PQ_run_sql()

enum GNUNET_GenericReturnValue GNUNET_PQ_run_sql	(	struct GNUNET_PQ_Context *	db,
		const char *	load_path
	)

Within the db context, run all the SQL files from the load_path from 0000-9999.sql (as long as the files exist contiguously).

Parameters

db	database context to use
load_path	where to find the XXXX.sql files

Returns

GNUNET_OK on success

Definition at line 188 of file pq_connect.c.

References apply_patch(), buf, GNUNET_break, GNUNET_DB_STATUS_HARD_ERROR, GNUNET_DB_STATUS_SUCCESS_ONE_RESULT, GNUNET_DISK_file_test(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_INFO, GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_PQ_cleanup_result(), GNUNET_PQ_eval_prepared_singleton_select(), GNUNET_PQ_query_param_end, GNUNET_PQ_query_param_string(), GNUNET_PQ_result_spec_end, GNUNET_PQ_result_spec_string(), GNUNET_snprintf(), GNUNET_SYSERR, GNUNET_YES, and ret.

Referenced by GNUNET_PQ_reconnect().

{
  const char *load_path_suffix;
  size_t slen = strlen (load_path) + 10;

  load_path_suffix = strrchr (load_path, '/');
  if (NULL == load_path_suffix)
  {
    GNUNET_break (0);
    return GNUNET_SYSERR;
  }
  load_path_suffix++; /* skip '/' */
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Loading SQL resources from `%s'\n",
              load_path);
  for (unsigned int i = 1; i<10000; i++)
  {
    enum GNUNET_DB_QueryStatus qs;
    {
      char buf[slen];

      /* First, check patch actually exists */
      GNUNET_snprintf (buf,
                       sizeof (buf),
                       "%s%04u.sql",
                       load_path,
                       i);
      if (GNUNET_YES !=
          GNUNET_DISK_file_test (buf))
        return GNUNET_OK;   /* We are done */
    }

    /* Second, check with DB versioning schema if this patch was already applied,
       if so, skip it. */
    {
      char patch_name[slen];

      GNUNET_snprintf (patch_name,
                       sizeof (patch_name),
                       "%s%04u",
                       load_path_suffix,
                       i);
      {
        char *applied_by;
        struct GNUNET_PQ_QueryParam params[] = {
          GNUNET_PQ_query_param_string (patch_name),
          GNUNET_PQ_query_param_end
        };
        struct GNUNET_PQ_ResultSpec rs[] = {
          GNUNET_PQ_result_spec_string ("applied_by",
                                        &applied_by),
          GNUNET_PQ_result_spec_end
        };

        qs = GNUNET_PQ_eval_prepared_singleton_select (db,
                                                       "gnunet_pq_check_patch",
                                                       params,
                                                       rs);
        if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT == qs)
        {
          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                      "Database version %s already applied by %s, skipping\n",
                      patch_name,
                      applied_by);
          GNUNET_PQ_cleanup_result (rs);
        }
        if (GNUNET_DB_STATUS_HARD_ERROR == qs)
        {
          GNUNET_break (0);
          return GNUNET_SYSERR;
        }
      }
    }
    if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT == qs)
      continue; /* patch already applied, skip it */

    /* patch not yet applied, run it! */
    {
      int ret;

      ret = apply_patch (db,
                         load_path,
                         i);
      if (GNUNET_NO == ret)
        break;
      if (GNUNET_SYSERR == ret)
        return GNUNET_SYSERR;
    }
  }
  return GNUNET_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_disconnect()

void GNUNET_PQ_disconnect

(

struct GNUNET_PQ_Context *

db

)

Disconnect from the database, destroying the prepared statements and releasing other associated resources.

Parameters

db	database handle to disconnect (will be free'd)

Definition at line 469 of file pq_connect.c.

References GNUNET_PQ_Context::channel_map, GNUNET_PQ_Context::config_str, GNUNET_PQ_Context::conn, GNUNET_PQ_Context::es, GNUNET_assert, GNUNET_CONTAINER_multishortmap_destroy(), GNUNET_CONTAINER_multishortmap_size(), GNUNET_free, GNUNET_PQ_Context::load_path, GNUNET_PQ_Context::notify_lock, and GNUNET_PQ_Context::ps.

Referenced by database_shutdown(), libgnunet_plugin_datacache_postgres_done(), and libgnunet_plugin_datastore_postgres_done().

{
  GNUNET_assert (0 ==
                 GNUNET_CONTAINER_multishortmap_size (db->channel_map));
  GNUNET_CONTAINER_multishortmap_destroy (db->channel_map);
  GNUNET_assert (0 ==
                 pthread_mutex_destroy (&db->notify_lock));
  GNUNET_free (db->es);
  GNUNET_free (db->ps);
  GNUNET_free (db->load_path);
  GNUNET_free (db->config_str);
  PQfinish (db->conn);
  GNUNET_free (db);
}

Here is the call graph for this function:

Here is the caller graph for this function: