PostgreSQL Source Code  git master
Macros | Functions | Variables
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 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)
 
long TimestampDifferenceMilliseconds (TimestampTz start_time, TimestampTz stop_time)
 
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)
 
TimestampTz timestamp2timestamptz_opt_overflow (Timestamp timestamp, int *overflow)
 
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

TimestampTz PgStartTime
 
TimestampTz PgReloadTime
 

Macro Definition Documentation

◆ DatumGetIntervalP

#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(), in_range_interval_interval(), interval_accum(), interval_accum_inv(), interval_avg(), interval_combine(), interval_dist(), time_dist(), timestamp_mi(), ts_dist(), and tstz_dist().

◆ DatumGetTimestamp

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

Definition at line 27 of file timestamp.h.

Referenced by compareDatetime(), convert_timevalue_to_scalar(), gbt_num_compress(), generate_series_timestamp(), in_range_timestamp_interval(), JsonEncodeDateTime(), map_sql_value_to_xml_value(), and timestamp_fastcmp().

◆ DatumGetTimestampTz

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

Definition at line 28 of file timestamp.h.

Referenced by compareDatetime(), convert_timevalue_to_scalar(), gbt_tstz_compress(), generate_series_timestamptz(), get_role_password(), in_range_timestamptz_interval(), JsonEncodeDateTime(), and validateRecoveryParameters().

◆ INTERVAL_FULL_PRECISION

#define INTERVAL_FULL_PRECISION   (0xFFFF)

Definition at line 50 of file timestamp.h.

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

◆ INTERVAL_FULL_RANGE

#define INTERVAL_FULL_RANGE   (0x7FFF)

Definition at line 48 of file timestamp.h.

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

◆ INTERVAL_MASK

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

Definition at line 45 of file timestamp.h.

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

◆ INTERVAL_PRECISION

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

Definition at line 53 of file timestamp.h.

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

◆ INTERVAL_PRECISION_MASK

#define INTERVAL_PRECISION_MASK   (0xFFFF)

Definition at line 51 of file timestamp.h.

◆ INTERVAL_RANGE

#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().

◆ INTERVAL_RANGE_MASK

#define INTERVAL_RANGE_MASK   (0x7FFF)

Definition at line 49 of file timestamp.h.

◆ INTERVAL_TYPMOD

#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().

◆ IntervalPGetDatum

#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(), in_range_date_interval(), in_range_interval_interval(), in_range_timestamp_interval(), in_range_timestamptz_interval(), 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().

◆ PG_GETARG_INTERVAL_P

#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(), in_range_date_interval(), in_range_interval_interval(), in_range_time_interval(), in_range_timestamp_interval(), in_range_timestamptz_interval(), in_range_timetz_interval(), interval_accum(), interval_accum_inv(), interval_cmp(), interval_div(), interval_eq(), interval_ge(), interval_gt(), interval_hash(), interval_hash_extended(), 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_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().

◆ PG_GETARG_TIMESTAMP

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

Definition at line 35 of file timestamp.h.

Referenced by date_cmp_timestamp(), date_eq_timestamp(), date_ge_timestamp(), date_gt_timestamp(), date_le_timestamp(), date_lt_timestamp(), date_ne_timestamp(), gbt_ts_consistent(), gbt_ts_distance(), generate_series_timestamp(), in_range_timestamp_interval(), timestamp_age(), timestamp_cmp(), timestamp_cmp_date(), timestamp_cmp_timestamptz(), timestamp_date(), timestamp_eq(), timestamp_eq_date(), timestamp_eq_timestamptz(), timestamp_finite(), timestamp_ge(), timestamp_ge_date(), timestamp_ge_timestamptz(), timestamp_gt(), timestamp_gt_date(), timestamp_gt_timestamptz(), timestamp_izone(), timestamp_larger(), timestamp_le(), timestamp_le_date(), timestamp_le_timestamptz(), timestamp_lt(), timestamp_lt_date(), timestamp_lt_timestamptz(), timestamp_mi(), timestamp_mi_interval(), timestamp_ne(), timestamp_ne_date(), timestamp_ne_timestamptz(), timestamp_out(), timestamp_part(), timestamp_pl_interval(), timestamp_scale(), timestamp_send(), timestamp_smaller(), timestamp_time(), timestamp_timestamptz(), timestamp_to_char(), timestamp_trunc(), timestamp_zone(), timestamptz_cmp_timestamp(), timestamptz_date(), timestamptz_eq_timestamp(), timestamptz_ge_timestamp(), timestamptz_gt_timestamp(), timestamptz_le_timestamp(), timestamptz_lt_timestamp(), timestamptz_ne_timestamp(), timestamptz_time(), timestamptz_timetz(), timestamptz_to_char(), ts_dist(), tsrange_subdiff(), and tstzrange_subdiff().

◆ PG_GETARG_TIMESTAMPTZ

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

Definition at line 36 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(), gbt_tstz_consistent(), gbt_tstz_distance(), generate_series_timestamptz(), in_range_timestamptz_interval(), pg_replication_origin_xact_setup(), timestamp_cmp_timestamptz(), timestamp_eq_timestamptz(), timestamp_ge_timestamptz(), timestamp_gt_timestamptz(), timestamp_le_timestamptz(), timestamp_lt_timestamptz(), timestamp_ne_timestamptz(), timestamptz_age(), timestamptz_cmp_date(), timestamptz_cmp_timestamp(), timestamptz_eq_date(), timestamptz_eq_timestamp(), timestamptz_ge_date(), timestamptz_ge_timestamp(), timestamptz_gt_date(), timestamptz_gt_timestamp(), timestamptz_izone(), timestamptz_le_date(), timestamptz_le_timestamp(), timestamptz_lt_date(), timestamptz_lt_timestamp(), timestamptz_mi_interval(), timestamptz_ne_date(), timestamptz_ne_timestamp(), timestamptz_out(), timestamptz_part(), timestamptz_pl_interval(), timestamptz_scale(), timestamptz_send(), timestamptz_timestamp(), timestamptz_trunc(), timestamptz_trunc_zone(), timestamptz_zone(), and tstz_dist().

◆ PG_RETURN_INTERVAL_P

#define PG_RETURN_INTERVAL_P (   x)    return IntervalPGetDatum(x)

Definition at line 41 of file timestamp.h.

