#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:

Macros
#define	PG_GETARG_LSN(n) DatumGetLSN(PG_GETARG_DATUM(n))

#define	PG_RETURN_LSN(x) return LSNGetDatum(x)

Functions
static XLogRecPtr	DatumGetLSN (Datum X)

static Datum	LSNGetDatum (XLogRecPtr X)

XLogRecPtr	pg_lsn_in_internal (const char str, bool have_error)

Macro Definition Documentation

◆ PG_GETARG_LSN

#define PG_GETARG_LSN ( n ) DatumGetLSN(PG_GETARG_DATUM(n))

Definition at line 33 of file pg_lsn.h.

◆ PG_RETURN_LSN

#define PG_RETURN_LSN ( x ) return LSNGetDatum(x)

Definition at line 34 of file pg_lsn.h.

Function Documentation

◆ DatumGetLSN()

static XLogRecPtr DatumGetLSN ( Datum X )

inlinestatic

Definition at line 22 of file pg_lsn.h.

 {
     return (XLogRecPtr) DatumGetInt64(X);
 }

References DatumGetInt64().

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

◆ LSNGetDatum()

static Datum LSNGetDatum ( XLogRecPtr X )

inlinestatic

Definition at line 28 of file pg_lsn.h.

 {
     return Int64GetDatum((int64) X);
 }

References Int64GetDatum().

Referenced by AddSubscriptionRelState(), AlterSubscription(), clear_subscription_skip_lsn(), copy_replication_slot(), CreateSubscription(), GetWALFPIInfo(), GetWALRecordInfo(), gist_page_opaque_info(), LogicalOutputWrite(), page_header(), pg_backup_stop(), 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(), and UpdateSubscriptionRelState().

◆ pg_lsn_in_internal()

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

Definition at line 30 of file pg_lsn.c.

 {
     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;
 }

References Assert(), InvalidXLogRecPtr, MAXPG_LSNCOMPONENT, and generate_unaccent_rules::str.

Referenced by check_recovery_target_lsn(), and pg_lsn_in().

Macros