timestamp.h File Reference

#include "datatype/timestamp.h"
#include "fmgr.h"
#include "pgtime.h"

Include dependency graph for timestamp.h:

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

Go to the source code of this file.

Macros
#define	PG_GETARG_TIMESTAMP(n)   DatumGetTimestamp(PG_GETARG_DATUM(n))
#define	PG_GETARG_TIMESTAMPTZ(n)   DatumGetTimestampTz(PG_GETARG_DATUM(n))
#define	PG_GETARG_INTERVAL_P(n)   DatumGetIntervalP(PG_GETARG_DATUM(n))
#define	PG_RETURN_TIMESTAMP(x)   return TimestampGetDatum(x)
#define	PG_RETURN_TIMESTAMPTZ(x)   return TimestampTzGetDatum(x)
#define	PG_RETURN_INTERVAL_P(x)   return IntervalPGetDatum(x)
#define	TIMESTAMP_MASK(b)   (1 << (b))
#define	INTERVAL_MASK(b)   (1 << (b))
#define	INTERVAL_FULL_RANGE   (0x7FFF)
#define	INTERVAL_RANGE_MASK   (0x7FFF)
#define	INTERVAL_FULL_PRECISION   (0xFFFF)
#define	INTERVAL_PRECISION_MASK   (0xFFFF)
#define	INTERVAL_TYPMOD(p, r)   ((((r) & INTERVAL_RANGE_MASK) << 16) | ((p) & INTERVAL_PRECISION_MASK))
#define	INTERVAL_PRECISION(t)   ((t) & INTERVAL_PRECISION_MASK)
#define	INTERVAL_RANGE(t)   (((t) >> 16) & INTERVAL_RANGE_MASK)
#define	TimestampTzPlusMilliseconds(tz, ms)   ((tz) + ((ms) * (int64) 1000))
#define	TimestampTzPlusSeconds(tz, s)   ((tz) + ((s) * (int64) 1000000))
#define	timestamptz_cmp_internal(dt1, dt2)   timestamp_cmp_internal(dt1, dt2)

Functions
static Timestamp	DatumGetTimestamp (Datum X)
static TimestampTz	DatumGetTimestampTz (Datum X)
static Interval *	DatumGetIntervalP (Datum X)
static Datum	TimestampGetDatum (Timestamp X)
static Datum	TimestampTzGetDatum (TimestampTz X)
static Datum	IntervalPGetDatum (const Interval *X)
static uint64	TimestampDifferenceMicroseconds (TimestampTz start_time, TimestampTz stop_time)
int32	anytimestamp_typmod_check (bool istz, int32 typmod)
TimestampTz	GetCurrentTimestamp (void)
TimestampTz	GetSQLCurrentTimestamp (int32 typmod)
Timestamp	GetSQLLocalTimestamp (int32 typmod)
void	TimestampDifference (TimestampTz start_time, TimestampTz stop_time, long *secs, int *microsecs)
long	TimestampDifferenceMilliseconds (TimestampTz start_time, TimestampTz stop_time)
bool	TimestampDifferenceExceeds (TimestampTz start_time, TimestampTz stop_time, int msec)
bool	TimestampDifferenceExceedsSeconds (TimestampTz start_time, TimestampTz stop_time, int threshold_sec)
TimestampTz	time_t_to_timestamptz (pg_time_t tm)
pg_time_t	timestamptz_to_time_t (TimestampTz t)
const char *	timestamptz_to_str (TimestampTz t)
int	tm2timestamp (struct pg_tm *tm, fsec_t fsec, int *tzp, Timestamp *result)
int	timestamp2tm (Timestamp dt, int *tzp, struct pg_tm *tm, fsec_t *fsec, const char **tzn, pg_tz *attimezone)
void	dt2time (Timestamp jd, int *hour, int *min, int *sec, fsec_t *fsec)
void	interval2itm (Interval span, struct pg_itm *itm)
int	itm2interval (struct pg_itm *itm, Interval *span)
int	itmin2interval (struct pg_itm_in *itm_in, Interval *span)
Timestamp	SetEpochTimestamp (void)
void	GetEpochTime (struct pg_tm *tm)
int	timestamp_cmp_internal (Timestamp dt1, Timestamp dt2)
TimestampTz	timestamp2timestamptz_safe (Timestamp timestamp, Node *escontext)
Timestamp	timestamptz2timestamp_safe (TimestampTz timestamp, Node *escontext)
int32	timestamp_cmp_timestamptz_internal (Timestamp timestampVal, TimestampTz dt2)
int	isoweek2j (int year, int week)
void	isoweek2date (int woy, int *year, int *mon, int *mday)
void	isoweekdate2date (int isoweek, int wday, int *year, int *mon, int *mday)
int	date2isoweek (int year, int mon, int mday)
int	date2isoyear (int year, int mon, int mday)
int	date2isoyearday (int year, int mon, int mday)
bool	TimestampTimestampTzRequiresRewrite (void)

Variables
PGDLLIMPORT TimestampTz	PgStartTime
PGDLLIMPORT TimestampTz	PgReloadTime

Macro Definition Documentation

INTERVAL_FULL_PRECISION

#define INTERVAL_FULL_PRECISION   (0xFFFF)

Definition at line 78 of file timestamp.h.

INTERVAL_FULL_RANGE

#define INTERVAL_FULL_RANGE   (0x7FFF)

Definition at line 76 of file timestamp.h.

INTERVAL_MASK

#define INTERVAL_MASK

(

b

)

(1 << (b))

Definition at line 73 of file timestamp.h.

INTERVAL_PRECISION

#define INTERVAL_PRECISION

(

t

)

((t) & INTERVAL_PRECISION_MASK)

Definition at line 81 of file timestamp.h.

INTERVAL_PRECISION_MASK

#define INTERVAL_PRECISION_MASK   (0xFFFF)

Definition at line 79 of file timestamp.h.

INTERVAL_RANGE

#define INTERVAL_RANGE

(

t

)

(((t) >> 16) & INTERVAL_RANGE_MASK)

Definition at line 82 of file timestamp.h.

INTERVAL_RANGE_MASK

#define INTERVAL_RANGE_MASK   (0x7FFF)

Definition at line 77 of file timestamp.h.

INTERVAL_TYPMOD

