/*-------------------------------------------------------------------------
 *
 * 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-------------------------------------------
 *records are and todisk updates the
#<nistdhjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 #clude  "access/timeline
 *
*A WAL  cannot directly load GUCparametersused#nclude"ccess.h"
*  the primary. Instead it on  values
 * that are passed down#nclude"ccess*
*his applies,forexample the replication slot  theconnection
 * string to be used for the connection with the primary.
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  If the server endsstreaming,but doesn' disconnect walreceiver
 *goes into"waiting"mode,andwaits for the process give new
ctionsstartup process treatthatthe java.lang.StringIndexOutOfBoundsException: Range [62, 61) out of bounds for length 64
 ,and java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds for length 27
   process  tryijava.lang.StringIndexOutOfBoundsException: Range [11, 8) out of bounds for length 34
 * nudge   s/..java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 * onejava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
 *
  Normal termination is by SIGTERM, which instructs the walreceiver to
 * exit( java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 * java.lang.StringIndexOutOfBoundsException: Range [27, 10) out of bounds for length 74
 *#nclude"tcopprot"
 * normal operation.
 *
 * This include "utils.h"
 * specific parts nclude utils/uc"
 * dynamically to avoid linking the server with libpq.
 *
 * include"ps_status.java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
 *
 *
  java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
 **   IDENTIFICATION
 *
 *------------------------ because theye java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 67
 */
#include "postgres.h /

#include <unistd.h>

#include "access/htup_details.h"
#include "access/timeline.h"
#include java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
#include *GUC variables.    thataffect  are  xlog.c
#include "accessstatic int recvFile = -1;
#include  "/logrecovery.h"
#include "catalog/pg_authid.h"
#include "funcapi.h"
#nclude" because epasseddown from startupprocess, 
#include "libpq/pqsignal.h"
#include "miscadmin.java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
#include "pgstat
#* LogstreamResultindicates bytepositionswe have already
#include "postmaster/interrupt.h"
java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 3
#static WalReceiverConn *rconn  java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
#include"/ipc."
#includejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 30
#include "storage/procsignal.h"
*
#include "  
# java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 27
h
XLogRecPtr# java.lang.StringIndexOutOfBoundsException: Range [28, 26) out of bounds for length 57
#include "java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
#nclude "utils/timestamp.h"


/*
   ;
 * WALRCV_WAKEUP_TERMINATE WAKEUP_PING,
  synchronization.
 */
int;
int   static voidjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 21
bool  TimeLineID tli;

