repack_internal.h File Reference

#include "nodes/execnodes.h"
#include "replication/decode.h"
#include "postmaster/bgworker.h"
#include "replication/logical.h"
#include "storage/buffile.h"
#include "storage/sharedfileset.h"
#include "storage/shm_mq.h"
#include "utils/resowner.h"

Include dependency graph for repack_internal.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	RepackDecodingState
struct	DecodingWorkerShared

Macros
#define	CHANGE_INSERT   'i'
#define	CHANGE_UPDATE_OLD   'u'
#define	CHANGE_UPDATE_NEW   'U'
#define	CHANGE_DELETE   'd'
#define	REPACK_ERROR_QUEUE_SIZE   16384

Typedefs
typedef char	ConcurrentChangeKind
typedef struct RepackDecodingState	RepackDecodingState
typedef struct DecodingWorkerShared	DecodingWorkerShared

Functions
void	DecodingWorkerFileName (char *fname, Oid relid, uint32 seq)

Macro Definition Documentation

CHANGE_DELETE

#define CHANGE_DELETE   'd'

Definition at line 32 of file repack_internal.h.

CHANGE_INSERT

#define CHANGE_INSERT   'i'

Definition at line 29 of file repack_internal.h.

CHANGE_UPDATE_NEW

#define CHANGE_UPDATE_NEW   'U'

Definition at line 31 of file repack_internal.h.

CHANGE_UPDATE_OLD

#define CHANGE_UPDATE_OLD   'u'

Definition at line 30 of file repack_internal.h.

REPACK_ERROR_QUEUE_SIZE

#define REPACK_ERROR_QUEUE_SIZE   16384

Definition at line 118 of file repack_internal.h.

Typedef Documentation

ConcurrentChangeKind

typedef char ConcurrentChangeKind

Definition at line 27 of file repack_internal.h.

DecodingWorkerShared

typedef struct DecodingWorkerShared DecodingWorkerShared

RepackDecodingState

typedef struct RepackDecodingState RepackDecodingState

Function Documentation

DecodingWorkerFileName()

void DecodingWorkerFileName ( char *  fname, Oid  relid, uint32  seq  )

extern

Definition at line 3494 of file repack.c.

{
    /* The PID is already present in the fileset name, so we needn't add it */
    snprintf(fname, MAXPGPATH, "%u-%u", relid, seq);
}

References fb(), MAXPGPATH, and snprintf.

Referenced by decode_concurrent_changes(), export_initial_snapshot(), get_initial_snapshot(), and process_concurrent_changes().