49 if (connOptions == NULL)
56 if (strcmp(opt->keyword,
"replication") == 0 ||
57 strcmp(opt->keyword,
"dbname") == 0 ||
58 strcmp(opt->keyword,
"fallback_application_name") == 0 ||
60 (opt->val != NULL && opt->val[0] ==
'\0'))
64 if (conninfo_buf.
len != 0)
81 if (conninfo_buf.
len != 0)
128 bool use_recovery_conf;
136 use_recovery_conf ?
"recovery.conf" :
"postgresql.auto.conf");
138 cf = fopen(
filename, use_recovery_conf ?
"w" :
"a");
142 if (fwrite(contents->
data, contents->
len, 1, cf) != 1)
147 if (!use_recovery_conf)
#define Assert(condition)
int PQserverVersion(const PGconn *conn)
PQconninfoOption * PQconninfo(PGconn *conn)
void PQconninfoFree(PQconninfoOption *connOptions)
static char * replication_slot
char * escape_single_quotes_ascii(const char *src)
PQExpBuffer createPQExpBuffer(void)
void initPQExpBuffer(PQExpBuffer str)
void appendPQExpBuffer(PQExpBuffer str, const char *fmt,...)
void appendPQExpBufferChar(PQExpBuffer str, char ch)
void appendPQExpBufferStr(PQExpBuffer str, const char *data)
void termPQExpBuffer(PQExpBuffer str)
#define PQExpBufferBroken(str)
#define PQExpBufferDataBroken(buf)
void WriteRecoveryConfig(PGconn *pgconn, const char *target_dir, PQExpBuffer contents)
PQExpBuffer GenerateRecoveryConfig(PGconn *pgconn, const char *replication_slot, char *dbname)
static char * escape_quotes(const char *src)
#define MINIMUM_VERSION_FOR_RECOVERY_GUC
void appendConnStrVal(PQExpBuffer buf, const char *str)