pq_query_helper.c File Reference

functions to initialize parameter arrays More...

#include "platform.h"
#include "gnunet_common.h"
#include "gnunet_pq_lib.h"
#include "gnunet_time_lib.h"
#include "pq.h"

Include dependency graph for pq_query_helper.c:

Go to the source code of this file.

Data Structures
struct	qconv_array_cls
	Closure for the array type handlers. More...

Macros
#define	RETURN_UNLESS(cond)

Functions
static int	qconv_null (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...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_null (void)
	Generate query parameter to create a NULL value. More...
static int	qconv_fixed (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...
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_bool (bool b)
	Pass a boolean into a query. More...
static int	qconv_uint16 (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...
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...
static int	qconv_uint32 (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...
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...
static int	qconv_uint64 (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...
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...
static int	qconv_rsa_public_key (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...
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...
static int	qconv_rsa_signature (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...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_rsa_signature (const struct GNUNET_CRYPTO_RsaSignature *x)
	Generate query parameter for an RSA signature. More...
static int	qconv_rel_time (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...
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...
static int	qconv_abs_time (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...
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_timestamp (const struct GNUNET_TIME_Timestamp *x)
	Generate query parameter for a timestamp. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_timestamp_nbo (const struct GNUNET_TIME_TimestampNBO *x)
	Generate query parameter for a timestamp in NBO. More...
static void	qconv_array_cls_cleanup (void *cls)
	Callback to cleanup a qconv_array_cls to be used during GNUNET_PQ_cleanup_query_params_closures. More...
static int	qconv_array (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 for arrays. More...
static struct GNUNET_PQ_QueryParam	query_param_array_generic (unsigned int num, bool continuous, const void *elements, const size_t *sizes, size_t same_size, enum array_types typ, Oid oid)
	Function to genreate a typ specific query parameter and corresponding closure. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_bool (unsigned int num, const bool *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of bool in host byte order. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_uint16 (unsigned int num, const uint16_t *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of uint16_t in host byte order. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_uint32 (unsigned int num, const uint32_t *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of uint32_t in host byte order. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_uint64 (unsigned int num, const uint64_t *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of uint64 in host byte order. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_bytes (unsigned int num, const void *elements, const size_t *sizes, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of buffers elements, each of corresponding size given in sizes. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_ptrs_bytes (unsigned int num, const void *elements[static num], const size_t *sizes, struct GNUNET_PQ_Context *db)
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_bytes_same_size (unsigned int num, const void *elements, size_t same_size, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of buffers elements, each of the same size size. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_ptrs_bytes_same_size (unsigned int num, const void *elements[static num], size_t same_size, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of pointers to buffers elements, each of the same size size. More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_string (unsigned int num, const char *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of strings (continuous) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_ptrs_string (unsigned int num, const char *elements[static num], struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of strings (pointers) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_abs_time (unsigned int num, const struct GNUNET_TIME_Absolute *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of absolute time stamps (continuous) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_ptrs_abs_time (unsigned int num, const struct GNUNET_TIME_Absolute *elements[], struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of absolute time stamps (pointers) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_rel_time (unsigned int num, const struct GNUNET_TIME_Relative *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of relative time stamps (continuous) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_ptrs_rel_time (unsigned int num, const struct GNUNET_TIME_Relative *elements[], struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of relative time stamps (pointers) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_timestamp (unsigned int num, const struct GNUNET_TIME_Timestamp *elements, struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of time stamps (continuous) More...
struct GNUNET_PQ_QueryParam	GNUNET_PQ_query_param_array_ptrs_timestamp (unsigned int num, const struct GNUNET_TIME_Timestamp *elements[], struct GNUNET_PQ_Context *db)
	Generate query parameter for an array of time stamps (pointers) More...

Detailed Description

functions to initialize parameter arrays

Author

Christian Grothoff

Definition in file pq_query_helper.c.

Macro Definition Documentation

RETURN_UNLESS

#define RETURN_UNLESS

(

cond

)

Value:

  do { \
    if (! (cond)) \
    { \
      GNUNET_break ((cond)); \
      noerror = false; \
      goto DONE; \
    } \
  } while (0)

Function Documentation

qconv_null()

static int qconv_null ( 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  )

static

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 47 of file pq_query_helper.c.

{
  (void) scratch;
  (void) scratch_length;
  (void) data;
  (void) data_len;
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  param_values[0] = NULL;
  param_lengths[0] = 0;
  param_formats[0] = 1;
  return 0;
}

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 47 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_null,
    .num_params = 1
  };
 
  return res;
}

References data, and GNUNET_break.

Referenced by postgres_plugin_put().

Here is the caller graph for this function:

qconv_fixed()

static int qconv_fixed ( 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  )

static

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 98 of file pq_query_helper.c.

{
  (void) scratch;
  (void) scratch_length;
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  param_values[0] = (void *) data;
  param_lengths[0] = data_len;
  param_formats[0] = 1;
  return 0;
}

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 98 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_fixed,
    .conv_cls = NULL,
    .data = ptr,
    .size = ptr_size,
    .num_params = 1
  };
 
  return res;
}

Referenced by postgres_plugin_put(), and postgres_plugin_remove_key().

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 98 of file pq_query_helper.c.

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

GNUNET_PQ_query_param_bool()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_bool

(

bool

b

)

Pass a boolean into a query.

Parameters

b	boolean bit to pass

Returns

query parameter to use

Definition at line 98 of file pq_query_helper.c.

{
  static uint8_t bt = 1;
  static uint8_t bf = 0;
 
  return GNUNET_PQ_query_param_fixed_size (b ? &bt : &bf,
                                           sizeof (uint8_t));
}

References data, and GNUNET_break.

qconv_uint16()

static int qconv_uint16 ( 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  )

static

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 170 of file pq_query_helper.c.

{
  const uint16_t *u_hbo = data;
  uint16_t *u_nbo;
 
  (void) scratch;
  (void) scratch_length;
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  u_nbo = GNUNET_new (uint16_t);
  scratch[0] = u_nbo;
  *u_nbo = htons (*u_hbo);
  param_values[0] = (void *) u_nbo;
  param_lengths[0] = sizeof(uint16_t);
  param_formats[0] = 1;
  return 1;
}

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 170 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_uint16,
    .data = x,
    .size = sizeof(*x),
    .num_params = 1
  };
 
  return res;
}

References data, GNUNET_break, and GNUNET_new.

Referenced by postgres_plugin_get_key().

Here is the caller graph for this function:

qconv_uint32()

static int qconv_uint32 ( 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  )

static

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 227 of file pq_query_helper.c.

{
  const uint32_t *u_hbo = data;
  uint32_t *u_nbo;
 
  (void) scratch;
  (void) scratch_length;
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  u_nbo = GNUNET_new (uint32_t);
  scratch[0] = u_nbo;
  *u_nbo = htonl (*u_hbo);
  param_values[0] = (void *) u_nbo;
  param_lengths[0] = sizeof(uint32_t);
  param_formats[0] = 1;
  return 1;
}

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 227 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_uint32,
    .data = x,
    .size = sizeof(*x),
    .num_params = 1
  };
 
  return res;
}

References data, GNUNET_break, and GNUNET_new.

Referenced by postgres_plugin_del(), postgres_plugin_get_closest(), postgres_plugin_get_key(), postgres_plugin_get_zero_anonymity(), and postgres_plugin_put().

Here is the caller graph for this function:

qconv_uint64()

static int qconv_uint64 ( 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  )

static

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 284 of file pq_query_helper.c.

{
  const uint64_t *u_hbo = data;
  uint64_t *u_nbo;
 
  (void) scratch;
  (void) scratch_length;
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  u_nbo = GNUNET_new (uint64_t);
  scratch[0] = u_nbo;
  *u_nbo = GNUNET_htonll (*u_hbo);
  param_values[0] = (void *) u_nbo;
  param_lengths[0] = sizeof(uint64_t);
  param_formats[0] = 1;
  return 1;
}

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 284 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_uint64,
    .data = x,
    .size = sizeof(*x),
    .num_params = 1
  };
 
  return res;
}

References data, GNUNET_break, GNUNET_htonll(), and GNUNET_new.

Referenced by postgres_plugin_get_key(), postgres_plugin_get_zero_anonymity(), postgres_plugin_put(), process_result(), and repl_proc().

Here is the call graph for this function:

Here is the caller graph for this function:

qconv_rsa_public_key()

static int qconv_rsa_public_key ( 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  )

static

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 341 of file pq_query_helper.c.

{
  const struct GNUNET_CRYPTO_RsaPublicKey *rsa = data;
  void *buf;
  size_t buf_size;
 
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  buf_size = GNUNET_CRYPTO_rsa_public_key_encode (rsa,
                                                  &buf);
  scratch[0] = buf;
  param_values[0] = (void *) buf;
  param_lengths[0] = buf_size;
  param_formats[0] = 1;
  return 1;
}

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 341 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_rsa_public_key,
    .data = x,
    .num_params = 1
  };
 
  return res;
}

References buf, data, GNUNET_break, and GNUNET_CRYPTO_rsa_public_key_encode().

Here is the call graph for this function:

qconv_rsa_signature()

static int qconv_rsa_signature ( 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  )

static

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 397 of file pq_query_helper.c.

{
  const struct GNUNET_CRYPTO_RsaSignature *sig = data;
  void *buf;
  size_t buf_size;
 
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  buf_size = GNUNET_CRYPTO_rsa_signature_encode (sig,
                                                 &buf);
  scratch[0] = buf;
  param_values[0] = (void *) buf;
  param_lengths[0] = buf_size;
  param_formats[0] = 1;
  return 1;
}

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 397 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_rsa_signature,
    .data = x,
    .num_params = 1
  };
 
  return res;
}

References buf, data, GNUNET_break, and GNUNET_CRYPTO_rsa_signature_encode().

Here is the call graph for this function:

qconv_rel_time()

static int qconv_rel_time ( 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  )

static

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 452 of file pq_query_helper.c.

{
  const struct GNUNET_TIME_Relative *u = data;
  struct GNUNET_TIME_Relative rel;
  uint64_t *u_nbo;
 
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  rel = *u;
  if (rel.rel_value_us > INT64_MAX)
    rel.rel_value_us = INT64_MAX;
  u_nbo = GNUNET_new (uint64_t);
  scratch[0] = u_nbo;
  *u_nbo = GNUNET_htonll (rel.rel_value_us);
  param_values[0] = (void *) u_nbo;
  param_lengths[0] = sizeof(uint64_t);
  param_formats[0] = 1;
  return 1;
}

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 452 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_rel_time,
    .data = x,
    .size = sizeof(*x),
    .num_params = 1
  };
 
  return res;
}

References data, GNUNET_break, GNUNET_htonll(), GNUNET_new, and GNUNET_TIME_Relative::rel_value_us.

Here is the call graph for this function:

qconv_abs_time()

static int qconv_abs_time ( 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  )

static

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 511 of file pq_query_helper.c.

{
  const struct GNUNET_TIME_Absolute *u = data;
  struct GNUNET_TIME_Absolute abs;
  uint64_t *u_nbo;
 
  GNUNET_break (NULL == cls);
  if (1 != param_length)
    return -1;
  abs = *u;
  if (abs.abs_value_us > INT64_MAX)
    abs.abs_value_us = INT64_MAX;
  u_nbo = GNUNET_new (uint64_t);
  scratch[0] = u_nbo;
  *u_nbo = GNUNET_htonll (abs.abs_value_us);
  param_values[0] = (void *) u_nbo;
  param_lengths[0] = sizeof(uint64_t);
  param_formats[0] = 1;
  return 1;
}

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 511 of file pq_query_helper.c.

{
  struct GNUNET_PQ_QueryParam res = {
    .conv = &qconv_abs_time,
    .data = x,
    .size = sizeof(*x),
    .num_params = 1
  };
 
  return res;
}

References GNUNET_TIME_Absolute::abs_value_us, data, GNUNET_break, GNUNET_htonll(), and GNUNET_new.

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

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 511 of file pq_query_helper.c.

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

GNUNET_PQ_query_param_timestamp()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_timestamp

(

const struct GNUNET_TIME_Timestamp *

x

)

Generate query parameter for a timestamp.

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 511 of file pq_query_helper.c.

{
  return GNUNET_PQ_query_param_absolute_time (&x->abs_time);
}

GNUNET_PQ_query_param_timestamp_nbo()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_timestamp_nbo

(

const struct GNUNET_TIME_TimestampNBO *

x

)

Generate query parameter for a timestamp in NBO.

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 511 of file pq_query_helper.c.

{
  return GNUNET_PQ_query_param_absolute_time_nbo (&x->abs_time_nbo);
}

qconv_array_cls_cleanup()

static void qconv_array_cls_cleanup ( void *  cls )

static

Callback to cleanup a qconv_array_cls to be used during GNUNET_PQ_cleanup_query_params_closures.

Definition at line 623 of file pq_query_helper.c.

{
  GNUNET_free (cls);
}

References GNUNET_free.

qconv_array()

static int qconv_array ( 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  )

static

Function called to convert input argument into SQL parameters for arrays.

Note: the format for the encoding of arrays for libpq is not very well documented. We peeked into various sources (postgresql and libpqtypes) for guidance.

Parameters

	cls	Closure of type struct qconv_array_cls*
	data	Pointer to first element in the array
	data_len	Number of elements in array 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 648 of file pq_query_helper.c.

{
  struct qconv_array_cls *meta = cls;
  size_t num = data_len;
  size_t total_size;
  const size_t *sizes;
  bool same_sized;
  size_t *string_lengths = NULL;
  void *elements = NULL;
  bool noerror = true;
 
  (void) (param_length);
  (void) (scratch_length);
 
  GNUNET_assert (NULL != meta);
  GNUNET_assert (num < INT_MAX);
 
  sizes = meta->sizes;
  same_sized = (0 != meta->same_size);
 
#define RETURN_UNLESS(cond) \
  do { \
    if (! (cond)) \
    { \
      GNUNET_break ((cond)); \
      noerror = false; \
      goto DONE; \
    } \
  } while (0)
 
  /* Calculate sizes and check bounds */
  {
    /* num * length-field */
    size_t x = sizeof(uint32_t);
    size_t y = x * num;
    RETURN_UNLESS ((0 == num) || (y / num == x));
 
    /* size of header */
    total_size  = x = sizeof(struct pq_array_header);
    total_size += y;
    RETURN_UNLESS (total_size >= x);
 
    /* sizes of elements */
    if (same_sized)
    {
      x = num * meta->same_size;
      RETURN_UNLESS ((0 == num) || (x / num == meta->same_size));
 
      y = total_size;
      total_size += x;
      RETURN_UNLESS (total_size >= y);
    }
    else  /* sizes are different per element */
    {
      /* for an array of strings we need to get their length's first */
      if (array_of_string == meta->typ)
      {
        string_lengths = GNUNET_new_array (num, size_t);
 
        if (meta->continuous)
        {
          const char *ptr = data;
          for (unsigned int i = 0; i < num; i++)
          {
            size_t len = strlen (ptr);
            string_lengths[i] = len;
            ptr += len + 1;
          }
        }
        else
        {
          const char **str = (const char **) data;
          for (unsigned int i = 0; i < num; i++)
            string_lengths[i] = strlen (str[i]);
        }
 
        sizes = string_lengths;
      }
 
      for (unsigned int i = 0; i < num; i++)
      {
        x = total_size;
        total_size += sizes[i];
        RETURN_UNLESS (total_size >= x);
      }
    }
 
    RETURN_UNLESS (total_size < INT_MAX);
 
    elements = GNUNET_malloc (total_size);
  }
 
  /* Write data */
  {
    char *in = (char *) data;
    char *out = elements;
    size_t nullbyte = (array_of_string == meta->typ) ? 1 : 0;
    struct pq_array_header h = {
      .ndim = htonl (1),        /* We only support one-dimensional arrays */
      .has_null = htonl (0),    /* We do not support NULL entries in arrays */
      .lbound = htonl (1),      /* Default start index value */
      .dim = htonl (num),
      .oid = htonl (meta->oid),
    };
 
    /* Write header */
    GNUNET_memcpy (out, &h, sizeof(h));
    out += sizeof(h);
 
 
    /* Write elements */
    for (unsigned int i = 0; i < num; i++)
    {
      size_t sz = same_sized ? meta->same_size : sizes[i];
      size_t hsz = htonl (sz);
 
      GNUNET_memcpy (out,
                     &hsz,
                     sizeof(hsz));
      out += sizeof(uint32_t);
 
      switch (meta->typ)
      {
      case array_of_bool:
        {
          GNUNET_assert (sizeof(bool) == sz);
          *(bool *) out = (*(bool *) in);
          in  += sz;
          break;
        }
      case array_of_uint16:
        {
          GNUNET_assert (sizeof(uint16_t) == sz);
          *(uint16_t *) out = htons (*(uint16_t *) in);
          in  += sz;
          break;
        }
      case array_of_uint32:
        {
          uint32_t v;
          GNUNET_assert (sizeof(uint32_t) == sz);
 
          v = htonl (*(uint32_t *) in);
          GNUNET_memcpy (out,
                         &v,
                         sizeof(v));
          in  += sz;
          break;
        }
      case array_of_uint64:
        {
          uint64_t tmp;
          GNUNET_assert (sizeof(uint64_t) == sz);
 
          tmp = GNUNET_htonll (*(uint64_t *) in);
          GNUNET_memcpy (out,
                         &tmp,
                         sizeof(tmp));
          in  += sz;
          break;
        }
      case array_of_byte:
      case array_of_string:
        {
          const void *ptr;
 
          if (meta->continuous)
          {
            ptr = in;
            in += sz + nullbyte;
          }
          else
            ptr = ((const void **) data)[i];
 
          GNUNET_memcpy (out,
                         ptr,
                         sz);
          break;
        }
      case array_of_abs_time:
      case array_of_rel_time:
      case array_of_timestamp:
        {
          uint64_t val;
 
          switch (meta->typ)
          {
          case array_of_abs_time:
            {
              const struct GNUNET_TIME_Absolute *abs =
                (const struct GNUNET_TIME_Absolute *) in;
 
              GNUNET_assert (sizeof(struct GNUNET_TIME_Absolute) == sz);
 
              if (! meta->continuous)
                abs = ((const struct GNUNET_TIME_Absolute **) data)[i];
 
              val = abs->abs_value_us;
              break;
            }
          case array_of_rel_time:
            {
              const struct GNUNET_TIME_Relative *rel =
                (const struct GNUNET_TIME_Relative *) in;
 
              GNUNET_assert (sizeof(struct GNUNET_TIME_Relative) == sz);
 
              if (! meta->continuous)
                rel = ((const struct GNUNET_TIME_Relative **) data)[i];
 
              val = rel->rel_value_us;
              break;
            }
          case array_of_timestamp:
            {
              const struct GNUNET_TIME_Timestamp *ts =
                (const struct GNUNET_TIME_Timestamp *) in;
 
              GNUNET_assert (sizeof(struct GNUNET_TIME_Timestamp) == sz);
 
              if (! meta->continuous)
                ts = ((const struct GNUNET_TIME_Timestamp **) data)[i];
 
              val = ts->abs_time.abs_value_us;
              break;
            }
          default:
            {
              GNUNET_assert (0);
            }
          }
 
          if (val > INT64_MAX)
            val = INT64_MAX;
 
          val = GNUNET_htonll (val);
          GNUNET_memcpy (out,
                         &val,
                         sizeof(val));
 
          if (meta->continuous)
            in += sz;
 
          break;
        }
      default:
        {
          GNUNET_assert (0);
          break;
        }
      }
      out += sz;
    }
  }
 
  param_values[0] = elements;
  param_lengths[0] = total_size;
  param_formats[0] = 1;
  scratch[0] = elements;
 
DONE:
  GNUNET_free (string_lengths);
 
  if (noerror)
    return 1;
 
  return -1;
}

query_param_array_generic()

static struct GNUNET_PQ_QueryParam query_param_array_generic ( unsigned int  num, bool  continuous, const void *  elements, const size_t *  sizes, size_t  same_size, enum array_types  typ, Oid  oid  )

static

Function to genreate a typ specific query parameter and corresponding closure.

Parameters

num	Number of elements in elements
continuous	If true, elements is an continuous array of data
elements	Array of num elements, either continuous or pointers
sizes	Array of num sizes, one per element, may be NULL
same_size	If not 0, all elements in elements have this size
typ	Supported internal type of each element in elements
oid	Oid of the type to be used in Postgres

Returns

Query parameter

Definition at line 648 of file pq_query_helper.c.

{
  struct qconv_array_cls *meta = GNUNET_new (struct qconv_array_cls);
 
  meta->typ = typ;
  meta->oid = oid;
  meta->sizes = sizes;
  meta->same_size = same_size;
  meta->continuous = continuous;
 
  {
    struct GNUNET_PQ_QueryParam res = {
      .conv = qconv_array,
      .conv_cls = meta,
      .conv_cls_cleanup = &qconv_array_cls_cleanup,
      .data = elements,
      .size = num,
      .num_params = 1,
    };
 
    return res;
  }
}

GNUNET_PQ_query_param_array_bool()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_bool	(	unsigned int	num,
		const bool *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of bool in host byte order.

Parameters

num	Number of elements in elements
elements	Continuous array of num boolean elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "bool",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(bool),
                                    array_of_bool,
                                    oid);
}

GNUNET_PQ_query_param_array_uint16()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_uint16	(	unsigned int	num,
		const uint16_t *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of uint16_t in host byte order.

Note that the (unsigend) elements are not checked to wrap over INT2_MAX

Parameters

num	Number of elements in elements
elements	Continuous array of num uint16 elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int2",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(uint16_t),
                                    array_of_uint16,
                                    oid);
}

GNUNET_PQ_query_param_array_uint32()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_uint32	(	unsigned int	num,
		const uint32_t *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of uint32_t in host byte order.

Note that the (unsigend) elements are not checked to wrap over INT4_MAX

Parameters

num	Number of elements in elements
elements	Continuous Array of num uint32_t elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int4",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(uint32_t),
                                    array_of_uint32,
                                    oid);
}

GNUNET_PQ_query_param_array_uint64()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_uint64	(	unsigned int	num,
		const uint64_t *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of uint64 in host byte order.

Note that the (unsigend) elements are not checked to wrap over INT8_MAX

Parameters

num	Number of elements in elements
elements	Continuous array of num uint64_t elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(uint64_t),
                                    array_of_uint64,
                                    oid);
}

GNUNET_PQ_query_param_array_bytes()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_bytes	(	unsigned int	num,
		const void *	elements,
		const size_t *	sizes,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of buffers elements, each of corresponding size given in sizes.

Parameters

num	Number of elements in elements
elements	Continous array of num buffers, each of corresponding size given in sizes.
sizes	Pointer to sizes in bytes of each element in elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "bytea",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    sizes,
                                    0,
                                    array_of_byte,
                                    oid);
}

GNUNET_PQ_query_param_array_ptrs_bytes()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_ptrs_bytes	(	unsigned int	num,
		const void *	elements[static num],
		const size_t *	sizes,
		struct GNUNET_PQ_Context *	db
	)

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "bytea",
                                            &oid));
  return query_param_array_generic (num,
                                    false,
                                    elements,
                                    sizes,
                                    0,
                                    array_of_byte,
                                    oid);
}

