Fix Y2038 issues with MyStartTime.
authorNathan Bossart <[email protected]>
Mon, 7 Oct 2024 18:51:03 +0000 (13:51 -0500)
committerNathan Bossart <[email protected]>
Mon, 7 Oct 2024 18:51:03 +0000 (13:51 -0500)
Several places treat MyStartTime as a "long", which is only 32 bits
wide on some platforms.  In reality, MyStartTime is a pg_time_t,
i.e., a signed 64-bit integer.  This will lead to interesting bugs
on the aforementioned systems in 2038 when signed 32-bit integers
are no longer sufficient to store Unix time (e.g., "pg_ctl start"
hanging).  To fix, ensure that MyStartTime is handled as a 64-bit
value everywhere.  (Of course, users will need to ensure that
time_t is 64 bits wide on their system, too.)

Co-authored-by: Max Johnson
Discussion: https://postgr.es/m/CO1PR07MB905262E8AC270FAAACED66008D682%40CO1PR07MB9052.namprd07.prod.outlook.com
Backpatch-through: 12

contrib/postgres_fdw/option.c
src/backend/utils/error/csvlog.c
src/backend/utils/error/elog.c
src/backend/utils/error/jsonlog.c
src/backend/utils/init/miscinit.c
src/bin/pg_ctl/pg_ctl.c

index 630b304338adabd13c86fcdb5d5a8c8be8d20f18..d740893918c2455631604a6c7be66145b9c8ba99 100644 (file)
@@ -522,7 +522,7 @@ process_pgfdw_appname(const char *appname)
                                appendStringInfoString(&buf, application_name);
                                break;
                        case 'c':
-                               appendStringInfo(&buf, "%lx.%x", (long) (MyStartTime), MyProcPid);
+                               appendStringInfo(&buf, "%" INT64_MODIFIER "x.%x", MyStartTime, MyProcPid);
                                break;
                        case 'C':
                                appendStringInfoString(&buf, cluster_name);
index 855e130a97dbb44a75482f25998502e7b6fac5ce..eab8df3fcc3fffa4fc08ffd59716b94040fa870f 100644 (file)
@@ -120,7 +120,7 @@ write_csvlog(ErrorData *edata)
        appendStringInfoChar(&buf, ',');
 
        /* session id */
-       appendStringInfo(&buf, "%lx.%x", (long) MyStartTime, MyProcPid);
+       appendStringInfo(&buf, "%" INT64_MODIFIER "x.%x", MyStartTime, MyProcPid);
        appendStringInfoChar(&buf, ',');
 
        /* Line number */
index 5cbb5b5416891acdf624c7ac8e961232d8d5bb67..987ff98067b610531211dc9ebd05d58389a95a89 100644 (file)
@@ -2944,12 +2944,12 @@ log_status_format(StringInfo buf, const char *format, ErrorData *edata)
                                {
                                        char            strfbuf[128];
 
-                                       snprintf(strfbuf, sizeof(strfbuf) - 1, "%lx.%x",
-                                                        (long) (MyStartTime), MyProcPid);
+                                       snprintf(strfbuf, sizeof(strfbuf) - 1, "%" INT64_MODIFIER "x.%x",
+                                                        MyStartTime, MyProcPid);
                                        appendStringInfo(buf, "%*s", padding, strfbuf);
                                }
                                else
-                                       appendStringInfo(buf, "%lx.%x", (long) (MyStartTime), MyProcPid);
+                                       appendStringInfo(buf, "%" INT64_MODIFIER "x.%x", MyStartTime, MyProcPid);
                                break;
                        case 'p':
                                if (padding != 0)
index bd0124869d5e07dc3e4df74c621887b6a1303f0b..2c7b14cacb14b048ca8a815dc007a806aac07686 100644 (file)
@@ -168,8 +168,8 @@ write_jsonlog(ErrorData *edata)
        }
 
        /* Session id */
-       appendJSONKeyValueFmt(&buf, "session_id", true, "%lx.%x",
-                                                 (long) MyStartTime, MyProcPid);
+       appendJSONKeyValueFmt(&buf, "session_id", true, "%" INT64_MODIFIER "x.%x",
+                                                 MyStartTime, MyProcPid);
 
        /* Line number */
        appendJSONKeyValueFmt(&buf, "line_num", false, "%ld", log_line_number);
index 537d92c0cfde2e744879f194b36bf31cca277712..ef60f41b8ce36db24f33320709b14f8f0b35b59f 100644 (file)
@@ -1372,10 +1372,10 @@ CreateLockFile(const char *filename, bool amPostmaster,
         * both datadir and socket lockfiles; although more stuff may get added to
         * the datadir lockfile later.
         */
-       snprintf(buffer, sizeof(buffer), "%d\n%s\n%ld\n%d\n%s\n",
+       snprintf(buffer, sizeof(buffer), "%d\n%s\n" INT64_FORMAT "\n%d\n%s\n",
                         amPostmaster ? (int) my_pid : -((int) my_pid),
                         DataDir,
-                        (long) MyStartTime,
+                        MyStartTime,
                         PostPortNumber,
                         socketDir);
 
index e7e878c22f04c3d4b3379004cb460e6d6db20e7a..d6bb2c33119eda5ca75b8a3114b2610ea79b0438 100644 (file)
@@ -618,7 +618,7 @@ wait_for_postmaster_start(pid_t pm_pid, bool do_checkpoint)
                         * Allow 2 seconds slop for possible cross-process clock skew.
                         */
                        pmpid = atol(optlines[LOCK_FILE_LINE_PID - 1]);
-                       pmstart = atol(optlines[LOCK_FILE_LINE_START_TIME - 1]);
+                       pmstart = atoll(optlines[LOCK_FILE_LINE_START_TIME - 1]);
                        if (pmstart >= start_time - 2 &&
 #ifndef WIN32
                                pmpid == pm_pid