pg_lsn.c File Reference

#include "postgres.h"
#include "libpq/pqformat.h"
#include "utils/fmgrprotos.h"
#include "utils/numeric.h"
#include "utils/pg_lsn.h"

Include dependency graph for pg_lsn.c:

Go to the source code of this file.

Macros
#define	MAXPG_LSNLEN   17
#define	MAXPG_LSNCOMPONENT   8

Functions
XLogRecPtr	pg_lsn_in_safe (const char *str, Node *escontext)
Datum	pg_lsn_in (PG_FUNCTION_ARGS)
Datum	pg_lsn_out (PG_FUNCTION_ARGS)
Datum	pg_lsn_recv (PG_FUNCTION_ARGS)
Datum	pg_lsn_send (PG_FUNCTION_ARGS)
Datum	pg_lsn_eq (PG_FUNCTION_ARGS)
Datum	pg_lsn_ne (PG_FUNCTION_ARGS)
Datum	pg_lsn_lt (PG_FUNCTION_ARGS)
Datum	pg_lsn_gt (PG_FUNCTION_ARGS)
Datum	pg_lsn_le (PG_FUNCTION_ARGS)
Datum	pg_lsn_ge (PG_FUNCTION_ARGS)
Datum	pg_lsn_larger (PG_FUNCTION_ARGS)
Datum	pg_lsn_smaller (PG_FUNCTION_ARGS)
Datum	pg_lsn_cmp (PG_FUNCTION_ARGS)
Datum	pg_lsn_hash (PG_FUNCTION_ARGS)
Datum	pg_lsn_hash_extended (PG_FUNCTION_ARGS)
Datum	pg_lsn_mi (PG_FUNCTION_ARGS)
Datum	pg_lsn_pli (PG_FUNCTION_ARGS)
Datum	pg_lsn_mii (PG_FUNCTION_ARGS)

Macro Definition Documentation

MAXPG_LSNCOMPONENT

#define MAXPG_LSNCOMPONENT   8

Definition at line 22 of file pg_lsn.c.

MAXPG_LSNLEN

#define MAXPG_LSNLEN   17

Definition at line 21 of file pg_lsn.c.

Function Documentation

pg_lsn_cmp()

Datum pg_lsn_cmp

(

PG_FUNCTION_ARGS

)

Definition at line 186 of file pg_lsn.c.

{
    XLogRecPtr  a = PG_GETARG_LSN(0);
    XLogRecPtr  b = PG_GETARG_LSN(1);
 
    if (a > b)
        PG_RETURN_INT32(1);
    else if (a == b)
        PG_RETURN_INT32(0);
    else
        PG_RETURN_INT32(-1);
}

References a, b, PG_GETARG_LSN, and PG_RETURN_INT32.

pg_lsn_eq()

Datum pg_lsn_eq

(

PG_FUNCTION_ARGS

)

