pq_result_helper.c File Reference

functions to extract result values More...

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

Include dependency graph for pq_result_helper.c:

Go to the source code of this file.

Functions
static void	clean_varsize_blob (void *cls, void *rd)
	Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter. More...
static int	extract_varsize_blob (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...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_variable_size (const char *name, void **dst, size_t *sptr)
	Variable-size result expected. More...
static int	extract_fixed_blob (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...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_fixed_size (const char *name, void *dst, size_t dst_size)
	Fixed-size result expected. More...
static int	extract_rsa_public_key (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...
static void	clean_rsa_public_key (void *cls, void *rd)
	Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter. 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...
static int	extract_rsa_signature (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...
static void	clean_rsa_signature (void *cls, void *rd)
	Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_rsa_signature (const char *name, struct GNUNET_CRYPTO_RsaSignature **sig)
	RSA signature expected. More...
static int	extract_string (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...
static void	clean_string (void *cls, void *rd)
	Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter. More...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_string (const char *name, char **dst)
	0-terminated string expected. More...
static int	extract_abs_time (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...
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_absolute_time_nbo (const char *name, struct GNUNET_TIME_AbsoluteNBO *at)
	Absolute time in network byte order expected. More...
static int	extract_uint16 (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...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_uint16 (const char *name, uint16_t *u16)
	uint16_t expected. More...
static int	extract_uint32 (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...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_uint32 (const char *name, uint32_t *u32)
	uint32_t expected. More...
static int	extract_uint64 (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...
struct GNUNET_PQ_ResultSpec	GNUNET_PQ_result_spec_uint64 (const char *name, uint64_t *u64)
	uint64_t expected. More...

Detailed Description

functions to extract result values

Author

Christian Grothoff

Definition in file pq_result_helper.c.

Function Documentation

clean_varsize_blob()

static void clean_varsize_blob ( void *  cls, void *  rd  )

static

Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter.

Parameters

cls	closure
rd	result data to clean up

Definition at line 38 of file pq_result_helper.c.

References GNUNET_free.

Referenced by GNUNET_PQ_result_spec_variable_size().

{
  void **dst = rd;

  (void)cls;
  if (NULL != *dst)
    {
      GNUNET_free(*dst);
      *dst = NULL;
    }
}

Here is the caller graph for this function:

extract_varsize_blob()

static int extract_varsize_blob ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field)

Definition at line 66 of file pq_result_helper.c.

References GNUNET_assert, GNUNET_break, GNUNET_malloc, GNUNET_memcpy, GNUNET_OK, GNUNET_SYSERR, len, and res.

Referenced by GNUNET_PQ_result_spec_variable_size().

{
  size_t len;
  const char *res;
  void *idst;
  int fnum;

  (void)cls;
  *dst_size = 0;
  *((void **)dst) = NULL;

  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      /* Let's allow this for varsize */
      return GNUNET_OK;
    }
  /* if a field is null, continue but
   * remember that we now return a different result */
  len = PQgetlength(result,
                    row,
                    fnum);
  res = PQgetvalue(result,
                   row,
                   fnum);
  GNUNET_assert(NULL != res);
  *dst_size = len;
  idst = GNUNET_malloc(len);
  *((void **)dst) = idst;
  GNUNET_memcpy(idst,
                res,
                len);
  return GNUNET_OK;
}

Here is the caller graph for this function:

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 124 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:

extract_fixed_blob()

static int extract_fixed_blob ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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]	dst_size	desired size, never NULL
[out]	dst	where to store the result

Returns

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

Definition at line 151 of file pq_result_helper.c.

References GNUNET_assert, GNUNET_break, GNUNET_memcpy, GNUNET_OK, GNUNET_SYSERR, len, and res.

Referenced by GNUNET_PQ_result_spec_fixed_size().

{
  size_t len;
  const char *res;
  int fnum;

  (void)cls;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }

  /* if a field is null, continue but
   * remember that we now return a different result */
  len = PQgetlength(result,
                    row,
                    fnum);
  if (*dst_size != len)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  res = PQgetvalue(result,
                   row,
                   fnum);
  GNUNET_assert(NULL != res);
  GNUNET_memcpy(dst,
                res,
                len);
  return GNUNET_OK;
}

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 208 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:

extract_rsa_public_key()

static int extract_rsa_public_key ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 235 of file pq_result_helper.c.

References GNUNET_break, GNUNET_CRYPTO_rsa_public_key_decode(), GNUNET_OK, GNUNET_SYSERR, len, pk, and res.

Referenced by GNUNET_PQ_result_spec_rsa_public_key().

{
  struct GNUNET_CRYPTO_RsaPublicKey **pk = dst;
  size_t len;
  const char *res;
  int fnum;

  (void)cls;
  *pk = NULL;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  /* if a field is null, continue but
   * remember that we now return a different result */
  len = PQgetlength(result,
                    row,
                    fnum);
  res = PQgetvalue(result,
                   row,
                   fnum);
  *pk = GNUNET_CRYPTO_rsa_public_key_decode(res,
                                            len);
  if (NULL == *pk)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  return GNUNET_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

clean_rsa_public_key()

static void clean_rsa_public_key ( void *  cls, void *  rd  )

static

Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter.

Parameters

cls	closure
rd	result data to clean up

Definition at line 290 of file pq_result_helper.c.

References GNUNET_CRYPTO_rsa_public_key_free(), and pk.

Referenced by GNUNET_PQ_result_spec_rsa_public_key().

{
  struct GNUNET_CRYPTO_RsaPublicKey **pk = rd;

  (void)cls;
  if (NULL != *pk)
    {
      GNUNET_CRYPTO_rsa_public_key_free(*pk);
      *pk = NULL;
    }
}

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 312 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:

extract_rsa_signature()

static int extract_rsa_signature ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 339 of file pq_result_helper.c.

References GNUNET_break, GNUNET_CRYPTO_rsa_signature_decode(), GNUNET_OK, GNUNET_SYSERR, len, and res.

Referenced by GNUNET_PQ_result_spec_rsa_signature().

{
  struct GNUNET_CRYPTO_RsaSignature **sig = dst;
  size_t len;
  const char *res;
  int fnum;

  (void)cls;
  *sig = NULL;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  /* if a field is null, continue but
   * remember that we now return a different result */
  len = PQgetlength(result,
                    row,
                    fnum);
  res = PQgetvalue(result,
                   row,
                   fnum);
  *sig = GNUNET_CRYPTO_rsa_signature_decode(res,
                                            len);
  if (NULL == *sig)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  return GNUNET_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

clean_rsa_signature()

static void clean_rsa_signature ( void *  cls, void *  rd  )

static

Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter.

Parameters

cls	closure
rd	result data to clean up

Definition at line 394 of file pq_result_helper.c.

References GNUNET_CRYPTO_rsa_signature_free().

Referenced by GNUNET_PQ_result_spec_rsa_signature().

{
  struct GNUNET_CRYPTO_RsaSignature **sig = rd;

  (void)cls;
  if (NULL != *sig)
    {
      GNUNET_CRYPTO_rsa_signature_free(*sig);
      *sig = NULL;
    }
}

Here is the call graph for this function:

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

extract_string()

static int extract_string ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 443 of file pq_result_helper.c.

References GNUNET_PQ_ResultSpec::dst, GNUNET_break, GNUNET_OK, GNUNET_strndup, GNUNET_SYSERR, len, and res.

Referenced by GNUNET_PQ_result_spec_string().

{
  char **str = dst;
  size_t len;
  const char *res;
  int fnum;

  (void)cls;
  *str = NULL;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  /* if a field is null, continue but
   * remember that we now return a different result */
  len = PQgetlength(result,
                    row,
                    fnum);
  res = PQgetvalue(result,
                   row,
                   fnum);
  *str = GNUNET_strndup(res,
                        len);
  if (NULL == *str)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  return GNUNET_OK;
}

Here is the caller graph for this function:

clean_string()

static void clean_string ( void *  cls, void *  rd  )

static

Function called to clean up memory allocated by a GNUNET_PQ_ResultConverter.

Parameters

cls	closure
rd	result data to clean up

Definition at line 498 of file pq_result_helper.c.

References GNUNET_free.

Referenced by GNUNET_PQ_result_spec_string().

{
  char **str = rd;

  (void)cls;
  if (NULL != *str)
    {
      GNUNET_free(*str);
      *str = NULL;
    }
}

Here is the caller 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 520 of file pq_result_helper.c.

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

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

extract_abs_time()

static int extract_abs_time ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 547 of file pq_result_helper.c.

References GNUNET_TIME_Absolute::abs_value_us, GNUNET_assert, GNUNET_break, GNUNET_ntohll(), GNUNET_OK, GNUNET_SYSERR, GNUNET_TIME_UNIT_FOREVER_ABS, and res.

Referenced by GNUNET_PQ_result_spec_absolute_time().

{
  struct GNUNET_TIME_Absolute *udst = dst;
  const int64_t *res;
  int fnum;

  (void)cls;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  GNUNET_assert(NULL != dst);
  if (sizeof(struct GNUNET_TIME_Absolute) != *dst_size)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (sizeof(int64_t) !=
      PQgetlength(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  res = (int64_t *)PQgetvalue(result,
                              row,
                              fnum);
  if (INT64_MAX == *res)
    *udst = GNUNET_TIME_UNIT_FOREVER_ABS;
  else
    udst->abs_value_us = GNUNET_ntohll((uint64_t)*res);
  return GNUNET_OK;
}

Here is the call graph for this function:

Here is the caller 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 606 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_absolute_time_nbo()

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

Absolute time in network byte order expected.

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

extract_uint16()

static int extract_uint16 ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 651 of file pq_result_helper.c.

References GNUNET_PQ_ResultSpec::dst, GNUNET_assert, GNUNET_break, GNUNET_OK, GNUNET_SYSERR, and res.

Referenced by GNUNET_PQ_result_spec_uint16().

{
  uint16_t *udst = dst;
  const uint16_t *res;
  int fnum;

  (void)cls;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  GNUNET_assert(NULL != dst);
  if (sizeof(uint16_t) != *dst_size)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (sizeof(uint16_t) !=
      PQgetlength(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  res = (uint16_t *)PQgetvalue(result,
                               row,
                               fnum);
  *udst = ntohs(*res);
  return GNUNET_OK;
}

Here is the caller graph for this function:

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 707 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:

extract_uint32()

static int extract_uint32 ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 734 of file pq_result_helper.c.

References GNUNET_PQ_ResultSpec::dst, GNUNET_assert, GNUNET_break, GNUNET_OK, GNUNET_SYSERR, and res.

Referenced by GNUNET_PQ_result_spec_uint32().

{
  uint32_t *udst = dst;
  const uint32_t *res;
  int fnum;

  (void)cls;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  GNUNET_assert(NULL != dst);
  if (sizeof(uint32_t) != *dst_size)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (sizeof(uint32_t) !=
      PQgetlength(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  res = (uint32_t *)PQgetvalue(result,
                               row,
                               fnum);
  *udst = ntohl(*res);
  return GNUNET_OK;
}

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

extract_uint64()

static int extract_uint64 ( void *  cls, PGresult *  result, int  row, const char *  fname, size_t *  dst_size, void *  dst  )

static

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_SYSERR if a result was invalid (non-existing field or NULL)

Definition at line 817 of file pq_result_helper.c.

References GNUNET_PQ_ResultSpec::dst, GNUNET_assert, GNUNET_break, GNUNET_ntohll(), GNUNET_OK, GNUNET_SYSERR, and res.

Referenced by GNUNET_PQ_result_spec_uint64().

{
  uint64_t *udst = dst;
  const uint64_t *res;
  int fnum;

  (void)cls;
  fnum = PQfnumber(result,
                   fname);
  if (fnum < 0)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (PQgetisnull(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  GNUNET_assert(NULL != dst);
  if (sizeof(uint64_t) != *dst_size)
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  if (sizeof(uint64_t) !=
      PQgetlength(result,
                  row,
                  fnum))
    {
      GNUNET_break(0);
      return GNUNET_SYSERR;
    }
  res = (uint64_t *)PQgetvalue(result,
                               row,
                               fnum);
  *udst = GNUNET_ntohll(*res);
  return GNUNET_OK;
}

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 873 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: