libpq-events.c File Reference

#include "postgres_fe.h"
#include "libpq-fe.h"
#include "libpq-int.h"

Include dependency graph for libpq-events.c:

Go to the source code of this file.

Functions
int	PQregisterEventProc (PGconn *conn, PGEventProc proc, const char *name, void *passThrough)
int	PQsetInstanceData (PGconn *conn, PGEventProc proc, void *data)
void *	PQinstanceData (const PGconn *conn, PGEventProc proc)
int	PQresultSetInstanceData (PGresult *result, PGEventProc proc, void *data)
void *	PQresultInstanceData (const PGresult *result, PGEventProc proc)
int	PQfireResultCreateEvents (PGconn *conn, PGresult *res)

Function Documentation

PQfireResultCreateEvents()

int PQfireResultCreateEvents	(	PGconn *	conn,
		PGresult *	res
	)

Definition at line 185 of file libpq-events.c.

{
    int         result = true;
    int         i;
 
    if (!res)
        return false;
 
    for (i = 0; i < res->nEvents; i++)
    {
        /* It's possible event was already fired, if so don't repeat it */
        if (!res->events[i].resultInitialized)
        {
            PGEventResultCreate evt;
 
            evt.conn = conn;
            evt.result = res;
            if (res->events[i].proc(PGEVT_RESULTCREATE, &evt,
                                    res->events[i].passThrough))
                res->events[i].resultInitialized = true;
            else
                result = false;
        }
    }
 
    return result;
}

References conn, PGEventResultCreate::conn, pg_result::events, i, pg_result::nEvents, PGEvent::passThrough, PGEVT_RESULTCREATE, PGEvent::proc, res, PGEventResultCreate::result, and PGEvent::resultInitialized.

Referenced by PQgetResult().

PQinstanceData()

void* PQinstanceData	(	const PGconn *	conn,
		PGEventProc	proc
	)

Definition at line 121 of file libpq-events.c.

{
    int         i;
 
    if (!conn || !proc)
        return NULL;
 
    for (i = 0; i < conn->nEvents; i++)
    {
        if (conn->events[i].proc == proc)
            return conn->events[i].data;
    }
 
    return NULL;
}

References conn, PGEvent::data, pg_conn::events, i, pg_conn::nEvents, and PGEvent::proc.

PQregisterEventProc()

int PQregisterEventProc	(	PGconn *	conn,
		PGEventProc	proc,
		const char *	name,
		void *	passThrough
	)

Definition at line 40 of file libpq-events.c.

{
    int         i;
    PGEventRegister regevt;
 
    if (!proc || !conn || !name || !*name)
        return false;           /* bad arguments */
 
    for (i = 0; i < conn->nEvents; i++)
    {
        if (conn->events[i].proc == proc)
            return false;       /* already registered */
    }
 
    if (conn->nEvents >= conn->eventArraySize)
    {
        PGEvent    *e;
        int         newSize;
 
        newSize = conn->eventArraySize ? conn->eventArraySize * 2 : 8;
        if (conn->events)
            e = (PGEvent *) realloc(conn->events, newSize * sizeof(PGEvent));
        else
            e = (PGEvent *) malloc(newSize * sizeof(PGEvent));
 
        if (!e)
            return false;
 
        conn->eventArraySize = newSize;
        conn->events = e;
    }
 
    conn->events[conn->nEvents].proc = proc;
    conn->events[conn->nEvents].name = strdup(name);
    if (!conn->events[conn->nEvents].name)
        return false;
    conn->events[conn->nEvents].passThrough = passThrough;
    conn->events[conn->nEvents].data = NULL;
    conn->events[conn->nEvents].resultInitialized = false;
    conn->nEvents++;
 
    regevt.conn = conn;
    if (!proc(PGEVT_REGISTER, &regevt, passThrough))
    {
        conn->nEvents--;
        free(conn->events[conn->nEvents].name);
        return false;
    }
 
    return true;
}

References conn, PGEventRegister::conn, PGEvent::data, pg_conn::eventArraySize, pg_conn::events, free, i, malloc, name, PGEvent::name, pg_conn::nEvents, PGEvent::passThrough, PGEVT_REGISTER, PGEvent::proc, realloc, and PGEvent::resultInitialized.

PQresultInstanceData()

void* PQresultInstanceData	(	const PGresult *	result,
		PGEventProc	proc
	)

Definition at line 165 of file libpq-events.c.

{
    int         i;
 
    if (!result || !proc)
        return NULL;
 
    for (i = 0; i < result->nEvents; i++)
        if (result->events[i].proc == proc)
            return result->events[i].data;
 
    return NULL;
}

References PGEvent::data, pg_result::events, i, pg_result::nEvents, and PGEvent::proc.

PQresultSetInstanceData()

int PQresultSetInstanceData	(	PGresult *	result,
		PGEventProc	proc,
		void *	data
	)

Definition at line 142 of file libpq-events.c.

{
    int         i;
 
    if (!result || !proc)
        return false;
 
    for (i = 0; i < result->nEvents; i++)
    {
        if (result->events[i].proc == proc)
        {
            result->events[i].data = data;
            return true;
        }
    }
 
    return false;
}

References PGEvent::data, data, pg_result::events, i, pg_result::nEvents, and PGEvent::proc.

PQsetInstanceData()

int PQsetInstanceData	(	PGconn *	conn,
		PGEventProc	proc,
		void *	data
	)

Definition at line 98 of file libpq-events.c.

{
    int         i;
 
    if (!conn || !proc)
        return false;
 
    for (i = 0; i < conn->nEvents; i++)
    {
        if (conn->events[i].proc == proc)
        {
            conn->events[i].data = data;
            return true;
        }
    }
 
    return false;
}

References conn, PGEvent::data, data, pg_conn::events, i, pg_conn::nEvents, and PGEvent::proc.