Referencia del Archivo src/libpq/libpq-int.h

#include "postgres_fe.h"
#include <time.h>
#include <sys/types.h>
#include <sys/time.h>
#include "getaddrinfo.h"
#include "libpq/pqcomm.h"
#include "pqexpbuffer.h"
#include <pthread.h>
#include <signal.h>

Ir al código fuente de este archivo.

Clases
union	pgresult_data
struct	pgresAttDesc
struct	pgresAttValue
struct	pgMessageField
struct	PGNoticeHooks
struct	pg_result
struct	PQEnvironmentOption
struct	pgParameterStatus
struct	pgLobjfuncs
struct	pg_conn
struct	pg_cancel
'defines'
#define	PQERRORMSG_LENGTH   1024
#define	CMDSTATUS_LEN   40
#define	NULL_LEN   (-1)
#define	pglock_thread()   pg_g_threadlock(true)
#define	pgunlock_thread()   pg_g_threadlock(false)
#define	pqIsnonblocking(conn)   ((conn)->nonblocking)
#define	libpq_gettext(x)   (x)
#define	SOCK_ERRNO   errno
#define	SOCK_STRERROR   pqStrerror
#define	SOCK_ERRNO_SET(e)   (errno = (e))
'typedefs'
typedef union pgresult_data	PGresult_data
typedef struct pgresAttDesc	PGresAttDesc
typedef struct pgresAttValue	PGresAttValue
typedef struct pgMessageField	PGMessageField
typedef struct PQEnvironmentOption	PQEnvironmentOption
typedef struct pgParameterStatus	pgParameterStatus
typedef struct pgLobjfuncs	PGlobjfuncs
Enumeraciones
enum	PGAsyncStatusType {   PGASYNC_IDLE, PGASYNC_BUSY, PGASYNC_READY, PGASYNC_COPY_IN,   PGASYNC_COPY_OUT }
enum	PGQueryClass { PGQUERY_SIMPLE, PGQUERY_EXTENDED, PGQUERY_PREPARE }
enum	PGSetenvStatusType {   SETENV_STATE_OPTION_SEND, SETENV_STATE_OPTION_WAIT, SETENV_STATE_QUERY1_SEND, SETENV_STATE_QUERY1_WAIT,   SETENV_STATE_QUERY2_SEND, SETENV_STATE_QUERY2_WAIT, SETENV_STATE_IDLE }
Funciones
int	pqPacketSend (PGconn *conn, char pack_type, const void *buf, size_t buf_len)
bool	pqGetHomeDirectory (char *buf, int bufsize)
void	pqSetResultError (PGresult *res, const char *msg)
void	pqCatenateResultError (PGresult *res, const char *msg)
void *	pqResultAlloc (PGresult *res, size_t nBytes, bool isBinary)
char *	pqResultStrdup (PGresult *res, const char *str)
void	pqClearAsyncResult (PGconn *conn)
void	pqSaveErrorResult (PGconn *conn)
PGresult *	pqPrepareAsyncResult (PGconn *conn)
void	pqInternalNotice (const PGNoticeHooks *hooks, const char *fmt,...) __attribute__((format(printf
void int	pqAddTuple (PGresult *res, PGresAttValue *tup)
void	pqSaveMessageField (PGresult *res, char code, const char *value)
void	pqSaveParameterStatus (PGconn *conn, const char *name, const char *value)
void	pqHandleSendFailure (PGconn *conn)
PostgresPollingStatusType	pqSetenvPoll (PGconn *conn)
char *	pqBuildStartupPacket2 (PGconn *conn, int *packetlen, const PQEnvironmentOption *options)
void	pqParseInput2 (PGconn *conn)
int	pqGetCopyData2 (PGconn *conn, char **buffer, int async)
int	pqGetline2 (PGconn *conn, char *s, int maxlen)
int	pqGetlineAsync2 (PGconn *conn, char *buffer, int bufsize)
int	pqEndcopy2 (PGconn *conn)
PGresult *	pqFunctionCall2 (PGconn *conn, Oid fnid, int *result_buf, int *actual_result_len, int result_is_int, const PQArgBlock *args, int nargs)
char *	pqBuildStartupPacket3 (PGconn *conn, int *packetlen, const PQEnvironmentOption *options)
void	pqParseInput3 (PGconn *conn)
int	pqGetErrorNotice3 (PGconn *conn, bool isError)
int	pqGetCopyData3 (PGconn *conn, char **buffer, int async)
int	pqGetline3 (PGconn *conn, char *s, int maxlen)
int	pqGetlineAsync3 (PGconn *conn, char *buffer, int bufsize)
int	pqEndcopy3 (PGconn *conn)
PGresult *	pqFunctionCall3 (PGconn *conn, Oid fnid, int *result_buf, int *actual_result_len, int result_is_int, const PQArgBlock *args, int nargs)
int	pqCheckOutBufferSpace (int bytes_needed, PGconn *conn)
int	pqCheckInBufferSpace (int bytes_needed, PGconn *conn)
int	pqGetc (char *result, PGconn *conn)
int	pqPutc (char c, PGconn *conn)
int	pqGets (PQExpBuffer buf, PGconn *conn)
int	pqPuts (const char *s, PGconn *conn)
int	pqGetnchar (char *s, size_t len, PGconn *conn)
int	pqPutnchar (const char *s, size_t len, PGconn *conn)
int	pqGetInt (int *result, size_t bytes, PGconn *conn)
int	pqPutInt (int value, size_t bytes, PGconn *conn)
int	pqPutMsgStart (char msg_type, bool force_len, PGconn *conn)
int	pqPutMsgEnd (PGconn *conn)
int	pqReadData (PGconn *conn)
int	pqFlush (PGconn *conn)
int	pqWait (int forRead, int forWrite, PGconn *conn)
int	pqWaitTimed (int forRead, int forWrite, PGconn *conn, time_t finish_time)
int	pqReadReady (PGconn *conn)
int	pqWriteReady (PGconn *conn)
int	pqsecure_initialize (PGconn *)
void	pqsecure_destroy (void)
PostgresPollingStatusType	pqsecure_open_client (PGconn *)
void	pqsecure_close (PGconn *)
ssize_t	pqsecure_read (PGconn *, void *ptr, size_t len)
ssize_t	pqsecure_write (PGconn *, const void *ptr, size_t len)
int	pq_block_sigpipe (sigset_t *osigset, bool *sigpipe_pending)
void	pq_reset_sigpipe (sigset_t *osigset, bool sigpipe_pending, bool got_epipe)
Variables
char *const	pgresStatus []
pgthreadlock_t	pg_g_threadlock

---

Documentación de los 'defines'

#define CMDSTATUS_LEN   40

#define libpq_gettext

(

x

)

(x)

#define NULL_LEN   (-1)

#define pglock_thread

(

)

pg_g_threadlock(true)

#define pgunlock_thread

(

)

pg_g_threadlock(false)

#define PQERRORMSG_LENGTH   1024

#define pqIsnonblocking

(

conn

)

((conn)->nonblocking)

#define SOCK_ERRNO   errno

#define SOCK_ERRNO_SET

(

e

)

(errno = (e))

#define SOCK_STRERROR   pqStrerror

---

Documentación de los 'typedefs'

typedef struct pgLobjfuncs PGlobjfuncs

typedef struct pgMessageField PGMessageField

typedef struct pgParameterStatus pgParameterStatus

typedef struct pgresAttDesc PGresAttDesc

typedef struct pgresAttValue PGresAttValue

typedef union pgresult_data PGresult_data

typedef struct PQEnvironmentOption PQEnvironmentOption

---

Documentación de las enumeraciones

enum PGAsyncStatusType

Valores de enumeraciones:

PGASYNC_IDLE
PGASYNC_BUSY
PGASYNC_READY
PGASYNC_COPY_IN
PGASYNC_COPY_OUT

enum PGQueryClass

Valores de enumeraciones:

PGQUERY_SIMPLE
PGQUERY_EXTENDED
PGQUERY_PREPARE

enum PGSetenvStatusType

Valores de enumeraciones:

SETENV_STATE_OPTION_SEND
SETENV_STATE_OPTION_WAIT
SETENV_STATE_QUERY1_SEND
SETENV_STATE_QUERY1_WAIT
SETENV_STATE_QUERY2_SEND
SETENV_STATE_QUERY2_WAIT
SETENV_STATE_IDLE

---

Documentación de las funciones

int pq_block_sigpipe	(	sigset_t *	osigset,
		bool *	sigpipe_pending
	)

void pq_reset_sigpipe	(	sigset_t *	osigset,
		bool	sigpipe_pending,
		bool	got_epipe
	)

void int pqAddTuple	(	PGresult *	res,
		PGresAttValue *	tup
	)

char* pqBuildStartupPacket2	(	PGconn *	conn,
		int *	packetlen,
		const PQEnvironmentOption *	options
	)

char* pqBuildStartupPacket3	(	PGconn *	conn,
		int *	packetlen,
		const PQEnvironmentOption *	options
	)

void pqCatenateResultError	(	PGresult *	res,
		const char *	msg
	)

int pqCheckInBufferSpace	(	int	bytes_needed,
		PGconn *	conn
	)

int pqCheckOutBufferSpace	(	int	bytes_needed,
		PGconn *	conn
	)

void pqClearAsyncResult

(

PGconn *

conn

)

int pqEndcopy2

(

PGconn *

conn

)

int pqEndcopy3

(

PGconn *

conn

)

int pqFlush

(

PGconn *

conn

)

PGresult* pqFunctionCall2	(	PGconn *	conn,
		Oid	fnid,
		int *	result_buf,
		int *	actual_result_len,
		int	result_is_int,
		const PQArgBlock *	args,
		int	nargs
	)

PGresult* pqFunctionCall3	(	PGconn *	conn,
		Oid	fnid,
		int *	result_buf,
		int *	actual_result_len,
		int	result_is_int,
		const PQArgBlock *	args,
		int	nargs
	)

int pqGetc	(	char *	result,
		PGconn *	conn
	)

int pqGetCopyData2	(	PGconn *	conn,
		char **	buffer,
		int	async
	)

int pqGetCopyData3	(	PGconn *	conn,
		char **	buffer,
		int	async
	)

int pqGetErrorNotice3	(	PGconn *	conn,
		bool	isError
	)

bool pqGetHomeDirectory	(	char *	buf,
		int	bufsize
	)

int pqGetInt	(	int *	result,
		size_t	bytes,
		PGconn *	conn
	)

int pqGetline2	(	PGconn *	conn,
		char *	s,
		int	maxlen
	)

int pqGetline3	(	PGconn *	conn,
		char *	s,
		int	maxlen
	)

int pqGetlineAsync2	(	PGconn *	conn,
		char *	buffer,
		int	bufsize
	)

int pqGetlineAsync3	(	PGconn *	conn,
		char *	buffer,
		int	bufsize
	)

int pqGetnchar	(	char *	s,
		size_t	len,
		PGconn *	conn
	)

int pqGets	(	PQExpBuffer	buf,
		PGconn *	conn
	)

void pqHandleSendFailure

(

PGconn *

conn

)

void pqInternalNotice	(	const PGNoticeHooks *	hooks,
		const char *	fmt,
			...
	)

int pqPacketSend	(	PGconn *	conn,
		char	pack_type,
		const void *	buf,
		size_t	buf_len
	)

void pqParseInput2

(

PGconn *

conn

)

void pqParseInput3

(

PGconn *

conn

)

PGresult* pqPrepareAsyncResult

(

PGconn *

conn

)

int pqPutc	(	char	c,
		PGconn *	conn
	)

int pqPutInt	(	int	value,
		size_t	bytes,
		PGconn *	conn
	)

int pqPutMsgEnd

(

PGconn *

conn

)

int pqPutMsgStart	(	char	msg_type,
		bool	force_len,
		PGconn *	conn
	)

int pqPutnchar	(	const char *	s,
		size_t	len,
		PGconn *	conn
	)

int pqPuts	(	const char *	s,
		PGconn *	conn
	)

int pqReadData

(

PGconn *

conn

)

int pqReadReady

(

PGconn *

conn

)

void* pqResultAlloc	(	PGresult *	res,
		size_t	nBytes,
		bool	isBinary
	)

char* pqResultStrdup	(	PGresult *	res,
		const char *	str
	)

void pqSaveErrorResult

(

PGconn *

conn

)

void pqSaveMessageField	(	PGresult *	res,
		char	code,
		const char *	value
	)

void pqSaveParameterStatus	(	PGconn *	conn,
		const char *	name,
		const char *	value
	)

void pqsecure_close

(

PGconn *

)

void pqsecure_destroy

(

void

)

int pqsecure_initialize

(

PGconn *

)

PostgresPollingStatusType pqsecure_open_client

(

PGconn *

)

ssize_t pqsecure_read	(	PGconn *	,
		void *	ptr,
		size_t	len
	)

ssize_t pqsecure_write	(	PGconn *	,
		const void *	ptr,
		size_t	len
	)

PostgresPollingStatusType pqSetenvPoll

(

PGconn *

conn

)

void pqSetResultError	(	PGresult *	res,
		const char *	msg
	)

int pqWait	(	int	forRead,
		int	forWrite,
		PGconn *	conn
	)

int pqWaitTimed	(	int	forRead,
		int	forWrite,
		PGconn *	conn,
		time_t	finish_time
	)

int pqWriteReady

(

PGconn *

conn

)

---

Documentación de las variables

pgthreadlock_t pg_g_threadlock

char* const pgresStatus[]