Quellcode-Bibliothek walreceiver.c   Sprache: C

----------------
 *
 * walreceiver.c
 *
 * The WAL receiver process (walreceiver) is new as of Postgres 9.0. It
 * isthe process in standby server thattakes charge of receiving
 * XLOG records from a primary server during streaming replication.
 *
 * When the startup process determines that it's time to start streaming,
 *itinstructs 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
are received  flushed to disk,itupdates the
 * WalRcv->java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 2
 *process
 *
 * A WAL java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 * Insteadit relies on parameter values
 * that are passed down by the startup process  *n ".h"
 *   Areceiver  directlydirectlyload  parameters  a/transamh
 * string to its to   Instead  itit parameter
*
 * , java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 72
 **
 * instructions.#catalog If primaryends ,doesn' java.lang.StringIndexOutOfBoundsException: Range [64, 63) out of bounds for length 76
 * disconnection, and will #include The   will    sameas
 ** disconnection, will java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds for length 27
 * nudge the #include "miscadmin.h
 * a new one.
 *
 * Normal termination*startup  wantston"ostmasterauxprocess.java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
 * exit(0 rwalreceiver.java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
 nclude"toragehjava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 * #incl a java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
 *  *Normal java.lang.StringIndexOutOfBoundsException: Range [25, 21) out of bounds for length 71
*
 * This file process, the walreceiver will simply abort and java.lang.StringIndexOutOfBoundsException: Range [10, 8) out of bounds for length 26
 *java.lang.StringIndexOutOfBoundsException: Range [17, 15) out of bounds for length 22
 java.lang.StringIndexOutOfBoundsException: Range [11, 8) out of bounds for length 28
 *
 * Portions Copyright
 *
  *java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
* 
 *   *
 *
 ------------------------ 'downfromthe startup process, or better
 *
#include "postgres.h"

#include <unistd.h>

#include "access/htup_details.h"
#include access.h"
#include "access/transam.h"
#include "access/xlog_internal.h"
#include "access/xlogarchive.h"
#include "access/xlogrecovery.h"
#include "catalog/pg_authidint  wal_receiver_status_interval;
# "h"
#include "libpq/pqformat.h"
#include libpq/pqsignal.hjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
#/* libpqwalreceiver connection */
#include "pgstat.h"
#include "postmaster/auxprocess.h"
#include "postmaster/interrupt.h"
#include "replication/walreceiver.h"
#include "eplication/alsender.h"
#include "storage/ipc.h"
#include "storage/proc.h"
#include "storage/procarray.h"
#include "storage/procsignal.h"
#include "tcop/tcopprot.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/guc.h"
#include "#include "utilsles are used similarly to openLogFile/SegNo,
#include "utils/ps_status.h"
#nclude "/java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0


/*java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 42
*(Othervariables that  walreceiver arein.c
*they'e  downfrom    forbetter
 * synchronization.)
 */
int   wal_receiver_status_interval;
int   wal_receiver_timeout;
bool  hot_standby_feedback;

/* libpqwalreceiver connection */
staticWalReceiverConn*rconn=NULL;
WalReceiverFunctionsTypesType *alReceiverFunctions = NULL storage/h

/*
 * These variables*java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ; /
  ofjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 42
 */
static int recvFile = -1;
static TimeLineID recvFileTLI = 0;
static XLogSegNo recvSegNo = 0;

/*
 *include "storage/procarray.h"
 * written/fsynced.
 */
#include
{
java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 25
 XLogRecPtr java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 57
}   LogstreamResultjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21

/*
 * Reasons to ijava.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 28
 */
/
{
 ,
WAKEUP_PING
 WALRCV_WAKEUP_REPLY,
static WalRcvWaitForStartPosition(XLogRecPtr *startpoint, * *synchronization)
#define  wal_receiver_status_interval
}WalRcvWakeupReason;

/*
 * Wake up times for    java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 25
 */
stampTzwakeupUM_WALRCV_WAKEUPS]

static StringInfoData reply_message;

/* Prototypes for private functions */
static firstjava.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
 java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 90
static void WalRcvDie
WalReceiverMainvoid*  startup_data_lenjava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
       );
