Arrange to fsync the contents of lockfiles (both postmaster.pid and the
authorTom Lane <[email protected]>
Mon, 16 Aug 2010 17:33:12 +0000 (17:33 +0000)
committerTom Lane <[email protected]>
Mon, 16 Aug 2010 17:33:12 +0000 (17:33 +0000)
socket lockfile) when writing them.  The lack of an fsync here may well
explain two different reports we've seen of corrupted lockfile contents,
which doesn't particularly bother the running server but can prevent a
new server from starting if the old one crashes.  Per suggestion from
Alvaro.

Back- to all supported versions.

src/backend/utils/init/miscinit.c

index 3651821210481e1fcc315b367d5ad3cf8e55624b..e488f5d05e23d930c6d59bbcf6d166117f899007 100644 (file)
@@ -8,7 +8,7 @@
  *
  *
  * IDENTIFICATION
- *   $PostgreSQL: pgsql/src/backend/utils/init/miscinit.c,v 1.159.2.2 2009/12/09 21:58:29 tgl Exp $
+ *   $PostgreSQL: pgsql/src/backend/utils/init/miscinit.c,v 1.159.2.3 2010/08/16 17:33:12 tgl Exp $
  *
  *-------------------------------------------------------------------------
  */
@@ -873,6 +873,9 @@ CreateLockFile(const char *filename, bool amPostmaster,
         * admin) but has left orphan backends behind.  Check for this by
         * looking to see if there is an associated shmem segment that is
         * still in use.
+        *
+        * Note: because postmaster.pid is written in two steps, we might not
+        * find the shmem ID values in it; we can't treat that as an error.
         */
        if (isDDLock)
        {
@@ -937,7 +940,18 @@ CreateLockFile(const char *filename, bool amPostmaster,
                (errcode_for_file_access(),
                 errmsg("could not write lock file \"%s\": %m", filename)));
    }
-   if (close(fd))
+   if (pg_fsync(fd) != 0)
+   {
+       int         save_errno = errno;
+
+       close(fd);
+       unlink(filename);
+       errno = save_errno;
+       ereport(FATAL,
+               (errcode_for_file_access(),
+                errmsg("could not write lock file \"%s\": %m", filename)));
+   }
+   if (close(fd) != 0)
    {
        int         save_errno = errno;
 
@@ -1098,7 +1112,14 @@ RecordSharedMemoryInLockFile(unsigned long id1, unsigned long id2)
        close(fd);
        return;
    }
-   if (close(fd))
+   if (pg_fsync(fd) != 0)
+   {
+       ereport(LOG,
+               (errcode_for_file_access(),
+                errmsg("could not write to file \"%s\": %m",
+                       DIRECTORY_LOCK_FILE)));
+   }
+   if (close(fd) != 0)
    {
        ereport(LOG,
                (errcode_for_file_access(),