From 9163ee94c0f9c9b0f1c20e08b89731133cd1ca8a Mon Sep 17 00:00:00 2001 From: Mason Sharp Date: Thu, 8 Jan 2015 19:59:32 -0800 Subject: Missed a couple of files when fixing pgxc_ctl init --- src/backend/pgxc/barrier/barrier.c | 4 ++-- src/backend/pgxc/cluster/pause.c | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/backend/pgxc/barrier/barrier.c b/src/backend/pgxc/barrier/barrier.c index 0c6f1afcb5..04e1aa568a 100644 --- a/src/backend/pgxc/barrier/barrier.c +++ b/src/backend/pgxc/barrier/barrier.c @@ -166,7 +166,7 @@ SendBarrierPrepareRequest(List *coords, const char *id) int msglen; int barrier_idlen; - coord_handles = get_handles(NIL, coords, true); + coord_handles = get_handles(NIL, coords, true, true); for (conn = 0; conn < coord_handles->co_conn_count; conn++) { @@ -354,7 +354,7 @@ ExecuteBarrier(const char *id) int msglen; int barrier_idlen; - conn_handles = get_handles(barrierDataNodeList, barrierCoordList, false); + conn_handles = get_handles(barrierDataNodeList, barrierCoordList, false, true); elog(DEBUG2, "Sending CREATE BARRIER <%s> EXECUTE message to " "Datanodes and Coordinator", id); diff --git a/src/backend/pgxc/cluster/pause.c b/src/backend/pgxc/cluster/pause.c index ecac0950b0..e5b4a000a3 100644 --- a/src/backend/pgxc/cluster/pause.c +++ b/src/backend/pgxc/cluster/pause.c @@ -121,7 +121,7 @@ HandleClusterPause(bool pause, bool initiator) * coordinators to respond back */ - coord_handles = get_handles(NIL, GetAllCoordNodes(), true); + coord_handles = get_handles(NIL, GetAllCoordNodes(), true, true); for (conn = 0; conn < coord_handles->co_conn_count; conn++) { @@ -308,7 +308,7 @@ PGXCCleanClusterLock(int code, Datum arg) if (IsConnFromCoord()) return; - coord_handles = get_handles(NIL, GetAllCoordNodes(), true); + coord_handles = get_handles(NIL, GetAllCoordNodes(), true, true); /* Try best-effort to UNPAUSE other coordinators now */ for (conn = 0; conn < coord_handles->co_conn_count; conn++) { -- cgit v1.2.3