Definition at line 113 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_BOOL(lsn1 == lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_BOOL.

pg_lsn_ge()

Datum pg_lsn_ge

(

PG_FUNCTION_ARGS

)

Definition at line 158 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_BOOL(lsn1 >= lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_BOOL.

pg_lsn_gt()

Datum pg_lsn_gt

(

PG_FUNCTION_ARGS

)

Definition at line 140 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_BOOL(lsn1 > lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_BOOL.

pg_lsn_hash()

Datum pg_lsn_hash

(

PG_FUNCTION_ARGS

)

Definition at line 201 of file pg_lsn.c.

{
    /* We can use hashint8 directly */
    return hashint8(fcinfo);
}

References hashint8().

pg_lsn_hash_extended()

Datum pg_lsn_hash_extended

(

PG_FUNCTION_ARGS

)

Definition at line 208 of file pg_lsn.c.

{
    return hashint8extended(fcinfo);
}

References hashint8extended().

pg_lsn_in()

Datum pg_lsn_in

(

PG_FUNCTION_ARGS

)

Definition at line 64 of file pg_lsn.c.

{
    char       *str = PG_GETARG_CSTRING(0);
    XLogRecPtr  result;
 
    result = pg_lsn_in_safe(str, fcinfo->context);
 
    PG_RETURN_LSN(result);
}

References PG_GETARG_CSTRING, pg_lsn_in_safe(), PG_RETURN_LSN, and str.

Referenced by libpqrcv_create_slot(), and parse_subscription_options().

pg_lsn_in_safe()

XLogRecPtr pg_lsn_in_safe	(	const char *	str,
		Node *	escontext
	)

Definition at line 32 of file pg_lsn.c.

{
    int         len1,
                len2;
    uint32      id,
                off;
    XLogRecPtr  result;
 
    /* Sanity check input format. */
    len1 = strspn(str, "0123456789abcdefABCDEF");
    if (len1 < 1 || len1 > MAXPG_LSNCOMPONENT || str[len1] != '/')
        goto syntax_error;
 
    len2 = strspn(str + len1 + 1, "0123456789abcdefABCDEF");
    if (len2 < 1 || len2 > MAXPG_LSNCOMPONENT || str[len1 + 1 + len2] != '\0')
        goto syntax_error;
 
    /* Decode result. */
    id = (uint32) strtoul(str, NULL, 16);
    off = (uint32) strtoul(str + len1 + 1, NULL, 16);
    result = ((uint64) id << 32) | off;
 
    return result;
 
syntax_error:
    ereturn(escontext, InvalidXLogRecPtr,
            (errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
             errmsg("invalid input syntax for type %s: \"%s\"",
                    "pg_lsn", str)));
}

References ereturn, errcode(), errmsg(), InvalidXLogRecPtr, MAXPG_LSNCOMPONENT, str, and syntax_error().

Referenced by check_recovery_target_lsn(), and pg_lsn_in().

pg_lsn_larger()

Datum pg_lsn_larger

(

PG_FUNCTION_ARGS

)

Definition at line 167 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_LSN((lsn1 > lsn2) ? lsn1 : lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_LSN.

pg_lsn_le()

Datum pg_lsn_le

(

PG_FUNCTION_ARGS

)

Definition at line 149 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_BOOL(lsn1 <= lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_BOOL.

pg_lsn_lt()

Datum pg_lsn_lt

(

PG_FUNCTION_ARGS

)

Definition at line 131 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_BOOL(lsn1 < lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_BOOL.

pg_lsn_mi()

Datum pg_lsn_mi

(

PG_FUNCTION_ARGS

)

Definition at line 219 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
    char        buf[256];
    Datum       result;
 
    /* Output could be as large as plus or minus 2^63 - 1. */
    if (lsn1 < lsn2)
        snprintf(buf, sizeof buf, "-" UINT64_FORMAT, lsn2 - lsn1);
    else
        snprintf(buf, sizeof buf, UINT64_FORMAT, lsn1 - lsn2);
 
    /* Convert to numeric. */
    result = DirectFunctionCall3(numeric_in,
                                 CStringGetDatum(buf),
                                 ObjectIdGetDatum(0),
                                 Int32GetDatum(-1));
 
    return result;
}

References buf, CStringGetDatum(), DirectFunctionCall3, Int32GetDatum(), numeric_in(), ObjectIdGetDatum(), PG_GETARG_LSN, snprintf, and UINT64_FORMAT.

Referenced by pg_wal_lsn_diff().

pg_lsn_mii()

Datum pg_lsn_mii

(

PG_FUNCTION_ARGS

)

Definition at line 280 of file pg_lsn.c.

{
    XLogRecPtr  lsn = PG_GETARG_LSN(0);
    Numeric     nbytes = PG_GETARG_NUMERIC(1);
    Datum       num;
    Datum       res;
    char        buf[32];
 
    if (numeric_is_nan(nbytes))
        ereport(ERROR,
                (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                 errmsg("cannot subtract NaN from pg_lsn")));
 
    /* Convert to numeric */
    snprintf(buf, sizeof(buf), UINT64_FORMAT, lsn);
    num = DirectFunctionCall3(numeric_in,
                              CStringGetDatum(buf),
                              ObjectIdGetDatum(0),
                              Int32GetDatum(-1));
 
    /* Subtract two numerics */
    res = DirectFunctionCall2(numeric_sub,
                              num,
                              NumericGetDatum(nbytes));
 
    /* Convert to pg_lsn */
    return DirectFunctionCall1(numeric_pg_lsn, res);
}

References buf, CStringGetDatum(), DirectFunctionCall1, DirectFunctionCall2, DirectFunctionCall3, ereport, errcode(), errmsg(), ERROR, Int32GetDatum(), numeric_in(), numeric_is_nan(), numeric_pg_lsn(), numeric_sub(), NumericGetDatum(), ObjectIdGetDatum(), PG_GETARG_LSN, PG_GETARG_NUMERIC, snprintf, and UINT64_FORMAT.

pg_lsn_ne()

Datum pg_lsn_ne

(

PG_FUNCTION_ARGS

)

Definition at line 122 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_BOOL(lsn1 != lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_BOOL.

pg_lsn_out()

Datum pg_lsn_out

(

PG_FUNCTION_ARGS

)

Definition at line 75 of file pg_lsn.c.

{
    XLogRecPtr  lsn = PG_GETARG_LSN(0);
    char        buf[MAXPG_LSNLEN + 1];
    char       *result;
 
    snprintf(buf, sizeof buf, "%X/%08X", LSN_FORMAT_ARGS(lsn));
    result = pstrdup(buf);
    PG_RETURN_CSTRING(result);
}

References buf, LSN_FORMAT_ARGS, MAXPG_LSNLEN, PG_GETARG_LSN, PG_RETURN_CSTRING, pstrdup(), and snprintf.

pg_lsn_pli()

Datum pg_lsn_pli

(

PG_FUNCTION_ARGS

)

Definition at line 246 of file pg_lsn.c.

{
    XLogRecPtr  lsn = PG_GETARG_LSN(0);
    Numeric     nbytes = PG_GETARG_NUMERIC(1);
    Datum       num;
    Datum       res;
    char        buf[32];
 
    if (numeric_is_nan(nbytes))
        ereport(ERROR,
                (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                 errmsg("cannot add NaN to pg_lsn")));
 
    /* Convert to numeric */
    snprintf(buf, sizeof(buf), UINT64_FORMAT, lsn);
    num = DirectFunctionCall3(numeric_in,
                              CStringGetDatum(buf),
                              ObjectIdGetDatum(0),
                              Int32GetDatum(-1));
 
    /* Add two numerics */
    res = DirectFunctionCall2(numeric_add,
                              num,
                              NumericGetDatum(nbytes));
 
    /* Convert to pg_lsn */
    return DirectFunctionCall1(numeric_pg_lsn, res);
}

References buf, CStringGetDatum(), DirectFunctionCall1, DirectFunctionCall2, DirectFunctionCall3, ereport, errcode(), errmsg(), ERROR, Int32GetDatum(), numeric_add(), numeric_in(), numeric_is_nan(), numeric_pg_lsn(), NumericGetDatum(), ObjectIdGetDatum(), PG_GETARG_LSN, PG_GETARG_NUMERIC, snprintf, and UINT64_FORMAT.

pg_lsn_recv()

Datum pg_lsn_recv

(

PG_FUNCTION_ARGS

)

Definition at line 87 of file pg_lsn.c.

{
    StringInfo  buf = (StringInfo) PG_GETARG_POINTER(0);
    XLogRecPtr  result;
 
    result = pq_getmsgint64(buf);
    PG_RETURN_LSN(result);
}

References buf, PG_GETARG_POINTER, PG_RETURN_LSN, and pq_getmsgint64().

pg_lsn_send()

Datum pg_lsn_send

(

PG_FUNCTION_ARGS

)

Definition at line 97 of file pg_lsn.c.

{
    XLogRecPtr  lsn = PG_GETARG_LSN(0);
    StringInfoData buf;
 
    pq_begintypsend(&buf);
    pq_sendint64(&buf, lsn);
    PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
}

References buf, PG_GETARG_LSN, PG_RETURN_BYTEA_P, pq_begintypsend(), pq_endtypsend(), and pq_sendint64().

pg_lsn_smaller()

Datum pg_lsn_smaller

(

PG_FUNCTION_ARGS

)

Definition at line 176 of file pg_lsn.c.

{
    XLogRecPtr  lsn1 = PG_GETARG_LSN(0);
    XLogRecPtr  lsn2 = PG_GETARG_LSN(1);
 
    PG_RETURN_LSN((lsn1 < lsn2) ? lsn1 : lsn2);
}

References PG_GETARG_LSN, and PG_RETURN_LSN.