GNUNET_PQ_query_param_array_bytes_same_size()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_bytes_same_size	(	unsigned int	num,
		const void *	elements,
		size_t	same_size,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of buffers elements, each of the same size size.

Parameters

num	Number of elements in elements
elements	Continous array of num buffers, each with the same size same_size
same_size	Size in bytes of each element in elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "bytea",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    same_size,
                                    array_of_byte,
                                    oid);
}

GNUNET_PQ_query_param_array_ptrs_bytes_same_size()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_ptrs_bytes_same_size	(	unsigned int	num,
		const void *	elements[static num],
		size_t	same_size,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of pointers to buffers elements, each of the same size size.

Parameters

num	Number of elements in elements
elements	Array of num pointers to buffers, each with the same size same_size
same_size	Size in bytes of each element in elements
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "bytea",
                                            &oid));
  return query_param_array_generic (num,
                                    false,
                                    elements,
                                    NULL,
                                    same_size,
                                    array_of_byte,
                                    oid);
}

GNUNET_PQ_query_param_array_string()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_string	(	unsigned int	num,
		const char *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of strings (continuous)

Parameters

num	Number of elements in elements
elements	Array of num continuous strings (zero-terminated each)
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "text",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    0,
                                    array_of_string,
                                    oid);
}

GNUNET_PQ_query_param_array_ptrs_string()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_ptrs_string	(	unsigned int	num,
		const char *	elements[static num],
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of strings (pointers)

Parameters

num	Number of elements in elements
elements	Array of num pointer to strings
db	Database context, needed for database-depending encoding of elements

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "text",
                                            &oid));
  return query_param_array_generic (num,
                                    false,
                                    elements,
                                    NULL,
                                    0,
                                    array_of_string,
                                    oid);
}

