oauth-utils.h File Reference

#include "libpq-fe.h"
#include "pqexpbuffer.h"

Include dependency graph for oauth-utils.h:

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

Go to the source code of this file.

Macros
#define	libpq_gettext(x)   (x)
#define	pglock_thread()   pg_g_threadlock(true)
#define	pgunlock_thread()   pg_g_threadlock(false)

Typedefs
typedef char *(*	libpq_gettext_func) (const char *msgid)

Enumerations
enum	PGTernaryBool { PG_BOOL_UNKNOWN = 0 , PG_BOOL_YES , PG_BOOL_NO }

Functions
PGDLLEXPORT void	libpq_oauth_init (libpq_gettext_func gettext_impl)
bool	oauth_unsafe_debugging_enabled (void)
int	pq_block_sigpipe (sigset_t *osigset, bool *sigpipe_pending)
void	pq_reset_sigpipe (sigset_t *osigset, bool sigpipe_pending, bool got_epipe)

Variables
pgthreadlock_t	pg_g_threadlock

Macro Definition Documentation

libpq_gettext

#define libpq_gettext

(

x

)

(x)

Definition at line 45 of file oauth-utils.h.

pglock_thread

#define pglock_thread

(

)

pg_g_threadlock(true)

Definition at line 50 of file oauth-utils.h.

pgunlock_thread

#define pgunlock_thread

(

)

pg_g_threadlock(false)

Definition at line 51 of file oauth-utils.h.

Typedef Documentation

libpq_gettext_func

typedef char *(* libpq_gettext_func) (const char *msgid)

Definition at line 21 of file oauth-utils.h.

Enumeration Type Documentation

PGTernaryBool

enum PGTernaryBool

Enumerator
PG_BOOL_UNKNOWN
PG_BOOL_YES
PG_BOOL_NO

Definition at line 31 of file oauth-utils.h.

{
    PG_BOOL_UNKNOWN = 0,        /* Currently unknown */
    PG_BOOL_YES,                /* Yes (true) */
    PG_BOOL_NO                  /* No (false) */
} PGTernaryBool;

Function Documentation

libpq_oauth_init()

PGDLLEXPORT void libpq_oauth_init ( libpq_gettext_func  gettext_impl )

extern

Definition at line 46 of file oauth-utils.c.

{
    pg_g_threadlock = PQgetThreadLock();
    libpq_gettext_impl = gettext_impl;
}

References fb(), libpq_gettext_impl, pg_g_threadlock, and PQgetThreadLock().

oauth_unsafe_debugging_enabled()

bool oauth_unsafe_debugging_enabled ( void  )

extern

Definition at line 82 of file oauth-utils.c.

{
    const char *env = getenv("PGOAUTHDEBUG");
 
    return (env && strcmp(env, "UNSAFE") == 0);
}

pq_block_sigpipe()

int pq_block_sigpipe ( sigset_t *  osigset, bool *  sigpipe_pending  )

extern

Definition at line 105 of file oauth-utils.c.

{
    sigset_t    sigpipe_sigset;
    sigset_t    sigset;
 
    sigemptyset(&sigpipe_sigset);
    sigaddset(&sigpipe_sigset, SIGPIPE);
 
    /* Block SIGPIPE and save previous mask for later reset */
    SOCK_ERRNO_SET(pthread_sigmask(SIG_BLOCK, &sigpipe_sigset, osigset));
    if (SOCK_ERRNO)
        return -1;
 
    /* We can have a pending SIGPIPE only if it was blocked before */
    if (sigismember(osigset, SIGPIPE))
    {
        /* Is there a pending SIGPIPE? */
        if (sigpending(&sigset) != 0)
            return -1;
 
        if (sigismember(&sigset, SIGPIPE))
            *sigpipe_pending = true;
        else
            *sigpipe_pending = false;
    }
    else
        *sigpipe_pending = false;
 
    return 0;
}

pq_reset_sigpipe()

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

extern

Definition at line 141 of file oauth-utils.c.

{
    int         save_errno = SOCK_ERRNO;
    int         signo;
    sigset_t    sigset;
 
    /* Clear SIGPIPE only if none was pending */
    if (got_epipe && !sigpipe_pending)
    {
        if (sigpending(&sigset) == 0 &&
            sigismember(&sigset, SIGPIPE))
        {
            sigset_t    sigpipe_sigset;
 
            sigemptyset(&sigpipe_sigset);
            sigaddset(&sigpipe_sigset, SIGPIPE);
 
            sigwait(&sigpipe_sigset, &signo);
        }
    }
 
    /* Restore saved block mask */
    pthread_sigmask(SIG_SETMASK, osigset, NULL);
 
    SOCK_ERRNO_SET(save_errno);
}

Variable Documentation

pg_g_threadlock

pgthreadlock_t pg_g_threadlock

extern

Definition at line 35 of file oauth-utils.c.