Referenced by interval_dist(), interval_div(), interval_in(), interval_justify_days(), interval_justify_hours(), interval_justify_interval(), interval_larger(), interval_mi(), interval_mul(), interval_pl(), interval_recv(), interval_scale(), interval_smaller(), interval_trunc(), interval_um(), make_interval(), time_dist(), time_interval(), time_mi_time(), timestamp_age(), timestamp_mi(), timestamptz_age(), ts_dist(), and tstz_dist().

◆ PG_RETURN_TIMESTAMP

#define PG_RETURN_TIMESTAMP (   x)    return TimestampGetDatum(x)

Definition at line 39 of file timestamp.h.

Referenced by date_timestamp(), date_timestamptz(), datetime_timestamp(), datetimetz_timestamptz(), float8_timestamptz(), make_timestamp(), timestamp_in(), timestamp_larger(), timestamp_pl_interval(), timestamp_recv(), timestamp_scale(), timestamp_smaller(), timestamp_trunc(), timestamptz_izone(), timestamptz_pl_interval(), timestamptz_timestamp(), timestamptz_trunc_zone(), timestamptz_zone(), and to_timestamp().

◆ PG_RETURN_TIMESTAMPTZ

#define PG_RETURN_TIMESTAMPTZ (   x)    return TimestampTzGetDatum(x)

Definition at line 40 of file timestamp.h.

Referenced by clock_timestamp(), make_timestamptz(), make_timestamptz_at_timezone(), now(), pg_conf_load_time(), pg_last_xact_replay_timestamp(), pg_postmaster_start_time(), pg_stat_get_backend_activity_start(), pg_stat_get_backend_start(), pg_stat_get_backend_xact_start(), pg_stat_get_bgwriter_stat_reset_time(), pg_stat_get_db_checksum_last_failure(), pg_stat_get_db_stat_reset_time(), pg_stat_get_last_analyze_time(), pg_stat_get_last_autoanalyze_time(), pg_stat_get_last_autovacuum_time(), pg_stat_get_last_vacuum_time(), pg_stat_get_snapshot_timestamp(), pg_xact_commit_timestamp(), statement_timestamp(), timestamp_izone(), timestamp_timestamptz(), timestamp_zone(), timestamptz_in(), timestamptz_recv(), timestamptz_scale(), timestamptz_trunc(), and timestamptz_trunc_zone().

◆ TIMESTAMP_MASK

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

Definition at line 44 of file timestamp.h.

◆ TimestampGetDatum

#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(), in_range_date_interval(), in_range_timestamp_interval(), leftmostvalue_timestamp(), parse_datetime(), timestamp_mi_interval(), and timestamptz_mi_interval().

◆ timestamptz_cmp_internal

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

Definition at line 100 of file timestamp.h.

Referenced by date_cmp_timestamptz_internal(), and timestamp_cmp_timestamptz_internal().

◆ TimestampTzGetDatum

#define TimestampTzGetDatum (   X)    Int64GetDatum(X)

Definition at line 32 of file timestamp.h.

Referenced by ExecEvalSQLValueFunction(), generate_series_timestamptz(), in_range_timestamptz_interval(), MakeOldSnapshotTimeMappingTuple(), parse_datetime(), 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_replication_slots(), pg_stat_get_slru(), pg_stat_get_subscription(), pg_stat_get_wal(), pg_stat_get_wal_receiver(), pg_stat_get_wal_senders(), and pg_xact_commit_timestamp_origin().

◆ TimestampTzPlusMilliseconds

#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(), MakeOldSnapshotTimeMappingTuple(), pgfdw_cancel_query(), pgfdw_exec_cleanup_query(), rebuild_database_list(), recoveryApplyDelay(), WalReceiverMain(), WalSndCheckTimeOut(), WalSndComputeSleeptime(), WalSndKeepaliveIfNecessary(), and WalSndWriteData().

Function Documentation

◆ anytimestamp_typmod_check()

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().

103 {
104  if (typmod < 0)
105  ereport(ERROR,
106  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
107  errmsg("TIMESTAMP(%d)%s precision must not be negative",
108  typmod, (istz ? " WITH TIME ZONE" : ""))));
109  if (typmod > MAX_TIMESTAMP_PRECISION)
110  {
111  ereport(WARNING,
112  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
113  errmsg("TIMESTAMP(%d)%s precision reduced to maximum allowed, %d",
114  typmod, (istz ? " WITH TIME ZONE" : ""),
115  MAX_TIMESTAMP_PRECISION)));
116  typmod = MAX_TIMESTAMP_PRECISION;
117  }
118 
119  return typmod;
120 }
errcode
int errcode(int sqlerrcode)
Definition: elog.c:691
ERROR
#define ERROR
Definition: elog.h:43
MAX_TIMESTAMP_PRECISION
#define MAX_TIMESTAMP_PRECISION
Definition: timestamp.h:53
WARNING
#define WARNING
Definition: elog.h:40
ereport
#define ereport(elevel,...)
Definition: elog.h:155
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:902

◆ date2isoweek()

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

Definition at line 4332 of file timestamp.c.

References date2j(), and j2day().

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

4333 {
4334  float8 result;
4335  int day0,
4336  day4,
4337  dayn;
4338 
4339  /* current day */
4340  dayn = date2j(year, mon, mday);
4341 
4342  /* fourth day of current year */
4343  day4 = date2j(year, 1, 4);
4344 
4345  /* day0 == offset to first day of week (Monday) */
4346  day0 = j2day(day4 - 1);
4347 
4348  /*
4349  * We need the first week containing a Thursday, otherwise this day falls
4350  * into the previous year for purposes of counting weeks
4351  */
4352  if (dayn < day4 - day0)
4353  {
4354  day4 = date2j(year - 1, 1, 4);
4355 
4356  /* day0 == offset to first day of week (Monday) */
4357  day0 = j2day(day4 - 1);
4358  }
4359 
4360  result = (dayn - (day4 - day0)) / 7 + 1;
4361 
4362  /*
4363  * Sometimes the last few days in a year will fall into the first week of
4364  * the next year, so check for this.
4365  */
4366  if (result >= 52)
4367  {
4368  day4 = date2j(year + 1, 1, 4);
4369 
4370  /* day0 == offset to first day of week (Monday) */
4371  day0 = j2day(day4 - 1);
4372 
4373  if (dayn >= day4 - day0)
4374  result = (dayn - (day4 - day0)) / 7 + 1;
4375  }
4376 
4377  return (int) result;
4378 }
float8
double float8
Definition: c.h:553
j2day
int j2day(int date)
Definition: datetime.c:327
date2j
int date2j(int y, int m, int d)
Definition: datetime.c:269

◆ date2isoyear()

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

Definition at line 4387 of file timestamp.c.

References date2j(), and j2day().

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

4388 {
4389  float8 result;
4390  int day0,
4391  day4,
4392  dayn;
4393 
4394  /* current day */
4395  dayn = date2j(year, mon, mday);
4396 
4397  /* fourth day of current year */
4398  day4 = date2j(year, 1, 4);
4399 
4400  /* day0 == offset to first day of week (Monday) */
4401  day0 = j2day(day4 - 1);
4402 
4403  /*
4404  * We need the first week containing a Thursday, otherwise this day falls
4405  * into the previous year for purposes of counting weeks
4406  */
4407  if (dayn < day4 - day0)
4408  {
4409  day4 = date2j(year - 1, 1, 4);
4410 
4411  /* day0 == offset to first day of week (Monday) */
4412  day0 = j2day(day4 - 1);
4413 
4414  year--;
4415  }
4416 
4417  result = (dayn - (day4 - day0)) / 7 + 1;
4418 
4419  /*
4420  * Sometimes the last few days in a year will fall into the first week of
4421  * the next year, so check for this.
4422  */
4423  if (result >= 52)
4424  {
4425  day4 = date2j(year + 1, 1, 4);
4426 
4427  /* day0 == offset to first day of week (Monday) */
4428  day0 = j2day(day4 - 1);
4429 
4430  if (dayn >= day4 - day0)
4431  year++;
4432  }
4433 
4434  return year;
4435 }
float8
double float8
Definition: c.h:553
j2day
int j2day(int date)
Definition: datetime.c:327
date2j
int date2j(int y, int m, int d)
Definition: datetime.c:269

◆ date2isoyearday()

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

Definition at line 4444 of file timestamp.c.

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

Referenced by DCH_to_char().

4445 {
4446  return date2j(year, mon, mday) - isoweek2j(date2isoyear(year, mon, mday), 1) + 1;
4447 }
date2isoyear
int date2isoyear(int year, int mon, int mday)
Definition: timestamp.c:4387
isoweek2j
int isoweek2j(int year, int week)
Definition: timestamp.c:4281
date2j
int date2j(int y, int m, int d)
Definition: datetime.c:269

◆ dt2time()

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

Definition at line 1793 of file timestamp.c.

References USECS_PER_HOUR, USECS_PER_MINUTE, and USECS_PER_SEC.

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

1794 {
1795  TimeOffset time;
1796 
1797  time = jd;
1798 
1799  *hour = time / USECS_PER_HOUR;
1800  time -= (*hour) * USECS_PER_HOUR;
1801  *min = time / USECS_PER_MINUTE;
1802  time -= (*min) * USECS_PER_MINUTE;
1803  *sec = time / USECS_PER_SEC;
1804  *fsec = time - (*sec * USECS_PER_SEC);
1805 } /* dt2time() */
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
USECS_PER_MINUTE
#define USECS_PER_MINUTE
Definition: timestamp.h:93
USECS_PER_HOUR
#define USECS_PER_HOUR
Definition: timestamp.h:92
TimeOffset
int64 TimeOffset
Definition: timestamp.h:40

◆ GetCurrentTimestamp()

TimestampTz GetCurrentTimestamp ( void  )

Definition at line 1578 of file timestamp.c.

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

Referenced by ApplyLauncherMain(), ApplyWorkerMain(), asyncQueueFillWarning(), autoprewarm_main(), autovac_refresh_stats(), AutoVacLauncherMain(), backend_read_statsfile(), BackgroundWriterMain(), check_log_duration(), CheckPointGuts(), CleanupBackgroundWorker(), clock_timestamp(), CreateCheckPoint(), CreateEndOfRecoveryRecord(), CreateRestartPoint(), DetermineSleepTime(), disable_timeout(), disable_timeouts(), do_analyze_rel(), do_start_bgworker(), do_start_worker(), drandom(), enable_timeout_after(), enable_timeout_at(), enable_timeouts(), get_role_password(), GetCurrentTransactionStopTimestamp(), GetReplicationApplyDelay(), GetSnapshotCurrentTimestamp(), handle_sig_alarm(), heap_vacuum_rel(), InitProcessGlobals(), launcher_determine_sleep(), 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_read_statsfiles(), pgstat_recv_inquiry(), pgstat_recv_resetreplslotcounter(), pgstat_recv_resetsharedcounter(), pgstat_recv_resetsinglecounter(), pgstat_recv_resetslrucounter(), pgstat_report_activity(), pgstat_report_analyze(), pgstat_report_autovac(), pgstat_report_checksum_failures_in_db(), 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(), StartTransaction(), StartupXLOG(), test_pattern(), throttle(), UpdateWorkerStats(), WaitExceedsMaxStandbyDelay(), WaitForWALToBecomeAvailable(), WalReceiverMain(), WalSndKeepalive(), WalSndLoop(), WalSndUpdateProgress(), WalSndWaitForWal(), WalSndWriteData(), XLogBackgroundFlush(), XLogFileRead(), XLogRestorePoint(), XLogSendPhysical(), XLogWalRcvSendHSFeedback(), and XLogWalRcvSendReply().