#define INTERVAL_TYPMOD	(		p,
			r
	)		((((r) & INTERVAL_RANGE_MASK) << 16) | ((p) & INTERVAL_PRECISION_MASK))

Definition at line 80 of file timestamp.h.

PG_GETARG_INTERVAL_P

#define PG_GETARG_INTERVAL_P

(

n

)

DatumGetIntervalP(PG_GETARG_DATUM(n))

Definition at line 65 of file timestamp.h.

PG_GETARG_TIMESTAMP

#define PG_GETARG_TIMESTAMP

(

n

)

DatumGetTimestamp(PG_GETARG_DATUM(n))

Definition at line 63 of file timestamp.h.

PG_GETARG_TIMESTAMPTZ

#define PG_GETARG_TIMESTAMPTZ

(

n

)

DatumGetTimestampTz(PG_GETARG_DATUM(n))

Definition at line 64 of file timestamp.h.

PG_RETURN_INTERVAL_P

#define PG_RETURN_INTERVAL_P

(

x

)

return IntervalPGetDatum(x)

Definition at line 69 of file timestamp.h.

PG_RETURN_TIMESTAMP

#define PG_RETURN_TIMESTAMP

(

x

)

return TimestampGetDatum(x)

Definition at line 67 of file timestamp.h.

PG_RETURN_TIMESTAMPTZ

#define PG_RETURN_TIMESTAMPTZ

(

x

)

return TimestampTzGetDatum(x)

Definition at line 68 of file timestamp.h.

TIMESTAMP_MASK

#define TIMESTAMP_MASK

(

b

)

(1 << (b))

Definition at line 72 of file timestamp.h.

timestamptz_cmp_internal

#define timestamptz_cmp_internal	(		dt1,
			dt2
	)		timestamp_cmp_internal(dt1, dt2)

Definition at line 143 of file timestamp.h.

TimestampTzPlusMilliseconds

#define TimestampTzPlusMilliseconds	(		tz,
			ms
	)		((tz) + ((ms) * (int64) 1000))

Definition at line 85 of file timestamp.h.

TimestampTzPlusSeconds

#define TimestampTzPlusSeconds	(		tz,
			s
	)		((tz) + ((s) * (int64) 1000000))

Definition at line 86 of file timestamp.h.

Function Documentation

anytimestamp_typmod_check()

int32 anytimestamp_typmod_check ( bool  istz, int32  typmod  )

extern

Definition at line 125 of file timestamp.c.

{
    if (typmod < 0)
        ereport(ERROR,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("TIMESTAMP(%d)%s precision must not be negative",
                        typmod, (istz ? " WITH TIME ZONE" : ""))));
    if (typmod > MAX_TIMESTAMP_PRECISION)
    {
        ereport(WARNING,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("TIMESTAMP(%d)%s precision reduced to maximum allowed, %d",
                        typmod, (istz ? " WITH TIME ZONE" : ""),
                        MAX_TIMESTAMP_PRECISION)));
        typmod = MAX_TIMESTAMP_PRECISION;
    }
 
    return typmod;
}

References ereport, errcode(), errmsg(), ERROR, fb(), MAX_TIMESTAMP_PRECISION, and WARNING.

Referenced by anytimestamp_typmodin(), executeDateTimeMethod(), and transformSQLValueFunction().

date2isoweek()

int date2isoweek ( int  year, int  mon, int  mday  )

extern

Definition at line 5295 of file timestamp.c.

{
    int         day0,
                day4,
                dayn,
                week;
 
    /* current day */
    dayn = date2j(year, mon, mday);
 
    /* fourth day of current year */
    day4 = date2j(year, 1, 4);
 
    /* day0 == offset to first day of week (Monday) */
    day0 = j2day(day4 - 1);
 
    /*
     * We need the first week containing a Thursday, otherwise this day falls
     * into the previous year for purposes of counting weeks
     */
    if (dayn < day4 - day0)
    {
        day4 = date2j(year - 1, 1, 4);
 
        /* day0 == offset to first day of week (Monday) */
        day0 = j2day(day4 - 1);
    }
 
    week = (dayn - (day4 - day0)) / 7 + 1;
 
    /*
     * Sometimes the last few days in a year will fall into the first week of
     * the next year, so check for this.
     */
    if (week >= 52)
    {
        day4 = date2j(year + 1, 1, 4);
 
        /* day0 == offset to first day of week (Monday) */
        day0 = j2day(day4 - 1);
 
        if (dayn >= day4 - day0)
            week = (dayn - (day4 - day0)) / 7 + 1;
    }
 
    return week;
}

References date2j(), fb(), and j2day().

Referenced by DCH_to_char(), extract_date(), timestamp_part_common(), timestamp_trunc(), timestamptz_part_common(), and timestamptz_trunc_internal().

date2isoyear()

int date2isoyear ( int  year, int  mon, int  mday  )

extern

Definition at line 5350 of file timestamp.c.

{
    int         day0,
                day4,
                dayn,
                week;
 
    /* current day */
    dayn = date2j(year, mon, mday);
 
    /* fourth day of current year */
    day4 = date2j(year, 1, 4);
 
    /* day0 == offset to first day of week (Monday) */
    day0 = j2day(day4 - 1);
 
    /*
     * We need the first week containing a Thursday, otherwise this day falls
     * into the previous year for purposes of counting weeks
     */
    if (dayn < day4 - day0)
    {
        day4 = date2j(year - 1, 1, 4);
 
        /* day0 == offset to first day of week (Monday) */
        day0 = j2day(day4 - 1);
 
        year--;
    }
 
    week = (dayn - (day4 - day0)) / 7 + 1;
 
    /*
     * Sometimes the last few days in a year will fall into the first week of
     * the next year, so check for this.
     */
    if (week >= 52)
    {
        day4 = date2j(year + 1, 1, 4);
 
        /* day0 == offset to first day of week (Monday) */
        day0 = j2day(day4 - 1);
 
        if (dayn >= day4 - day0)
            year++;
    }
 
    return year;
}

References date2j(), fb(), and j2day().

Referenced by date2isoyearday(), DCH_to_char(), extract_date(), timestamp_part_common(), and timestamptz_part_common().

date2isoyearday()

int date2isoyearday ( int  year, int  mon, int  mday  )

extern

Definition at line 5407 of file timestamp.c.