GNUNET_PQ_query_param_array_abs_time()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_abs_time	(	unsigned int	num,
		const struct GNUNET_TIME_Absolute *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of absolute time stamps (continuous)

Parameters

num	Number of elements in elements
elements	Array of num absolute timestamps

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(struct GNUNET_TIME_Absolute),
                                    array_of_abs_time,
                                    oid);
}

References GNUNET_TIME_Timestamp::abs_time, GNUNET_TIME_Absolute::abs_value_us, array_of_abs_time, array_of_bool, array_of_byte, array_of_rel_time, array_of_string, array_of_timestamp, array_of_uint16, array_of_uint32, array_of_uint64, data, GNUNET_assert, GNUNET_free, GNUNET_htonll(), GNUNET_malloc, GNUNET_memcpy, GNUNET_new_array, h, INT_MAX, len, meta, GNUNET_TIME_Relative::rel_value_us, RETURN_UNLESS, and qconv_array_cls::sizes.

Here is the call graph for this function:

GNUNET_PQ_query_param_array_ptrs_abs_time()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_ptrs_abs_time	(	unsigned int	num,
		const struct GNUNET_TIME_Absolute *	elements[],
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of absolute time stamps (pointers)

Parameters

num	Number of elements in elements
elements	Array of num pointers to absolute timestamps

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    false,
                                    elements,
                                    NULL,
                                    sizeof(struct GNUNET_TIME_Absolute),
                                    array_of_abs_time,
                                    oid);
}

