pg_lsn.h File Reference

#include "access/xlogdefs.h"
#include "fmgr.h"

Include dependency graph for pg_lsn.h:

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

Go to the source code of this file.

Macros
#define	DatumGetLSN(X)   ((XLogRecPtr) DatumGetInt64(X))
#define	LSNGetDatum(X)   (Int64GetDatum((int64) (X)))
#define	PG_GETARG_LSN(n)   DatumGetLSN(PG_GETARG_DATUM(n))
#define	PG_RETURN_LSN(x)   return LSNGetDatum(x)

Functions
XLogRecPtr	pg_lsn_in_internal (const char *str, bool *have_error)

Macro Definition Documentation

DatumGetLSN

#define DatumGetLSN

(

X

)

((XLogRecPtr) DatumGetInt64(X))

Definition at line 21 of file pg_lsn.h.

Referenced by GetSubscriptionNotReadyRelations(), GetSubscriptionRelations(), GetSubscriptionRelState(), and libpqrcv_create_slot().

LSNGetDatum

#define LSNGetDatum

(

X

)

(Int64GetDatum((int64) (X)))

Definition at line 22 of file pg_lsn.h.

Referenced by AddSubscriptionRelState(), copy_replication_slot(), gist_page_opaque_info(), LogicalOutputWrite(), page_header(), pg_control_checkpoint(), pg_control_recovery(), pg_create_logical_replication_slot(), pg_create_physical_replication_slot(), pg_get_replication_slots(), pg_replication_slot_advance(), pg_show_replication_origin_status(), pg_stat_get_subscription(), pg_stat_get_wal_receiver(), pg_stat_get_wal_senders(), pg_stop_backup_v2(), and UpdateSubscriptionRelState().

PG_GETARG_LSN

#define PG_GETARG_LSN

(

n

)

DatumGetLSN(PG_GETARG_DATUM(n))

Definition at line 24 of file pg_lsn.h.

Referenced by brin_minmax_multi_distance_pg_lsn(), pg_logical_slot_get_changes_guts(), pg_lsn_cmp(), pg_lsn_eq(), pg_lsn_ge(), pg_lsn_gt(), pg_lsn_larger(), pg_lsn_le(), pg_lsn_lt(), pg_lsn_mi(), pg_lsn_mii(), pg_lsn_ne(), pg_lsn_out(), pg_lsn_pli(), pg_lsn_send(), pg_lsn_smaller(), pg_replication_origin_advance(), pg_replication_origin_xact_setup(), pg_replication_slot_advance(), pg_walfile_name(), and pg_walfile_name_offset().

PG_RETURN_LSN

#define PG_RETURN_LSN

(

x

)

return LSNGetDatum(x)

Definition at line 25 of file pg_lsn.h.

Referenced by numeric_pg_lsn(), pg_create_restore_point(), pg_current_wal_flush_lsn(), pg_current_wal_insert_lsn(), pg_current_wal_lsn(), pg_last_wal_receive_lsn(), pg_last_wal_replay_lsn(), pg_logical_emit_message_bytea(), pg_lsn_in(), pg_lsn_larger(), pg_lsn_recv(), pg_lsn_smaller(), pg_replication_origin_progress(), pg_replication_origin_session_progress(), pg_start_backup(), pg_stop_backup(), and pg_switch_wal().

Function Documentation

pg_lsn_in_internal()

XLogRecPtr pg_lsn_in_internal	(	const char *	str,
		bool *	have_error
	)

Definition at line 30 of file pg_lsn.c.

References Assert, InvalidXLogRecPtr, and MAXPG_LSNCOMPONENT.

Referenced by check_recovery_target_lsn(), and pg_lsn_in().

{
    int         len1,
                len2;
    uint32      id,
                off;
    XLogRecPtr  result;

    Assert(have_error != NULL);
    *have_error = false;

    /* Sanity check input format. */
    len1 = strspn(str, "0123456789abcdefABCDEF");
    if (len1 < 1 || len1 > MAXPG_LSNCOMPONENT || str[len1] != '/')
    {
        *have_error = true;
        return InvalidXLogRecPtr;
    }
    len2 = strspn(str + len1 + 1, "0123456789abcdefABCDEF");
    if (len2 < 1 || len2 > MAXPG_LSNCOMPONENT || str[len1 + 1 + len2] != '\0')
    {
        *have_error = true;
        return InvalidXLogRecPtr;
    }

    /* Decode result. */
    id = (uint32) strtoul(str, NULL, 16);
    off = (uint32) strtoul(str + len1 + 1, NULL, 16);
    result = ((uint64) id << 32) | off;

    return result;
}