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

Macros
#define	DatumGetTimestamp(X) ((Timestamp) DatumGetInt64(X))

#define	DatumGetTimestampTz(X) ((TimestampTz) DatumGetInt64(X))

#define	DatumGetIntervalP(X) ((Interval *) DatumGetPointer(X))

#define	TimestampGetDatum(X) Int64GetDatum(X)

#define	TimestampTzGetDatum(X) Int64GetDatum(X)

#define	IntervalPGetDatum(X) PointerGetDatum(X)

#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	timestamptz_cmp_internal(dt1, dt2) timestamp_cmp_internal(dt1, dt2)

Functions
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)

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

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 *dt)

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

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

int	interval2tm (Interval span, struct pg_tm tm, fsec_t fsec)

int	tm2interval (struct pg_tm tm, fsec_t fsec, Interval span)

Timestamp	SetEpochTimestamp (void)

void	GetEpochTime (struct pg_tm *tm)

int	timestamp_cmp_internal (Timestamp dt1, Timestamp 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)

Variables
TimestampTz	PgStartTime

TimestampTz	PgReloadTime

Macro Definition Documentation

#define DatumGetIntervalP ( X ) ((Interval *) DatumGetPointer(X))

Definition at line 29 of file timestamp.h.

Referenced by abs_interval(), check_timezone(), convert_timevalue_to_scalar(), gbt_intv_compress(), gbt_time_dist(), gbt_time_penalty(), gbt_ts_dist(), interval_accum(), interval_accum_inv(), interval_avg(), interval_combine(), interval_dist(), time_dist(), timestamp_mi(), ts_dist(), and tstz_dist().

#define DatumGetTimestamp ( X ) ((Timestamp) DatumGetInt64(X))

Definition at line 27 of file timestamp.h.

Referenced by convert_timevalue_to_scalar(), datum_to_json(), datum_to_jsonb(), gbt_num_compress(), generate_series_timestamp(), map_sql_value_to_xml_value(), and timestamp_fastcmp().

#define DatumGetTimestampTz ( X ) ((TimestampTz) DatumGetInt64(X))

Definition at line 28 of file timestamp.h.

Referenced by convert_timevalue_to_scalar(), datum_to_json(), datum_to_jsonb(), gbt_tstz_compress(), generate_series_timestamptz(), get_role_password(), and readRecoveryCommandFile().

#define INTERVAL_FULL_PRECISION (0xFFFF)

Definition at line 50 of file timestamp.h.

Referenced by AdjustIntervalForTypmod(), interval_transform(), intervaltypmodin(), and intervaltypmodout().

#define INTERVAL_FULL_RANGE (0x7FFF)

Definition at line 48 of file timestamp.h.

Referenced by AdjustIntervalForTypmod(), DecodeDateTime(), DecodeInterval(), DecodeTimeOnly(), interval_in(), intervaltypmodin(), intervaltypmodleastfield(), intervaltypmodout(), and reltimein().

#define INTERVAL_MASK ( b ) (1 << (b))

Definition at line 45 of file timestamp.h.

Referenced by AdjustIntervalForTypmod(), DecodeInterval(), DecodeTime(), intervaltypmodin(), intervaltypmodleastfield(), and intervaltypmodout().

#define INTERVAL_PRECISION ( t ) ((t) & INTERVAL_PRECISION_MASK)

Definition at line 53 of file timestamp.h.

Referenced by AdjustIntervalForTypmod(), interval_transform(), and intervaltypmodout().

#define INTERVAL_PRECISION_MASK (0xFFFF)

Definition at line 51 of file timestamp.h.

#define INTERVAL_RANGE ( t ) (((t) >> 16) & INTERVAL_RANGE_MASK)

Definition at line 54 of file timestamp.h.

Referenced by AdjustIntervalForTypmod(), interval_in(), intervaltypmodleastfield(), and intervaltypmodout().

#define INTERVAL_RANGE_MASK (0x7FFF)

Definition at line 49 of file timestamp.h.

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

Definition at line 52 of file timestamp.h.

Referenced by intervaltypmodin().

#define IntervalPGetDatum ( X ) PointerGetDatum(X)

Definition at line 33 of file timestamp.h.

Referenced by abs_interval(), gbt_intveq(), gbt_intvge(), gbt_intvgt(), gbt_intvkey_cmp(), gbt_intvle(), gbt_intvlt(), interval_accum(), interval_accum_inv(), interval_avg(), interval_combine(), leftmostvalue_interval(), pg_stat_get_wal_senders(), pg_timezone_abbrevs(), pg_timezone_names(), and timestamp_mi().

