pg_backup_null.c File Reference

#include "postgres_fe.h"
#include "fe_utils/string_utils.h"
#include "libpq/libpq-fs.h"
#include "pg_backup_archiver.h"
#include "pg_backup_utils.h"

Include dependency graph for pg_backup_null.c:

Go to the source code of this file.

Functions
static void	_WriteData (ArchiveHandle *AH, const void *data, size_t dLen)
static void	_WriteLOData (ArchiveHandle *AH, const void *data, size_t dLen)
static void	_EndData (ArchiveHandle *AH, TocEntry *te)
static int	_WriteByte (ArchiveHandle *AH, const int i)
static void	_WriteBuf (ArchiveHandle *AH, const void *buf, size_t len)
static void	_CloseArchive (ArchiveHandle *AH)
static void	_PrintTocData (ArchiveHandle *AH, TocEntry *te)
static void	_StartLOs (ArchiveHandle *AH, TocEntry *te)
static void	_StartLO (ArchiveHandle *AH, TocEntry *te, Oid oid)
static void	_EndLO (ArchiveHandle *AH, TocEntry *te, Oid oid)
static void	_EndLOs (ArchiveHandle *AH, TocEntry *te)
void	InitArchiveFmt_Null (ArchiveHandle *AH)

Function Documentation

_CloseArchive()

static void _CloseArchive ( ArchiveHandle *  AH )

static

Definition at line 221 of file pg_backup_null.c.

{
    /* Nothing to do */
}

Referenced by InitArchiveFmt_Null().

_EndData()

static void _EndData ( ArchiveHandle *  AH, TocEntry *  te  )

static

Definition at line 110 of file pg_backup_null.c.

{
    ahprintf(AH, "\n\n");
}

References ahprintf().

Referenced by InitArchiveFmt_Null().

_EndLO()

static void _EndLO ( ArchiveHandle *  AH, TocEntry *  te, Oid  oid  )

static

Definition at line 165 of file pg_backup_null.c.

{
    AH->WriteDataPtr = _WriteData;
 
    ahprintf(AH, "SELECT pg_catalog.lo_close(0);\n\n");
}

References _WriteData(), ahprintf(), and _archiveHandle::WriteDataPtr.

Referenced by InitArchiveFmt_Null().

_EndLOs()

static void _EndLOs ( ArchiveHandle *  AH, TocEntry *  te  )

static

Definition at line 178 of file pg_backup_null.c.

{
    ahprintf(AH, "COMMIT;\n\n");
}

References ahprintf().

Referenced by _PrintTocData(), and InitArchiveFmt_Null().

_PrintTocData()

static void _PrintTocData ( ArchiveHandle *  AH, TocEntry *  te  )

static

Definition at line 189 of file pg_backup_null.c.

{
    if (te->dataDumper)
    {
        AH->currToc = te;
 
        if (strcmp(te->desc, "BLOBS") == 0)
            _StartLOs(AH, te);
 
        te->dataDumper((Archive *) AH, te->dataDumperArg);
 
        if (strcmp(te->desc, "BLOBS") == 0)
            _EndLOs(AH, te);
 
        AH->currToc = NULL;
    }
}

References _EndLOs(), _StartLOs(), _archiveHandle::currToc, _tocEntry::dataDumper, _tocEntry::dataDumperArg, and _tocEntry::desc.

Referenced by InitArchiveFmt_Null().

_StartLO()

static void _StartLO ( ArchiveHandle *  AH, TocEntry *  te, Oid  oid  )

static

Definition at line 138 of file pg_backup_null.c.

{
    bool        old_lo_style = (AH->version < K_VERS_1_12);
 
    if (oid == 0)
        pg_fatal("invalid OID for large object");
 
    /* With an old archive we must do drop and create logic here */
    if (old_lo_style && AH->public.ropt->dropSchema)
        DropLOIfExists(AH, oid);
 
    if (old_lo_style)
        ahprintf(AH, "SELECT pg_catalog.lo_open(pg_catalog.lo_create('%u'), %d);\n",
                 oid, INV_WRITE);
    else
        ahprintf(AH, "SELECT pg_catalog.lo_open('%u', %d);\n",
                 oid, INV_WRITE);
 
    AH->WriteDataPtr = _WriteLOData;
}