GNUNET_PQ_query_param_array_rel_time()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_rel_time	(	unsigned int	num,
		const struct GNUNET_TIME_Relative *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of relative time stamps (continuous)

Parameters

num	Number of elements in elements
elements	Array of num relative timestamps

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(struct GNUNET_TIME_Relative),
                                    array_of_abs_time,
                                    oid);
}

GNUNET_PQ_query_param_array_ptrs_rel_time()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_ptrs_rel_time	(	unsigned int	num,
		const struct GNUNET_TIME_Relative *	elements[],
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of relative time stamps (pointers)

Parameters

num	Number of elements in elements
elements	Array of num pointers to relative timestamps

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    false,
                                    elements,
                                    NULL,
                                    sizeof(struct GNUNET_TIME_Relative),
                                    array_of_abs_time,
                                    oid);
}

GNUNET_PQ_query_param_array_timestamp()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_timestamp	(	unsigned int	num,
		const struct GNUNET_TIME_Timestamp *	elements,
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of time stamps (continuous)

Parameters

num	Number of elements in elements
elements	Array of num timestamps

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    true,
                                    elements,
                                    NULL,
                                    sizeof(struct GNUNET_TIME_Timestamp),
                                    array_of_timestamp,
                                    oid);
}

GNUNET_PQ_query_param_array_ptrs_timestamp()

struct GNUNET_PQ_QueryParam GNUNET_PQ_query_param_array_ptrs_timestamp	(	unsigned int	num,
		const struct GNUNET_TIME_Timestamp *	elements[],
		struct GNUNET_PQ_Context *	db
	)

Generate query parameter for an array of time stamps (pointers)

Parameters

num	Number of elements in elements
elements	Array of num pointers to relative timestamps

Returns

query parameter to use

Definition at line 648 of file pq_query_helper.c.

{
  Oid oid;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_PQ_get_oid_by_name (db,
                                            "int8",
                                            &oid));
  return query_param_array_generic (num,
                                    false,
                                    elements,
                                    NULL,
                                    sizeof(struct GNUNET_TIME_Timestamp),
                                    array_of_timestamp,
                                    oid);
}