File tree Expand file tree Collapse file tree 1 file changed +14
-7
lines changed
src/backend/replication/logical Expand file tree Collapse file tree 1 file changed +14
-7
lines changed Original file line number Diff line number Diff line change @@ -1070,13 +1070,20 @@ replorigin_session_setup(RepOriginId node)
1070
1070
if (curstate -> roident != node )
1071
1071
continue ;
1072
1072
1073
- else if (curstate -> acquired_by != 0 )
1074
- {
1075
- ereport (ERROR ,
1076
- (errcode (ERRCODE_OBJECT_IN_USE ),
1077
- errmsg ("replication identifier %d is already active for PID %d" ,
1078
- curstate -> roident , curstate -> acquired_by )));
1079
- }
1073
+ /*
1074
+ * MTM-CRUTCH.
1075
+ *
1076
+ * Allow multiple backends to setup same replication session.
1077
+ *
1078
+ * else if (curstate->acquired_by != 0)
1079
+ * {
1080
+ * ereport(ERROR,
1081
+ * (errcode(ERRCODE_OBJECT_IN_USE),
1082
+ * errmsg("replication identifier %d is already active for PID %d",
1083
+ * curstate->roident, curstate->acquired_by)));
1084
+ * }
1085
+ *
1086
+ */
1080
1087
1081
1088
/* ok, found slot */
1082
1089
session_replication_state = curstate ;
You can’t perform that action at this time.
0 commit comments