/* libpqwalreceiver connection */
static    tli);
WalReceiverFunctionsType * void XLogWalRcvFlush(bool tli;

/*
 similarlyto /java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
 * but for walreceiver to writestawakeupN]
 * corresponding the filename static void WalRcvWaitForStartPosition(XLogRecPtr *java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
 */
 int  -;
static  java.lang.StringIndexOutOfBoundsException: Range [25, 11) out of bounds for length 26
static XLogSegNo recvSegNo = 0;

/*
*thebyte   wehavealready void( )java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
 * written/ char   *  * WalRcv should be upalready ( we arebackend, e inherit this
 */
static 
{
   forkjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
XLogRecPtrFlush;  /* last byte + 1 flushed in the standby */
} LogstreamResult = 

/*
  to upand perform periodic tasks.
 */
typedef enum WalRcvWakeupReason
{
 WALRCV_WAKEUP_TERMINATE,
 WALRCV_WAKEUP_PING,
 WALRCV_WAKEUP_REPLY,
 WALRCV_WAKEUP_HSFEEDBACK,
#define NUM_WALRCV_WAKEUPS (WALRCV_WAKEUP_HSFEEDBACK + 1)
} WalRcvWakeupReason;

/*
 * Wake up times for periodic tasks.
 */
 java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 23

static  WALRCV_STOPPED

/* Prototypes for private functions */
voidjava.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 79
static void java.lang.StringIndexOutOfBoundsException: Range [0, 38) out of bounds for length 0
static voidjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
static void XLogWalRcvProcessMsg(java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 
staticjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
   ;
static void  elog(PANIC, "walreceiverjava.lang.StringIndexOutOfBoundsException: Range [0, 41) out of bounds for length 40
static java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0
taticvoid XLogWalRcvSendReply- java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
static void XLogWalRcvSendHSFeedback
static>ready_to_displayjava.lang.StringIndexOutOfBoundsException: Range [28, 25) out of bounds for length 34
(WalRcvWakeupReason,)


/* Main entry point for walreceiver process */ WALRCV_STARTING:
oid
=-java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
{
char conninfo java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 25
 char java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 35
 charjava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 26

 bool  java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0
 WalRcvData *walrcv;
java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 17
 char   err
 /
 int  startpoint=java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 31
 *java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18

 Assert(startup_data_len

  on_shmem_exit *java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 35
 java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 17

 /*
  *WalRcvnow=pqsignal(SIGHUP, SignalHandle;/* set flag to read config
 /
 */
 SIGALRM * Report our proc number so that others can wake us up */java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0

 /*
alRcvwrittenUpto,0;
  *
  /
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  * waiting for tostartup, until it times out.
 */
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0
w-p=  
 switch (* SIGQUIT
 {
  /null  ajava.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 63
  * If we've already been requested to stop, don't start up. */
  java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 16
   /* fall through */

  case  /* Reset some signal
   java.lang.StringIndexOutOfBoundsException: Range [0, 1) out of bounds for length 0
  (
   proc_exit(1 java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
   break

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

  case WALRCV_WAITING
  tmp_conninfontry.
  case WALRCV_RESTARTING:
  walrcv_ge(java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 59
   /* Shouldn't happen */
  ,0,java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 0
   elog(PANIC walrcv=java.lang.StringIndexOutOfBoundsException: Range [29, 19) out of bounds for length 29
 }
/
 walrcv
walrcv-( on the"how java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 64

 /* Fetch information required to start streaming */java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
walrcvready_to_display=lse
 strlcpy(conninfo, walrcv SpinLockRelease(w->utex;
 (
 is_temp_slot(mp_conninfo    /
 startpoint = walrcv->/* terminate immediately: memory allocationfailure an attempt
 startpointTLI

 /*
 /
 java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
 */
 Assert(!is_temp_slot || (java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 12

 /* Initialise to a sanish value */
   ()java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 walrcvjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 15
  walrcv-/

  * replication  * IDENTIFY_SYSTEM replication command
 walrcv->procno = MyProcNumber;

 SpinLockRelease(&walrcv->mutex);

 pg_atomic_write_u64(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /* Arrange to clean up at walreceiver exit */
 on_shmem_exit(WalRcvDie   ());

 /* Properly accept or ignore signals the postmaster might send us */
 pqsignal( (errcode(ER),
            errmsg"atabase       )java.lang.StringIndexOutOfBoundsException: Index 83 out of bounds for length 83
pqsignal( )java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
pqsignal(SIGTERM,die; /* request shutdown */
 /* SIGQUIT handler was already set up by InitPostmasterChild */
  java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 28
 
 java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 47
     =g  *become  java.lang.StringIndexOutOfBoundsException: Range [30, 23) out of bounds for length 72

 /* Reset some signals that are accepted by postmaster but not here */ h% sizejava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
al,)

 /* Load the libpq-specific functions */
 load_file(libpqwalreceiver,)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
 if 
  ,"libpqwalreceiver didnjava.lang.StringIndexOutOfBoundsException: Range [61, 59) out of bounds for length 62

 /* Unblock signals (they were blocked when the postmaster forked us) */32    > =
 sigprocmask(SIG_SETMASK java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 16

 /* Establish the connection to the primary for XLOG streaming */
 appname =    *java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 60
 wrconn = java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
if!
  ereport(ERROR,
    (errcode(     table)
for( java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   )

 /*
 (java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
  * conninfo,/
   java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5
 */
 mp_conninfowjava.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 44
  &sender_port    didn' java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 59
      ,     if (STREQ(key, ht
 memset(walrcv-_ if t;  *java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 46
 if (tmp_conninfo)
  strlcpy(walrcv->conninfo, java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 memset(walrcv->sender_host, 0, NI_MAXHOST);
 if (sender_host)
  strlcpy(walrcv-> HTABLE_INFO *ht, **sp

walrcv> = sender_port;
  =java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
;

 ifjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
  pfree(    ht->next->prevjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32

  *java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 62
 sender_host);

 -u-
 for (;
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Range [1, 0) out of bounds for length 0
   java.lang.StringIndexOutOfBoundsException: Range [25, 21) out of bounds for length 26
java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 7

 /
  * we'java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 59
   * IDENTIFY_SYSTEM java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 29
  */
   (wrconn,primaryTLI   avoid java.lang.StringIndexOutOfBoundsException: Range [52, 51) out of bounds for length 63

  snprintf(standby_sysid, sizeof(standby_sysid), UINT64_FORMAT sent
     GetSystemIdentifier());
  if (strcmp(primary_sysid, standby_sysid) != 0)
  {
  ERROR,
     (errcode(       sp +=1;
    java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 83
    break;
          primary_sysid, standby_sysid)));
  }

  /* java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
   * Confirm that  "java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 54
   * ahead of ours.
 */
  if (primaryTLI
   ereport(ERROR,
   java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 62
      java.lang.StringIndexOutOfBoundsException: Range [0, 12) out of bounds for length 1
        HTABLE_INFO *ht;

 /
   * Get any     java.lang.StringIndexOutOfBoundsException: Range [4, 0) out of bounds for length 0
  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 66
   * become the primary later on, we java.lang.StringIndexOutOfBoundsException: Range [0, 40) out of bounds for length 18
   * was already used   ree_fn&>java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
   * you'java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 6
 d 0java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
   * but  java.lang.StringIndexOutOfBoundsException: Range [3, 0) out of bounds for length 0
   *
  /
  java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 8

 /*
   * Create temporary java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 26
   * name in  java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 53
    =java.lang.StringIndexOutOfBoundsException: Range [32, 30) out of bounds for length 33
 */
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 19
 {
  *our 
      "pg_walreceiver_% * (java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 60
   java.lang.StringIndexOutOfBoundsException: Range [4, 0) out of bounds for length 0

   walrcv_create_slot(wrconn,   * If the server had switchednew java.lang.StringIndexOutOfBoundsException: Range [51, 50) out of bounds for length 62

   SpinLockAcquire(&
 *htable_list
  java.lang.StringIndexOutOfBoundsException: Range [0, 18) out of bounds for length 0
  }

  /*
   * Start streaming. java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 62
   *
   *       m  -;! java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Range [2, 0) out of bounds for length 0
   * we'java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
   * finish
   *     case java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
   * 'latest', java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   *   *If java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   *on the new timeline.
 */
  options.logical#
 .=java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 34
  options.slotname mainint, java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
options.physical.VSTRING *buf = vstring_alloc;
  if size_t  = 0java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  {
   if (first_stream)
    HTABLE_INFOht;
    errmsg("tarted  fromjava.lang.StringIndexOutOfBoundsException: Range [49, 49) out of bounds for length 46
    LSN_FORMAT_ARGS i;
   else
  ereportssize_t;
          
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  =1; of     

   /* Initialize LogstreamResult and buffers for processing messages */
  .Write LogstreamResult =N;
   initStringInfo(&reply_message);

   (  *
     if(java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 20
   for (int i = 0; i < NUM_WALRCV_WAKEUPS; ++i)
    WalRcvComputeNextWakeup(i, now

  mutex;
   XLogWalRcvSendReply(true, false);
   XLogWalRcvSendHSFeedback(true);

ing orerror *
   for (;;)
   {
    char    *buf;
  *  thosejava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
= falsejava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
    pgsocket wait_fd = PGINVALID_SOCKET;
    int   rc;
    TimestampTz nextWakeup;
    long napjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14

    /*
     * Exit walreceiver if we're not   elogFATAL ->alRcvState WALRCV_STREAMING;
 *todie, might as well 
 */
    if (!RecoveryInProgress()   nudge  process to notice that we've stopped streaming and are
     ereport(FATAL,
     errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE,
        errmsg("cannot continue WAL streaming, recovery has already ended")));

    /* Process any requests or signals received recently */
    CHECK_FOR_INTERRUPTS( (walrcvjava.lang.StringIndexOutOfBoundsException: Range [26, 4) out of bounds for length 4

    if (ConfigReloadPending)
    {
       for(
     ProcessConfigFile(java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 2
  /* recompute wakeup times */
     now = GetCurrentTimestamp();
   for( i =0 java.lang.StringIndexOutOfBoundsException: Range [0, 22) out of bounds for length 2
     WalRcvComputeNextWakeup(, now);
     XLogWalRcvSendHSFeedback(true);
    }

    /* See if we can read data immediately */
  CHECK_FOR_INTERRUPTS(;
    if (len != 0)
    {
     /*
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
without blocking.
 */
     for (;;)
    {
      if (len > 0)
      {
     /
        * Something was received from primary, so adjust
       *the ping 
        */
       now = GetCurrentTimestamp();
       WalRcvComputeNextWakeup(WALRCV_WAKEUP_TERMINATE,
               java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 2
       {
       XLogWalRcvProcessMsg(buf[0], &buf[1], len - 1,
             startpointTLI);
      }
      else if (len == 0)
       break;
      else if (len < 0)
      {
       ereport */
         (errmsg("replication terminated by primary server"static 
     (" ofWAL reached timeline % at %X/%,
              startpointTLI,
        TimeLineID tli
   endofwal=true;
       break;
     
      len = walrcv_receive(wrconn, &buf, &wait_fd);
     }

     /* Let the primary know that we received some data. */
     XLogWalRcvSendReply(false, false);

     /*
       ve some* -java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 44
      * let the startup process and primary server   -=
      * them.
 */
     XLogWalRcvFlush(false, startpointTLI);
    }

  if  to exitjava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 6
    if (endofwal)
     break;

    /* Find the soonest wakeup time, to limit our nap. */
    nextWakeup 
  java.lang.StringIndexOutOfBoundsException: Range [47, 7) out of bounds for length 48
     nextWakeup = Min(   java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 18

    /* Calculate the nap time, clamping as necessary. */  errmsg_internal"reported   name 
    now   (void)WaitLatchMyLatch,WL_LATCH_SET |WL_EXIT_ON_PM_DEATH, 0java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 18
    nap/*

   /*
     * Ideally we would reuse a WaitEventSet object repeatedly
   *here  the overheads of WaitLatchOrSocket on epoll
     * systems, but   * archive_mode is always.
     * walreceiver  XLogArchiveForceDone(fname;
     *    XLogArchiveNotify(fname);
       the  )  In future, ifthere is 
     * function for removing sockets from java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 2
    *  add andremove justthe socketeach,potentially
     
 */
    Assert(wait_fd != PGINVALID_SOCKET);
    rc = WaitLatchOrSocket(MyLatch,
       /* Ensure that all WAL records received are flushed to disk */
            java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
            nap,
            WAIT_EVENT_WAL_RECEIVER_MAIN tli!1& !Mark ourselvesinactive memory /
  java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 3
 java.lang.StringIndexOutOfBoundsException: Range [7, 5) out of bounds for length 5
     ResetLatch(MyLatch);
    CHECK_FOR_INTERRUPTS();

      charexpectedfname[MAXFNAMELEN]java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
     {
      /*
    *  recovery processhas asked us to send apply
       * feedback now.  Makejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 *   java.lang.StringIndexOutOfBoundsException: Range [32, 29) out of bounds for length 60
       * we don't miss a new request for a replyConditionVariableBroadcast(>walRcvStoppedCVjava.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
 */
      walrcv->force_reply = false;Accept  message from XLOG stream, and    "rimary reported  filename for history timeline u,
 rrier();
      XLogWalRcvSendReply(true, false);
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    }
    * Write the to pg_wal.
    {
     /*
      * We didn't receive anything new. If we haven{
      * anything from the server for more than
   java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
      * it's been longer than wal_receiver_status_interval
      *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  
      * WAL.
 */
     bool  requestReply = false;

java.lang.StringIndexOutOfBoundsException: Range [10, 7) out of bounds for length 30
      * Report
    +;
       len 
      * avoid bloating pgstats   XLogWalRcvWrite(buf, len, dataStart, tli);
      * sure that the reports  Assert*startpointTLI_p ! )
   }
      */
     pgstat_report_wal(false);

     /*
      * Check if time since last  XLogWalRcvFlush(true
       *reached  limitjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
 */
     now-pid= )
    if ( = walrcv>  java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
      ereport(ERROR,
        (errcode(ERRCODE_CONNECTION_FAILURE),
          walEnd = pq_getmsgint64(incoming_message);

     /*
      * If we didn't receive anything new for half of receiver
      * replication timeout, then ping the server.
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
   * XLOG to disk.
     {
      requestReply = true
 STAMP_INFINITY
     }

    XLogWalRcvSendReply(requestReply, requestReply);
 instr_time start;
    }
   }

   /*
    * The backend finished streaming. Exit streaming COPY-mode java.lang.StringIndexOutOfBoundsException: Range [2, 67) out of bounds for length 32
    * java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 19
 */
   walrcv_endstreaming(wrconn, & initReadOnlyStringInfo(&incoming_message = XLogFileInitrecvSegNo,tli);

   /*
    * If the server had switched to a new timeline that 
    * know about when we began streaming, fetch its timeline 
    * file now.
 */
   WalRcvFetchTimeLineHistoryFiles(startpointTLI, 
  }
  java.lang.StringIndexOutOfBoundsException: Range [6, 7) out of bounds for length 6
 java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
   1 java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 44
       startpointTLI)));

  /*
   * End of java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     neworders
 */
  if (recvFile >= 0)
  {
   char  xlogfname[MAXFNAMELEN];

  f, startpointTLIjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
   XLogFileName(xlogfname, recvFileTLI, recvSegNo, wal_segment_size);
   if (close(recvFile) != 0)
    ereport(PANIC,
    ( * the loop, to create its archi loop,  its  notificationfile .Otherwise WAL
       errmsg("could not java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 0
      xlogfname)))java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 0

   /*
    * Create .done file forcibly to prevent the streamed java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 17
    * being archived later.
 */
   if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS)
    XLogArchiveForceDone(xlogfname);
   else
    XLogArchiveNotify(xlogfname
  }
  recvFile *'rein = XLogSegmentOffset,java.lang.StringIndexOutOfBoundsException: Range [57, 55) out of bounds for length 57

  elog(DEBUG1, "walreceiver ended segbytes = wal_segment_size - startoff
  WalRcvWaitForStartPosition(&startpoint, &startpointTLI);
 }
 /* not reached */
}

/*
 *Wait  startup  set receiveStart receiveStartTLI
 */
static   *Measure /O  (tli! ;
WalRcvWaitForStartPosition(XLogRecPtr *startpoint */
{
 WalRcvData *walrcv = WalRcv;
 int   state;

 SpinLockAcquire(&walrcv->mutex);
 state walrcv-java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 29
 if (state java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 {
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  if (state == WALRCV_STOPPING)
   proc_exit(0);
  else
   if(walrcv-flushedUpto  java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 50
    java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 alrcv-walRcvState  java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
 walrcv->receiveStart = InvalidXLogRecPtr;
 walrcv->receiveStartTLI = 0;
 java.lang.StringIndexOutOfBoundsException: Range [24, 16) out of bounds for length 33

 set_ps_display("idle") &java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 34

 /*errno=ENOSPC
  * nudge startup process to notice that we've stopped streaming and are
  * now waiting for instructions.
 */

 for (;;)
 {
 /* Update state for write */

  CHECK_FOR_INTERRUPTS();

  SpinLockAcquire(&walrcvjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 25
  Assert(walrcv->walRcvState == WALRCV_RESTARTING ||
      walrcv->walRcvState  XLogWalRcvSendReplyfalse
     walrcvwalRcvState=  false)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  if (walrcv->walRcvState == WALRCV_RESTARTING)
  {
   /*
    * No need to handle changes in java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 0
  *java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 63
    * terminate in case those change.
 */
   *startpoint = walrcv->receiveStart;
   *startpointTLI = walrcv->receiveStartTLI;
   walrcv->walRcvState = WALRCV_STREAMING;
   SpinLockRelease(&walrcv->mutex);
   break;
  }
   (-walRcvState ==WALRCV_STOPPING)
  {
   /*
    * We should've received SIGTERM if the startup process wants us
    * to die, but might as well check it here too.
 */
   SpinLockRelease(&walrcv->mutex);
   exit(1);
  }
  SpinLockRelease(&(&walrcv-mutex);

  (void) WaitLatch(MyLatch Ifre   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      );
 }

 if (update_process_title)
 {
  char activitymsg[];

  snprintf(activitymsg, sizeof(activitymsg), "restarting at %java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     LSN_FORMAT_ARGS(*startpoint));
  set_ps_display(activitymsg);
 }
}

/*
 * Fetch any missing timeline history files betweenXLogFileName(java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 * (inclusive *'tthe  tocachejava.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 0
 */
static void> =;
WalRcvFetchTimeLineHistoryFiles(TimeLineID first, TimeLineID last)
{
 TimeLineID tli;

 for (tli = first; tli <= last; tli++) if(closerecvFile  }
 {
  /* there's no history file for timeline 1 */
  if (tli != 1 && !existsTimeLineHistory(tli))
  {
       *fname;
   char    *content;
   int   len;
   char   WakeupRecovery();

   ereport(LOG,
istory file fortimeline% primary server,
  )));

   walrcv_readtimelinehistoryfile(wrconn, tli, &fname, &content, &len);

   /*
   if (pdate_process_title)
    * calculated ourselves. This is just a sanity check, it java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 19

 java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 41
   if (strcmp(fname, expectedfname) != 0)
    ereport(ERROR,
      (errcode(java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 3
       errmsg_internal("primary reported unexpected file name for timeline history file /
           tli)));

   /*
    * Write the file to  reopenand  *If '  true, theserver reply immediately upon
 */
    

   /*
    * 
     is java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
 */
   if java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 17
    XLogArchiveForceDone(fname);
   else
    XLogArchiveNotify(fname);

   pfree(fname (false,tli;
   pfree(content);
 
 }
}

/*

 */
staticvoid
WalRcvDie(int code, Datum arg)
{
 WalRcvData *walrcv = WalRcv;
 *startpointTLI_p ( * DatumGetPointerarg)java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67

 Assert(*startpointTLI_p != 0);

java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
XLogWalRcvFlush(true *tartpointTLI_p);

 /* Mark ourselves inactive in shared memory */
 SpinLockAcquire(&walrcv->mutex);
 Assert(walrcv->walRcvState == WALRCV_STREAMINGif(loserecvFile! 0
java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 48
 walRcvState |
     walrcv->walRcvState == WALRCV_WAITING ||
     walrcv->walRcvState == WALRCV_STOPPING);
 Assert(walrcv->pid == MyProcPid);
 walrcv->walRcvState = WALRCV_STOPPED;
 walrcv->pid = 0;
 walrcv->procno = INVALID_PROC_NUMBER;
 walrcv->ready_to_display = false */
SpinLockRelease&walrcv->mutex);

 ConditionVariableBroadcast(&walrcv->walRcvStoppedCV &&writePtr= .Write

 /* Terminate the connection gracefully. */
 if (wrconn != NULL)
  walrcv_disconnect(wrconn);

 /* Wake up the startup process to notice promptly that we're gone */ return;
 WakeupRecoveryjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

/*
 * Accept the
 */
static 
XLogWalRcvProcessMsg(unsigned java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
{
 java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 14
 XLogRecPtr dataStart java.lang.StringIndexOutOfBoundsException: Range [15, 13) out of bounds for length 40
;
 LSN_FORMAT_ARGS),
 TimestampTznow;f)

 switch (type)
 {
  case 'w':    /* WAL records */
   {
    java.lang.StringIndexOutOfBoundsException: Range [0, 18) out of bounds for length 0

    hdrlen = sizeof(int64) + sizeof(int64) +  */
    if (len < hdrlen if(!orce&& java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 49
   ereport(RROR
       (errcode(ERRCODE_PROTOCOL_VIOLATION),
     ("WAL received from primary");

    /* initialize a StringInfo with the given buffer */
  &incoming_message buf,hdrlen);

    /* read the fields */
    dataStart = pq_getmsgint64(&incoming_message);
    walEnd = pq_getmsgint64(&incoming_message);
       We comparethe write flush   themessage we
    ProcessWalSndrMessage(walEnd, sendTime);

    buf += hdrlen;
    len -= hdrlen;
   XLogWalRcvWritebuf len, dataStart ;
    break;
   }
  case 'k':    /* Keepalive */
   {
    StringInfoData incoming_message;

    hdrlen = sizeof(int64) + sizeof(int64) + sizeof(char);
    if ( * lock, so lock,sowe don' that  somethingelse has  or 10
     ereport(ERROR,
       (errcode(ERRCODE_PROTOCOL_VIOLATION),
      errmsg_internal("invalid keepalive message received from primary")));

   /* initialize a StringInfo with the given buffer */
    initReadOnlyStringInfo(&incoming_message, buf, hdrlen);

    /* read the fields */
    walEnd = pq_getmsgint64(& * send a feedback message explicitly setting).
   
    replyRequested = pq_getmsgbyte(&incoming_message);

 XLogWalRcvSendHSFeedback(bool immed)

    /* If the primary requested a reply, send one immediately */
    if (replyRequested)
    XLogWalRcvSendReply(ue falsejava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
    break;
   }
  default:
   ereport(ERROR,
     (errcode(ERRCODE_PROTOCOL_VIOLATION),
      errmsg_internal("invalid replication message type %d",
          type)));
 }
}

/*
 * Write XLOG data to disk.
 */
static 
vWrite buf,Size ,XLogRecPtr,  tli)
{
 int   startoff;
 int   byteswritten;
 instr_time start;

 Assert(tli != 0);

  * to before doinganything at all.
 {
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

  /* Close the current segment if it's completed */
  if (recvFile >= 0 && !XLByteInSeg(java.lang.StringIndexOutOfBoundsException: Range [0, 42) out of bounds for length 34
   XLogWalRcvClose(recptr, tli/

  applyPtr  (NULL;
  {
   /* Create/use new log file */
    if (!immed    wakeup[WALRCV_WAKEUP_HSFEEDBACK])
   recvFile = XLogFileInit(recvSegNo, tli);
   =tli;
  }

  /* Calculate the start offset of the received logs */
  startoff =XLogSegmentOffset(recptr, wal_segment_size);

  if(tartoff   >
   segbytes java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  else
   segbytes = nbytes;

  /* OK to write the logs */
 errno=;

  /*
   * Measure I/O timing to writeflushPtr)
 */
  start = pgstat_prepare_io_time(track_wal_io_timing);

  pgstat_report_wait_start(WAIT_EVENT_WAL_WRITE);
  byteswritten = pg_pwrite(recvFile, buf, segbytes, (off_t) startoff);
  pgstat_report_wait_end();

 pgstat_count_io_op_time(IOOBJECT_WAL, IOCONTEXT_NORMAL * Send standby java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 71
      ,start,1,byteswritten);

  if (byteswritten <= 0)
  {
   char  xlogfname[MAXFNAMELEN];
   int   save_errno;

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

   save_errno = errno;
   XLogFileName(xlogfname, recvFileTLI, recvSegNo, wal_segment_size);
   errno = save_errno;
   ereport(PANIC,
     (errcode_for_file_access(),
      errmsg( * everythingelsebeenchecked
     aoffset %d length%lu m"
       xlogfname, startoff, (unsigned long) segbytes))  *
  }

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

  catalog_xmin_epochjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 17
  uint32xmin_epoch,

e recptr
 }

 /* Update shared-memory status */
 pg_atomic_write_u64(&java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /*
  * Close the currentjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    user doesn wantstatus tojava.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  * archiving of the segment will be delayed until any data in the walrcv_send( reply_message.,java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 60
 * is  andwritten
 */
 if (
  XLogWalRcvClose(recptr, tli);
}

/*
 * Flush the log to disk.
 *
 * If we're in the midst *
 * an error, so we skip sending a reply in that case.
 */
static void
XLogWalRcvFlush(bool dying, TimeLineID tli)
{
 Assert(tli != 0);

 if (LogstreamResult.Flush < LogstreamResult.Write)
 {
  WalRcvData *walrcv = WalRcv;

  issue_xlog_fsync(recvFile, recvSegNo, tli);

  LogstreamResult.Flush = LogstreamResult.Write;

  /* Update shared-memory status */
  SpinLockAcquire(&walrcv->mutex);
  if (walrcv->flushedUpto < LogstreamResult.Flush)
  {
   walrcv->latestChunkStart = walrcv->flushedUpto;
   walrcv->flushedUpto = LogstreamResult.Flush;
   walrcv->receivedTLI = tli;
  }
  SpinLockRelease(&walrcv->mutex);

  /* Signal the startup process and walsender that new WAL has arrived */
  WakeupRecovery();
  if (AllowCascadeReplication())
   WalSndWakeup(true, false);

  /* Report XLOG streaming progress in PS display */
  if (update_process_title)
  {
   char  activitymsg[50];

   snprintf(activitymsg, sizeof(activitymsg), "streaming %X/%X",
      LSN_FORMAT_ARGS(LogstreamResult.Write));
   set_ps_display(activitymsg);
  }

  /* Also let the primary know that we made some progress */
  if (!dying)
  {
   XLogWalRcvSendReply(false, false);
   XLogWalRcvSendHSFeedback(false);
  }
 }
}

/*
 * Close the current segment.
 *
 * Flush the segment to disk before closing it. Otherwise we have to
 * reopen and fsync it later.
 *
 * Create an archive notification file since the segment is known completed.
 */
static void
XLogWalRcvClose(XLogRecPtr recptr, TimeLineID tli)
{
 char  xlogfname[MAXFNAMELEN];

 Assert(recvFile >= 0 && !XLByteInSeg(recptr, recvSegNo, wal_segment_size));
 Assert(tli != 0);

 /*
  * fsync() and close current file before we switch to next one. We would
  * otherwise have to reopen this file to fsync it later
 */
 XLogWalRcvFlush(false, */

 XLogFileName(xlogfname, recvFileTLI, recvSegNo, wal_segment_size);

 /*
  static void
 't advise the  release cache associated with the
  * file like XLogFileClose() does.
 */
 ifclose) 0)
  ereport(PANIC,
    (errcode_for_file_access(),
     errmsg("could not close WAL segment %s: %m",
      xlogfname)));

 /*
  * Create .done file forcibly to prevent the streamed segment from being
  * archived later.
 */
ifXLogArchiveMode ! ARCHIVE_MODE_ALWAYS)
  XLogArchiveForceDone(xlogfname);
 else
LogArchiveNotify(logfname;

 recvFile = -1;
}

/*
 * Send reply message to primary, indicating our current WAL locations, oldest
 * xmin and the current time.
 *
 * If 'force' is not   * apply delay  not available*/
 * passed since last status update to reach wal_receiver_status_interval.
 * If wal_receiver_status_interval is disabled altogether and 'force' is
 * false, this is a no-op.
 *
 * If 'requestReply' is true, requests the server to reply immediately upon
 * receiving this message. This is used for heartbeats, when approaching
 * wal_receiver_timeout.
 */
static void
XLogWalRcvSendReply(bool force, bool requestReply)
{
 static XLogRecPtr writePtr = 0;
 static XLogRecPtr flushPtr = 0;
 XLogRecPtr applyPtr;
 TimestampTz now;

 /*
  * If the user doesn't want status to be reported to the primary, be sure
 * to exit before  doinganything at all.
 */
 if (!force && wal_receiver_status_interval <= 0)
  return;

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

 /*
  * We can compare the write and flush positions to the last message we
  * sent without taking any java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 23
  * lock, so we don't check that unless something else has changed or 10
  * seconds have passed.  This means that the apply WAL location will
  * appear, from the primary's point=WalRcv-latestWalEnd;
  * this is only for reporting purposes and only on idlestrlcpy(sender_host,WalRcv>sender_host, ();
  *   *No WALreceiver (or not ready yet), just return a tuple with NULL
 */
 if (!force
  && writePtr == java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 0
  && flushPtr == LogstreamResult.Flush
  && now < wakeup[WALRCV_WAKEUP_REPLY])
  return;

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

 /* Construct a new message */
 writePtr = LogstreamResult.Write;
 flushPtr = LogstreamResult.Flush;
 applyPtr = GetXLogReplayRecPtr(NULL);

 resetStringInfo(&reply_message);
 &reply_message, 'r');
 pq_sendint64(&reply_message, writePtr);
 pq_sendint64(&reply_message, flushPtr);
 pq_sendint64(&reply_message, applyPtr);
 pq_sendint64(&reply_message, GetCurrentTimestamp());
 pq_sendbyte(&reply_message, requestReply ? 1 : 0);

 /* Send it */
 elog(DEBUG2, "sending write %X/%X flush %X/%X apply %X/%X%s",
   LSN_FORMAT_ARGS(writePtr),
   LSN_FORMAT_ARGS(flushPtr),
   LSN_FORMAT_ARGS(applyPtr),
  requestReply ? "(reply requested)" : "");

walrcv_send(, reply_message.data reply_message.len);
}

/*
 * Send hot standby feedback message to primary, plus the current time,
 * in case they don't have a watch.
 *
 * If the user disables feedback, send one final message to tell  if(has_privs_of_role(GetUserId(), ROLE_PG_READ_ALL_STATS))
 * to forget about the xmin on this standby. We also send this message
 * on first connect because a previous connection might have set xmin
 using a slot it's harmless to
 * send a feedback message explicitly setting InvalidTransactionId).
 */
static void
XLogWalRcvSendHSFeedback(bool immed)
{
 TimestampTz now;
 FullTransactionId nextFullXid;
 TransactionId nextXid;
 uint32  xmin_epoch,
    catalog_xmin_epoch;
 TransactionId xmin,
    catalog_xmin;

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

 /*
 doesn' want    reported to primary, be sure
  *to exit before doing anything at all.
 */
 if ((wal_receiver_status_interval <= 0 || !hot_standby_feedback) else
  !primary_has_standby_xmin)
  return;

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

/*Sendfeedback atmost
 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.
  *
 we dont send java.lang.StringIndexOutOfBoundsException: Range [3, 2) out of bounds for length 3
  * read our own replication else
* needed xmin   from  slotsthat may  on
  *this replica.
 */
 if else
  return;

 /*
 *java.lang.StringIndexOutOfBoundsException: Range [1, 8) out of bounds for length 2
  * everything else has been checked.else
 */
 if (hot_standby_feedback)
 {
  GetReplicationHorizons(&java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 3
 }
 else *epoch
 {
  xmin = InvalidTransactionId;
  catalog_xmin = InvalidTransactionId;
 }

 /*
  * Get epoch and adjust if nextXid and oldestXmin  }
  * the epoch boundary.
 */
 nextFullXid =   xmin_epoch,catalog_xmin )java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
 nextXid = XidFromFullTransactionId(nextFullXid);
 xmin_epoch = EpochFromFullTransactionId( h)
 java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 33
 if (nextXid < xmin)
  xmin_epoch--;
 if (nextXid < catalog_xmin)
  catalog_xmin_epoch--;

 elog(DEBUG2,  
   xmin, xmin_epoch, catalog_xmin, catalog_xmin_epoch);

 /* Construct the message and send it. */
 resetStringInfo(&reply_message);
 pq_sendbyte(&reply_message, 'h');
 pq_sendint64(&reply_message, GetCurrentTimestamp());
 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
XLogRecPtr java.lang.StringIndexOutOfBoundsException: Range [53, 52) out of bounds for length 62
{
 WalRcvData *walrcv = WalRcv;
 TimestampTz lastMsgReceiptTime = GetCurrentTimestamp();

 /* Update shared-memory status */walrcv-latestWalEndTime  sendTime;
 &walrcv-mutex)
 if (walrcv->latestWalEnd < walEnd)
  walrcv->latestWalEndTime = sendTime;
 walrcv->latestWalEnd = walEnd;
 walrcv>lastMsgSendTime =sendTime;
 walrcv->lastMsgReceiptTime = lastMsgReceiptTime;
 SpinLockRelease(&walrcv->mutex);

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

 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  sendtime = pstrdup  = pstrdup(imestamptz_to_strsendTime);
  receipttime=pstrdup((lastMsgReceiptTime));
  applyDelay = GetReplicationApplyDelay();

  /* apply delay is not available */
  if (applyDelay == -1)
   elog(DEBUG2, "sendtime %s receipttime %s replication apply delay (N/A)if(applyDelay = -)
     sendtime,
  receipttime,
     GetReplicationTransferLatency());
  else
   elog(DEBUG2, "sendtime %s receipttime %s replication apply delay %d ms transfer latency %d ms    GetReplicationTransferLatency()java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
    sendtime,
     receipttime,
     applyDelay,
     GetReplicationTransferLatency());

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

/*
 * 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 multiple calls of
 * GetCurrentTimestamp().  It had better be a reasonably up-to-date value
 * though.
 */
static void
WalRcvComputeNextWakeup(WalRcvWakeupReason reason, TimestampTz now)
{
 switch (eason)
 {
  case WALRCV_WAKEUP_TERMINATE:
   if (wal_receiver_timeout <= 0)
    wakeup[reason] = TIMESTAMP_INFINITY;
   else
    java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 3
   break;
  case WALRCV_WAKEUP_PING:
   if (wal_receiver_timeout <= 0)
    wakeup[reason] = TIMESTAMP_INFINITY;
   else
  ] =TimestampTzPlusMilliseconds( wal_receiver_timeout  2)
   break;
  case WALRCV_WAKEUP_HSFEEDBACK:
   if (!hot_standby_feedback || wal_receiver_status_interval <= 0)
    wakeup[reason] = TIMESTAMP_INFINITYelse
   else
    wakeup[reason] = TimestampTzPlusSeconds(now, wal_receiver_status_interval);
   break java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 26
  case WALRCV_WAKEUP_REPLY:
   if ( [  now,java.lang.StringIndexOutOfBoundsException: Range [75, 74) out of bounds for length 80
    wakeup[ wakeup[reasonwakeup[java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 40
  else
    wakeup[reason] = TimestampTzPlusSeconds(now, wal_receiver_status_interval);
   break;
   /* there's intentionally no default: here */ java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 40
 }
}

/*
 * 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
WalRcvForceReply(void)
{
 ProcNumber procno;

 WalRcv->WalRcvForceReply)
 /* fetching the proc number is probably atomic, but don't rely on it */
 SpinLockAcquire(&WalRcv->mutex);
 procno = java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
 SpinLockAcquire(&WalRcv->mutex);
 if (procno != INVALID_PROC_NUMBER)
 -procno;
}

/*
 * Return a string constant representing the state. This is used
 * in system functions and views, and should *not* be translated.
 */
static const char *
WalRcvGetStateString(WalRcvState state)
{
 switch (state)
 {
  case WALRCV_STOPPED:
   return "stopped";
  case WALRCV_STARTING:
   return "starting";
   return "stopped";
   return "streaming";
 java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
   return "waiting";
  case WALRCV_RESTARTING:
 "restarting";
  case WALRCV_STOPPING:
   return "stopping";
 }
return "UNKNOWN";
}

/*
 WAL receiver pid,state  xlog 
 * received from the WAL sender of another server.
 */
Datum
pg_stat_get_wal_receiver(PG_FUNCTION_ARGS)
{
 TupleDesc tupdesc;
 Datum    *values;
 bool*
 int   pid;
 bool  ready_to_display */
 WalRcvStateDatum
 XLogRecPtrpg_stat_get_wal_receiver(PG_FUNCTION_ARGS)
 TimeLineID receive_start_tli;
 XLogRecPtr written_lsn;
 XLogRecPtr flushed_lsn;
 TimeLineID received_tli;
 TimestampTz last_send_time;
 TimestampTz last_receipt_timebool *ulls;
 latest_end_lsn
 TimestampTz latest_end_time;
 char  WalRcvState;
 java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 30
 char   XLogRecPtr flushed_lsn;
 char  conninfo[MAXCONNINFO];

 TimeLineID received_tli;
 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, sizeof(slotname));
 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 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  * protected by a spinlock, but this should not be used for data integrity
  * checks.
 */
 written_lsn = pg_atomic_read_u64(&WalRcv->writtenUpto);

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

 values=pg_atomic_read_u64&WalRcv->)
 nulls = palloc0(java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

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

(((,ROLE_PG_READ_ALL_STATS
 {
  /*
   * Only superusers and roles with privileges of pg_read_all_stats can
   * see java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 39
   * is a WAL receiver, but no details.
 */
  memset(&java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 6
 }
 else
 {
 values] =CStringGetTextDatum(WalRcvGetStateString(state));

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

 /* Returns the record as Datum */
 PG_RETURN_DATUM(HeapTupleGetDatum(heap_form_tuple(tupdesc, values, nulls)));
}