pq.h File Reference

shared internal data structures of libgnunetpq More...

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

Include dependency graph for pq.h:

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

Go to the source code of this file.

Data Structures
struct	GNUNET_PQ_Context
	Handle to Postgres database. More...
struct	pq_array_header
	The header for a postgresql array in binary format. More...

Enumerations
enum	array_types {   array_of_bool , array_of_uint16 , array_of_uint32 , array_of_uint64 ,   array_of_byte , array_of_string , array_of_abs_time , array_of_rel_time ,   array_of_timestamp , array_of_MAX }
	Internal types that are supported as array types. More...

Functions
struct pq_array_header	__attribute__ ((packed))
void	GNUNET_PQ_reconnect_ (struct GNUNET_PQ_Context *db)
	Reinitialize the database db.
void	GNUNET_PQ_event_reconnect_ (struct GNUNET_PQ_Context *db, int fd)
	Internal API.

Variables
uint32_t	ndim
uint32_t	has_nulls
uint32_t	oid
uint32_t	dim
uint32_t	lbound

Detailed Description

shared internal data structures of libgnunetpq

Author

Christian Grothoff

Definition in file pq.h.

Enumeration Type Documentation

array_types

enum array_types

Internal types that are supported as array types.

Enumerator
array_of_bool
array_of_uint16
array_of_uint32
array_of_uint64
array_of_byte
array_of_string
array_of_abs_time
array_of_rel_time
array_of_timestamp
array_of_MAX

Definition at line 134 of file pq.h.

{
  array_of_bool,
  array_of_uint16,
  array_of_uint32,
  array_of_uint64,
  array_of_byte,      /* buffers of (char *), (void *), ... */
  array_of_string,    /* NULL-terminated (char *) */
  array_of_abs_time,
  array_of_rel_time,
  array_of_timestamp,
  array_of_MAX,       /* must be last */
};

Function Documentation

__attribute__()

struct pq_array_header __attribute__

(

(packed)

)

GNUNET_PQ_reconnect_()

void GNUNET_PQ_reconnect_

(

struct GNUNET_PQ_Context *

db

)

Reinitialize the database db.

Parameters

db	database connection to reinitialize

Deprecated:

Definition at line 552 of file pq_connect.c.

{
  GNUNET_PQ_event_reconnect_ (db,
                              -1);
  reset_connection (db);
  db->versioning_ok = GNUNET_SYSERR; /* new connection, new game */
  db->conn = PQconnectdb (db->config_str);
  if ( (NULL == db->conn) ||
       (CONNECTION_OK != PQstatus (db->conn)) )
  {
    GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
                     "pq",
                     "Database connection to '%s' failed: %s\n",
                     db->config_str,
                     (NULL != db->conn)
                     ? PQerrorMessage (db->conn)
                     : "PQconnectdb returned NULL");
    reset_connection (db);
    return;
  }
  PQsetNoticeReceiver (db->conn,
                       &pq_notice_receiver_cb,
                       db);
  PQsetNoticeProcessor (db->conn,
                        &pq_notice_processor_cb,
                        db);
  if (NULL != db->rc)
    db->rc (db->rc_cls,
            db);
 
  /* Prepare statement for OID lookup by name */
  if (GNUNET_OK !=
      prepare_get_oid_by_name (db))
    return;
 
  /* Reset the OID-cache and retrieve the OIDs for the supported Array types */
  db->oids.num = 0;
  if (GNUNET_SYSERR == load_initial_oids (db))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Failed to retrieve OID information for array types!\n");
    reset_connection (db);
    return;
  }
  GNUNET_PQ_event_reconnect_ (db,
                              PQsocket (db->conn));
}

References db, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_log_from, GNUNET_OK, GNUNET_PQ_event_reconnect_(), GNUNET_SYSERR, load_initial_oids(), pq_notice_processor_cb(), pq_notice_receiver_cb(), prepare_get_oid_by_name(), and reset_connection().

Referenced by do_scheduler_notify(), GNUNET_PQ_eval_result(), GNUNET_PQ_event_do_poll(), GNUNET_PQ_exec_prepared(), GNUNET_PQ_init(), and GNUNET_PQ_reconnect_if_down().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_PQ_event_reconnect_()

void GNUNET_PQ_event_reconnect_	(	struct GNUNET_PQ_Context *	db,
		int	fd
	)

Internal API.

Reconnect should re-register notifications after a disconnect.

Parameters

db	the DB handle
fd	socket to listen on

Definition at line 434 of file pq_event.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Change in PQ event FD to %d\n",
              fd);
  scheduler_fd_cb (db,
                   fd);
  GNUNET_CONTAINER_multishortmap_iterate (db->channel_map,
                                          &register_notify,
                                          db);
}

References db, GNUNET_CONTAINER_multishortmap_iterate(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, register_notify(), and scheduler_fd_cb().

Referenced by GNUNET_PQ_reconnect_().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

ndim

uint32_t ndim

Definition at line 0 of file pq.h.

has_nulls

uint32_t has_nulls

Definition at line 1 of file pq.h.

Referenced by qconv_array().

oid

uint32_t oid

Definition at line 2 of file pq.h.

dim

uint32_t dim

Definition at line 3 of file pq.h.

lbound

uint32_t lbound

Definition at line 4 of file pq.h.