|
|
@ -441,13 +441,13 @@ pgoutput_startup(LogicalDecodingContext *ctx, OutputPluginOptions *opt, |
|
|
|
if (data->protocol_version > LOGICALREP_PROTO_MAX_VERSION_NUM) |
|
|
|
if (data->protocol_version > LOGICALREP_PROTO_MAX_VERSION_NUM) |
|
|
|
ereport(ERROR, |
|
|
|
ereport(ERROR, |
|
|
|
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED), |
|
|
|
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED), |
|
|
|
errmsg("client sent proto_version=%d but we only support protocol %d or lower", |
|
|
|
errmsg("client sent proto_version=%d but server only supports protocol %d or lower", |
|
|
|
data->protocol_version, LOGICALREP_PROTO_MAX_VERSION_NUM))); |
|
|
|
data->protocol_version, LOGICALREP_PROTO_MAX_VERSION_NUM))); |
|
|
|
|
|
|
|
|
|
|
|
if (data->protocol_version < LOGICALREP_PROTO_MIN_VERSION_NUM) |
|
|
|
if (data->protocol_version < LOGICALREP_PROTO_MIN_VERSION_NUM) |
|
|
|
ereport(ERROR, |
|
|
|
ereport(ERROR, |
|
|
|
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED), |
|
|
|
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED), |
|
|
|
errmsg("client sent proto_version=%d but we only support protocol %d or higher", |
|
|
|
errmsg("client sent proto_version=%d but server only supports protocol %d or higher", |
|
|
|
data->protocol_version, LOGICALREP_PROTO_MIN_VERSION_NUM))); |
|
|
|
data->protocol_version, LOGICALREP_PROTO_MIN_VERSION_NUM))); |
|
|
|
|
|
|
|
|
|
|
|
if (data->publication_names == NIL) |
|
|
|
if (data->publication_names == NIL) |
|
|
|