fix pg_set_noblock usage

kelvich · kelvich · commit d63aa275db84 · 2018-02-01T01:00:59.000+03:00
diff --git a/arbiter.c b/arbiter.c
@@ -468,7 +468,7 @@ static int MtmConnectSocket(int node, int port)
 		MTM_ELOG(LOG, "Arbiter failed to create socket: %s", strerror(errno));
 		goto Error;
 	}
-	if (pg_set_noblock(sd, MtmUseRDMA)) {
+	if (!pg_set_noblock(sd, MtmUseRDMA)) {
 		MTM_ELOG(LOG, "Arbiter failed to switch socket to non-blocking mode: %s", strerror(errno));
 		goto Error;
 	}
@@ -637,7 +637,7 @@ static void MtmAcceptOneConnection()
 		MtmHandshakeMessage req;
 		MtmArbiterMessage resp;		
 		int rc;
-		if (pg_set_noblock(fd,MtmUseRDMA)) {
+		if (!pg_set_noblock(fd,MtmUseRDMA)) {
 			MTM_ELOG(ERROR, "Arbiter failed to switch socket to non-blocking mode: %s", strerror(errno));
 		}
 		rc = MtmReadSocket(fd, &req, sizeof req);

Original file line number	Diff line number	Diff line change
`@@ -468,7 +468,7 @@ static int MtmConnectSocket(int node, int port)`
`468`	`468`	`MTM_ELOG(LOG, "Arbiter failed to create socket: %s", strerror(errno));`
`469`	`469`	`goto Error;`
`470`	`470`	`}`
`471`		`- if (pg_set_noblock(sd, MtmUseRDMA)) {`
	`471`	`+ if (!pg_set_noblock(sd, MtmUseRDMA)) {`
`472`	`472`	`MTM_ELOG(LOG, "Arbiter failed to switch socket to non-blocking mode: %s", strerror(errno));`
`473`	`473`	`goto Error;`
`474`	`474`	`}`
`@@ -637,7 +637,7 @@ static void MtmAcceptOneConnection()`
`637`	`637`	`MtmHandshakeMessage req;`
`638`	`638`	`MtmArbiterMessage resp;`
`639`	`639`	`int rc;`
`640`		`- if (pg_set_noblock(fd,MtmUseRDMA)) {`
	`640`	`+ if (!pg_set_noblock(fd,MtmUseRDMA)) {`
`641`	`641`	`MTM_ELOG(ERROR, "Arbiter failed to switch socket to non-blocking mode: %s", strerror(errno));`
`642`	`642`	`}`
`643`	`643`	`rc = MtmReadSocket(fd, &req, sizeof req);`