From 40f908bdcdc726fc11912cd95dfd2f89603d1f37 Mon Sep 17 00:00:00 2001 From: Heikki Linnakangas Date: Fri, 15 Jan 2010 09:19:10 +0000 Subject: Introduce Streaming Replication. This includes two new kinds of postmaster processes, walsenders and walreceiver. Walreceiver is responsible for connecting to the primary server and streaming WAL to disk, while walsender runs in the primary server and streams WAL from disk to the client. Documentation still needs work, but the basics are there. We will probably pull the replication section to a new chapter later on, as well as the sections describing file-based replication. But let's do that as a separate patch, so that it's easier to see what has been added/changed. This patch also adds a new section to the chapter about FE/BE protocol, documenting the protocol used by walsender/walreceivxer. Bump catalog version because of two new functions, pg_last_xlog_receive_location() and pg_last_xlog_replay_location(), for monitoring the progress of replication. Fujii Masao, with additional hacking by me --- src/include/access/xlogdefs.h | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) (limited to 'src/include/access/xlogdefs.h') diff --git a/src/include/access/xlogdefs.h b/src/include/access/xlogdefs.h index 8f524df75e2..8ecc3a21b1c 100644 --- a/src/include/access/xlogdefs.h +++ b/src/include/access/xlogdefs.h @@ -7,7 +7,7 @@ * Portions Copyright (c) 1996-2010, PostgreSQL Global Development Group * Portions Copyright (c) 1994, Regents of the University of California * - * $PostgreSQL: pgsql/src/include/access/xlogdefs.h,v 1.24 2010/01/02 16:58:01 momjian Exp $ + * $PostgreSQL: pgsql/src/include/access/xlogdefs.h,v 1.25 2010/01/15 09:19:06 heikki Exp $ */ #ifndef XLOG_DEFS_H #define XLOG_DEFS_H @@ -56,6 +56,22 @@ typedef struct XLogRecPtr ((a).xlogid == (b).xlogid && (a).xrecoff == (b).xrecoff) +/* + * Macro for advancing a record pointer by the specified number of bytes. + */ +#define XLByteAdvance(recptr, nbytes) \ + do { \ + if (recptr.xrecoff + nbytes >= XLogFileSize) \ + { \ + recptr.xlogid += 1; \ + recptr.xrecoff \ + = recptr.xrecoff + nbytes - XLogFileSize; \ + } \ + else \ + recptr.xrecoff += nbytes; \ + } while (0) + + /* * TimeLineID (TLI) - identifies different database histories to prevent * confusion after restoring a prior state of a database installation. -- cgit v1.2.3