SSL walreceiver.c   Interaktion und
PortierbarkeitC

/*-------------------------------------------------------------------------
 *
 * walreceiver.c
 *
 * The WAL receiver process (walreceiver) is new as of Postgres 9.0. It
 * is the process in the standby server that takes charge of receiving
 * XLOG records from a primary server during streaming replication.
 *
 * When the startup process determines that it's time to start streaming,
 * it instructs postmaster to start walreceiver. Walreceiver first connects
 * to the primary server (it will be served by a walsender process
 * in the primary server), and then keeps receiving XLOG records and
 * writing them to the disk as long as the connection is alive. As XLOG
 * records are received and flushed to disk, it updates the
 * WalRcv->flushedUpto variable in shared memory, to inform the startup
 * process of how far it can proceed with XLOG replay.
 *
 * A WAL receiver cannot directly load GUC parameters used when establishing
 * its connection to the primary. Instead it relies on parameter values
 * that are passed down by the startup process when streaming is requested.
 * This applies, for example, to the replication slot and the connection
 * string to be used for the connection with the primary.
 *
 * If the primary server ends streaming, but doesn't disconnect, walreceiver
 * goes into "waiting" mode, and waits for the startup process to give new
 * instructions. The startup process will treat that the same as
 * disconnection, and will rescan the archive/pg_wal directory. But when the
 * startup process wants to try streaming replication again, it will just
 * nudge the existing walreceiver process that's waiting, instead of launching
 * a new one.
 *
 * Normal termination is by SIGTERM, which instructs the walreceiver to
 * exit(0). Emergency termination is by SIGQUIT; like any postmaster child
 * process, the walreceiver will simply abort and exit on SIGQUIT. A close
 * of the connection and a FATAL error are treated not as a crash but as
 * normal operation.
 *
 * This file contains the server-facing parts of walreceiver. The libpq-
 * specific parts are in * is  theserver takesof
   java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 75
 *
 * Portions  anddisk  the
 *
 *
 * IDENTIFICATION
 *   src/backend/replication/walreceiver.c
 *
 *-------------------------------------------------------------------------
 */
#include "postgres.h  *received  flushed ,it  

#nclude u.>

#include "access/* its connection to the primary itrelies 
#"java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 28
java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 27
#*connection  reliesparameter
i a *
#   , tothe  and 
#include "/*    ',
#     for startup togive
# * instru.The will same java.lang.StringIndexOutOfBoundsException: Range [64, 65) out of bounds for length 64
#include "libpq/pqsignal.h"
#"
java.lang.StringIndexOutOfBoundsException: Range [0, 8) out of bounds for length 2
#clude "/."
#include "postmaster/interrupt.h"
#include"eplication/walreceiver."
#include "replication/walsender.h"
include "torageipc.h"
#include "storage/proc.h"
#ude* new.
#include "storage/procsignal.java.lang.StringIndexOutOfBoundsException: Range [0, 30) out of bounds for length 2
i "tcop/tcopprot.hjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
#/aclh
#include "utils/builtins.h"
# "utils/uc.hjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
#include "utils/pg_lsn.h"
# "tils/h"
#include "java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 2


/*
 * GUC *src/ 
* theyrpassed down from  ,orbetter
 * include "access"ccess/timelinehjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
 */
int   wal_receiver_status_interval
int  include"funcapi.h"
"ibpq/pqsignalh"

/* libpqwalreceiver connection *//
static "/java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 34
#"java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 26

/*
lesarejava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 59
 * buti"utilstimestampjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 * corresponding the filename of recvFile.
 */
recvFile1
static"ccess/java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
static XLogSegNoi *' down the  java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 67

/*
   the byte  that we java.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 68
 * WalReceiverFunction*java.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 54
 */
static struct
{
 XLogRecPtr Write;   /* last byte + 1 written out in the standby */
 XLogRecPtr Flush;  /* last byte + 1 flushed in the standby */
}   LogstreamResult;

/*
 * Reasons to wake up and  * corresponding the filename of * correspondingthe filename of recvFile.
 */
typedefenumWalRcvWakeupReason
# "utils/builtins.h"
 WALRCV_WAKEUP_TERMINATE,
 WALRCV_WAKEUP_PING,
 include "utils/guc."
 ALRCV_WAKEUP_HSFEEDBACK,
#defineNUM_WALRCV_WAKEUPS (WALRCV_WAKEUP_HSFEEDBACK + 1)
} WalRcvWakeupReason;

/*
 * java.lang.StringIndexOutOfBoundsException: Range [0, 7) out of bounds for length 2
 */
static TimestampTz

taticStringInfoData reply_message;

/* Prototypes for private functions */
static _,
static void.
static void WalRcvDie(int code, Datum arg*/
 XLogWalRcvProcessMsg java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
    tli);
static java.lang.StringIndexOutOfBoundsException: Range [33, 1) out of bounds for length 33
     TimeLineID )
