Commit2355da8

committed

more portable way to switch socket to nonblock mode

1 parent9527db9 commit2355da8Copy full SHA for 2355da8

File tree

-1

lines changed

-1

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -16,6 +16,7 @@`
`16`	`16`	`#include<errno.h>`
`17`	`17`	`#include<netdb.h>`
`18`	`18`	`#include<time.h>`
	`19`	`+#include<fcntl.h>`
`19`	`20`
`20`	`21`	`#include"postgres.h"`
`21`	`22`	`#include"fmgr.h"`
`@@ -380,10 +381,11 @@ static int MtmConnectSocket(char const* host, int port, int max_attempts)`
`380`	`381`	`while (1) {`
`381`	`382`	`intrc=-1;`
`382`	`383`
`383`		`-sd=socket(AF_INET,SOCK_STREAM\|SOCK_NONBLOCK,0);`
	`384`	`+sd=socket(AF_INET,SOCK_STREAM,0);`
`384`	`385`	`if (sd<0) {`
`385`	`386`	`elog(ERROR,"Arbiter failed to create socket: %d",errno);`
`386`	`387`	`}`
	`388`	`+fcntl(sd,F_SETFL,O_NONBLOCK);`
`387`	`389`	`busy_socket=sd;`
`388`	`390`	`for (i=0;i<n_addrs;++i) {`
`389`	`391`	`memcpy(&sock_inet.sin_addr,&addrs[i],sizeofsock_inet.sin_addr);`

Comments

(0)