Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit feaa891

Browse files
knizhnikkelvich
authored andcommitted
Fix RDMS build of multimaster
1 parent 33f01b4 commit feaa891

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

arbiter.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ static int MtmWaitSocket(int sd, bool forWrite, timestamp_t timeoutMsec)
214214
FD_SET(sd, &set);
215215
tv.tv_sec = (deadline - now)/USECS_PER_SEC;
216216
tv.tv_usec = (deadline - now)%USECS_PER_SEC;
217-
} while ((rc = pg_select([sd+1, forWrite ? NULL : &set, forWrite ? &set : NULL, NULL, &tv, MtmUseRDMA)) < 0 && errno == EINTR);
217+
} while ((rc = pg_select(sd+1, forWrite ? NULL : &set, forWrite ? &set : NULL, NULL, &tv, MtmUseRDMA)) < 0 && errno == EINTR);
218218

219219
return rc;
220220
}
@@ -688,7 +688,7 @@ static void MtmAcceptIncomingConnections()
688688
if (gateway < 0) {
689689
MTM_ELOG(ERROR, "Arbiter failed to create socket: %s", strerror(errno));
690690
}
691-
if (pg_setsockopt(gateway, SOL_SOCKET, SO_REUSEADDR, (char*)&on, sizeof on) < 0) {
691+
if (pg_setsockopt(gateway, SOL_SOCKET, SO_REUSEADDR, (char*)&on, sizeof on, MtmUseRDMA) < 0) {
692692
MTM_ELOG(ERROR, "Arbiter failed to set options for socket: %s", strerror(errno));
693693
}
694694

pglogical_receiver.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
#include "fmgr.h"
2424
#include "miscadmin.h"
2525
#include "pg_socket.h"
26-
#include "libpq-fe.h"
2726
#include "pqexpbuffer.h"
2827
#include "access/xact.h"
2928
#include "access/clog.h"
@@ -42,6 +41,7 @@
4241
#include "replication/origin.h"
4342
#include "utils/portal.h"
4443
#include "tcop/pquery.h"
44+
#include "libpq-int.h"
4545

4646
#include "multimaster.h"
4747
#include "spill.h"

0 commit comments

Comments
 (0)