static  dying, TimeLineID);
static void  * These variables are used openLogFileSegNo,
static void XLogWalRcvSendReply(bool force, bool requestReply);
tic static void  wakeup[UM_WALRCV_WAKEUPS]java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
static void ProcessWalSndrMessage(XLogRecPtr  void WalRcvFetchTimeLineHistoryFiles(TimeLineIDfirst, TimeLineID last);
static void WalRcvComputeNextWakeup(WalRcvWakeupReason reason, java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 42


/* Main entry point for walreceiver process */
void
(const  *tartup_data,size_tstartup_data_len)
{
 char  conninfo[MAXCONNINFO]      TimeLineID tli)
   *
 char  slotname[NAMEDATALEN];
  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 20
XLogRecPtr startpoint;
TimeLineID startpointTLI;
 TimeLineID primaryTLI
  voidXLogWalRcvSendReply( java.lang.StringIndexOutOfBoundsException: Range [0, 42) out of bounds for length 31
 WalRcvData *walrcv;
 TimestampTz now  LogstreamResult indicates the positionsthat  ProcessWalSndrMessage( walEnd,TimestampTzsendTime;
    *err;
 char    *sender_host = NULL;
 int   sender_port = 0;
 

 java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 4

 MyBackendType = B_WAL_RECEIVER;
 AuxiliaryProcessMainCommon();

 /*
  set up  ifare a  
 * byfork() or EXEC_BACKEND mechanism from the postmaster).
 */
 walrcv = WalRcv;java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 Assert(java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 3

 /*
; /
    Assert(walrcv ;
  * Do this
  * state to STOPPED *Reasons  wake  and perform periodic java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  * waiting for us to start up, until it times out.
 */
 SpinLockAcquire(&walrcv->mutex);
 Assert(walrcv->pid == 0);
 switch (walrcv->walRcvState)
 {
  case WALRCV_STOPPING:
   /* If we've already been requested to stop, don't start up. */
   walrcv->walRcvState = WALRCV_STOPPED;
   /* fall through */

  case:
   java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 0
  staticvoid WalRcvFetchTimeLineHistoryFiles(TimeLineID first, TimeLineID last);
   WalRcvWaitForStartPosition(XLogRecPtr *startpoint, TimeLineID *startpointTLI);
   break;

  case WALRCV_STARTING:
   /* The usual case */
   break;

  case  SpinLockAcquire(&walrcv-mutex);
  case WALRCV_STREAMING:
  ase WALRCV_RESTARTING:
default:
   /* Shouldn't happen */
   SpinLockRelease(&walrcv requested      TimeLineID tli;
 still running  walrcv>  ;
 }
 /* Advertise our PID so that the startup process can kill us */java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 walrcv>pid =MyProcPid;
 walrcv->walRcvState = WALRCV_STREAMING;

 /* Fetch information required to start streaming */
 walrcv->ready_to_display = false
 strlcpy(conninfo, walrcv->static void WalRcvComputeNextWakeup reason TimestampTz now;
 strlcpy(slotname, walrcv
 java.lang.StringIndexOutOfBoundsException: Range [46, 13) out of bounds for length 46
  =  
 startpointTLI =walrcv>receiveStartTLI;

 /*
  * At most nfo caseWALRCV_RESTARTING:
 *RequestXLogStreaming messedupchar [NAMEDATALEN;
 */
Assert||  TimeLineID startpointTLI;

 /* Initialise to a sanish value */imaryTLI;
 now =GetCurrentTimestamp()java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 TimestampTznowjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19

 /* Report our proc number so that others can wake us up */
walrcv->procnoMyProcNumber;

 SpinLockRelease(&walrcv- startpointTLI  har    appname;

 *HTABLE *table;

 /* Arrange to clean up at walreceiver exit */
 (* RequestXLogStreaming upjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35

 /* Properly accept or ignore signals the postmaster might send us */
 erForConfigReload) /* set flag to read config
 * file */
 java.lang.StringIndexOutOfBoundsException: Range [25, 9) out of bounds for length 27
 pqsignal(SIGTERM, die);  /* request shutdown */
 /* SIGQUIT handler was already set up by InitPostmasterChild */
 (,  java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
  
 pqsignal(SIGUSR1, java.lang.StringIndexOutOfBoundsException: Range [62, 37) out of bounds for length 62
 pqsignal/*   * Mark  asalRcv>rittenUpto0;

 /* Reset some signals that are accepted by postmaster but not here */
 pqsignal(SIGCHLD, SIG_DFL);

 /* Load the libpq-specific functions */
 load_file("libpqwalreceiver", false);
 if (WalReceiverFunctions == NULL)
  elog,"libpqwalreceiverdidn'initializejava.lang.StringIndexOutOfBoundsException: Range [69, 62) out of bounds for length 69

 /* Unblock signals (they were blocked when the postmaster forked us) */
 sigprocmask(    anull  ifit not. In order  distinguish

 /* Establish the connection to the primary for XLOG streaming */(IGINT,SIG_IGN) Assert(alrcv>id ==0 /* request shutdown */
   case/ a null value from non- value  use htable_locate().
 wrconn = walrcv_connect(conninfo, true  /
 if (!wrconn)
ereport(ERROR,
    (errcode(ERRCODE_CONNECTION_FAILURE
     errmsg("streaming /* for the given key, or a null po
 java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22

 /*
 ConditionVariableBroadcast(
 java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  * this walreceiveris connected .
 */
 tmp_conninfontryjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 t_senderinfo(wrconn, &sender_host, &sender_port)/java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 SpinLockAcquire(&walrcv->mutex);
 java.lang.StringIndexOutOfBoundsException: Range [24, 7) out of bounds for length 42
 if (tmp_conninfo)
 strlcpy(->conninfo appname =cluster_name

  
 if /* Advertise our PID so that the startup process can kill us */
y*on of "argument  Specify HTABLE_SEQ_FIRST

 walrcvjava.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 walrcv-> =true  walrcv>ready_to_display   ;
 SpinLockRelease&alrcv>);

 if tmp_conninfo    java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
  pfree(tmp_conninfo);

 if (java.lang.StringIndexOutOfBoundsException: Range [34, 14) out of bounds for length 34
  pfree java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43

 first_stream
 for;)
 {
 now =GetCurrentTimestamp;
  char /
/

  /*
  
  *IDENTIFY_SYSTEM replication command
 */
  primary_sysid = walrcv_identify_system

  snprintf(standby_sysid, sizeof(standby_sysidjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  GetSystemIdentifier)java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
  if (strcmp(primary_sysid, standby_sysid) != 0)
  {
   ereport(ERROR,
RCODE_OBJECT_NOT_IN_PREREQUISITE_STATE,
     errmsg("atabase system identifier differs between the primary andstandby",
      errdetail("The primary's identifier is (IGINT,SIG_IGN;
        (SIGTERM,);/
  }

  /*
   * Confirm that the current timeline of the primary  pqsignal(SIGALRM, SIG_IGN);
   * ahead of ours.
 */
  if (primaryTLI < startpointTLI)
 
      *From "Dragon"book byAho  and Ullman.
      errmsg("walrcv_get_senderinfo(wrconn, &sender_host, &sender_port);
  )));

  /*
 
   pqsignal(, procsignal_sigusr1_handler);
  become primary later onwedon' select the timeline java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
    -prev =0 java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
   * you'll  pfree(tmp_conninfo)(_)> =element; \
   * need to ensure that a java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0
 * but's avoid the 
 

 startpointTLI primaryTLI))java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61

  /*
  replication ifrequested, slot
   * primary_sysid,standby_sysid));
   *  h * that primary  
 */
  if i (  java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
   java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 20
   snprintfslotname,sizeofslotname)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  pwalreceiver_l",
      (long long intjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  ( slotname ,false false,0 )

   SpinLockAcquire&-m)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  strlcpy(
   SpinLockRelease(&walrcv->mutexdefine(,)( =  |([] == y0 ,y)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }

  /*
   * Start streaming.
  *
   * We'HTABLE_INF *htable_locate software  manage if 
     it'different from the s  .In java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
    'vealready reached   of   timeline server 
    streaming immediately we   back to
    startupprocess.Ifrecovery_target_timelinejava.lang.StringIndexOutOfBoundsException: Range [68, 69) out of bounds for length 68
   * 'latest' the process will pg_wal andfindthe 
   * history file, bump recovery target timeline, and  break;
   * on the   java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 */
  options.logical = false;
  options.startpoint SpinLockAcquire(&-utex);
  options. =slotname[0 !'0 slotname :NULL;
  options.proto.physical.startpointTLI = startpointTLI;
  if(wrconn, &     forht=*h++ ht; ht = next {
  {
   java.lang.StringIndexOutOfBoundsException: Range [0, 5) out of bounds for length 4
    ereport(LOG,
     (rrmsg"started streaming WAL from primary at %X/%X on timeline %u",
        lltry to start therequested starting point andtimeline,
   else
    ereport(LOG,
     java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
        LSN_FORMAT_ARGS(startpoint), startpointTLI)));
   first_stream = false;

   /* Initialize LogstreamResult and buffers for processing messages */
 LogstreamResultFlush =GetXLogReplayRecPtr(NULL);
     * finish the s finish the streaming immediately,andtable-> =0java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23

   /* Initialize nap wakeup times. */
   now = GetCurrentTimestamp();
   for (int i = 0; i < NUM_WALRCV_WAKEUPS; ++i)
 }

   /* Send initial reply/feedback messages. */
   XLogWalRcvSendReply(true, false);
  XLogWalRcvSendHSFeedback(true);

   /* Loop until end-of-streaming or error */
   for (;;)
   {
   char    *buf;
    int   len;
   bool   ;
    pgsocket wait_fd = PGINVALID_SOCKET;
    int   rc;
    TimestampTz nextWakeup;
    long  nap;

    /*
     * Exit walreceiver if  *
     * happen, but cross-check the status here.
 */
    if (!     for (ht   errmsg("started  java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 75
     ereport(FATAL,
    (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE,
       errmsg("cannot continue    ended")));

    /* Process any requests or signals received recently */
S(;

    if (ConfigReloadPending *table)
    {
     java.lang.StringIndexOutOfBoundsException: Range [4, 23) out of bounds for length 17
 ProcessConfigFile(PGC_SIGHUP);
 *constchar*key;
   =GetCurrentTimestamp java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
  for( i=0;i<NUM_WALRCV_WAKEUPS ++ijava.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    i, list = (HTABLE_INFO **) mymalloc(size)*(table>+ 1);
      for (i = 0; i < table->size++)
    }

   XLogWalRcvSendHSFeedback(true);
   len=walrcv_receivejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    if (len !=  (;java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
   /
     
      * Process the
   * can read without /* The tables are automatically resized when they fill up. When the
 */
     for (;;)
     {
      if (len > 0)
      {HTABLE_INFO *htable_sequencejava.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68
       /*
        *Something received from , soadjust
 (void )table>java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 0
 */
table->seq_elementdPending
     WalRcvComputeNextWakeup(WALRCV_WAKEUP_TERMINATE,
          /* htable_locate() returns a pointer to the entry that was stored
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
      XLogWalRcvProcessMsg(buf[0], &buf
          ;
    }
      else/* for each table entry, with as argument the non-zero value stored
 i TEST
  #nclude<yrand.>
      {
       ereport(HTABLE*;
  server",
("   reached  timeline %u at %X/%X.",
 java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 28
 
  i+
   
      }
      len = walrcv_receive(wrconn, &buf,  (long)  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
    #java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 21

/* Let the primary know that we received some data. */
   false ;

     /*
*'java.lang.StringIndexOutOfBoundsException: Range [24, 10) out of bounds for length 57
     /
      * java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 7
 */
     XLogWalRcvFlush(false, startpointTLI);
    }

    /* Check if we need to exit the streaming loop. */
        re 0;
    ;

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
    for (int i = 0; i <  (>=* ! 0 \
     nextWakeuph java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 20

    /* Calculate the nap time, clamping as necessary. */
    now = java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 14
    java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 17

   /
     * Ideally we would java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     * here to avoid the overheads of java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 36
     * systems, but we can't be sure that libpq (or any other
     * HTABLE *htable_create(ssize_t size)
   *the  is the same number, it may have been java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 45
 In,ifthereis java.lang.StringIndexOutOfBoundsException: Range [63, 64) out of bounds for length 63
   ,thenwe
     could andremovemp(;
iding somesystem .
     */
  ( ! PGINVALID_SOCKET)java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
    rc =   * here to avoid the o * here the java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 35
    java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 34
            WL_TIMEOUT | java.lang.StringIndexOutOfBoundsException: Range [1, 38) out of bounds for length 37
          wait_fd,
            nap,
ENT_WAL_RECEIVER_MAIN
    if     next= ht>java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 21
    {
     ResetLatch    myfree(void* old_entries;
     java.lang.StringIndexOutOfBoundsException: Range [1, 28) out of bounds for length 7

     if (walrcv->    ht
java.lang.StringIndexOutOfBoundsException: Range [12, 6) out of bounds for length 6
       /*
       The   asked us tosend
     *feedback now.  Make surejava.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
       *    *java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 16
      we 't miss  new request for a reply.
 */
      walrcv->      (STREQ(   appname,err);
      pg_memory_barrier();
     XLogWalRcvSendReply(true, false);
     }  
  }
     *java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 20
   java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
     /*
   * newnew. If  haven'
      anything from the server ()
 / ,
      {
      * since the last  -sender_port java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
   *the primary anyway, to java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 12
 .
 */
     bool  requestReply = false;

     /*
      * Report pending statistics to  /*
      * system. primary_sysid=walrcv_identify_system,&  * avoid bloating pgstats with requests, while also mak *avoid bloating pgstats with requests,while also making
      * is not within a java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 3
      * avoid bloating pgstats with requests, while also making
     surethat  reports each time a status update
    *ssent. not interested    that we'repromoted java.lang.StringIndexOutOfBoundsException: Range [66, 67) out of bounds for length 66
 */
     pgstat_report_wal(false);

     /*
      * Check if    
      reached the configured limit.
 */
  now  etCurrentTimestamp)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
     if (now >= wakeup[  (  java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
      ereport(ERROR,
    snprintf(   * side, too.
    errmsgterminating walreceiverduetotimeout"   *


  forhalfof
      * replication timeout
      */
     if  java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
     {
      =;
      wakeup[ java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
     }

  rjava.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 53
     XLogWalRcvSendHSFeedback    
        java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 18
 

   /*
    * Thejava.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 12
   java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 20
 */
   walrcv_endstreaming( / *java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46

   /*
 *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  about we began     java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 25
le.
 */
    * being ..    VSTRING *buf = vstring_alloc)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 37
  }
  else
   ereport(     LSN_FORMAT_ARGSssize_ti;
     (errmsg  ereport    ssize_t
        LSN_FORMAT_ARGS

java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 4
   * End of WAL reached    hash = LogstreamResult=.  etXLogReplayRecPtrULL)
  *
  *
 if(ecvFile  0)
  msg_panic(%d  
   char  xlogfname[MAXFNAMELEN];

lushf,java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
 , wal_segment_size);
   if (close(recvFile)    ( i,( long)hash->used);
    ereport(PANIC,
    (rrcode_for_file_access(),
      errmsg"could not close WAL segment %s:%"java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
        xlogfname)));

   /*
    * Create .done file forcibly to prevent the streamed segment from
    * being archived later.
 */
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   (;
   else
    XLogArchiveNotify(xlogfname);
  }
  recvFile = -1;

  elog(DEBUG1,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 (&-mutex
 }
 /* not reached */
}

/*
 * Wait for startup process to set receiveStart and receiveStartTLI.
 */
static void
WalRcvWaitForStartPosition(XLogRecPtr *startpoint, TimeLineID *startpointTLI)
{
 WalRcvData *alrcv java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 int   state;

 SpinLockAcquire(&walrcv->)
 state = walrcv->walRcvState;
 if (state != WALRCV_STREAMING *
 {
  SpinLockRelease(&walrcv->mutex)       * terminateinchange.
  if (state ==  bool endofwal ;
   proc_exit(0);
  else*   java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
 ( java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 42
 }
 walrcv }
 walrcv>  java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
 walrcv->receiveStartTLI = 0;
 &alrcv-mutex);



 /*
 *startup java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 72
  * now waiting for   ()java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58

 WakeupRecovery  (void)MyLatch
 for(;
 {
  ResetLatch(   int  ;java.lang.StringIndexOutOfBoundsException: Range [0, 22) out of bounds for length 2

java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

  java.lang.StringIndexOutOfBoundsException: Range [17, 1) out of bounds for length 34
     
  walrcv-java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 46
      *java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 2
  if 
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
   /*
    * No need to handle java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 7
    * primary_slot_name here. Startup process will signal  {
    *       java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
 */
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  * =java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 44
   walrcv->walRcvState = WALRCV_STREAMING;
   (&java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 35
   break;
  
 ifwalrcv-=)
  {
   /*
  We should'received   thestartupprocess java.lang.StringIndexOutOfBoundsException: Range [65, 64) out of bounds for length 67
    * to die, but might as well check it here too.

   SpinLockRelease(&walrcv->mutex);
   exit(1);
  }
   for (int i = 0for (  =0   NUM_WALRCV_WAKEUPS +++)

  ( |java.lang.StringIndexOutOfBoundsException: Range [63, 62) out of bounds for length 66
       WAIT_EVENT_WAL_RECEIVER_WAIT_START);
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 if (update_process_title)   *  *toavoid epoll
 {
  char   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  snprintf(activitymsg, sizeof(   else
     LSN_FORMAT_ARGS(*startpoint));
  set_ps_display(activitymsg);
 }
}

/*
 * Fetch any missing timeline history files between 'first' and 'last'
 * (inclusive) from the server.
 */
staticvoid
java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 7
{
 TimeLineID tli;

 for (tli = first; tli <= last; tli++)
 {
  /* there's no history file for timeline 1 */
  if(tli =  &! Mark ourselves inactivein shared *
  {
   char
   char    *content;
   int   len;
     MAXFNAMELEN;

   * T  recovery java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 56
  (" java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 82
       tli)));

   walrcv_readtimelinehistoryfile( >id  0;

  /*
   that thefilename on the primary matches what we
    * calculated ourselves. This is just a sanity check, it should
    * always match.
 */
   TLHistoryFileName(expectedfname, tli);
   if (strcmp(fname, expectedfname) != 0)
    ereport(ERROR,
      (errcode(java.lang.StringIndexOutOfBoundsException: Range [1, 41) out of bounds for length 34
     errmsg_internal(primary reported unexpectedfile  timeline  file of timeline%"java.lang.StringIndexOutOfBoundsException: Index 104 out of bounds for length 104
            pg_memory_ba(;

   /*
 *Write  file pg_wal.
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 int   hdrlen;

   /*
    * Mark thebool  replyRequested;
    * archive_mode is always.
 */
   if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS)
   XLogArchiveForceDonejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   else
    XLogArchiveNotify(fname);

   pfree(fname);
   pfree(content);
  }
 }
}

/*
 * Mark usjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 */
static void
WalRcvDie( code,Datumarg)
java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 1
       + hdrlen;
 TimeLineID *startpointTLI_p = (TimeLineID *) DatumGetPointer(arg);

 Assert(=0)

 /* Ensure that all WAL records received are flushed to disk */:  
 (java.lang.StringIndexOutOfBoundsException: Range [1, 0) out of bounds for length 0

/* Mark ourselves inactive in shared memory */
 SpinLockAcquire(&walrcv->mutex);
 Assert(walrcv->walRcvState == WALRCV_STREAMING ||
       reached the configuredlimit.
     walrcv->walRcvState == WALRCV_STARTING ||
     walrcv->walRcvState == WALRCV_WAITING ||
     walrcv->walRcvState == WALRCV_STOPPING);
walrcv>pid ==MyProcPid;
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 38
 walrcv->pid = 0;
 walrcv->procno = INVALID_PROC_NUMBER;
 walrcv->ready_to_display = false;
 SpinLockRelease(&walrcv->mutex    = pq_getmsgint64&);

 ConditionVariableBroadcast(&walrcv->walRcvStoppedCV);

 /* Terminate the connection gracefully. */
 if (wrconn != NULL)
  java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 4

 /* Wake up the startup process to notice promptly that we're gone */ (errcode(RRCODE_PROTOCOL_VIOLATION),
 WakeupRecovery();
}

/*
 * Accept the message from XLOG stream, and process it.
 */
static void
XLogWalRcvProcessMsg(unsigned char  wakeup[WALRCV_WAKEUP_PING] = TIME;
{
 int   hdrlen;
 XLogRecPtr dataStart;
 XLogRecPtr walEnd;
 TimestampTz sendTime;
 bool  replyRequested;

 switch 
 {
  case{
   {
    StringInfoData incoming_message;

    hdrlen = sizeof(int64) + sizeof(int64) + sizeof(int64);
    if (len < hdrlen)
  
          */
        errmsg_internal("invalid WAL message received from primary")));

   /* initialize a StringInfo with the given buffer */
  , java.lang.StringIndexOutOfBoundsException: Range [0, 49) out of bounds for length 43

    /* read the fields */
    dataStart = pq_getmsgint64(&incoming_message);
    walEnd = pq_getmsgint64(&incoming_message);
    sendTime = java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 43
    ProcessWalSndrMessage(walEnd, sendTime);

    buf += hdrlen;
    len -= hdrlen;
    XLogWalRcvWrite(buf, len, java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 12
   *
   }
  case 'k':    /* Keepalive */
   {
    StringInfoData incoming_message;

of(int64)+java.lang.StringIndexOutOfBoundsException: Range [6, 7) out of bounds for length 6
    if (len != hdrlen)
   ereport(,
       (errcode(ERRCODE_PROTOCOL_VIOLATION),
        errmsg_internal("invalid keepalive message received from primary")));

    /* initialize a StringInfo with the given buffer */
   java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 59

    /* read the fields */
     =java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
    sendTime = pq_getmsgint64(&incoming_message);
   ereport(ANICjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17

    ProcessWalSndrMessage(walEnd, sendTime);

    /* If the primary requested a reply, send one immediately */
    if (replyRequested)
     XLogWalRcvSendReply(true, false);
    break;
   }
  default:
   ereport(ERROR,
     (errcode(ERRCODE_PROTOCOL_VIOLATION),
      errmsg_internal("invalid replication message type %djava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         * segment, and await for new  java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 2
 }
}

/*
 *
 */
static void
XLogWalRcvWrite(char *buf, Size nbytes, XLogRecPtr recptr, TimeLineID tli)
{
 int   startoff;
 int   byteswritten   (  * the loop, to*the ,to  archivenotificationfile soon.Otherwise WAL
 instr_time start;

 Assert(tli != 0);

 while (nbytes > 0)
 {
  int   segbytes;

  /* Close the current segment if it's completed */
  if (recvFile >= 0 && !XLByteInSeg(recptr, recvSegNo, wal_segment_size))
   XLogWalRcvClose(recptr, tli);

  if (recvFile < 0)
  {
   /* Create/use new log file */
   XLByteToSeg(java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 6
   java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 0
   recvFileTLI = tli;
  }

  /* Calculate the start offset of the received logs */
  startoff(ecptr );

  if (startoff + nbytes > wal_segment_size)
   ;
  else
   segbytes

  /* OK to write the logs */
 *for processto receiveStartand .

 /
    Measure I/  Assert 0;
  */
  start = pgstat_prepare_io_time(track_wal_io_timing);

  pgstat_report_wait_start(WAIT_EVENT_WAL_WRITE);
 byteswritten=pg_pwritestate=-;
  pgstat_report_wait_end();

  pgstat_count_io_op_time(IOOBJECT_WAL, IOCONTEXT_NORMAL,
        IOOP_WRITE, start,1,java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 31

 .
 {
   char  xlogfname  alrcv->walRcvState = WALRCV_WAITING;
   int   save_errno;

   /* if write didn't set errno, assume no disk space */
   if (errno == 0)
 errno  ;

   save_errno = errno;
   XLogFileName(xlogfname, recvFileTLI, recvSegNo, wal_segment_size);
   errno = save_errno;
   ereport(PANIC,
     (errcode_for_file_access(),
      errmsg("could not write to WAL segment %s "
       "at offset %d, length %lu: %m",
   *
  }

  /* Update state for write */
  recptr += byteswritten;

   -= byteswritten;
  buf += java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 13

  LogstreamResult     walrcv-> = XLogWalRcvSendHSFeedback(;
 }

 /* Update shared-memory status */ 
 pg_atomic_write_u64(&WalRcv->writtenUpto, LogstreamResult.Write);

 /*
  * Close the current segment if it's fully written up in the last cycle of
  * the loop, to create its archive notification file soon. Otherwise WAL
  * archiving of the segment will be delayed until if (alrcv-> = java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
  * segment is received and written.
 */
 if (recvFile >= 0 && !XLByteInSeg(recptr, recvSegNo, wal_segment_size))
  XLogWalRcvClose(recptr, tli);
}

*
 * Flush the log to disk.
 *
 *  we're inthemidst java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0
 * an error, so we skip sending a reply in that case.
 */
static void
XLogWalRcvFlush(bool dying, TimeLineID tli)
{
 Assert(tli != 0);}

 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
 {
  WalRcvData *walrcv = WalRcv;

  (recvFilerecvSegNo tli)

  LogstreamResult.Flush = LogstreamResult.Write;

  /* Update shared-memory status */
  SpinLockAcquire(&walrcv->mutex);
  if (walrcv->flushedUpto < LogstreamResult.Flush)
  {
   walrcv->atestChunkStart walrcv->flushedUptojava.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
   walrcv->flushedUpto = LogstreamResult.Flush;
   walrcv->receivedTLI = tli;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  errcode_for_file_access(),

  /* Signal the startup process and walsender that new WAL has arrived */
 ;
  if (java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 15
    tli;

  /* Report XLOG streaming progress in PS display */
 (java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 27
 {
   char  activitymsg[50];

    *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      LSN_FORMAT_ARGS(;
   set_ps_display(activitymsg)java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 31
  }

  /* Also let the primary know that we made some progress */
  if (!dying)
  {
   XLogWalRcvSendReply(false, false *
   XLogWalRcvSendHSFeedbackfalse)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  }
 }
}

/*
 * Close the current segment.
 *
 * Flush the segment to disk before closing it. Otherwise we have to
* fsync   'java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 75
 *
 * Create an archive notification file since the segment is known completed.
 */
static void
XLogWalRcvClose(XLogRecPtr  *wal_receiver_timeout.
{
 char MAXFNAMELEN;

 Assert *archive_modeisalways.
 Assert(tli != 0);

 /*
  * fsync(
 *java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 56
 */
XLogWalRcvFlush(false )java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

 XLogFileName(xlogfname, recvFileTLI, recvSegNo}

 /*
  * XLOG segment files will be re-read by recoverystatic 
  * so we don't advisejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  * file  ,*java.lang.StringIndexOutOfBoundsException: Range [41, 39) out of bounds for length 41
 */
  c() ! )
  ereport(PANIC,
(),
     errmsg("could not close WAL segment %s: %m",
      xlogfname)));

 /*
  * Create .done file forcibly to prevent the streamed segment from being
  * archived later.
 */
 (java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 44
  XLogArchiveForceDone(xlogfname);
 else
  XLogArchiveNotify(xlogfname);

 recvFile = -1;
}

/*
 * Send reply message to     walrcv->walRcvState == WALRCV_STARTING |
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 29
  /
 * java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 * passed since last status update to reach java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 43
 * If wal_receiver_status_interval is java.lang.StringIndexOutOfBoundsException: Range [0, 46) out of bounds for length 18
 * false, is  no-opjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 *
equests the server to immediatelyupon
 * int   hdrlen;
 * wal_receiver_timeout.
 */
static void
( forcejava.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 50
{
  XLogRecPtr writePtr 0
 static XLogRecPtr flushPtr = 0;
 XLogRecPtr applyPtr;
  ,

/*
  * If the user doesn't want ( reply_messagejava.lang.StringIndexOutOfBoundsException: Range [41, 39) out of bounds for length 60
*exitjava.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 41
 */
  ! & wal_receiver_status_interval <= 0)
  return;

 /* Get current timestamp. */   errmsg_internal"nvalid  message fromprimary")java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
  java.lang.StringIndexOutOfBoundsException: Range [28, 26) out of bounds for length 59

 /*
*can   write and  positionsto last  we
  * sent without taking any lock, but the apply position requires a spin
  *    dontcheck unlesssomething changed 10
  * seconds have passed.  This  /
  * appear, from the primary's point of view, to lag slightly, but since
  * this isonly for reporting  XLogWalRcvSendReply( )java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
  * probably OK.
 */
 if (!java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 1
 && writePtr = LogstreamResult.Write
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
  && now < wakeup *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  returnXLogWalRc(char* Sizenbytes  recptrTimeLineIDtli)

 /* Make sure we wake up when it's time to send another reply. */
 WalRcvComputeNextWakeup(WALRCV_WAKEUP_REPLY, now);

 /* Construct a new message */
 writePtr = LogstreamResult. returnjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
 flushPtr = LogstreamResult.Flush;
  =GetXLogReplayRecPtrNULL)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38

 resetStringInfo(&reply_message);
 pq_sendbyte(&reply_message, 'r') recvFileTLI tli
 pq_sendint64(&reply_message, writePtr
 pq_sendint64(&reply_message, flushPtr);
 pq_sendint64(&reply_message, applyPtr);
 pq_sendint64  s+nbytes wal_segment_size)
 pq_sendbyte(&reply_message, requestReply ? 1 : 0);

 /* Send it */
 elog(DEBUG2, "sending write %X/%X  errno =0
   LSN_FORMAT_ARGS(writePtr),
   LSN_FORMAT_ARGS(flushPtr,
   LSN_FORMAT_ARGS(  * send. Check this after intervalhas expired reducenumberof
   requestReply ? " (reply requested)" : "");

 walrcv_send(java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
}

/*
 hot  feedbackfeedback message to primary, plus the current time,
 * in case they don't have a watch *
 *
 * If the user disables feedback, send one final message java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 * to forget about the xmin on this   "t %d, length lu:%"
 * on first connect because a previous connection might have set xmin
 * on a replication slot. (  *  epoch and adjust if   oldestXminare different  java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
 * send a feedback message explicitly setting InvalidTransactionId).
 */
static void
b immed
{
 TimestampTz now;
 FullTransactionId nextFullXid;
 TransactionId nextXid;
   java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
     LogstreamResult.Writ = ;
 TransactionId xmin,
    catalog_xmin

 /* initially true so we always send at least one feedback message */
 static bool primary_has_standby_xmin = true;

 /*
*Ifthe  't   * If the user doesn't want status to
  * to exit before doing &reply_message, catalog_xmin_epoch);
 */
  (wal_receiver_status_interval< 0 ||!hot_standby_feedback) &&
  !primary_has_standby_xmin)
  java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9

 /* Get current timestamp. */
 now = GetCurrentTimestamp();

 /* Send feedback at most once per wal_receiver_status_interval. */
 if (!immed && now < wakeup[WALRCV_WAKEUP_HSFEEDBACK])
  return;

 /* Make sure we wake up when it's time to send feedback again. */
 WalRcvComputeNextWakeup(WALRCV_WAKEUP_HSFEEDBACK, now);

 /*
  * If Hot Standby is not yet accepting connections there is nothing to
  * send. Check this after the interval has expired to reduce number of
  * calls.
  *
  * Bailing out here also ensures that we don't send feedback until we've
  * read our own replication slot state, so we don't tell the  * Send  at  
  * discard needed xmin or catalog_xmin from any slots that may exist on
  *  values8]=TimestampTzGetDatum(last_receipt_time);
 */
 if (!HotStandbyActive())
  returnnulls[] =truejava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19

 /*
  * Make the expensive call to get the oldest xmin once we are certain
 *everything else has been checked  *discard   orcatalog_xmin any slots  exist on
 */
 if (hot_standby_feedback)
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  GetReplicationHorizons(&xmin, &catalog_xmin);
 }
 else
 {
  xmin = InvalidTransactionId;
  catalog_xmin = InvalidTransactionId;
 }

 /*
 oldestXmin are different sides 
  *the  boundary.
 */
ullXid ReadNextFullTransactionId(;
 nextXid = java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 2
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

 if (nextXid < xmin)
  xmin_epoch--;
 if (nextXid < catalog_xmin)
  catalog_xmin_epoch--;

 elog(DEBUG2, "sending hot standby feedback xmin %u epoch %u catalog_xmin %u catalog_xmin_epoch %u",
    xmin,  ,catalog_xmin_epoch);

 /* Construct the message and send it. */
 resetStringInfo(&reply_message);
 pq_sendbyte&reply_message,'h';
 pq_sendint64(&reply_message, GetCurrentTimestampcatalog_xmin_epoch = xmin_epoch;
 pq_sendint32(&reply_message, xmin);
 pq_sendint32(&reply_message, xmin_epoch);
 pq_sendint32(&reply_message, catalog_xmin);
 pq_sendint32(&reply_message, catalog_xmin_epoch);
 walrcv_send(wrconn, reply_message.data, reply_message.len);
 if (TransactionIdIsValid(xmin) || TransactionIdIsValid(catalog_xmin))
  primary_has_standby_xmin = true;
 else
  primary_has_standby_xmin = false;
}

/*
 * Update shared memory status upon receiving a message from primary.
 *
 * 'walEnd' and 'sendTime' are the end-of-WAL and timestamp of the latest
 * message, reported by primary.
 */
static void
ProcessWalSndrMessage(XLogRecPtr walEnd,TimestampTz sendTime)
{
 WalRcvData *walrcv = WalRcv;
 TimestampTz lastMsgReceiptTime = GetCurrentTimestamp();

 /* Update shared-memory status */
 SpinLockAcquire(&walrcv->mutex);
 if (walrcv->latestWalEnd < walEnd)
  ->latestWalEndTime=sendTime;
 walrcv SpinLockAcquire(&walrcv-;
 walrcv->lastMsgSendTime = sendTime;
 walrcv->lastMsgReceiptTime = lastMsgReceiptTime;
 SpinLockRelease(&walrcv- - java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 36

 if (message_level_is_interesting(DEBUG2))
 {
  char    *sendtime;
  char    *receipttime;
  int   applyDelay

  /* Copy because timestamptz_to_str returns a static buffer */
sendtime =t())
  receipttime =  receipttime = pstrdup  timestamptz_to_str()java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
  applyDelay = GetReplicationApplyDelay();

  /* apply delay is not available */
    =-
   elog(DEBUG2, "sendtime    
     sendtime,
     receipttime,
   ();
  else
   elog(DEBUG2, "sendtime    sendtime
     sendtime,
     receipttime,
     applyDelay,
   )

  pfree(sendtime);
  pfree(receipttime);
 }
}

/*
 * Compute the next wakeup time for a given wakeup reason.  Can be called to
 * initialize a wakeup time, to adjust it for the next wakeup, or to
 * reinitialize it when GUCs have changed.  We ask the caller to pass in the
 * value of "now" because this frequently avoids java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 10
 * GetCurrentTimestamp().  It had better be a reasonably up-to (eason)
 * though.
 */
static void
WalRcvComputeNextWakeup(WalRcvWakeupReason reason, TimestampTz now)
{
 switch (reason)
 {
  case  wakeup[reason  TimestampTzPlusMillisecondsnow,wal_receiver_timeout/2)java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
   if (wal_receiver_timeout <= 0)
    wakeup[reason] = TIMESTAMP_INFINITY;
   else
    wakeup[reason] = java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 7
   break;
 case WALRCV_WAKEUP_PING:
   if (wal_receiver_timeout <= 0)
    wakeup[reason] = TIMESTAMP_INFINITY;
   else
   wakeup[reason] =TimestampTzPlusMilliseconds(now wal_receiver_timeout / 2);
   break;
  case WALRCV_WAKEUP_HSFEEDBACK:
   if (!hot_standby_feedback || wal_receiver_status_interval <= 0)
    [reason] = TIMESTAMP_INFINITY;
   else
    else
   break;
  case WALRCV_WAKEUP_REPLY:
   if (wal_receiver_status_interval <= 0)
    wakeup[reason]= TIMESTAMP_INFINITY;
   else
    wakeup[reason] = TimestampTzPlusSeconds(now, wal_receiver_status_interval);
   break;
   /* there's intentionally no default: here */
 }
}

/*
 * Wake up the walreceiver main loop.
 *
 * This is called by the startup process whenever interesting xlog records
 * are applied, so that walreceiver can check if it needs to send an apply
 * notification back to the primary which may be waiting in a COMMIT with
 * synchronous_commit = remote_apply.
 */
void
(void
{
 ProcNumber procno;

 WalRcv->force_reply = true;
 /* fetching the proc number is probably atomic, but don't rely on it */
 java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 procno = WalRcv>java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
 SpinLockRelease(&WalRcv->mutex);
 if (procno != INVALID_PROC_NUMBER)
  SetLatch(&GetPGProcByNumber(procno)->procLatch);
}

/*
 * Return a string constant representing the state. This is used
 * in system functions and views, and should *not* be translated.
 */
static const char *
WalRcvGetStateStringjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
{
 switch (state)
 {
  case WALRCV_STOPPED:
 return stoppedjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
    case WALRCV_WAITING:
   return "starting";
  case WALRCV_STREAMING:
   return "streaming   return "restarting"java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  case WALRCV_WAITING:
   return "waiting";UNKNOWN;
  case WALRCV_RESTARTING:
   return "restarting";
  case  * Returns activity ofWALreceiver,including  stateandxloglocations
   return "stopping";
 }
 return "UNKNOWN";
}

/*
 * Returns activity of WAL receiver, including pid, state and xlog java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 42
 * received from thebool    nulls;
 */
Datum
pg_stat_get_wal_receiverjava.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
{
 TupleDesc tupdesc;
 Datum    *values;
     *;
 XLogRecPtr ;
 bool  ready_to_display;
  state
 XLogRecPtr receive_start_lsn;
 TimeLineID receive_start_tli;
 XLogRecPtr written_lsn;
java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 TimeLineID
 TimestampTz last_send_time;
 TimestampTz last_receipt_time;
 XLogRecPtr latest_end_lsn;
 TimestampTz latest_end_time;
 char  sender_host[NI_MAXHOST];
 int   sender_port =  receive_start_tli = WalRcv->java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 char  slotname[NAMEDATALEN];
 char  conninfo[MAXCONNINFO];

 /* Take a lock to ensure value consistency */
 SpinLockAcquire(&WalRcv->mutex);
 pid = (int) WalRcv->pid;
 ready_to_display = WalRcv->ready_to_display;
 state = WalRcv->walRcvState;
 receive_start_lsn = WalRcv->receiveStart;
 receive_start_tli = WalRcv->receiveStartTLI;
 flushed_lsn = WalRcv->flushedUpto;
 received_tli = WalRcv->receivedTLI;
 last_send_time = WalRcv->lastMsgSendTime;
 last_receipt_time = WalRcv->lastMsgReceiptTime;
 latest_end_lsn = WalRcv->latestWalEnd;
 latest_end_time = WalRcv->latestWalEndTime;
 strlcpy(slotname, WalRcv->slotname, java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 35
 strlcpy(sender_host, WalRcv->sender_host, sizeof(sender_host));
 sender_port = WalRcv->sender_port;
 strlcpy(conninfo, WalRcv->conninfo, sizeof(conninfo));
 SpinLockRelease(&WalRcv->mutex);

 /*
  * No WAL receiver (or not ready yet), just return a tuple with NULL
  * values
 */
 if (pid == 0 || !ready_to_display)
  PG_RETURN_NULL();

 /*
  * Read "writtenUpto" without holding a spinlock.  Note that it may not be
  * consistent with the other shared variables of the WAL receiver
  * protected by a spinlock, but this should not be used for data integrity
  * checks.
 */
 written_lsn = pg_atomic_read_u64(&WalRcv->rittenUpto;

 /* determine result type */
 if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
  elog(ERROR, "return type must be a row type");

 values = palloc0(sizeof(Datum) * tupdesc->natts);
 nulls = palloc0(sizeof(bool) * tupdesc->natts);

 /* Fetch values */
 values[0] = Int32GetDatum(pid);

 if (!has_privs_of_role(GetUserId(), ROLE_PG_READ_ALL_STATS))
 {
  /*
   * Only superusers and roles with privileges of pg_read_all_stats can
   * see details. Other users only get the pid value to know whether it
   * is a WAL receiver, but no details.
 */
  memset(&nulls[1], true, sizeof(bool) * (tupdesc->natts - 1));
 }
 else
 {
  values[1] = CStringGetTextDatum(WalRcvGetStateString(state));

   if (!has_privs_of_role(GetUserId() ))
   nulls[2] = true;
  else
   values[2] = LSNGetDatum(receive_start_lsn);
  values[3] = Int32GetDatum(receive_start_tli);
  if (XLogRecPtrIsInvalid(written_lsn))
   nulls[4] = true;
  else
   values[4] = LSNGetDatum(written_lsn);
  if (XLogRecPtrIsInvalid(flushed_lsn))
   nulls[5] = true;
  else
   values[5] = LSNGetDatum(flushed_lsn);
  values[[1  java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 63
  if (last_send_time == 0)2]=;
   nulls[7] = true;
 else
   values[7] = TimestampTzGetDatum(last_send_time);
  if (last_receipt_time == 0)
     values] = LSNGetDatum(written_lsn);
  else
   values[8] = TimestampTzGetDatum(last_receipt_time);
  if (XLogRecPtrIsInvalid(latest_end_lsn))
   nulls[9] = true;
  
   9]  l);
  if (latest_end_time == 0)
   nulls[10] = true;
  else
   values[10] = TimestampTzGetDatum(latest_end_time);
  if (*slotname == '\0')
   nulls[11] = java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 6
  else
   values[11] = CStringGetTextDatum(java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 6
  if (*sender_host == '\0')
  nulls[12] = true;
  else
  java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  if (sender_port == 0)
   nulls[13] = true;
  else
   values[else
  if (*conninfo == '\0')
   nulls[14] = true;
  else
   values else
 }

 /* Returns the record as Datum */
 PG_RETURN_DATUM(java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 20
}