#define PG_GETARG_INTERVAL_P ( n ) DatumGetIntervalP(PG_GETARG_DATUM(n))

Definition at line 37 of file timestamp.h.

Referenced by date_mi_interval(), date_pl_interval(), gbt_intv_consistent(), gbt_intv_distance(), generate_series_timestamp(), generate_series_timestamptz(), interval_accum(), interval_accum_inv(), interval_cmp(), interval_div(), interval_eq(), interval_ge(), interval_gt(), interval_hash(), interval_justify_days(), interval_justify_hours(), interval_justify_interval(), interval_larger(), interval_le(), interval_lt(), interval_mi(), interval_mul(), interval_ne(), interval_out(), interval_part(), interval_pl(), interval_reltime(), interval_scale(), interval_send(), interval_smaller(), interval_time(), interval_to_char(), interval_trunc(), interval_um(), time_mi_interval(), time_pl_interval(), timestamp_izone(), timestamp_mi_interval(), timestamp_pl_interval(), timestamptz_izone(), timestamptz_mi_interval(), timestamptz_pl_interval(), timetz_izone(), timetz_mi_interval(), and timetz_pl_interval().

#define PG_GETARG_TIMESTAMP ( n ) DatumGetTimestamp(PG_GETARG_DATUM(n))

Definition at line 35 of file timestamp.h.

#define PG_GETARG_TIMESTAMPTZ ( n ) DatumGetTimestampTz(PG_GETARG_DATUM(n))

Definition at line 36 of file timestamp.h.

#define PG_RETURN_INTERVAL_P ( x ) return IntervalPGetDatum(x)

#define PG_RETURN_TIMESTAMP ( x ) return TimestampGetDatum(x)

#define PG_RETURN_TIMESTAMPTZ ( x ) return TimestampTzGetDatum(x)

#define TIMESTAMP_MASK ( b ) (1 << (b))

Definition at line 44 of file timestamp.h.

#define TimestampGetDatum ( X ) Int64GetDatum(X)

Definition at line 31 of file timestamp.h.

Referenced by date_mi_interval(), date_pl_interval(), ExecEvalSQLValueFunction(), gbt_num_fetch(), generate_series_timestamp(), leftmostvalue_timestamp(), timestamp_mi_interval(), and timestamptz_mi_interval().

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

Definition at line 98 of file timestamp.h.

Referenced by date_cmp_timestamptz(), date_eq_timestamptz(), date_ge_timestamptz(), date_gt_timestamptz(), date_le_timestamptz(), date_lt_timestamptz(), date_ne_timestamptz(), timestamptz_cmp_date(), timestamptz_eq_date(), timestamptz_ge_date(), timestamptz_gt_date(), timestamptz_le_date(), timestamptz_lt_date(), and timestamptz_ne_date().

#define TimestampTzGetDatum ( X ) Int64GetDatum(X)

Definition at line 32 of file timestamp.h.

Referenced by ExecEvalSQLValueFunction(), generate_series_timestamptz(), pg_control_checkpoint(), pg_control_system(), pg_cursor(), pg_last_committed_xact(), pg_ls_dir_files(), pg_prepared_statement(), pg_prepared_xact(), pg_stat_file(), pg_stat_get_activity(), pg_stat_get_archiver(), pg_stat_get_subscription(), and pg_stat_get_wal_receiver().

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

Definition at line 56 of file timestamp.h.

Referenced by autoprewarm_main(), backend_read_statsfile(), BackgroundWriterMain(), DetermineSleepTime(), enable_timeout_after(), enable_timeouts(), GetStandbyLimitTime(), launch_worker(), LogicalRepApplyLoop(), pgfdw_cancel_query(), pgfdw_exec_cleanup_query(), rebuild_database_list(), recoveryApplyDelay(), WalReceiverMain(), WalSndCheckTimeOut(), WalSndComputeSleeptime(), and WalSndKeepaliveIfNecessary().

Function Documentation

int32 anytimestamp_typmod_check	(	bool	istz,
		int32	typmod
	)

Definition at line 102 of file timestamp.c.

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

Referenced by anytimestamp_typmodin(), and transformSQLValueFunction().

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

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

Definition at line 4073 of file timestamp.c.

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

Referenced by DCH_to_char(), timestamp_part(), timestamp_trunc(), timestamptz_part(), and timestamptz_trunc().

 {
     float8      result;
     int         day0,
                 day4,
                 dayn;
 
     /* 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);
     }
 
     result = (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 (result >= 52)
     {
         day4 = date2j(year + 1, 1, 4);
 
         /* day0 == offset to first day of week (Monday) */
         day0 = j2day(day4 - 1);
 
         if (dayn >= day4 - day0)
             result = (dayn - (day4 - day0)) / 7 + 1;
     }
 
     return (int) result;
 }

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