{
    return date2j(year, mon, mday) - isoweek2j(date2isoyear(year, mon, mday), 1) + 1;
}

References date2isoyear(), date2j(), fb(), and isoweek2j().

Referenced by DCH_to_char().

DatumGetIntervalP()

static Interval * DatumGetIntervalP ( Datum  X )

inlinestatic

Definition at line 40 of file timestamp.h.

{
    return (Interval *) DatumGetPointer(X);
}

References DatumGetPointer(), and fb().

Referenced by abs_interval(), check_timezone(), convert_timevalue_to_scalar(), gbt_intv_compress(), gbt_time_dist(), gbt_time_penalty(), gbt_ts_dist(), generate_series_timestamp_support(), in_range_interval_interval(), interval_dist(), time_dist(), timestamp_mi(), ts_dist(), and tstz_dist().

DatumGetTimestamp()

static Timestamp DatumGetTimestamp ( Datum  X )

inlinestatic

Definition at line 28 of file timestamp.h.

{
    return (Timestamp) DatumGetInt64(X);
}

References DatumGetInt64(), and fb().

Referenced by compareDatetime(), convert_timevalue_to_scalar(), cvt_timestamp_date(), cvt_timestamp_timestamptz(), executeDateTimeMethod(), gbt_num_compress(), generate_series_timestamp(), generate_series_timestamp_support(), in_range_timestamp_interval(), JsonEncodeDateTime(), map_sql_value_to_xml_value(), timestamp_decrement(), and timestamp_increment().

DatumGetTimestampTz()

static TimestampTz DatumGetTimestampTz ( Datum  X )

inlinestatic

Definition at line 34 of file timestamp.h.

{
    return (TimestampTz) DatumGetInt64(X);
}

References DatumGetInt64(), and fb().

Referenced by compareDatetime(), convert_timevalue_to_scalar(), cvt_timestamptz_date(), cvt_timestamptz_timestamp(), executeDateTimeMethod(), gbt_tstz_compress(), get_role_password(), JsonEncodeDateTime(), uuidv7_interval(), and validateRecoveryParameters().

dt2time()

void dt2time ( Timestamp  jd, int *  hour, int *  min, int *  sec, fsec_t *  fsec  )

extern

Definition at line 1883 of file timestamp.c.

{
    TimeOffset  time;
 
    time = jd;
 
    *hour = time / USECS_PER_HOUR;
    time -= (*hour) * USECS_PER_HOUR;
    *min = time / USECS_PER_MINUTE;
    time -= (*min) * USECS_PER_MINUTE;
    *sec = time / USECS_PER_SEC;
    *fsec = time - (*sec * USECS_PER_SEC);
}                               /* dt2time() */

References fb(), USECS_PER_HOUR, USECS_PER_MINUTE, and USECS_PER_SEC.

Referenced by DecodeDateTime(), DecodeTimeOnly(), timestamp2tm(), and timestamp2tm().

GetCurrentTimestamp()

TimestampTz GetCurrentTimestamp ( void  )

extern

Definition at line 1645 of file timestamp.c.