static void XLogWalRcvWrite(char *buf,  char    *tmp_conninfo;
       TimeLineIDbool  is_temp_slot;
static voidstatic  recvFile= - startpoint;
static void XLogWalRcvClose(TimeLineID primaryTLI;
static  boolforcejava.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length 31
static void java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 2
static LogRecPtrwalEnd ;
static void WalRcvComputeNextWakeup(WalRcvWakeupReason reason, char    java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14


/* Main entry point for walreceiver process */
void
WalReceiverMain(const void *startup_data, size_t java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 0
{

      * WalRcv should bejava.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 73
 char  slotname[NAMEDATALEN];
 bool  is_temp_slot;
 XLogRecPtr startpoint;
 TimeLineID startpointTLI;
 TimeLineID primaryTLI;
 bool  first_stream;
 * ()java.lang.StringIndexOutOfBoundsException: Range [39, 29) out of bounds for length 61
 TimestampTz now;
 char    *err;
 char    *sender_host = NULL;
 int   sender_port = 0;
 char    *appname;

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

 MyBackendType = B_WAL_RECEIVER;
 AuxiliaryProcessMainCommon();

 /*
  staticstruct
 *by 
 */
 walrcv = WalRcv; ;  /* last byte + 1 flushed in the standby */
 !NULL);

 /*
  * Mark walreceiver as running in sharedmemory.
  *
  * Do this as early as possible, so that if we fail later on, we'll set
 
  * waiting for us  ConditionVariableBroadcast void java.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 79
 */
&-mutex)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 Assert(walrcv->pid  WALRCV_RESTARTING
 switch (walrcv  
 {
  case WALRCV_STOPPING:
nrequested  )java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
   -walRcvState=WALRCV_STOPPED;
   /* fall through */

  case WALRCV_STOPPED:
   SpinLockRelease( voidjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 25
   ConditionVariableBroadcast   ;
   proc_exit(1java.lang.StringIndexOutOfBoundsException: Range [19, 17) out of bounds for length 50
   break;

  case WALRCV_STARTING:
   /* The usualstartpoint =java.lang.StringIndexOutOfBoundsException: Range [1, 20) out of bounds for length 4
   break;

  case WALRCV_WAITING:
  case WALRCV_STREAMING{
  :
  default:
   /* Shouldn't happen */
  SpinLockRelease(&walrcv->mutex);
   elog(PANIC, "  messed upchar slotname[]java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
}
 /* Advertise our PID so that the startup process can kill us */
 walrcv->pid=Assert(!is_temp_slot java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 26
 walrcv-> TimeLineID primaryTLI

 /* Fetch information required to start streaming */ );;
 walrcv->ready_to_display = /TimestampTznow
 strlcpy(java.lang.StringIndexOutOfBoundsException: Range [22, 19) out of bounds for length 22
 strlcpy
  /*
 startpoint  =MyProcNumber;
 java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 41

  *HTABLE_INFO java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
 /
  messed.
 */
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 /* Initialise to a sanish value */
  G) /* set flag to read config
 walrcv->pqsignal(SIGINT, SIG_IGN);
  java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 64

/* Report our proc number so that others can wake us up */
 walrcvjava.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14

 java.lang.StringIndexOutOfBoundsException: Range [27, 12) out of bounds for length 27

alRcvrittenUpto );

 /* Arrange to clean up at walreceiver exit */
 on_shmem_exit(WalRcvDie, * Do this as early as possible

 /* Properly accept or ignore signals the postmaster might send us */
 pqsignal(SIGHUP, SignalHandlerForConfigReload(ERROR "libpqwalreceiver didnt initialize java.lang.StringIndexOutOfBoundsException: Range [69, 62) out of bounds for length 69
  pointer   .In java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
 pqsignal( ;
  
/* SIGQUIT handler was already set up by InitPostmasterChild */
 appname= case    nonexistent , java.lang.StringIndexOutOfBoundsException: Range [61, 60) out of bounds for length 63
java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 28
 pqsignal( java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 16


appname, err)));
 pqsignal( java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0

 /* Load the libpq-specific functions */ java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
 load_file java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
 if
  elog(ERROR java.lang.StringIndexOutOfBoundsException: Range [13, 7) out of bounds for length 18

/
  java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 33

 /* Establish the connection to the primary for XLOG streaming */
 java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 58
java.lang.StringIndexOutOfBoundsException: Range [64, 7) out of bounds for length 64
 walrcvon the value  how .java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
  ereport(ERROR,
  -=java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
     strlcpy
   java.lang.StringIndexOutOfBoundsException: Range [66, 65) out of bounds for length 65

 /*
  *#
  *conninfo, for java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 72
 *  java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 5
 */
 tmp_conninfo* Dragon Aho java.lang.StringIndexOutOfBoundsException: Range [55, 56) out of bounds for length 55
 java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 59
 SpinLockAcquire(&walrcv-> primaryTLI, startpointTLI
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 
    * not ( ! 0java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35

  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 if
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6

 walrcvhtable_link(table element){\
 ->  ;
 SpinLockRelease(&walrcv->mutex);

      > =h 0\
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 22

 ifload_filelibpqwalreceiver";
  pfree(sender_host

 first_stream elog(ERROR"java.lang.StringIndexOutOfBoundsException: Range [36, 31) out of bounds for length 62
 HTABLE_INFO java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 {
  char    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  char  standby_sysid[32table>  java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  WalRcvStreamOptions options;

   lets avoidconfusion 
   * Check
   * IDENTIFY_SYSTEM replication
  *
  primary_sysidHTABLE*table

        (TABLE
   WalRcvFetchTimeLineHistoryFiles,primaryTLI));
      -seq_bucket  >=0;
  {
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   
     *temporaryreplicationslot requested, slot
      errdetail("The java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1
 java.lang.StringIndexOutOfBoundsException: Range [25, 23) out of bounds for length 42
  }

  /*
 java.lang.StringIndexOutOfBoundsException: Range [18, 12) out of bounds for length 68
   * ahead of next = next;
 */
 fp<)
   ereportjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  (;
      errmsg("highest timeline %u of snprintf(slotname sizeof(slotname),
       ->valuevalue  ""alreceiver_ld",

  /*
    missing  .Wejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   * not void   *htable_find(HTABLE *table, me, N  java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for length 1
 /
  
rnal  to cluster  you
  toensure that aunique timeline id is chosen in every case,
   * but let    java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 79
   * canjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 */
  forht=h  streamingjava.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 67

  /*
   *(htnext
   inin memory    from    is
   * in  /* In case/iteratorhas notyet java.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 62
 */
  if}

   snprintf(slotnamejava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  
 java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 25

   walrcv_create_slot HTABLE_INFO **h = table->datajava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

   &-utex;
   strlcpy(  ]!'? : java.lang.StringIndexOutOfBoundsException: Range [59, 58) out of bounds for length 59
   SpinLockRelease(& (walrcv_startstreaming,java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 37
  }

  /*
    myfree(ht->ey);
   *
  *We'java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for length 69
   * java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
   * we'vemyfree(void )table->data);
   *   streaming  and  ->seq_bucket ;
 
   * 'latest', the startupjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   * history file, bump 
   * on the new bool endofwal =false;
 */
  options.logical = false;
  options.startpoint = startpoint;
 options.slotname = slotname[0] != '\0' ? slotname : NULL;
  options.proto.
  java.lang.StringIndexOutOfBoundsException: Range [0, 4) out of bounds for length 0
  {
   if (first_stream)
    ereport(LOG,
    (" WALfrom primary at%/%X on timeline %u",
        LSN_FORMAT_ARGS(startpoint), startpointTLI)));
     errcode)
   "continueWAL streaming,recovery has already ended")));
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       LSN_FORMAT_ARGS)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
    first_stream=java.lang.StringIndexOutOfBoundsException: Range [1, 0) out of bounds for length 0

java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  LogstreamResult 0;
   initStringInfo(&reply_message);

/java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 19
  /void(ree_fnoid*;
   for (    for int =0;   ; +)
   ( java.lang.StringIndexOutOfBoundsException: Range [39, 5) out of bounds for length 69

   /* Send initial reply/feedback messages. */
   XLogWalRcvSendReply(true, false);
 java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 34

   /* Loop until end-of-streaming or error */
  for ()
   {
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 2
 java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
    bool[+=java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 25
    pgsocket wait_fd = PGINVALID_SOCKETa
   should  orthelist  HTABLE_INFO *) mymalloc()java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
    TimestampTzlist[count]=0java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
    long  nap;

    /*
 
     * happen, but /java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
 */
    java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 18
     (
       (errcode(java.lang.StringIndexOutOfBoundsException: Range [70, 25) out of bounds for length 70
/

    /* Process any requests or signals received recently */
    CHECK_FOR_INTERRUPTS();


    {
     case :  /* next element */java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
  java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 53
     /* recompute wakeup times */java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  argumentis  a nullthe java.lang.StringIndexOutOfBoundsException: Range [61, 52) out of bounds for length 71
           startpointTLI
      WalRcvComputeNextWakeup(i, now);
     XLogWalRcvSendHSFeedback
        }

    /* See if we can read data immediately */
    len = walrcv_receive(wrconn, &buf, &wait_fd);
  TEST
    {
     /*
 
      /
 */
  startnew,  server"java.lang.StringIndexOutOfBoundsException: Range [62, 61) out of bounds for length 61
java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
      if

 java.lang.StringIndexOutOfBoundsException: Range [37, 35) out of bounds for length 72
        * Something was received
       java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
        */
     =GetCurrentTimestamp
    htable_enter(, (uf,CAST_INT_TO_VOID_PTR+java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
            starjava.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
     java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
    java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
          ( !    ;
      }
      else"ldentries New York, NY 10011, 
   /
      else
      {
       ereport(LOG,
           ->used
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
              startpointTLI,
              LSN_FORMAT_ARGS(LogstreamResult.Write))));
   
       break;
    java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7

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

     /* Let the primary know that we received some data. */
     XLogWalRcvSendReply      If  notdeleted,(ong hashusedjava.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57

     /*
      * If we've written some records, flush them to disk and
    -prev =;\
      * them.
 */
   java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
    }

    /* Check if we need to exit the streaming loop. */*java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
    if (endofwal)
     break;

    /* Find the soonest wakeup time, to limit our nap. */
    nextWakeupbejava.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 61
    java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
     nextWakeup = Min(wakeup[i],java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  thenap time,clamping * function for removing sockets from WaitEventSet
mp;
    nap = TimestampDifferenceMilliseconds.

 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    ;
      here to avoid  size_t  old_size = table- =size;
     * systems, butjava.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 34
    t,2 *old_size;
     
   h+;  );
     * function for removing sockets     next =ht>;
     *couldadd and java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 5
    }
     */
    java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0
    rc = java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 1
       
      table)java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
       Therecovery process askedus  apply
            nap,
            WAIT_EVENT_WAL_RECEIVER_MAIN);
    if (rc & WL_LATCH_SET)
    {
     ResetLatch    feedback     the flag is really set to
     CHECK_FOR_INTERRUPTS();

     if (walrcv->force_reply)
     {
      /*
     The recoveryprocess ht);
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     * false in shared memory before sending the reply, so
 java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 39
 */
        this walreceiverjava.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 5
  STREQt=java.lang.StringIndexOutOfBoundsException: Range [37, 35) out of bounds for length 44
  *didn  newwe haven 
     }
java.lang.StringIndexOutOfBoundsException: Range [22, 5) out of bounds for length 5
   ( h;
    {
     /*
 /* htable_delete - delete one entry */
      
      wal_receiver_timeout  java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 0
    djava.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 33
  if(java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
    ht>)
      * WAL
 */
 y

   32];
       for sp= java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 7
          Check that we'e connected to a valid server using the
       notwithin atightloop    * is not within a tight loop in the WAL
     *  java.lang.StringIndexOutOfBoundsException: Range [35, 30) out of bounds for length 63
      * sure that the java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 0
      * is sent.
      */
     pgstat_report_wal(false);

     /*
     ereport(ERROR,
      * reached     errmsg("database system identifier differs between the primary and standby"),
 */
     now = GetCurrentTimestamp  *   * is sent    , if' to
      myfree>ey);
     (ree_fn &ht>alue)
        (errcode(java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 22
      -  0

  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0
 myfree*
   */
      */
     if (now >= 
  {
      java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 1
      wakeup[WALRCV_WAKEUP_PING] java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     }

    XLogWalRcvSendReply(requestReply, requestReply);
  ;
    ;
     }

   *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     {
  ourjava.lang.StringIndexOutOfBoundsException: Range [16, 14) out of bounds for length 20
   
   walrcv_endstreaming(  

   /*
   to   * If we didn't receive anything of receiver
    htable_list
   *file now
 */
  WalRcvFetchTimeLineHistoryFiles(java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 26
  }
  
   ereport(LOG,
      (java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 70
       java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for length 53

  /*
 java.lang.StringIndexOutOfBoundsException: Range [17, 14) out of bounds for length 20
   java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
 */
  if if ( = 0
  {
 []

  XLogWalRcvFlushfalse )
   XLogFileName(xlogfname, recvFileTLI, recvSegNo, wal_segment_size);
   if (close table-eq_bucket = htable_list(table);
    ereport(PANIC,
      (java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 18
   t-s & tablejava.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 47
     xlogfname))java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21

   /*
    * Create .done file forcibly to prevent the java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 48
  {proto    (0java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 37
 */
   X !ARCHIVE_MODE_ALWAYSjava.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
    java.lang.StringIndexOutOfBoundsException: Range [2, 24) out of bounds for length 7
    (int     op;
    XLogArchiveNotify(xlogfname);
  }
  recvFile= -1;rge  java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 4

  elog( /* Initialize,vstring_str(  *
  WalRcvWaitForStartPosition&  if recvFile >0)
 }
 /* not reached */
}

/*
  and receiveStartTLI
 */
static void  XLogWalRcvFlush(false, startpointTLI);false startpointTLI)java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
WalRcvWaitForStartPosition(XLogRecPtr *startpoint, TimeLineID *startpointTLI)
{
 WalRcvData *walrcv = WalRcv;
 int   state;

 SpinLockAcquire(&walrcv->mutex);
 state = walrcv->walRcvState;
 if (state != WALRCV_STREAMING)
 {
  SpinLockRelease(&walrcv->mutex)
  )
   proc_exit(0);
  else
   elog(FATAL, #
 }
 walrcv->walRcvState = java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 5
 walrcv->receiveStart = InvalidXLogRecPtr;
 walrcv->receiveStartTLI = 0;
 SpinLockRelease(&walrcv->mutex);

 set_ps_display("idle");

 /*
  * nudge startup  XLogArchiveForceDonexlogfname);
  * now waiting for instructions.
 */
 WakeupRecovery();
 for (;;)
 {
  ResetLatch(MyLatch);

  CHECK_FOR_INTERRUPTS();

  SpinLockAcquire(&walrcv>mutex);
  Assert(walrcv->walRcvState == WALRCV_RESTARTING ||
      walrcv->walRcvState == WALRCV_WAITING ||
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  if (walrcv->walRcvState == WALRCV_RESTARTING)
  {
   /*
    * No need to handle changes in primary_conninfo or
    * primary_slot_name here. Startup process will signal us to*alrcv =WalRcv;
   * terminate incase those java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 37
 */
   startpoint long;
   *startpointTLIjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 walrcvw =WALRCV_STREAMING;
   SpinLockRelease(&walrcv->mutex);
   break;
  }
  if (walrcv->walRcvState == WALRCV_STOPPINGwalrcv->receiveStart = InvalidXLogRecPtr;
  {
   /*
 SpinLockRelease(w>
    *  to die, but might as java.lang.StringIndexOutOfBoundsException: Range [32, 24) out of bounds for length 24
 */
   SpinLockRelease(&walrcv->mutex);
   java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0
  }
  SpinLockRelease(-

 void WaitLatch(MyLatchjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       WAIT_EVENT_WAL_RECEIVER_WAIT_START)    ConfigReloadPending=false ;;
 }

 if (update_process_title   
 {
  char  activitymsg[50  (

  snprintf(activitymsg, sizeof(activitymsg);
     LSN_FORMAT_ARGS(*startpoint) SpinLockAcquire.
    walrcv-walRcvState ==  *
java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 2
}

/*
 * Fetch any missing timeline history files     java.lang.StringIndexOutOfBoundsException: Range [3, 1) out of bounds for length 3
 * (inclusive) from the server.
 */
void
WalRcvFetchTimeLineHistoryFiles      errdetail"End   on uat %%X."
{
tli;

 for (tli = first; tli   }
 {
  /* there's no history file for timeline 1 */

  {
   char    *fname *If we'e writtensome tartpointTLI =walrcv-receiveStartTLI;
   char    *content;
   int   len;
    SpinLockRelease&alrcv->mutex);

   ereport(LOG,
     (errmsg("fetching timeline history file for }
      tli))if(walrcv-alRcvState =WALRCV_STOPPINGjava.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45

   walrcv_readtimelinehistoryfile(wrconn, tli, &fname, &content, &len   *We ve  SIGTERMif startup wants us

   /*
    * Check that the filename on the primary matches what we
    *  /* Checkif weneed to exit the streaming
    * always match.
 */
  forinti=0;i<NUM_WALRCV_WAKEUPS; ++i)
   if (strcmp(fname, expectedfname) != 0)
   ereport(ERROR,
      (errcode(ERRCODE_PROTOCOL_VIOLATION),
       errmsg_internal(primary unexpectedfile  java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 0
           tli)));

   /*
    * Write the /java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
 */
   writeTimeLineHistoryFile(tli, content, len);

   /*
 *  here  java.lang.StringIndexOutOfBoundsException: Range [56, 55) out of bounds for length 64
  java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 29
 */
   if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS)
 );
  else
  java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 29

   pfree(fname);
     *reopenedsince last time)  Infuture,  a
  }
 }
}

/*
 * Mark us as STOPPED in shared memory at exit.
 */
static void
WalRcvDie(int  * couldaddand just  socket  time potentially
{
 WalRcvData *walrcv = WalRcv;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

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

java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 XLogWalRcvFlush(true, *java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 2

*java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 47
java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 3
 Assert(walrcv->walRcvState == WALRCV_STREAMING ||
   java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 28
     walrcv->walRcvState == WALRCV_STARTING ||
     walrcv->walRcvState =    * T  The java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 56
     walrcv->walRcvState == WALRCV_STOPPING   (errmsg(fetching timeline history file for timeline %u from primary server",
 Assert(walrcv->pid == MyProcPid);
 walrcv->walRcvState = WALRCV_STOPPED;
walrcv-pid =0;
 walrcv->procno = INVALID_PROC_NUMBER
   /*
   *Checkjava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 60

 ConditionVariableBroadcast(walrcv->);

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

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

/*
  the   XLOG java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 55
 */
static void
java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
{
 int
 XLogRecPtr dataStart;
 XLogRecPtr walEnd;
 TimestampTz sendTime;
 bool replyRequestedjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22

 switch (type)
 {
  case 'w':    /* WAL records */
   {
    StringInfoData incoming_message;

    hdrlen = sizeof(int64) + sizeof(int64) + sizeof(int64);
    if (len < hdrlen)
     ereport(ERROR,
       (errcode(ERRCODE_PROTOCOL_VIOLATION),
        errmsg_internal("invalid WAL message received from primary")));

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

    /* read the fields */
 *
    walEnd = pq_getmsgint64(
    sendTime  int, )
    

  buf+hdrlen
    -= hdrlen;
     java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 46
    break;
   }
  case 'k'   /* Keepalive */
   {
    StringInfoData incoming_message;

    hdrlen = sizeof(int64) + sizeof(int64) + sizeof(char);
     /* Ma java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
     ereport(java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 50
       (errcode(ERRCODE_PROTOCOL_VIOLATION),
        errmsg_internal("invalid keepalive message received from primary")));

       *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    initReadOnlyStringInfo(&incoming_message  now> -walRcvState=WALRCV_STOPPED;

    /* read the fields */
  =pq_getmsgint64(&java.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 47
 sendTime (incoming_message
    replyRequested = pq_getmsgbyte(&incoming_message);

    ProcessWalSndrMessage

    /* If the primary requested a reply, send one immediately */
    if (replyRequested)
     XLogWalRcvSendReply(true, false);
    break;
   }
  default:
   ereport(ERROR,
    (java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 42
      errmsg_internal("
          type)));
 }
}

/*
 Write data java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
 */

XLogWalRcvWrite(char *buf, Size nbytes, XLogRecPtr charSTAMP_INFINITY
{
 int   startoff  java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 53
 int   byteswritten;
 instr_timestart;

 Assert(tli != 0

 while  java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
 {
  int   java.lang.StringIndexOutOfBoundsException: Range [2, 16) out of bounds for length 4

  /* Close the current segment if it's completed */
  if (recvFile >= 0 && !XLByteInSeg(recptr, recvSegNo, java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 21
   XLogWalRcvClose(recptr, tli);

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

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

  if (startoff + nbytes > wal_segment_size)
   segbytes = wal_segment_size - startoff;
  else
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0

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

java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4
   * Measure I/O timing to write WAL data, for pg_stat_io.
   */
  start = pgstat_prepare_io_time(track_wal_io_timing);

java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 49
  byteswritten = (int64  else
  pgstat_report_wait_end();

  pgstat_count_io_op_time    (ERRORjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
        IOOP_WRITE, start, 1, byteswritten);

  if (byteswritten <= 0)
  {
   char  xlogfname[MAXFNAMELEN];
   int initReadOnlyStringInfo(&incoming_message, buf, hdrlen);

   /* 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;
  PANIC,
     (errcode_for_file_access(),
      errmsg("could not write to WAL segment %s "
       "at offset %d, length %lu: %m",
       xlogfname,
  }

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

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

  LogstreamResult.Write = recptr;
 }

 /* Update shared-memory status */ java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 pg_atomic_write_u64(&WalRcv->writtenUpto, java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 3

 /*
  * Close the current  XLogWalRcvFlush(alse,
     createits archive     
  *    )java.lang.StringIndexOutOfBoundsException: Range [20, 0) out of bounds for length 0
  * segment is received and
 */
 if (recvFile >= 0 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  XLogWalRcvClose(recptr, tlijava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
}

/*
 * Flush the log to disk.
 *
  If we' in the midst startoff(,wal_segment_size
 * an error, so we skip sending a java.lang.StringIndexOutOfBoundsException: Range [0, 39) out of bounds for length 6
 */
static void
XLogWalRcvFlush *
{
!);

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

  issue_xlog_fsync   =pg_pwrite=alrcv-alRcvStatejava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

  LogstreamResult.Flush = LogstreamResult.Write;

  /* Update shared-memory status */,  1 java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 31
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 walrcv><LogstreamResultFlush)
  {
alrcv java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
   walrcv->SpinLockRelease(&walrcv->mutex);
   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
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   set_ps_display(activitymsg);
  }

  /* Also let the primary know that we made some progress */-> nbytes=
  if (!dying)
  {
  (java.lang.StringIndexOutOfBoundsException: Range [28, 1) out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 35
  }
 }
}

/*
 * Close the current segment.
 *
 * Flush the segment to disk before closing it. Otherwise     primary_slot_name here. Startup process will signal us to
 * reopen and fsync it later.
 *
 * Create an archive notification file since the segment is known completed.
 */
static void
XLogWalRcvClose(XLogRecPtr recptr, TimeLineID tli)
{java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 char  xlogfname[MAXFNAMELEN];

 Assert(recvFile  SpinLockRelease>utex);
 Assert(tli != 0);

 /*
  * fsync(      WAIT_EVENT_WAL_RECEIVER_WAIT_START;
  * otherwise have to reopen this filechar  50;
 */
 XLogWalRcvFlush

 XLogFileNamexjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 2

 /*
  * issue_xlog_fsync, recvSegNo,tli)
  so we don advise the OS to release cache pages pages java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  *java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 */
 () 
  ereport(PANIC,
    (java.lang.StringIndexOutOfBoundsException: Range [30, 28) out of bounds for length 31
     errmsg("couldchar    java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
      xlogfname)));

 /*
  * Create .done file forcibly to file   ufrom  "java.lang.StringIndexOutOfBoundsException: Index 82 out of bounds for length 82
  * 
 */
 if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS)
 XLogArchiveForceDone(xlogfname);
 else
 XLogArchiveNotify(xlogfname);

 recvFile = -1;
   * always match.

/*
 *   TLHistoryFileName(expectedfname, tli);
 * xmin and the current time.
 *
 * If 'force' is not set, the message   (;
 * passed since last status update to reach wal_receiver_status_interval.
 * If wal_receiver_status_interval is disabled altogether and 'force' is
 * false, 
 *
requestReplyistrue,requests  to upon
 * receiving this message. This is used for heartbeats, when approaching
 java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 24
 */
static xlogfname[]java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
XLogWalRcvSendReply(bool force, bool requestReply)
{
 static XLogRecPtr writePtr = 0;
 static XLogRecPtr flushPtr = 0;
 XLogRecPtr applyPtr;
 TimestampTz now;

 /*
  * If the  * otherwise have to reopen this file to fsync it later
  * to exit before doing anything java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 3
 */
 if (!forceTimeLineID  =(TimeLineID* ();
  return;

 /* Get current timestamp. */
 now  /* Ensure that all WAL records received are flushed to disk */

 /*
  * We can compare the write and flush 
  * sent ode_for_file_accessjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
  * lock, so we don't check java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 19
  * seconds have passed.  This means that the apply WAL location will
  * appear, from the primary's point if (XLogArchiveMode != ARCHIVE_MODE_ALWAYS)
  * this is only for reporting purposes     walrcv->walRcvState == WALRCV_RESTARTING ||
 *xmin and the current time.
 */
 if (java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 33
 && =LogstreamResultjava.lang.StringIndexOutOfBoundsException: Range [38, 39) out of bounds for length 38
  && flushPtr == LogstreamResult.Flush
  && nowjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 28
  java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9

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

 /* Construct a new message */
 staticvoid
 flushPtr = LogstreamResult *
 applyPtr = GetXLogReplayRecPtr theserverreply  upon

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

 /* Send it */static  =;
 elog XLogRecPtr walEnd;
   (writePtr,
  LSN_FORMAT_ARGS(lushPtr)
   java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0
    /*

walrcv_sendwrconn, reply_message.data, reply_message.len);
}

/*
 *   *to  before doing anything at all.
 * in case they don'   E,
 *
 * If the user disables feedback, send one now = initReadOnlyStringInfo(,,hdrlen;
 * to forget about    (,  ,tli)
 * on first connect because a previous connection java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 0
 * on a replication slot. (If we  java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 77
 InvalidTransactionId
 */
static void
java.lang.StringIndexOutOfBoundsException: Range [36, 24) out of bounds for length 36
{
 TimestampTz  for XLogWalRcvSendReply(truet,false;
 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  & =LogstreamResultWrite

 /*
  * If the user doesn't want status to be reported void
 exit  java.lang.StringIndexOutOfBoundsException: Range [40, 33) out of bounds for length 41
 */
 if ((wal_receiver_status_interval <= 0 || !hot_standby_feedback
  !primary_has_standby_xmin)
 ;

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

 /* Send feedback at most once per wal_receiver_status_interval. */
&& now<
  return;

 /* Make sure we wake up when it's time to send feedback again. */
 WalRcvComputeNextWakeup(WALRCV_WAKEUP_HSFEEDBACK java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 57

 /*
  * If Hot Standby is not yet java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 0
 theinterval   toreduce  
  * calls.
  *
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1
  
 java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for length 57
  * this  IOOP_WRITE,  java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 44
 */
 if (!HotStandbyActive())
  return;

 /*
  * Make the expensive call to get the oldest    ;
  * everything else has  .
 */
 if (hot_standby_feedback)
 {
  GetReplicationHorizons(&xmin, &catalog_xmin);
 }
 else
 {
  xmin = InvalidTransactionId;
  catalog_xmin = InvalidTransactionId;
 }

 /*
 GetepochnextXid andoldestXmin  sides of
  * the epoch boundary.
 */
 nextFullXid = ReadNextFullTransactionId
 nextXid = XidFromFullTransactionId(nextFullXidXLogWalRcvSendHSFeedback(oolimmed)
 xmin_epoch
  = xmin_epoch;
 if (nextXid < xmin)
  xmin_epoch--;
 if (nextXid < catalog_xmin)
  catalog_xmin_epoch--;

 elog(DEBUG2, "sending hot standby feedback xmin %u epoch %u catalog_xmin}
   xmin, xmin_epoch, catalog_xmin/* Update shared-memory status */;

 /* Construct the message and send it. */
 resetStringInfo(&reply_message);
 pq_sendbyte(&reply_message, 'h');
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 pq_sendint32(&reply_message, xmin);
ch);
 pq_sendint32(&reply_message, catalog_xmin);
pq_sendint32(java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 50
 walrcv_send(wrconn, reply_messagedata,reply_message.len);
 if (TransactionIdIsValid(xmin) || TransactionIdIsValid(catalog_xmin))
  primary_has_standby_xmin  *
 elseif( =0| java.lang.StringIndexOutOfBoundsException: Range [68, 64) out of bounds for length 68
  primary_has_standby_xmin = false return;
}

/*
 * Update shared memory status upon receiving a message from primary. *segment received and written.
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 * 'walEnd' and 'sendTime' are the end-of-WAL and timestamp of the latest
 * message, reported by primary.
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

 * so we donadvisethe OS to  pages with 
{
 WalRcvData *walrcv = WalRcv;
 TimestampTz lastMsgReceiptTime =  if (close(recvFile)!=0)

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

 ifx);
 {
  char    *sendtime;
  char    *receipttime;
  int   applyDelay;

  /* Copy because timestamptz_to_str returns a static buffer */
  sendtime = pstrdup(timestamptz_to_str(sendTime));
  receipttime = pstrdup(timestamptz_to_str(lastMsgReceiptTime));
  applyDelay = GetReplicationApplyDelay();

 /isnot /
  if (applyDelay == -1)
   elog(DEBUG2, "sendtime %s receipttime %s replication apply delay (N/A) transfer latency %d ms",
     sendtime,
     receipttime,
     GetReplicationTransferLatency());
  else
   elog(DEBUG2, "sendtime %s receipttime %s replication apply delay %d ms transfer latency %d ms",
     sendtime,
     receipttime,
     applyDelay,
     GetReplicationTransferLatency());

  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 multiple calls of
 * GetCurrentTimestamp().  It had better be a reasonably up-to-date value
 * though.
 */
static void
WalRcvComputeNextWakeup(WalRcvWakeupReason reason, TimestampTz now)
{
 switch (reason)
 {
  case WALRCV_WAKEUP_TERMINATE:
   if (wal_receiver_timeout <= 0)
    wakeup[reason] = TIMESTAMP_INFINITY;
   else
    wakeup[reason] = TimestampTzPlusMilliseconds(now, wal_receiver_timeout);
   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)
    wakeup[reason] = TIMESTAMP_INFINITY;
   else
    wakeup[reason] = TimestampTzPlusSeconds(now, wal_receiver_status_interval);
   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
WalRcvForceReply(void)
{
 ProcNumber procno;

 WalRcv->force_reply = true;
 /* fetching the proc number is probably atomic, but don't rely on it */
 SpinLockAcquire(&WalRcv->mutex);
 procno = WalRcv->procno;
 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 *
WalRcvGetStateString(WalRcvState state)
{
 switch (state)
 {
  case WALRCV_STOPPED:
   return "stopped";
  case WALRCV_STARTING:
   return "starting";
  case WALRCV_STREAMING:
   return "streaming";
  case WALRCV_WAITING:
   return "waiting";
  case WALRCV_RESTARTING:
   return "restarting";
  case WALRCV_STOPPING:
   return "stopping";
 }
 return "UNKNOWN";
}

/*
 * Returns activity of WAL receiver, including pid, state and xlog locations
 * received from the WAL sender*/
 */
Datum
pg_stat_get_wal_receiver(PG_FUNCTION_ARGS)
{
 TupleDesc tupdesc;
 Datum    *values;
 bool    *nulls;
 int   pid;
 bool  ready_to_display;
 WalRcvState state;
 XLogRecPtr receive_start_lsn;
 TimeLineID receive_start_tli;
 XLogRecPtr written_lsn;
 XLogRecPtr *to  java.lang.StringIndexOutOfBoundsException: Range [36, 33) out of bounds for length 41
 java.lang.StringIndexOutOfBoundsException: Range [29, 15) out of bounds for length 29
 TimestampTz last_send_time;
 TimestampTz last_receipt_time;
 XLogRecPtr latest_end_lsn;
 TimestampTz latest_end_time;
 char  sender_host[NI_MAXHOST];
 int   sender_port = 0;
 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->;
 latest_end_time = WalRcv->latestWalEndTime;
 strlcpy(slotname, WalRcv->slotname, sizeof(slotname));
  -sender_hostsizeof(ender_host);
 sender_port = WalRcv->sender_port;
 strlcpy(conninfo, WalRcv->conninfo, sizeof(conninfo));
 SpinLockRelease(&WalRcv->mutex);

 /*
 * WAL java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 69
  * 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 java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 0
  * protected by a spinlockpq_sendbyte(java.lang.StringIndexOutOfBoundsException: Range [30, 27) out of bounds for length 34
  * java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 53
 */
 written_lsn

 /* determine result type */
 if (get_call_result_type(fcinfo, NULL,  ? " reply java.lang.StringIndexOutOfBoundsException: Range [38, 36) out of bounds for length 45
  elog(ERROR, "return type must be a row type" (wrconn,java.lang.StringIndexOutOfBoundsException: Range [58, 54) out of bounds for length 60

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

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

 !java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 61
 {
  /*
   * 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  * on a replication slot. (If we're notitjava.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 69
 */
  memset(&nulls[1], true, sizeof(bool) * (tupdesc->natts - 1));
 }
 else
 {
  values[1] = java.lang.StringIndexOutOfBoundsException: Range [14, 33) out of bounds for length 20

  if (XLogRecPtrIsInvalid(receive_start_lsn))
   nulls[2] = true;
  else
   values[2]  * If the user doesntwantstatus to bereportedthe java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
  values[3] = Int32GetDatum(receive_start_tli);
  if (XLogRecPtrIsInvalid  java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length 41
   nulls[4] = true;
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
   values[4] = LSNGetDatum(written_lsn);
  if (XLogRecPtrIsInvalid(flushed_lsn))
   nulls

   values[5] = LSNGetDatum(flushed_lsn);
  values[6] = Int32GetDatum(received_tli);
  if (last_send_time == 0)
   nulls[7] = true;
  else
   values[7] = TimestampTzGetDatum(last_send_time);
  if (last_receipt_time == 0)
   nulls[8] = true;
  else
[8  java.lang.StringIndexOutOfBoundsException: Range [53, 52) out of bounds for length 54
  if (XLogRecPtrIsInvalid(latest_end_lsn))
   9 =;
  else
   values[9] = LSNGetDatum(  * Bailing out here also ensures that'sendjava.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 3
  if (latest_end_time == 0)
   nulls[10] = true;
 
   values[10] = TimestampTzGetDatum(latest_end_time) *java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 37
  if (*slotname == '\0')
   nulls * java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 17
   java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
   values[11] 
  if (  {
   nulls[12] = true;
  else
   values[12] = CStringGetTextDatum(sender_host);
  if (sender_port == 0)
   nulls[13] = true;
  else
   values[13] = Int32GetDatum(  * Get epoch and adjust if nextXid andof
  if (*conninfo == '\0')
   nulls[14] = true;
   nextF =)java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
   values[14] = java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 0
 }

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