Definition at line 4127 of file timestamp.c.

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

Referenced by date2isoyearday(), DCH_to_char(), timestamp_part(), and timestamptz_part().

 {
     float8      result;
     int         day0,
                 day4,
                 dayn;
 
     /* 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--;
     }
 
     result = (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 (result >= 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;
 }

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

Definition at line 4184 of file timestamp.c.

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

Referenced by DCH_to_char().

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

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

Definition at line 1731 of file timestamp.c.

References USECS_PER_HOUR, USECS_PER_MINUTE, and USECS_PER_SEC.

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

 {
     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() */

TimestampTz GetCurrentTimestamp ( void )

Definition at line 1570 of file timestamp.c.

References gettimeofday(), NULL, POSTGRES_EPOCH_JDATE, result, SECS_PER_DAY, UNIX_EPOCH_JDATE, and USECS_PER_SEC.

Referenced by ApplyLauncherMain(), ApplyWorkerMain(), asyncQueueFillWarning(), autoprewarm_main(), autovac_refresh_stats(), AutoVacLauncherMain(), backend_read_statsfile(), BackendInitialize(), BackgroundWriterMain(), check_log_duration(), CheckPointBuffers(), CleanupBackgroundWorker(), clock_timestamp(), CreateCheckPoint(), CreateEndOfRecoveryRecord(), CreateRestartPoint(), DetermineSleepTime(), disable_timeout(), disable_timeouts(), do_analyze_rel(), do_start_bgworker(), do_start_worker(), enable_timeout_after(), enable_timeout_at(), enable_timeouts(), get_role_password(), GetCurrentTransactionStopTimestamp(), GetReplicationApplyDelay(), GetSnapshotCurrentTimestamp(), handle_sig_alarm(), launcher_determine_sleep(), lazy_vacuum_rel(), log_disconnections(), LogCheckpointEnd(), logicalrep_worker_launch(), LogicalRepApplyLoop(), maybe_start_bgworkers(), perform_base_backup(), pgfdw_cancel_query(), pgfdw_exec_cleanup_query(), pgfdw_get_cleanup_result(), pgstat_bestart(), pgstat_read_statsfiles(), pgstat_recv_inquiry(), pgstat_recv_resetsharedcounter(), pgstat_recv_resetsinglecounter(), pgstat_report_activity(), pgstat_report_analyze(), pgstat_report_autovac(), pgstat_report_vacuum(), pgstat_send_archiver(), pgstat_write_statsfiles(), PostgresMain(), PostmasterMain(), PrepareTransaction(), process_syncing_tables_for_apply(), ProcessRepliesIfAny(), ProcessStandbyReplyMessage(), ProcessWalSndrMessage(), ProcSleep(), rebuild_database_list(), RecordTransactionAbort(), RecordTransactionAbortPrepared(), RecordTransactionCommitPrepared(), recoveryApplyDelay(), reschedule_timeouts(), reset_dbentry_counters(), ResolveRecoveryConflictWithBufferPin(), ResolveRecoveryConflictWithLock(), ResolveRecoveryConflictWithVirtualXIDs(), send_feedback(), SetCurrentStatementStartTimestamp(), SetCurrentTransactionStopTimestamp(), StartupXLOG(), throttle(), UpdateWorkerStats(), WaitExceedsMaxStandbyDelay(), WaitForWALToBecomeAvailable(), WalReceiverMain(), WalSndKeepalive(), WalSndLoop(), WalSndUpdateProgress(), WalSndWaitForWal(), WalSndWriteData(), XLogBackgroundFlush(), XLogFileRead(), XLogRestorePoint(), XLogSendPhysical(), XLogWalRcvSendHSFeedback(), and XLogWalRcvSendReply().

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

void GetEpochTime ( struct pg_tm * tm )

Definition at line 1984 of file timestamp.c.

References epoch, pg_gmtime(), 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(), and SetEpochTimestamp().

 {
     struct pg_tm *t0;
     pg_time_t   epoch = 0;
 
     t0 = pg_gmtime(&epoch);
 
     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++;
 }

TimestampTz GetSQLCurrentTimestamp ( int32 typmod )

Definition at line 1588 of file timestamp.c.

References AdjustTimestampForTypmod(), and GetCurrentTransactionStartTimestamp().

Referenced by ExecEvalSQLValueFunction().

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

Timestamp GetSQLLocalTimestamp ( int32 typmod )

Definition at line 1602 of file timestamp.c.

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

Referenced by ExecEvalSQLValueFunction().

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

int interval2tm	(	Interval	span,
		struct pg_tm *	tm,
		fsec_t *	fsec
	)

Definition at line 1902 of file timestamp.c.

References Interval::day, ereport, errcode(), errmsg(), ERROR, Interval::month, MONTHS_PER_YEAR, SAMESIGN, Interval::time, pg_tm::tm_hour, pg_tm::tm_mday, pg_tm::tm_min, pg_tm::tm_mon, pg_tm::tm_sec, pg_tm::tm_year, USECS_PER_HOUR, USECS_PER_MINUTE, and USECS_PER_SEC.

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

 {
     TimeOffset  time;
     TimeOffset  tfrac;
 
     tm->tm_year = span.month / MONTHS_PER_YEAR;
     tm->tm_mon = span.month % MONTHS_PER_YEAR;
     tm->tm_mday = span.day;
     time = span.time;
 
     tfrac = time / USECS_PER_HOUR;
     time -= tfrac * USECS_PER_HOUR;
     tm->tm_hour = tfrac;
     if (!SAMESIGN(tm->tm_hour, tfrac))
         ereport(ERROR,
                 (errcode(ERRCODE_DATETIME_VALUE_OUT_OF_RANGE),
                  errmsg("interval out of range")));
     tfrac = time / USECS_PER_MINUTE;
     time -= tfrac * USECS_PER_MINUTE;
     tm->tm_min = tfrac;
     tfrac = time / USECS_PER_SEC;
     *fsec = time - (tfrac * USECS_PER_SEC);
     tm->tm_sec = tfrac;
 
     return 0;
 }

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

Definition at line 4042 of file timestamp.c.

References isoweek2j(), and j2date().

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

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

int isoweek2j	(	int	year,
		int	week
	)

Definition at line 4022 of file timestamp.c.

References date2j(), and j2day().

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

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

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

Definition at line 4055 of file timestamp.c.

References isoweek2j(), and j2date().

Referenced by do_to_timestamp().

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

Timestamp SetEpochTimestamp ( void )

Definition at line 2003 of file timestamp.c.

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

Referenced by dttofmtasc_replace(), PGTYPEStimestamp_from_asc(), timestamp_in(), timestamp_part(), timestamptz_in(), and timestamptz_part().

 {
     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() */

TimestampTz time_t_to_timestamptz ( pg_time_t tm )

Definition at line 1670 of file timestamp.c.

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

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

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

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

Definition at line 1758 of file timestamp.c.

References dt2time(), INT64CONST, j2date(), NULL, pg_localtime(), POSTGRES_EPOCH_JDATE, SECS_PER_DAY, session_timezone, 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 datum_to_json(), datum_to_jsonb(), DetermineTimeZoneAbbrevOffsetTS(), GetCurrentDateTime(), GetCurrentTimeUsec(), GetSQLCurrentDate(), GetSQLCurrentTime(), GetSQLLocalTime(), make_timestamptz_at_timezone(), map_sql_value_to_xml_value(), pg_timezone_names(), PGTYPEStimestamp_add_interval(), PGTYPEStimestamp_fmt_asc(), PGTYPEStimestamp_to_asc(), timestamp2timestamptz(), timestamp_abstime(), timestamp_age(), timestamp_date(), timestamp_out(), timestamp_part(), timestamp_pl_interval(), timestamp_recv(), timestamp_time(), timestamp_to_char(), timestamp_trunc(), timestamp_zone(), timestamptz2timestamp(), timestamptz_abstime(), timestamptz_age(), timestamptz_date(), timestamptz_out(), timestamptz_part(), timestamptz_pl_interval(), timestamptz_recv(), timestamptz_time(), timestamptz_timetz(), timestamptz_to_char(), timestamptz_to_str(), timestamptz_trunc(), and timestamptz_zone().

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

int timestamp_cmp_internal	(	Timestamp	dt1,
		Timestamp	dt2
	)

Definition at line 2023 of file timestamp.c.

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

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

Definition at line 1624 of file timestamp.c.

References start_time, and USECS_PER_SEC.

Referenced by autoprewarm_main(), BackendRun(), check_log_duration(), DetermineSleepTime(), GetReplicationApplyDelay(), GetReplicationTransferLatency(), launcher_determine_sleep(), lazy_vacuum_rel(), log_disconnections(), LogCheckpointEnd(), pgfdw_get_cleanup_result(), ProcSleep(), recoveryApplyDelay(), schedule_alarm(), WaitForWALToBecomeAvailable(), and WalSndComputeSleeptime().

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

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

Definition at line 1649 of file timestamp.c.

References INT64CONST, and start_time.

Referenced by ApplyLauncherMain(), asyncQueueFillWarning(), autovac_refresh_stats(), AutoVacLauncherMain(), do_analyze_rel(), do_start_worker(), lazy_vacuum_rel(), logicalrep_worker_launch(), maybe_start_bgworkers(), pgstat_report_stat(), process_syncing_tables_for_apply(), ResolveRecoveryConflictWithVirtualXIDs(), send_feedback(), WaitForWALToBecomeAvailable(), WalSndUpdateProgress(), XLogBackgroundFlush(), XLogWalRcvSendHSFeedback(), and XLogWalRcvSendReply().

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

const char* timestamptz_to_str ( TimestampTz t )

Definition at line 1710 of file timestamp.c.

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

Referenced by backend_read_statsfile(), commit_ts_desc(), CreateRestartPoint(), pg_decode_commit_txn(), pgstat_recv_inquiry(), ProcessWalSndrMessage(), readRecoveryCommandFile(), recoveryStopsAfter(), recoveryStopsBefore(), StartupXLOG(), xact_desc_abort(), xact_desc_commit(), and xlog_desc().

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

pg_time_t timestamptz_to_time_t ( TimestampTz t )

Definition at line 1692 of file timestamp.c.

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

Referenced by BackendInitialize(), DetermineTimeZoneAbbrevOffsetTS(), and timestamptz_to_str().

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

int tm2interval	(	struct pg_tm *	tm,
		fsec_t	fsec,
		Interval *	span
	)

Definition at line 1930 of file timestamp.c.

References Interval::day, INT64CONST, Interval::month, MONTHS_PER_YEAR, Interval::time, pg_tm::tm_hour, pg_tm::tm_mday, pg_tm::tm_min, pg_tm::tm_mon, pg_tm::tm_sec, pg_tm::tm_year, and USECS_PER_SEC.

Referenced by interval_in(), interval_trunc(), pg_timezone_abbrevs(), pg_timezone_names(), timestamp_age(), and timestamptz_age().

 {
     double      total_months = (double) tm->tm_year * MONTHS_PER_YEAR + tm->tm_mon;
 
     if (total_months > INT_MAX || total_months < INT_MIN)
         return -1;
     span->month = total_months;
     span->day = tm->tm_mday;
     span->time = (((((tm->tm_hour * INT64CONST(60)) +
                      tm->tm_min) * INT64CONST(60)) +
                    tm->tm_sec) * USECS_PER_SEC) + fsec;
 
     return 0;
 }

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

Definition at line 1854 of file timestamp.c.

References date2j(), dt2local(), IS_VALID_JULIAN, IS_VALID_TIMESTAMP, NULL, POSTGRES_EPOCH_JDATE, time2t(), pg_tm::tm_hour, pg_tm::tm_mday, pg_tm::tm_min, pg_tm::tm_mon, pg_tm::tm_sec, pg_tm::tm_year, and USECS_PER_DAY.

Referenced by abstime_timestamp(), abstime_timestamptz(), PGTYPEStimestamp_add_interval(), PGTYPEStimestamp_current(), PGTYPEStimestamp_defmt_scan(), PGTYPEStimestamp_from_asc(), SetEpochTimestamp(), timestamp2timestamptz(), timestamp_in(), timestamp_pl_interval(), timestamp_trunc(), timestamp_zone(), timestamptz2timestamp(), timestamptz_in(), timestamptz_pl_interval(), timestamptz_trunc(), timestamptz_zone(), and to_timestamp().

 {
     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);
 
     *result = date * USECS_PER_DAY + time;
     /* check for major overflow */
     if ((*result - time) / USECS_PER_DAY != date)
     {
         *result = 0;            /* keep compiler quiet */
         return -1;
     }
     /* check for just-barely overflow (okay except time-of-day wraps) */
     /* caution: we want to allow 1999-12-31 24:00:00 */
     if ((*result < 0 && date > 0) ||
         (*result > 0 && date < -1))
     {
         *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;
 }

Variable Documentation

TimestampTz PgReloadTime

Definition at line 52 of file timestamp.c.

Referenced by pg_conf_load_time().

TimestampTz PgStartTime

Definition at line 49 of file timestamp.c.

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

Macros

Functions

Variables

Macro Definition Documentation

Function Documentation

Variable Documentation