Remove misleading comments. Move _Clone and _DeClone functions before
authorHeikki Linnakangas <[email protected]>
Fri, 3 Dec 2010 12:58:24 +0000 (14:58 +0200)
committerHeikki Linnakangas <[email protected]>
Fri, 3 Dec 2010 12:58:24 +0000 (14:58 +0200)
the "END OF FORMAT CALLBACKS" comment, because they are format callbacks too.

src/bin/pg_dump/pg_backup_custom.c

index f2969e2fac45b7cc999599f62f6607f0c83b873d..87c6fb6ec2a3a9bda5b621eae9f367bbda1754e7 100644 (file)
@@ -597,8 +597,6 @@ _skipData(ArchiveHandle *AH)
  * Mandatory.
  *
  * Called by the archiver to do integer & byte output to the archive.
- * These routines are only used to read & write headers & TOC.
- *
  */
 static int
 _WriteByte(ArchiveHandle *AH, const int i)
@@ -620,7 +618,6 @@ _WriteByte(ArchiveHandle *AH, const int i)
  * Mandatory
  *
  * Called by the archiver to read bytes & integers from the archive.
- * These routines are only used to read & write headers & TOC.
  * EOF should be treated as a fatal error.
  */
 static int
@@ -642,8 +639,6 @@ _ReadByte(ArchiveHandle *AH)
  * Mandatory.
  *
  * Called by the archiver to write a block of bytes to the archive.
- * These routines are only used to read & write headers & TOC.
- *
  */
 static size_t
 _WriteBuf(ArchiveHandle *AH, const void *buf, size_t len)
@@ -667,8 +662,6 @@ _WriteBuf(ArchiveHandle *AH, const void *buf, size_t len)
  * Mandatory.
  *
  * Called by the archiver to read a block of bytes from the archive
- * These routines are only used to read & write headers & TOC.
- *
  */
 static size_t
 _ReadBuf(ArchiveHandle *AH, void *buf, size_t len)
@@ -770,6 +763,39 @@ _ReopenArchive(ArchiveHandle *AH)
                     strerror(errno));
 }
 
+/*
+ * Clone format-specific fields during parallel restoration.
+ */
+static void
+_Clone(ArchiveHandle *AH)
+{
+   lclContext *ctx = (lclContext *) AH->formatData;
+
+   AH->formatData = (lclContext *) malloc(sizeof(lclContext));
+   if (AH->formatData == NULL)
+       die_horribly(AH, modulename, "out of memory\n");
+   memcpy(AH->formatData, ctx, sizeof(lclContext));
+   ctx = (lclContext *) AH->formatData;
+
+   /* sanity check, shouldn't happen */
+   if (ctx->cs != NULL)
+       die_horribly(AH, modulename, "compressor active\n");
+
+   /*
+    * Note: we do not make a local lo_buf because we expect at most one BLOBS
+    * entry per archive, so no parallelism is possible.  Likewise,
+    * TOC-entry-local state isn't an issue because any one TOC entry is
+    * touched by just one worker child.
+    */
+}
+
+static void
+_DeClone(ArchiveHandle *AH)
+{
+   lclContext *ctx = (lclContext *) AH->formatData;
+   free(ctx);
+}
+
 /*--------------------------------------------------
  * END OF FORMAT CALLBACKS
  *--------------------------------------------------
@@ -889,36 +915,3 @@ _CustomReadFunc(ArchiveHandle *AH, char **buf, size_t *buflen)
    }
    return cnt;
 }
-
-/*
- * Clone format-specific fields during parallel restoration.
- */
-static void
-_Clone(ArchiveHandle *AH)
-{
-   lclContext *ctx = (lclContext *) AH->formatData;
-
-   AH->formatData = (lclContext *) malloc(sizeof(lclContext));
-   if (AH->formatData == NULL)
-       die_horribly(AH, modulename, "out of memory\n");
-   memcpy(AH->formatData, ctx, sizeof(lclContext));
-   ctx = (lclContext *) AH->formatData;
-
-   /* sanity check, shouldn't happen */
-   if (ctx->cs != NULL)
-       die_horribly(AH, modulename, "compressor active\n");
-
-   /*
-    * Note: we do not make a local lo_buf because we expect at most one BLOBS
-    * entry per archive, so no parallelism is possible.  Likewise,
-    * TOC-entry-local state isn't an issue because any one TOC entry is
-    * touched by just one worker child.
-    */
-}
-
-static void
-_DeClone(ArchiveHandle *AH)
-{
-   lclContext *ctx = (lclContext *) AH->formatData;
-   free(ctx);
-}