References _WriteLOData(), ahprintf(), DropLOIfExists(), _restoreOptions::dropSchema, INV_WRITE, K_VERS_1_12, pg_fatal, _archiveHandle::public, Archive::ropt, _archiveHandle::version, and _archiveHandle::WriteDataPtr.

Referenced by InitArchiveFmt_Null().

_StartLOs()

static void _StartLOs ( ArchiveHandle *  AH, TocEntry *  te  )

static

Definition at line 125 of file pg_backup_null.c.

{
    ahprintf(AH, "BEGIN;\n\n");
}

References ahprintf().

Referenced by _PrintTocData(), and InitArchiveFmt_Null().

_WriteBuf()

static void _WriteBuf ( ArchiveHandle *  AH, const void *  buf, size_t  len  )

static

Definition at line 215 of file pg_backup_null.c.

{
    /* Don't do anything */
}

Referenced by InitArchiveFmt_Null().

_WriteByte()

static int _WriteByte ( ArchiveHandle *  AH, const int  i  )

static

Definition at line 208 of file pg_backup_null.c.

{
    /* Don't do anything */
    return 0;
}

Referenced by InitArchiveFmt_Null().

_WriteData()

static void _WriteData ( ArchiveHandle *  AH, const void *  data, size_t  dLen  )

static

Definition at line 81 of file pg_backup_null.c.

{
    /* Just send it to output, ahwrite() already errors on failure */
    ahwrite(data, 1, dLen, AH);
}

References ahwrite(), and data.

Referenced by _EndLO(), and InitArchiveFmt_Null().

_WriteLOData()

static void _WriteLOData ( ArchiveHandle *  AH, const void *  data, size_t  dLen  )

static

Definition at line 92 of file pg_backup_null.c.

{
    if (dLen > 0)
    {
        PQExpBuffer buf = createPQExpBuffer();
 
        appendByteaLiteralAHX(buf,
                              (const unsigned char *) data,
                              dLen,
                              AH);
 
        ahprintf(AH, "SELECT pg_catalog.lowrite(0, %s);\n", buf->data);
 
        destroyPQExpBuffer(buf);
    }
}

References ahprintf(), appendByteaLiteralAHX, buf, createPQExpBuffer(), data, and destroyPQExpBuffer().

Referenced by _StartLO().

InitArchiveFmt_Null()

void InitArchiveFmt_Null

(

ArchiveHandle *

AH

)

Definition at line 48 of file pg_backup_null.c.

{
    /* Assuming static functions, this can be copied for each format. */
    AH->WriteDataPtr = _WriteData;
    AH->EndDataPtr = _EndData;
    AH->WriteBytePtr = _WriteByte;
    AH->WriteBufPtr = _WriteBuf;
    AH->ClosePtr = _CloseArchive;
    AH->ReopenPtr = NULL;
    AH->PrintTocDataPtr = _PrintTocData;
 
    AH->StartLOsPtr = _StartLOs;
    AH->StartLOPtr = _StartLO;
    AH->EndLOPtr = _EndLO;
    AH->EndLOsPtr = _EndLOs;
    AH->ClonePtr = NULL;
    AH->DeClonePtr = NULL;
 
    /*
     * Now prevent reading...
     */
    if (AH->mode == archModeRead)
        pg_fatal("this format cannot be read");
}

References _CloseArchive(), _EndData(), _EndLO(), _EndLOs(), _PrintTocData(), _StartLO(), _StartLOs(), _WriteBuf(), _WriteByte(), _WriteData(), archModeRead, _archiveHandle::ClonePtr, _archiveHandle::ClosePtr, _archiveHandle::DeClonePtr, _archiveHandle::EndDataPtr, _archiveHandle::EndLOPtr, _archiveHandle::EndLOsPtr, _archiveHandle::mode, pg_fatal, _archiveHandle::PrintTocDataPtr, _archiveHandle::ReopenPtr, _archiveHandle::StartLOPtr, _archiveHandle::StartLOsPtr, _archiveHandle::WriteBufPtr, _archiveHandle::WriteBytePtr, and _archiveHandle::WriteDataPtr.

Referenced by _allocAH().