1579 {
1580  TimestampTz result;
1581  struct timeval tp;
1582 
1583  gettimeofday(&tp, NULL);
1584 
1585  result = (TimestampTz) tp.tv_sec -
1586  ((POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY);
1587  result = (result * USECS_PER_SEC) + tp.tv_usec;
1588 
1589  return result;
1590 }
gettimeofday
int gettimeofday(struct timeval *tp, struct timezone *tzp)
Definition: gettimeofday.c:104
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
SECS_PER_DAY
#define SECS_PER_DAY
Definition: timestamp.h:86
UNIX_EPOCH_JDATE
#define UNIX_EPOCH_JDATE
Definition: timestamp.h:162
POSTGRES_EPOCH_JDATE
#define POSTGRES_EPOCH_JDATE
Definition: timestamp.h:163

◆ GetEpochTime()

void GetEpochTime ( struct pg_tm *  tm)

Definition at line 2046 of file timestamp.c.

References elog, epoch, ERROR, 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().

2047 {
2048  struct pg_tm *t0;
2049  pg_time_t epoch = 0;
2050 
2051  t0 = pg_gmtime(&epoch);
2052 
2053  if (t0 == NULL)
2054  elog(ERROR, "could not convert epoch to timestamp: %m");
2055 
2056  tm->tm_year = t0->tm_year;
2057  tm->tm_mon = t0->tm_mon;
2058  tm->tm_mday = t0->tm_mday;
2059  tm->tm_hour = t0->tm_hour;
2060  tm->tm_min = t0->tm_min;
2061  tm->tm_sec = t0->tm_sec;
2062 
2063  tm->tm_year += 1900;
2064  tm->tm_mon++;
2065 }
pg_time_t
int64 pg_time_t
Definition: pgtime.h:23
pg_gmtime
struct pg_tm * pg_gmtime(const pg_time_t *timep)
Definition: localtime.c:1387
pg_tm::tm_hour
int tm_hour
Definition: pgtime.h:29
pg_tm
Definition: pgtime.h:25
ERROR
#define ERROR
Definition: elog.h:43
pg_tm::tm_mday
int tm_mday
Definition: pgtime.h:30
pg_tm::tm_mon
int tm_mon
Definition: pgtime.h:31
pg_tm::tm_year
int tm_year
Definition: pgtime.h:32
elog
#define elog(elevel,...)
Definition: elog.h:228
epoch
static const unsigned __int64 epoch
Definition: gettimeofday.c:34
pg_tm::tm_sec
int tm_sec
Definition: pgtime.h:27
pg_tm::tm_min
int tm_min
Definition: pgtime.h:28

◆ GetSQLCurrentTimestamp()

TimestampTz GetSQLCurrentTimestamp ( int32  typmod)

Definition at line 1596 of file timestamp.c.

References AdjustTimestampForTypmod(), and GetCurrentTransactionStartTimestamp().

Referenced by ExecEvalSQLValueFunction().

1597 {
1598  TimestampTz ts;
1599 
1600  ts = GetCurrentTransactionStartTimestamp();
1601  if (typmod >= 0)
1602  AdjustTimestampForTypmod(&ts, typmod);
1603  return ts;
1604 }
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
AdjustTimestampForTypmod
void AdjustTimestampForTypmod(Timestamp *time, int32 typmod)
Definition: timestamp.c:392
GetCurrentTransactionStartTimestamp
TimestampTz GetCurrentTransactionStartTimestamp(void)
Definition: xact.c:798

◆ GetSQLLocalTimestamp()

Timestamp GetSQLLocalTimestamp ( int32  typmod)

Definition at line 1610 of file timestamp.c.

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

Referenced by ExecEvalSQLValueFunction().

1611 {
1612  Timestamp ts;
1613 
1614  ts = timestamptz2timestamp(GetCurrentTransactionStartTimestamp());
1615  if (typmod >= 0)
1616  AdjustTimestampForTypmod(&ts, typmod);
1617  return ts;
1618 }
AdjustTimestampForTypmod
void AdjustTimestampForTypmod(Timestamp *time, int32 typmod)
Definition: timestamp.c:392
timestamptz2timestamp
static Timestamp timestamptz2timestamp(TimestampTz timestamp)
Definition: timestamp.c:5269
Timestamp
int64 Timestamp
Definition: timestamp.h:38
GetCurrentTransactionStartTimestamp
TimestampTz GetCurrentTransactionStartTimestamp(void)
Definition: xact.c:798

◆ interval2tm()

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

Definition at line 1964 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().

1965 {
1966  TimeOffset time;
1967  TimeOffset tfrac;
1968 
1969  tm->tm_year = span.month / MONTHS_PER_YEAR;
1970  tm->tm_mon = span.month % MONTHS_PER_YEAR;
1971  tm->tm_mday = span.day;
1972  time = span.time;
1973 
1974  tfrac = time / USECS_PER_HOUR;
1975  time -= tfrac * USECS_PER_HOUR;
1976  tm->tm_hour = tfrac;
1977  if (!SAMESIGN(tm->tm_hour, tfrac))
1978  ereport(ERROR,
1979  (errcode(ERRCODE_DATETIME_VALUE_OUT_OF_RANGE),
1980  errmsg("interval out of range")));
1981  tfrac = time / USECS_PER_MINUTE;
1982  time -= tfrac * USECS_PER_MINUTE;
1983  tm->tm_min = tfrac;
1984  tfrac = time / USECS_PER_SEC;
1985  *fsec = time - (tfrac * USECS_PER_SEC);
1986  tm->tm_sec = tfrac;
1987 
1988  return 0;
1989 }
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
pg_tm::tm_hour
int tm_hour
Definition: pgtime.h:29
USECS_PER_MINUTE
#define USECS_PER_MINUTE
Definition: timestamp.h:93
errcode
int errcode(int sqlerrcode)
Definition: elog.c:691
Interval::day
int32 day
Definition: timestamp.h:47
MONTHS_PER_YEAR
#define MONTHS_PER_YEAR
Definition: timestamp.h:69
ERROR
#define ERROR
Definition: elog.h:43
pg_tm::tm_mday
int tm_mday
Definition: pgtime.h:30
pg_tm::tm_mon
int tm_mon
Definition: pgtime.h:31
USECS_PER_HOUR
#define USECS_PER_HOUR
Definition: timestamp.h:92
Interval::time
TimeOffset time
Definition: timestamp.h:45
SAMESIGN
#define SAMESIGN(a, b)
Definition: timestamp.c:47
Interval::month
int32 month
Definition: timestamp.h:48
TimeOffset
int64 TimeOffset
Definition: timestamp.h:40
ereport
#define ereport(elevel,...)
Definition: elog.h:155
pg_tm::tm_year
int tm_year
Definition: pgtime.h:32
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:902
pg_tm::tm_sec
int tm_sec
Definition: pgtime.h:27
pg_tm::tm_min
int tm_min
Definition: pgtime.h:28

◆ isoweek2date()

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

Definition at line 4301 of file timestamp.c.

References isoweek2j(), and j2date().

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

4302 {
4303  j2date(isoweek2j(*year, woy), year, mon, mday);
4304 }
j2date
void j2date(int jd, int *year, int *month, int *day)
Definition: datetime.c:294
isoweek2j
int isoweek2j(int year, int week)
Definition: timestamp.c:4281

◆ isoweek2j()

int isoweek2j ( int  year,
int  week 
)

Definition at line 4281 of file timestamp.c.

References date2j(), and j2day().

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

4282 {
4283  int day0,
4284  day4;
4285 
4286  /* fourth day of current year */
4287  day4 = date2j(year, 1, 4);
4288 
4289  /* day0 == offset to first day of week (Monday) */
4290  day0 = j2day(day4 - 1);
4291 
4292  return ((week - 1) * 7) + (day4 - day0);
4293 }
j2day
int j2day(int date)
Definition: datetime.c:327
date2j
int date2j(int y, int m, int d)
Definition: datetime.c:269

◆ isoweekdate2date()

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

Definition at line 4314 of file timestamp.c.

References isoweek2j(), and j2date().

Referenced by do_to_timestamp().

4315 {
4316  int jday;
4317 
4318  jday = isoweek2j(*year, isoweek);
4319  /* convert Gregorian week start (Sunday=1) to ISO week start (Monday=1) */
4320  if (wday > 1)
4321  jday += wday - 2;
4322  else
4323  jday += 6;
4324  j2date(jday, year, mon, mday);
4325 }
j2date
void j2date(int jd, int *year, int *month, int *day)
Definition: datetime.c:294
isoweek2j
int isoweek2j(int year, int week)
Definition: timestamp.c:4281

◆ SetEpochTimestamp()

Timestamp SetEpochTimestamp ( void  )

Definition at line 2068 of file timestamp.c.

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

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

2069 {
2070  Timestamp dt;
2071  struct pg_tm tt,
2072  *tm = &tt;
2073 
2074  GetEpochTime(tm);
2075  /* we don't bother to test for failure ... */
2076  tm2timestamp(tm, 0, NULL, &dt);
2077 
2078  return dt;
2079 } /* SetEpochTimestamp() */
pg_tm
Definition: pgtime.h:25
tm
static struct pg_tm tm
Definition: localtime.c:102
Timestamp
int64 Timestamp
Definition: timestamp.h:38
tm2timestamp
int tm2timestamp(struct pg_tm *tm, fsec_t fsec, int *tzp, Timestamp *result)
Definition: timestamp.c:1916
GetEpochTime
void GetEpochTime(struct pg_tm *tm)
Definition: timestamp.c:2046

◆ time_t_to_timestamptz()

TimestampTz time_t_to_timestamptz ( pg_time_t  tm)

Definition at line 1730 of file timestamp.c.

References POSTGRES_EPOCH_JDATE, 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().

1731 {
1732  TimestampTz result;
1733 
1734  result = (TimestampTz) tm -
1735  ((POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY);
1736  result *= USECS_PER_SEC;
1737 
1738  return result;
1739 }
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
tm
static struct pg_tm tm
Definition: localtime.c:102
SECS_PER_DAY
#define SECS_PER_DAY
Definition: timestamp.h:86
UNIX_EPOCH_JDATE
#define UNIX_EPOCH_JDATE
Definition: timestamp.h:162
POSTGRES_EPOCH_JDATE
#define POSTGRES_EPOCH_JDATE
Definition: timestamp.h:163

◆ timestamp2timestamptz_opt_overflow()

TimestampTz timestamp2timestamptz_opt_overflow ( Timestamp  timestamp,
int *  overflow 
)

Definition at line 5200 of file timestamp.c.

References DetermineTimeZoneOffset(), dt2local(), ereport, errcode(), errmsg(), ERROR, IS_VALID_TIMESTAMP, MIN_TIMESTAMP, session_timezone, timestamp2tm(), TIMESTAMP_NOBEGIN, TIMESTAMP_NOEND, TIMESTAMP_NOT_FINITE, and tm.

Referenced by timestamp2timestamptz(), and timestamp_cmp_timestamptz_internal().

5201 {
5202  TimestampTz result;
5203  struct pg_tm tt,
5204  *tm = &tt;
5205  fsec_t fsec;
5206  int tz;
5207 
5208  if (overflow)
5209  *overflow = 0;
5210 
5211  if (TIMESTAMP_NOT_FINITE(timestamp))
5212  return timestamp;
5213 
5214  /* We don't expect this to fail, but check it pro forma */
5215  if (timestamp2tm(timestamp, NULL, tm, &fsec, NULL, NULL) == 0)
5216  {
5217  tz = DetermineTimeZoneOffset(tm, session_timezone);
5218 
5219  result = dt2local(timestamp, -tz);
5220 
5221  if (IS_VALID_TIMESTAMP(result))
5222  {
5223  return result;
5224  }
5225  else if (overflow)
5226  {
5227  if (result < MIN_TIMESTAMP)
5228  {
5229  *overflow = -1;
5230  TIMESTAMP_NOBEGIN(result);
5231  }
5232  else
5233  {
5234  *overflow = 1;
5235  TIMESTAMP_NOEND(result);
5236  }
5237  return result;
5238  }
5239  }
5240 
5241  ereport(ERROR,
5242  (errcode(ERRCODE_DATETIME_VALUE_OUT_OF_RANGE),
5243  errmsg("timestamp out of range")));
5244 
5245  return 0;
5246 }
TIMESTAMP_NOEND
#define TIMESTAMP_NOEND(j)
Definition: timestamp.h:117
session_timezone
PGDLLIMPORT pg_tz * session_timezone
Definition: pgtz.c:28
timestamp
int64 timestamp
Definition: pgtypes_timestamp.h:10
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
timestamp2tm
int timestamp2tm(Timestamp dt, int *tzp, struct pg_tm *tm, fsec_t *fsec, const char **tzn, pg_tz *attimezone)
Definition: timestamp.c:1820
errcode
int errcode(int sqlerrcode)
Definition: elog.c:691
pg_tm
Definition: pgtime.h:25
tm
static struct pg_tm tm
Definition: localtime.c:102
TIMESTAMP_NOT_FINITE
#define TIMESTAMP_NOT_FINITE(j)
Definition: timestamp.h:122
ERROR
#define ERROR
Definition: elog.h:43
DetermineTimeZoneOffset
int DetermineTimeZoneOffset(struct pg_tm *tm, pg_tz *tzp)
Definition: datetime.c:1478
TIMESTAMP_NOBEGIN
#define TIMESTAMP_NOBEGIN(j)
Definition: timestamp.h:112
fsec_t
int32 fsec_t
Definition: timestamp.h:41
MIN_TIMESTAMP
#define MIN_TIMESTAMP
Definition: timestamp.h:184
ereport
#define ereport(elevel,...)
Definition: elog.h:155
IS_VALID_TIMESTAMP
#define IS_VALID_TIMESTAMP(t)
Definition: timestamp.h:195
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:902
dt2local
static Timestamp dt2local(Timestamp dt, int timezone)
Definition: timestamp.c:2014

◆ timestamp2tm()

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

Definition at line 1820 of file timestamp.c.

References dt2time(), j2date(), 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 DetermineTimeZoneAbbrevOffsetTS(), GetCurrentTimeUsec(), JsonEncodeDateTime(), make_timestamptz_at_timezone(), map_sql_value_to_xml_value(), pg_timezone_names(), PGTYPEStimestamp_add_interval(), PGTYPEStimestamp_fmt_asc(), PGTYPEStimestamp_to_asc(), timestamp2timestamptz_opt_overflow(), timestamp_age(), timestamp_date(), timestamp_out(), timestamp_part(), timestamp_pl_interval(), timestamp_recv(), timestamp_time(), timestamp_to_char(), timestamp_trunc(), timestamp_zone(), timestamptz2timestamp(), 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_internal(), and timestamptz_zone().

1821 {
1822  Timestamp date;
1823  Timestamp time;
1824  pg_time_t utime;
1825 
1826  /* Use session timezone if caller asks for default */
1827  if (attimezone == NULL)
1828  attimezone = session_timezone;
1829 
1830  time = dt;
1831  TMODULO(time, date, USECS_PER_DAY);
1832 
1833  if (time < INT64CONST(0))
1834  {
1835  time += USECS_PER_DAY;
1836  date -= 1;
1837  }
1838 
1839  /* add offset to go from J2000 back to standard Julian date */
1840  date += POSTGRES_EPOCH_JDATE;
1841 
1842  /* Julian day routine does not work for negative Julian days */
1843  if (date < 0 || date > (Timestamp) INT_MAX)
1844  return -1;
1845 
1846  j2date((int) date, &tm->tm_year, &tm->tm_mon, &tm->tm_mday);
1847  dt2time(time, &tm->tm_hour, &tm->tm_min, &tm->tm_sec, fsec);
1848 
1849  /* Done if no TZ conversion wanted */
1850  if (tzp == NULL)
1851  {
1852  tm->tm_isdst = -1;
1853  tm->tm_gmtoff = 0;
1854  tm->tm_zone = NULL;
1855  if (tzn != NULL)
1856  *tzn = NULL;
1857  return 0;
1858  }
1859 
1860  /*
1861  * If the time falls within the range of pg_time_t, use pg_localtime() to
1862  * rotate to the local time zone.
1863  *
1864  * First, convert to an integral timestamp, avoiding possibly
1865  * platform-specific roundoff-in-wrong-direction errors, and adjust to
1866  * Unix epoch. Then see if we can convert to pg_time_t without loss. This
1867  * coding avoids hardwiring any assumptions about the width of pg_time_t,
1868  * so it should behave sanely on machines without int64.
1869  */
1870  dt = (dt - *fsec) / USECS_PER_SEC +
1871  (POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY;
1872  utime = (pg_time_t) dt;
1873  if ((Timestamp) utime == dt)
1874  {
1875  struct pg_tm *tx = pg_localtime(&utime, attimezone);
1876 
1877  tm->tm_year = tx->tm_year + 1900;
1878  tm->tm_mon = tx->tm_mon + 1;
1879  tm->tm_mday = tx->tm_mday;
1880  tm->tm_hour = tx->tm_hour;
1881  tm->tm_min = tx->tm_min;
1882  tm->tm_sec = tx->tm_sec;
1883  tm->tm_isdst = tx->tm_isdst;
1884  tm->tm_gmtoff = tx->tm_gmtoff;
1885  tm->tm_zone = tx->tm_zone;
1886  *tzp = -tm->tm_gmtoff;
1887  if (tzn != NULL)
1888  *tzn = tm->tm_zone;
1889  }
1890  else
1891  {
1892  /*
1893  * When out of range of pg_time_t, treat as GMT
1894  */
1895  *tzp = 0;
1896  /* Mark this as *no* time zone available */
1897  tm->tm_isdst = -1;
1898  tm->tm_gmtoff = 0;
1899  tm->tm_zone = NULL;
1900  if (tzn != NULL)
1901  *tzn = NULL;
1902  }
1903 
1904  return 0;
1905 }
pg_time_t
int64 pg_time_t
Definition: pgtime.h:23
session_timezone
PGDLLIMPORT pg_tz * session_timezone
Definition: pgtz.c:28
pg_tm::tm_isdst
int tm_isdst
Definition: pgtime.h:35
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
pg_tm::tm_hour
int tm_hour
Definition: pgtime.h:29
date
long date
Definition: pgtypes_date.h:9
pg_tm::tm_gmtoff
long int tm_gmtoff
Definition: pgtime.h:36
pg_tm
Definition: pgtime.h:25
SECS_PER_DAY
#define SECS_PER_DAY
Definition: timestamp.h:86
pg_tm::tm_mday
int tm_mday
Definition: pgtime.h:30
pg_tm::tm_mon
int tm_mon
Definition: pgtime.h:31
USECS_PER_DAY
#define USECS_PER_DAY
Definition: timestamp.h:91
pg_tm::tm_zone
const char * tm_zone
Definition: pgtime.h:37
j2date
void j2date(int jd, int *year, int *month, int *day)
Definition: datetime.c:294
Timestamp
int64 Timestamp
Definition: timestamp.h:38
dt2time
void dt2time(Timestamp jd, int *hour, int *min, int *sec, fsec_t *fsec)
Definition: timestamp.c:1793
pg_localtime
struct pg_tm * pg_localtime(const pg_time_t *timep, const pg_tz *tz)
Definition: localtime.c:1342
pg_tm::tm_year
int tm_year
Definition: pgtime.h:32
UNIX_EPOCH_JDATE
#define UNIX_EPOCH_JDATE
Definition: timestamp.h:162
POSTGRES_EPOCH_JDATE
#define POSTGRES_EPOCH_JDATE
Definition: timestamp.h:163
pg_tm::tm_sec
int tm_sec
Definition: pgtime.h:27
pg_tm::tm_min
int tm_min
Definition: pgtime.h:28
TMODULO
#define TMODULO(t, q, u)
Definition: datetime.h:249

◆ timestamp_cmp_internal()

int timestamp_cmp_internal ( Timestamp  dt1,
Timestamp  dt2 
)

Definition at line 2088 of file timestamp.c.

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

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

◆ timestamp_cmp_timestamptz_internal()

int32 timestamp_cmp_timestamptz_internal ( Timestamp  timestampVal,
TimestampTz  dt2 
)

Definition at line 2192 of file timestamp.c.

References timestamp2timestamptz_opt_overflow(), 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().

2193 {
2194  TimestampTz dt1;
2195  int overflow;
2196 
2197  dt1 = timestamp2timestamptz_opt_overflow(timestampVal, &overflow);
2198  if (overflow > 0)
2199  {
2200  /* dt1 is larger than any finite timestamp, but less than infinity */
2201  return TIMESTAMP_IS_NOEND(dt2) ? -1 : +1;
2202  }
2203  if (overflow < 0)
2204  {
2205  /* dt1 is less than any finite timestamp, but more than -infinity */
2206  return TIMESTAMP_IS_NOBEGIN(dt2) ? +1 : -1;
2207  }
2208 
2209  return timestamptz_cmp_internal(dt1, dt2);
2210 }
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
timestamp2timestamptz_opt_overflow
TimestampTz timestamp2timestamptz_opt_overflow(Timestamp timestamp, int *overflow)
Definition: timestamp.c:5200
timestamptz_cmp_internal
#define timestamptz_cmp_internal(dt1, dt2)
Definition: timestamp.h:100
TIMESTAMP_IS_NOEND
#define TIMESTAMP_IS_NOEND(j)
Definition: timestamp.h:120
TIMESTAMP_IS_NOBEGIN
#define TIMESTAMP_IS_NOBEGIN(j)
Definition: timestamp.h:115

◆ TimestampDifference()

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

Definition at line 1654 of file timestamp.c.

References start_time, and USECS_PER_SEC.

Referenced by check_log_duration(), DetermineSleepTime(), heap_vacuum_rel(), launcher_determine_sleep(), log_disconnections(), ProcSleep(), and schedule_alarm().

1656 {
1657  TimestampTz diff = stop_time - start_time;
1658 
1659  if (diff <= 0)
1660  {
1661  *secs = 0;
1662  *microsecs = 0;
1663  }
1664  else
1665  {
1666  *secs = (long) (diff / USECS_PER_SEC);
1667  *microsecs = (int) (diff % USECS_PER_SEC);
1668  }
1669 }
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
start_time
static time_t start_time
Definition: pg_ctl.c:99

◆ TimestampDifferenceExceeds()

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

Definition at line 1709 of file timestamp.c.

References start_time.

Referenced by ApplyLauncherMain(), asyncQueueFillWarning(), autovac_refresh_stats(), AutoVacLauncherMain(), do_analyze_rel(), do_start_worker(), heap_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().

1712 {
1713  TimestampTz diff = stop_time - start_time;
1714 
1715  return (diff >= msec * INT64CONST(1000));
1716 }
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
start_time
static time_t start_time
Definition: pg_ctl.c:99

◆ TimestampDifferenceMilliseconds()

long TimestampDifferenceMilliseconds ( TimestampTz  start_time,
TimestampTz  stop_time 
)

Definition at line 1691 of file timestamp.c.

References start_time.

Referenced by autoprewarm_main(), GetReplicationApplyDelay(), GetReplicationTransferLatency(), LogCheckpointEnd(), pgfdw_get_cleanup_result(), recoveryApplyDelay(), WaitForWALToBecomeAvailable(), and WalSndComputeSleeptime().

1692 {
1693  TimestampTz diff = stop_time - start_time;
1694 
1695  if (diff <= 0)
1696  return 0;
1697  else
1698  return (long) ((diff + 999) / 1000);
1699 }
TimestampTz
int64 TimestampTz
Definition: timestamp.h:39
start_time
static time_t start_time
Definition: pg_ctl.c:99

◆ TimestampTimestampTzRequiresRewrite()

bool TimestampTimestampTzRequiresRewrite ( void  )

Definition at line 5169 of file timestamp.c.

References pg_get_timezone_offset(), and session_timezone.

Referenced by ATColumnChangeRequiresRewrite().

5170 {
5171  long offset;
5172 
5173  if (pg_get_timezone_offset(session_timezone, &offset) && offset == 0)
5174  return false;
5175  return true;
5176 }
session_timezone
PGDLLIMPORT pg_tz * session_timezone
Definition: pgtz.c:28
pg_get_timezone_offset
bool pg_get_timezone_offset(const pg_tz *tz, long int *gmtoff)
Definition: localtime.c:1849

◆ timestamptz_to_str()

const char* timestamptz_to_str ( TimestampTz  t)

Definition at line 1772 of file timestamp.c.

References buf, EncodeDateTime(), EncodeSpecialTimestamp(), MAXDATELEN, snprintf, 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(), pg_decode_stream_commit(), pgstat_recv_inquiry(), ProcessStandbyHSFeedbackMessage(), ProcessStandbyReplyMessage(), ProcessWalSndrMessage(), recoveryStopsAfter(), recoveryStopsBefore(), StartupXLOG(), xact_desc_abort(), xact_desc_commit(), xact_desc_prepare(), and xlog_desc().

1773 {
1774  static char buf[MAXDATELEN + 1];
1775  int tz;
1776  struct pg_tm tt,
1777  *tm = &tt;
1778  fsec_t fsec;
1779  const char *tzn;
1780 
1781  if (TIMESTAMP_NOT_FINITE(t))
1782  EncodeSpecialTimestamp(t, buf);
1783  else if (timestamp2tm(t, &tz, tm, &fsec, &tzn, NULL) == 0)
1784  EncodeDateTime(tm, fsec, true, tz, tzn, USE_ISO_DATES, buf);
1785  else
1786  strlcpy(buf, "(timestamp out of range)", sizeof(buf));
1787 
1788  return buf;
1789 }
MAXDATELEN
#define MAXDATELEN
Definition: datetime.h:201
timestamp2tm
int timestamp2tm(Timestamp dt, int *tzp, struct pg_tm *tm, fsec_t *fsec, const char **tzn, pg_tz *attimezone)
Definition: timestamp.c:1820
EncodeSpecialTimestamp
void EncodeSpecialTimestamp(Timestamp dt, char *str)
Definition: timestamp.c:1531
pg_tm
Definition: pgtime.h:25
USE_ISO_DATES
#define USE_ISO_DATES
Definition: miscadmin.h:214
tm
static struct pg_tm tm
Definition: localtime.c:102
TIMESTAMP_NOT_FINITE
#define TIMESTAMP_NOT_FINITE(j)
Definition: timestamp.h:122
buf
static char * buf
Definition: pg_test_fsync.c:68
EncodeDateTime
void EncodeDateTime(struct pg_tm *tm, fsec_t fsec, bool print_tz, int tz, const char *tzn, int style, char *str)
Definition: datetime.c:4002
fsec_t
int32 fsec_t
Definition: timestamp.h:41
strlcpy
size_t strlcpy(char *dst, const char *src, size_t siz)
Definition: strlcpy.c:45

◆ timestamptz_to_time_t()

pg_time_t timestamptz_to_time_t ( TimestampTz  t)

Definition at line 1752 of file timestamp.c.

References POSTGRES_EPOCH_JDATE, SECS_PER_DAY, UNIX_EPOCH_JDATE, and USECS_PER_SEC.

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

1753 {
1754  pg_time_t result;
1755 
1756  result = (pg_time_t) (t / USECS_PER_SEC +
1757  ((POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * SECS_PER_DAY));
1758 
1759  return result;
1760 }
pg_time_t
int64 pg_time_t
Definition: pgtime.h:23
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
SECS_PER_DAY
#define SECS_PER_DAY
Definition: timestamp.h:86
UNIX_EPOCH_JDATE
#define UNIX_EPOCH_JDATE
Definition: timestamp.h:162
POSTGRES_EPOCH_JDATE
#define POSTGRES_EPOCH_JDATE
Definition: timestamp.h:163

◆ tm2interval()

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

Definition at line 1992 of file timestamp.c.

References Interval::day, 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().

1993 {
1994  double total_months = (double) tm->tm_year * MONTHS_PER_YEAR + tm->tm_mon;
1995 
1996  if (total_months > INT_MAX || total_months < INT_MIN)
1997  return -1;
1998  span->month = total_months;
1999  span->day = tm->tm_mday;
2000  span->time = (((((tm->tm_hour * INT64CONST(60)) +
2001  tm->tm_min) * INT64CONST(60)) +
2002  tm->tm_sec) * USECS_PER_SEC) + fsec;
2003 
2004  return 0;
2005 }
USECS_PER_SEC
#define USECS_PER_SEC
Definition: timestamp.h:94
pg_tm::tm_hour
int tm_hour
Definition: pgtime.h:29
Interval::day
int32 day
Definition: timestamp.h:47
MONTHS_PER_YEAR
#define MONTHS_PER_YEAR
Definition: timestamp.h:69
pg_tm::tm_mday
int tm_mday
Definition: pgtime.h:30
pg_tm::tm_mon
int tm_mon
Definition: pgtime.h:31
Interval::time
TimeOffset time
Definition: timestamp.h:45
Interval::month
int32 month
Definition: timestamp.h:48
pg_tm::tm_year
int tm_year
Definition: pgtime.h:32
pg_tm::tm_sec
int tm_sec
Definition: pgtime.h:27
pg_tm::tm_min
int tm_min
Definition: pgtime.h:28

◆ tm2timestamp()

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

Definition at line 1916 of file timestamp.c.

References date2j(), dt2local(), IS_VALID_JULIAN, IS_VALID_TIMESTAMP, 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 check_recovery_target_time(), parse_datetime(), PGTYPEStimestamp_add_interval(), PGTYPEStimestamp_current(), PGTYPEStimestamp_defmt_scan(), PGTYPEStimestamp_from_asc(), SetEpochTimestamp(), timestamp_in(), timestamp_pl_interval(), timestamp_trunc(), timestamp_zone(), timestamptz2timestamp(), timestamptz_in(), timestamptz_pl_interval(), timestamptz_trunc_internal(), timestamptz_zone(), and to_timestamp().

1917 {
1918  TimeOffset date;
1919  TimeOffset time;
1920 
1921  /* Prevent overflow in Julian-day routines */
1922  if (!IS_VALID_JULIAN(tm->tm_year, tm->tm_mon, tm->tm_mday))
1923  {
1924  *result = 0; /* keep compiler quiet */
1925  return -1;
1926  }
1927 
1928  date = date2j(tm->tm_year, tm->tm_mon, tm->tm_mday) - POSTGRES_EPOCH_JDATE;
1929  time = time2t(tm->tm_hour, tm->tm_min, tm->tm_sec, fsec);
1930 
1931  *result = date * USECS_PER_DAY + time;
1932  /* check for major overflow */
1933  if ((*result - time) / USECS_PER_DAY != date)
1934  {
1935  *result = 0; /* keep compiler quiet */
1936  return -1;
1937  }
1938  /* check for just-barely overflow (okay except time-of-day wraps) */
1939  /* caution: we want to allow 1999-12-31 24:00:00 */
1940  if ((*result < 0 && date > 0) ||
1941  (*result > 0 && date < -1))
1942  {
1943  *result = 0; /* keep compiler quiet */
1944  return -1;
1945  }
1946  if (tzp != NULL)
1947  *result = dt2local(*result, -(*tzp));
1948 
1949  /* final range check catches just-out-of-range timestamps */
1950  if (!IS_VALID_TIMESTAMP(*result))
1951  {
1952  *result = 0; /* keep compiler quiet */
1953  return -1;
1954  }
1955 
1956  return 0;
1957 }
time2t
static TimeOffset time2t(const int hour, const int min, const int sec, const fsec_t fsec)
Definition: timestamp.c:2008
pg_tm::tm_hour
int tm_hour
Definition: pgtime.h:29
date
long date
Definition: pgtypes_date.h:9
pg_tm::tm_mday
int tm_mday
Definition: pgtime.h:30
pg_tm::tm_mon
int tm_mon
Definition: pgtime.h:31
IS_VALID_JULIAN
#define IS_VALID_JULIAN(y, m, d)
Definition: timestamp.h:155
USECS_PER_DAY
#define USECS_PER_DAY
Definition: timestamp.h:91
TimeOffset
int64 TimeOffset
Definition: timestamp.h:40
date2j
int date2j(int y, int m, int d)
Definition: datetime.c:269
IS_VALID_TIMESTAMP
#define IS_VALID_TIMESTAMP(t)
Definition: timestamp.h:195
pg_tm::tm_year
int tm_year
Definition: pgtime.h:32
POSTGRES_EPOCH_JDATE
#define POSTGRES_EPOCH_JDATE
Definition: timestamp.h:163
dt2local
static Timestamp dt2local(Timestamp dt, int timezone)
Definition: timestamp.c:2014
pg_tm::tm_sec
int tm_sec
Definition: pgtime.h:27
pg_tm::tm_min
int tm_min
Definition: pgtime.h:28

Variable Documentation

◆ PgReloadTime

TimestampTz PgReloadTime

Definition at line 53 of file timestamp.c.

Referenced by pg_conf_load_time(), and PostmasterMarkPIDForWorkerNotify().

◆ PgStartTime

TimestampTz PgStartTime

Definition at line 50 of file timestamp.c.

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