{
    TimestampTz result;
    struct timeval tp;
 
    gettimeofday(&tp, NULL);
 
    result = (TimestampTz) tp.tv_sec -
        ((POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY);
    result = (result * USECS_PER_SEC) + tp.tv_usec;
 
    return result;
}

References fb(), gettimeofday(), POSTGRES_EPOCH_JDATE, SECS_PER_DAY, UNIX_EPOCH_JDATE, and USECS_PER_SEC.

Referenced by ApplyLauncherMain(), asyncQueueFillWarning(), autoprewarm_main(), AutoVacLauncherMain(), BackendStartup(), BackgroundWriterMain(), bbsink_copystream_archive_contents(), bbsink_copystream_end_archive(), bbsink_copystream_new(), bbsink_throttle_begin_backup(), check_log_duration(), CheckPointGuts(), CleanupBackend(), clock_timestamp(), CreateCheckPoint(), CreateEndOfRecoveryRecord(), CreateOverwriteContrecordRecord(), CreateRestartPoint(), dblink_cancel_query(), DetermineSleepTime(), disable_timeout(), disable_timeouts(), do_analyze_rel(), do_start_worker(), enable_startup_progress_timeout(), enable_timeout_after(), enable_timeout_at(), enable_timeout_every(), enable_timeouts(), entry_alloc(), entry_reset(), get_candidate_xid(), get_role_password(), GetCurrentTransactionStopTimestamp(), GetReplicationApplyDelay(), handle_sig_alarm(), has_startup_progress_timeout_expired(), heap_vacuum_rel(), initialize_prng(), InitProcessGlobals(), InvalidatePossiblyObsoleteSlot(), KnownAssignedXidsCompress(), launch_sync_worker(), launcher_determine_sleep(), libpqsrv_cancel(), LockBufferForCleanup(), log_disconnections(), LogCheckpointEnd(), logicalrep_worker_launch(), LogicalRepApplyLoop(), maybe_start_bgworkers(), pa_send_data(), PerformAuthentication(), PerformWalRecovery(), pg_sleep(), pgfdw_abort_cleanup_begin(), pgfdw_cancel_query(), pgfdw_exec_cleanup_query(), pgfdw_finish_abort_cleanup(), pgfdw_get_cleanup_result(), pgss_shmem_startup(), pgstat_build_snapshot(), pgstat_report_activity(), pgstat_report_analyze(), pgstat_report_archiver(), pgstat_report_autovac(), pgstat_report_checksum_failures_in_db(), pgstat_report_replslotsync(), pgstat_report_stat(), pgstat_report_vacuum(), pgstat_reset(), pgstat_reset_after_failure(), pgstat_reset_counters(), pgstat_reset_of_kind(), pgstat_reset_slru(), PostgresMain(), PostgresSingleUserMain(), postmaster_child_launch(), PostmasterMain(), PrepareTransaction(), ProcessConfigFileInternal(), ProcessPendingWrites(), ProcessRepliesIfAny(), ProcessStandbyPSRequestMessage(), ProcessStandbyReplyMessage(), ProcessWalSndrMessage(), ProcSleep(), rebuild_database_list(), RecordTransactionAbort(), RecordTransactionAbortPrepared(), RecordTransactionCommitPrepared(), recoveryApplyDelay(), ReplicationSlotRelease(), request_publisher_status(), reschedule_timeouts(), ResolveRecoveryConflictWithBufferPin(), ResolveRecoveryConflictWithLock(), ResolveRecoveryConflictWithVirtualXIDs(), RestoreSlotFromDisk(), send_feedback(), SetCurrentStatementStartTimestamp(), SetupApplyOrSyncWorker(), should_stop_conflict_info_retention(), StartBackgroundWorker(), StartTransaction(), test_pattern(), test_random(), test_random_operations(), throttle(), update_synced_slots_inactive_since(), UpdateWorkerStats(), wait_for_local_flush(), WaitExceedsMaxStandbyDelay(), WaitForLSN(), WaitForWalSummarization(), WaitForWALToBecomeAvailable(), WalReceiverMain(), WalSndKeepalive(), WalSndLoop(), WalSndUpdateProgress(), WalSndWaitForWal(), WalSndWriteData(), XLogBackgroundFlush(), XLogFileRead(), XLogPrefetchResetStats(), XLogPrefetchShmemInit(), XLogRestorePoint(), XLogSendPhysical(), XLogWalRcvSendHSFeedback(), and XLogWalRcvSendReply().

GetEpochTime()

void GetEpochTime ( struct pg_tm *  tm )

extern

Definition at line 2168 of file timestamp.c.

{
    struct pg_tm *t0;
    pg_time_t   epoch = 0;
 
    t0 = pg_gmtime(&epoch);
 
    if (t0 == NULL)
        elog(ERROR, "could not convert epoch to timestamp: %m");
 
    tm->tm_year = t0->tm_year;
    tm->tm_mon = t0->tm_mon;
    tm->tm_mday = t0->tm_mday;
    tm->tm_hour = t0->tm_hour;
    tm->tm_min = t0->tm_min;
    tm->tm_sec = t0->tm_sec;
 
    tm->tm_year += 1900;
    tm->tm_mon++;
}

References elog, epoch, ERROR, fb(), pg_gmtime(), tm, pg_tm::tm_hour, pg_tm::tm_mday, pg_tm::tm_min, pg_tm::tm_mon, pg_tm::tm_sec, and pg_tm::tm_year.

Referenced by date_in(), PGTYPESdate_from_asc(), SetEpochTimestamp(), and SetEpochTimestamp().

GetSQLCurrentTimestamp()

TimestampTz GetSQLCurrentTimestamp ( int32  typmod )

extern

Definition at line 1663 of file timestamp.c.

{
    TimestampTz ts;
 
    ts = GetCurrentTransactionStartTimestamp();
    if (typmod >= 0)
        AdjustTimestampForTypmod(&ts, typmod, NULL);
    return ts;
}

References AdjustTimestampForTypmod(), fb(), and GetCurrentTransactionStartTimestamp().

Referenced by ExecEvalSQLValueFunction().

GetSQLLocalTimestamp()

Timestamp GetSQLLocalTimestamp ( int32  typmod )

extern

Definition at line 1677 of file timestamp.c.

{
    Timestamp   ts;
 
    ts = timestamptz2timestamp(GetCurrentTransactionStartTimestamp());
    if (typmod >= 0)
        AdjustTimestampForTypmod(&ts, typmod, NULL);
    return ts;
}

References AdjustTimestampForTypmod(), fb(), GetCurrentTransactionStartTimestamp(), and timestamptz2timestamp().

Referenced by ExecEvalSQLValueFunction().

interval2itm()

void interval2itm ( Interval  span, struct pg_itm *  itm  )

extern

Definition at line 2047 of file timestamp.c.

{
    TimeOffset  time;
    TimeOffset  tfrac;
 
    itm->tm_year = span.month / MONTHS_PER_YEAR;
    itm->tm_mon = span.month % MONTHS_PER_YEAR;
    itm->tm_mday = span.day;
    time = span.time;
 
    tfrac = time / USECS_PER_HOUR;
    time -= tfrac * USECS_PER_HOUR;
    itm->tm_hour = tfrac;
    tfrac = time / USECS_PER_MINUTE;
    time -= tfrac * USECS_PER_MINUTE;
    itm->tm_min = (int) tfrac;
    tfrac = time / USECS_PER_SEC;
    time -= tfrac * USECS_PER_SEC;
    itm->tm_sec = (int) tfrac;
    itm->tm_usec = (int) time;
}

References fb(), MONTHS_PER_YEAR, USECS_PER_HOUR, USECS_PER_MINUTE, and USECS_PER_SEC.

Referenced by interval_out(), interval_part_common(), interval_to_char(), and interval_trunc().

IntervalPGetDatum()

static Datum IntervalPGetDatum ( const Interval *  X )

inlinestatic

Definition at line 58 of file timestamp.h.

{
    return PointerGetDatum(X);
}

References fb(), and PointerGetDatum().

Referenced by abs_interval(), gbt_intv_ssup_cmp(), gbt_intveq(), gbt_intvge(), gbt_intvgt(), gbt_intvkey_cmp(), gbt_intvle(), gbt_intvlt(), in_range_date_interval(), in_range_interval_interval(), in_range_timestamp_interval(), interval_avg(), leftmostvalue_interval(), pg_stat_get_wal_senders(), pg_timezone_abbrevs_abbrevs(), pg_timezone_abbrevs_zone(), pg_timezone_names(), timestamp_mi(), and uuidv7_interval().

isoweek2date()

void isoweek2date ( int  woy, int *  year, int *  mon, int *  mday  )

extern

Definition at line 5264 of file timestamp.c.

{
    j2date(isoweek2j(*year, woy), year, mon, mday);
}

References fb(), isoweek2j(), and j2date().

Referenced by do_to_timestamp(), timestamp_trunc(), and timestamptz_trunc_internal().

isoweek2j()

int isoweek2j ( int  year, int  week  )

extern

Definition at line 5244 of file timestamp.c.

{
    int         day0,
                day4;
 
    /* fourth day of current year */
    day4 = date2j(year, 1, 4);
 
    /* day0 == offset to first day of week (Monday) */
    day0 = j2day(day4 - 1);
 
    return ((week - 1) * 7) + (day4 - day0);
}

References date2j(), fb(), and j2day().

Referenced by date2isoyearday(), do_to_timestamp(), isoweek2date(), and isoweekdate2date().

isoweekdate2date()

void isoweekdate2date ( int  isoweek, int  wday, int *  year, int *  mon, int *  mday  )

extern

Definition at line 5277 of file timestamp.c.

{
    int         jday;
 
    jday = isoweek2j(*year, isoweek);
    /* convert Gregorian week start (Sunday=1) to ISO week start (Monday=1) */
    if (wday > 1)
        jday += wday - 2;
    else
        jday += 6;
    j2date(jday, year, mon, mday);
}

References fb(), isoweek2j(), and j2date().

Referenced by do_to_timestamp().

itm2interval()

int itm2interval ( struct pg_itm *  itm, Interval *  span  )

extern

Definition at line 2077 of file timestamp.c.

{
    int64       total_months = (int64) itm->tm_year * MONTHS_PER_YEAR + itm->tm_mon;
 
    if (total_months > INT_MAX || total_months < INT_MIN)
        return -1;
    span->month = (int32) total_months;
    span->day = itm->tm_mday;
    if (pg_mul_s64_overflow(itm->tm_hour, USECS_PER_HOUR,
                            &span->time))
        return -1;
    /* tm_min, tm_sec are 32 bits, so intermediate products can't overflow */
    if (pg_add_s64_overflow(span->time, itm->tm_min * USECS_PER_MINUTE,
                            &span->time))
        return -1;
    if (pg_add_s64_overflow(span->time, itm->tm_sec * USECS_PER_SEC,
                            &span->time))
        return -1;
    if (pg_add_s64_overflow(span->time, itm->tm_usec,
                            &span->time))
        return -1;
    if (INTERVAL_NOT_FINITE(span))
        return -1;
    return 0;
}

References fb(), INTERVAL_NOT_FINITE, MONTHS_PER_YEAR, pg_add_s64_overflow(), pg_mul_s64_overflow(), USECS_PER_HOUR, USECS_PER_MINUTE, and USECS_PER_SEC.

Referenced by interval_trunc(), timestamp_age(), and timestamptz_age().

itmin2interval()

int itmin2interval ( struct pg_itm_in *  itm_in, Interval *  span  )

extern

Definition at line 2115 of file timestamp.c.

{
    int64       total_months = (int64) itm_in->tm_year * MONTHS_PER_YEAR + itm_in->tm_mon;
 
    if (total_months > INT_MAX || total_months < INT_MIN)
        return -1;
    span->month = (int32) total_months;
    span->day = itm_in->tm_mday;
    span->time = itm_in->tm_usec;
    return 0;
}

References fb(), and MONTHS_PER_YEAR.

Referenced by interval_in(), pg_timezone_abbrevs_abbrevs(), pg_timezone_abbrevs_zone(), and pg_timezone_names().

SetEpochTimestamp()

Timestamp SetEpochTimestamp ( void  )

extern

Definition at line 2190 of file timestamp.c.

{
    Timestamp   dt;
    struct pg_tm tt,
               *tm = &tt;
 
    GetEpochTime(tm);
    /* we don't bother to test for failure ... */
    tm2timestamp(tm, 0, NULL, &dt);
 
    return dt;
}                               /* SetEpochTimestamp() */

References fb(), GetEpochTime(), tm, and tm2timestamp().

time_t_to_timestamptz()

TimestampTz time_t_to_timestamptz ( pg_time_t  tm )

extern

Definition at line 1820 of file timestamp.c.

{
    TimestampTz result;
 
    result = (TimestampTz) tm -
        ((POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY);
    result *= USECS_PER_SEC;
 
    return result;
}

References POSTGRES_EPOCH_JDATE, SECS_PER_DAY, tm, UNIX_EPOCH_JDATE, and USECS_PER_SEC.

Referenced by pg_control_checkpoint(), pg_control_system(), pg_ls_dir_files(), and pg_stat_file().

timestamp2timestamptz_safe()

TimestampTz timestamp2timestamptz_safe ( Timestamp  timestamp, Node *  escontext  )

extern

Definition at line 6448 of file timestamp.c.

{
    TimestampTz result;
    struct pg_tm tt,
               *tm = &tt;
    fsec_t      fsec;
    int         tz;
 
    if (TIMESTAMP_NOT_FINITE(timestamp))
        return timestamp;
 
    /* timestamp2tm should not fail on valid timestamps, but cope */
    if (timestamp2tm(timestamp, NULL, tm, &fsec, NULL, NULL) == 0)
    {
        tz = DetermineTimeZoneOffset(tm, session_timezone);
 
        result = dt2local(timestamp, -tz);
 
        if (IS_VALID_TIMESTAMP(result))
            return result;
    }
 
    if (timestamp < 0)
        TIMESTAMP_NOBEGIN(result);
    else
        TIMESTAMP_NOEND(result);
 
    ereturn(escontext, result,
            (errcode(ERRCODE_DATETIME_VALUE_OUT_OF_RANGE),
             errmsg("timestamp out of range")));
}

References DetermineTimeZoneOffset(), dt2local(), ereturn, errcode(), errmsg(), fb(), IS_VALID_TIMESTAMP, session_timezone, timestamp2tm(), TIMESTAMP_NOBEGIN, TIMESTAMP_NOEND, TIMESTAMP_NOT_FINITE, and tm.

Referenced by cvt_timestamp_timestamptz(), timestamp2timestamptz(), and timestamp_cmp_timestamptz_internal().

timestamp2tm()

int timestamp2tm ( Timestamp  dt, int *  tzp, struct pg_tm *  tm, fsec_t *  fsec, const char **  tzn, pg_tz *  attimezone  )

extern

Definition at line 1910 of file timestamp.c.

{
    Timestamp   date;
    Timestamp   time;
    pg_time_t   utime;
 
    /* Use session timezone if caller asks for default */
    if (attimezone == NULL)
        attimezone = session_timezone;
 
    time = dt;
    TMODULO(time, date, USECS_PER_DAY);
 
    if (time < INT64CONST(0))
    {
        time += USECS_PER_DAY;
        date -= 1;
    }
 
    /* add offset to go from J2000 back to standard Julian date */
    date += POSTGRES_EPOCH_JDATE;
 
    /* Julian day routine does not work for negative Julian days */
    if (date < 0 || date > (Timestamp) INT_MAX)
        return -1;
 
    j2date((int) date, &tm->tm_year, &tm->tm_mon, &tm->tm_mday);
    dt2time(time, &tm->tm_hour, &tm->tm_min, &tm->tm_sec, fsec);
 
    /* Done if no TZ conversion wanted */
    if (tzp == NULL)
    {
        tm->tm_isdst = -1;
        tm->tm_gmtoff = 0;
        tm->tm_zone = NULL;
        if (tzn != NULL)
            *tzn = NULL;
        return 0;
    }
 
    /*
     * If the time falls within the range of pg_time_t, use pg_localtime() to
     * rotate to the local time zone.
     *
     * First, convert to an integral timestamp, avoiding possibly
     * platform-specific roundoff-in-wrong-direction errors, and adjust to
     * Unix epoch.  Then see if we can convert to pg_time_t without loss. This
     * coding avoids hardwiring any assumptions about the width of pg_time_t,
     * so it should behave sanely on machines without int64.
     */
    dt = (dt - *fsec) / USECS_PER_SEC +
        (POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY;
    utime = (pg_time_t) dt;
    if ((Timestamp) utime == dt)
    {
        struct pg_tm *tx = pg_localtime(&utime, attimezone);
 
        tm->tm_year = tx->tm_year + 1900;
        tm->tm_mon = tx->tm_mon + 1;
        tm->tm_mday = tx->tm_mday;
        tm->tm_hour = tx->tm_hour;
        tm->tm_min = tx->tm_min;
        tm->tm_sec = tx->tm_sec;
        tm->tm_isdst = tx->tm_isdst;
        tm->tm_gmtoff = tx->tm_gmtoff;
        tm->tm_zone = tx->tm_zone;
        *tzp = -tm->tm_gmtoff;
        if (tzn != NULL)
            *tzn = tm->tm_zone;
    }
    else
    {
        /*
         * When out of range of pg_time_t, treat as GMT
         */
        *tzp = 0;
        /* Mark this as *no* time zone available */
        tm->tm_isdst = -1;
        tm->tm_gmtoff = 0;
        tm->tm_zone = NULL;
        if (tzn != NULL)
            *tzn = NULL;
    }
 
    return 0;
}

References dt2time(), fb(), INT64CONST, j2date(), pg_localtime(), POSTGRES_EPOCH_JDATE, SECS_PER_DAY, session_timezone, tm, pg_tm::tm_gmtoff, pg_tm::tm_hour, pg_tm::tm_isdst, pg_tm::tm_mday, pg_tm::tm_min, pg_tm::tm_mon, pg_tm::tm_sec, pg_tm::tm_year, pg_tm::tm_zone, TMODULO, UNIX_EPOCH_JDATE, USECS_PER_DAY, and USECS_PER_SEC.

Referenced by DetermineTimeZoneAbbrevOffsetTS(), executeDateTimeMethod(), GetCurrentTimeUsec(), JsonEncodeDateTime(), map_sql_value_to_xml_value(), pg_timezone_names(), timestamp2date_safe(), timestamp_time(), timestamp_to_char(), timestamptz2date_safe(), timestamptz_time(), timestamptz_timetz(), timestamptz_to_char(), and timetz_zone().

timestamp_cmp_internal()

int timestamp_cmp_internal ( Timestamp  dt1, Timestamp  dt2  )

extern

Definition at line 2210 of file timestamp.c.

{
    return (dt1 < dt2) ? -1 : ((dt1 > dt2) ? 1 : 0);
}

References fb().

Referenced by date_cmp_timestamp_internal(), generate_series_timestamp(), generate_series_timestamptz_internal(), timestamp_cmp(), timestamp_eq(), timestamp_ge(), timestamp_gt(), timestamp_larger(), timestamp_le(), timestamp_lt(), timestamp_ne(), and timestamp_smaller().

timestamp_cmp_timestamptz_internal()

int32 timestamp_cmp_timestamptz_internal ( Timestamp  timestampVal, TimestampTz  dt2  )

extern

Definition at line 2363 of file timestamp.c.

{
    TimestampTz dt1;
    ErrorSaveContext escontext = {T_ErrorSaveContext};
 
    dt1 = timestamp2timestamptz_safe(timestampVal, (Node *) &escontext);
    if (escontext.error_occurred)
    {
        if (TIMESTAMP_IS_NOEND(dt1))
        {
            /* dt1 is larger than any finite timestamp, but less than infinity */
            return TIMESTAMP_IS_NOEND(dt2) ? -1 : +1;
        }
        if (TIMESTAMP_IS_NOBEGIN(dt1))
        {
            /* dt1 is less than any finite timestamp, but more than -infinity */
            return TIMESTAMP_IS_NOBEGIN(dt2) ? +1 : -1;
        }
    }
 
    return timestamptz_cmp_internal(dt1, dt2);
}

References ErrorSaveContext::error_occurred, fb(), timestamp2timestamptz_safe(), TIMESTAMP_IS_NOBEGIN, TIMESTAMP_IS_NOEND, and timestamptz_cmp_internal.

Referenced by cmpTimestampToTimestampTz(), timestamp_cmp_timestamptz(), timestamp_eq_timestamptz(), timestamp_ge_timestamptz(), timestamp_gt_timestamptz(), timestamp_le_timestamptz(), timestamp_lt_timestamptz(), timestamp_ne_timestamptz(), timestamptz_cmp_timestamp(), timestamptz_eq_timestamp(), timestamptz_ge_timestamp(), timestamptz_gt_timestamp(), timestamptz_le_timestamp(), timestamptz_lt_timestamp(), and timestamptz_ne_timestamp().

TimestampDifference()

void TimestampDifference ( TimestampTz  start_time, TimestampTz  stop_time, long *  secs, int *  microsecs  )

extern

Definition at line 1721 of file timestamp.c.

{
    TimestampTz diff = stop_time - start_time;
 
    if (diff <= 0)
    {
        *secs = 0;
        *microsecs = 0;
    }
    else
    {
        *secs = (long) (diff / USECS_PER_SEC);
        *microsecs = (int) (diff % USECS_PER_SEC);
    }
}

References fb(), start_time, and USECS_PER_SEC.

Referenced by check_log_duration(), has_startup_progress_timeout_expired(), heap_vacuum_rel(), InvalidatePossiblyObsoleteSlot(), launcher_determine_sleep(), log_disconnections(), LogRecoveryConflict(), pgstat_report_activity(), pgstat_update_dbstats(), ProcSleep(), schedule_alarm(), and TimestampDifferenceExceedsSeconds().

TimestampDifferenceExceeds()

bool TimestampDifferenceExceeds ( TimestampTz  start_time, TimestampTz  stop_time, int  msec  )

extern

Definition at line 1781 of file timestamp.c.

{
    TimestampTz diff = stop_time - start_time;
 
    return (diff >= msec * INT64CONST(1000));
}

References fb(), INT64CONST, and start_time.

Referenced by asyncQueueFillWarning(), AutoVacLauncherMain(), do_analyze_rel(), do_start_worker(), get_candidate_xid(), heap_vacuum_rel(), launch_sync_worker(), LockBufferForCleanup(), logicalrep_worker_launch(), maybe_start_bgworkers(), pa_send_data(), pgstat_report_stat(), ProcSleep(), ResolveRecoveryConflictWithVirtualXIDs(), send_feedback(), should_stop_conflict_info_retention(), update_most_recent_deletion_info(), wait_for_local_flush(), WaitForWALToBecomeAvailable(), WalSndLoop(), WalSndUpdateProgress(), WalSndWaitForWal(), and XLogBackgroundFlush().

TimestampDifferenceExceedsSeconds()

bool TimestampDifferenceExceedsSeconds ( TimestampTz  start_time, TimestampTz  stop_time, int  threshold_sec  )

extern

Definition at line 1795 of file timestamp.c.

{
    long        secs;
    int         usecs;
 
    /* Calculate the difference in seconds */
    TimestampDifference(start_time, stop_time, &secs, &usecs);
 
    return (secs >= threshold_sec);
}

References fb(), start_time, and TimestampDifference().

Referenced by DetermineSlotInvalidationCause().

TimestampDifferenceMicroseconds()

static uint64 TimestampDifferenceMicroseconds ( TimestampTz  start_time, TimestampTz  stop_time  )

inlinestatic

Definition at line 90 of file timestamp.h.

{
    if (start_time >= stop_time)
        return 0;
    return (uint64) stop_time - start_time;
}

References fb(), and start_time.

Referenced by PostgresMain().

TimestampDifferenceMilliseconds()

long TimestampDifferenceMilliseconds ( TimestampTz  start_time, TimestampTz  stop_time  )

extern

Definition at line 1757 of file timestamp.c.

{
    TimestampTz diff;
 
    /* Deal with zero or negative elapsed time quickly. */
    if (start_time >= stop_time)
        return 0;
    /* To not fail with timestamp infinities, we must detect overflow. */
    if (pg_sub_s64_overflow(stop_time, start_time, &diff))
        return (long) INT_MAX;
    if (diff >= (INT_MAX * INT64CONST(1000) - 999))
        return (long) INT_MAX;
    else
        return (long) ((diff + 999) / 1000);
}

References fb(), INT64CONST, pg_sub_s64_overflow(), and start_time.

Referenced by ApplyLauncherMain(), autoprewarm_main(), bbsink_copystream_archive_contents(), DetermineSleepTime(), do_analyze_rel(), GetReplicationApplyDelay(), GetReplicationTransferLatency(), libpqsrv_cancel(), LogCheckpointEnd(), pgfdw_get_cleanup_result(), pgstat_report_analyze(), pgstat_report_vacuum(), recoveryApplyDelay(), wait_for_local_flush(), WaitForLSN(), WaitForWalSummarization(), WaitForWALToBecomeAvailable(), WalReceiverMain(), and WalSndComputeSleeptime().

TimestampGetDatum()

static Datum TimestampGetDatum ( Timestamp  X )

inlinestatic

Definition at line 46 of file timestamp.h.

{
    return Int64GetDatum(X);
}

References fb(), and Int64GetDatum().

Referenced by cvt_date_timestamp(), cvt_timestamptz_timestamp(), date_mi_interval(), date_pl_interval(), ExecEvalSQLValueFunction(), executeDateTimeMethod(), gbt_num_fetch(), gbt_ts_dist(), gbt_ts_ssup_cmp(), gbt_tseq(), gbt_tsge(), gbt_tsgt(), gbt_tskey_cmp(), gbt_tsle(), gbt_tslt(), generate_series_timestamp(), generate_series_timestamp_support(), in_range_date_interval(), in_range_timestamp_interval(), leftmostvalue_timestamp(), parse_datetime(), timestamp_decrement(), timestamp_increment(), timestamp_mi_interval(), and timestamp_skipsupport().

TimestampTimestampTzRequiresRewrite()

bool TimestampTimestampTzRequiresRewrite ( void  )

extern

Definition at line 6417 of file timestamp.c.

{
    long        offset;
 
    if (pg_get_timezone_offset(session_timezone, &offset) && offset == 0)
        return false;
    return true;
}

References pg_get_timezone_offset(), and session_timezone.

Referenced by ATColumnChangeRequiresRewrite().

timestamptz2timestamp_safe()

Timestamp timestamptz2timestamp_safe ( TimestampTz  timestamp, Node *  escontext  )

extern

Definition at line 6520 of file timestamp.c.

{
    Timestamp   result;
    struct pg_tm tt,
               *tm = &tt;
    fsec_t      fsec;
    int         tz;
 
    if (TIMESTAMP_NOT_FINITE(timestamp))
        result = timestamp;
    else
    {
        if (timestamp2tm(timestamp, &tz, tm, &fsec, NULL, NULL) != 0)
        {
            if (timestamp < 0)
                TIMESTAMP_NOBEGIN(result);
            else
                TIMESTAMP_NOEND(result);
 
            ereturn(escontext, result,
                    (errcode(ERRCODE_DATETIME_VALUE_OUT_OF_RANGE),
                     errmsg("timestamp out of range")));
        }
        if (tm2timestamp(tm, fsec, NULL, &result) != 0)
        {
            if (timestamp < 0)
                TIMESTAMP_NOBEGIN(result);
            else
                TIMESTAMP_NOEND(result);
 
            ereturn(escontext, result,
                    (errcode(ERRCODE_DATETIME_VALUE_OUT_OF_RANGE),
                     errmsg("timestamp out of range")));
        }
    }
    return result;
}

References ereturn, errcode(), errmsg(), fb(), timestamp2tm(), TIMESTAMP_NOBEGIN, TIMESTAMP_NOEND, TIMESTAMP_NOT_FINITE, tm, and tm2timestamp().

Referenced by cvt_timestamptz_timestamp(), and timestamptz2timestamp().

timestamptz_to_str()

const char * timestamptz_to_str ( TimestampTz  t )

extern

Definition at line 1862 of file timestamp.c.

{
    static char buf[MAXDATELEN + 1];
    int         tz;
    struct pg_tm tt,
               *tm = &tt;
    fsec_t      fsec;
    const char *tzn;
 
    if (TIMESTAMP_NOT_FINITE(t))
        EncodeSpecialTimestamp(t, buf);
    else if (timestamp2tm(t, &tz, tm, &fsec, &tzn, NULL) == 0)
        EncodeDateTime(tm, fsec, true, tz, tzn, USE_ISO_DATES, buf);
    else
        strlcpy(buf, "(timestamp out of range)", sizeof(buf));
 
    return buf;
}

References buf, EncodeDateTime(), EncodeSpecialTimestamp(), fb(), MAXDATELEN, snprintf, strlcpy(), timestamp2tm(), TIMESTAMP_NOT_FINITE, timestamptz_to_time_t(), tm, USE_ISO_DATES, and USECS_PER_SEC.

Referenced by CreateRestartPoint(), errdetail_apply_conflict(), getRecoveryStopReason(), InitWalRecovery(), PerformWalRecovery(), pg_decode_commit_prepared_txn(), pg_decode_commit_txn(), pg_decode_prepare_txn(), pg_decode_rollback_prepared_txn(), pg_decode_stream_commit(), pg_decode_stream_prepare(), ProcessStandbyHSFeedbackMessage(), ProcessStandbyReplyMessage(), ProcessWalSndrMessage(), recoveryStopsAfter(), recoveryStopsBefore(), xact_desc_abort(), xact_desc_commit(), xact_desc_prepare(), xlog_desc(), and xlogrecovery_redo().

timestamptz_to_time_t()

pg_time_t timestamptz_to_time_t ( TimestampTz  t )

extern

Definition at line 1842 of file timestamp.c.

{
    pg_time_t   result;
 
    result = (pg_time_t) (t / USECS_PER_SEC +
                          ((POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY));
 
    return result;
}

References POSTGRES_EPOCH_JDATE, SECS_PER_DAY, UNIX_EPOCH_JDATE, and USECS_PER_SEC.

Referenced by DetermineTimeZoneAbbrevOffsetTS(), InitProcessGlobals(), pg_timezone_abbrevs_zone(), and timestamptz_to_str().

TimestampTzGetDatum()

static Datum TimestampTzGetDatum ( TimestampTz  X )

inlinestatic

Definition at line 52 of file timestamp.h.

{
    return Int64GetDatum(X);
}

References fb(), and Int64GetDatum().

Referenced by cvt_date_timestamptz(), cvt_timestamp_timestamptz(), ExecEvalSQLValueFunction(), executeDateTimeMethod(), generate_series_timestamptz_internal(), parse_datetime(), pg_control_checkpoint(), pg_control_system(), pg_cursor(), pg_get_replication_slots(), pg_last_committed_xact(), pg_lock_status(), pg_ls_dir_files(), pg_prepared_statement(), pg_prepared_xact(), pg_stat_file(), pg_stat_get_activity(), pg_stat_get_archiver(), pg_stat_get_recovery_prefetch(), pg_stat_get_replication_slot(), pg_stat_get_slru(), pg_stat_get_subscription(), pg_stat_get_subscription_stats(), pg_stat_get_wal_receiver(), pg_stat_get_wal_senders(), pg_stat_io_build_tuples(), pg_stat_statements_info(), pg_stat_statements_internal(), pg_stat_wal_build_tuple(), pg_xact_commit_timestamp_origin(), test_custom_stats_fixed_report(), and uuidv7_interval().

tm2timestamp()

int tm2timestamp ( struct pg_tm *  tm, fsec_t  fsec, int *  tzp, Timestamp *  result  )

extern

Definition at line 2006 of file timestamp.c.

{
    TimeOffset  date;
    TimeOffset  time;
 
    /* Prevent overflow in Julian-day routines */
    if (!IS_VALID_JULIAN(tm->tm_year, tm->tm_mon, tm->tm_mday))
    {
        *result = 0;            /* keep compiler quiet */
        return -1;
    }
 
    date = date2j(tm->tm_year, tm->tm_mon, tm->tm_mday) - POSTGRES_EPOCH_JDATE;
    time = time2t(tm->tm_hour, tm->tm_min, tm->tm_sec, fsec);
 
    if (unlikely(pg_mul_s64_overflow(date, USECS_PER_DAY, result) ||
                 pg_add_s64_overflow(*result, time, result)))
    {
        *result = 0;            /* keep compiler quiet */
        return -1;
    }
    if (tzp != NULL)
        *result = dt2local(*result, -(*tzp));
 
    /* final range check catches just-out-of-range timestamps */
    if (!IS_VALID_TIMESTAMP(*result))
    {
        *result = 0;            /* keep compiler quiet */
        return -1;
    }
 
    return 0;
}

References date2j(), dt2local(), fb(), IS_VALID_JULIAN, IS_VALID_TIMESTAMP, pg_add_s64_overflow(), pg_mul_s64_overflow(), POSTGRES_EPOCH_JDATE, time2t(), tm, pg_tm::tm_hour, pg_tm::tm_mday, pg_tm::tm_min, pg_tm::tm_mon, pg_tm::tm_sec, pg_tm::tm_year, unlikely, and USECS_PER_DAY.

Referenced by check_recovery_target_time(), parse_datetime(), PGTYPEStimestamp_defmt_scan(), and to_timestamp().

Variable Documentation

PgReloadTime

PGDLLIMPORT TimestampTz PgReloadTime

extern

Definition at line 57 of file timestamp.c.

Referenced by pg_conf_load_time(), and ProcessConfigFileInternal().

PgStartTime

PGDLLIMPORT TimestampTz PgStartTime

extern

Definition at line 54 of file timestamp.c.

Referenced by pg_postmaster_start_time(), PostgresSingleUserMain(), and PostmasterMain().