pq_query_helper.c File Reference

functions to initialize parameter arrays More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_pq_lib.h"

Include dependency graph for pq_query_helper.c:

Go to the source code of this file.

Functions
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...
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 uint64_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...

Detailed Description

functions to initialize parameter arrays

Author

Christian Grothoff

Definition in file pq_query_helper.c.

Function Documentation

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

References GNUNET_break.

Referenced by GNUNET_PQ_query_param_fixed_size().

{
  (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;
}

Here is the caller 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

Definition at line 75 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

Definition at line 91 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:

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

References data, GNUNET_break, and GNUNET_new.

Referenced by GNUNET_PQ_query_param_uint16().

{
  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;
}

Here is the caller graph for this function:

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

Definition at line 146 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:

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

References data, GNUNET_break, and GNUNET_new.

Referenced by GNUNET_PQ_query_param_uint32().

{
  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;
}

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

Definition at line 204 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:

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

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

Referenced by GNUNET_PQ_query_param_uint64().

{
  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;
}

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 uint64_t in host byte order.

Generate query parameter for an uint16_t in host byte order.

Parameters

x	pointer to the query parameter to pass

Definition at line 262 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:

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

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

Referenced by GNUNET_PQ_query_param_rsa_public_key().

{
  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;
}

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

array entry for the query parameters to use

Definition at line 321 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:

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

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

Referenced by GNUNET_PQ_query_param_rsa_signature().

{
  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;
}

Here is the call graph for this function:

Here is the caller 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

array entry for the query parameters to use

Definition at line 381 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:

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

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

Referenced by GNUNET_PQ_query_param_relative_time().

{
  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;
}

Here is the call graph for this function:

Here is the caller 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

array entry for the query parameters to use

Definition at line 443 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:

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

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

Referenced by GNUNET_PQ_query_param_absolute_time().

{
  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;
}

Here is the call graph for this function:

Here is the caller 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

array entry for the query parameters to use

Definition at line 505 of file pq_query_helper.c.

References qconv_abs_time(), and res.

Referenced by 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

Definition at line 521 of file pq_query_helper.c.

References GNUNET_PQ_query_param_auto_from_type.

Referenced by delete_old_block(), and namecache_postgres_cache_block().

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

Here is the caller graph for this function: