mirrors/bgpq4
1
0
Fork 0
mirror of https://github.com/bgp/bgpq4 synced 2025-02-28 08:53:11 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

drop nonblocking before closing socket

Browse Source
This commit is contained in:
Alexandre Snarskii
2019-08-15 20:11:03 +03:00
parent d092e8a9c3
commit d607a8ab04
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
bgpq_expander.c
View File

@@ -756,6 +756,9 @@ bgpq_expand(struct bgpq_expander* b)
int fd=-1, err, ret;
struct sx_slentry* mc;
struct addrinfo hints, *res=NULL, *rp;
struct linger sl;
sl.l_onoff = 1;
sl.l_linger = 5;
memset(&hints,0,sizeof(struct addrinfo));
hints.ai_socktype=SOCK_STREAM;
@@ -775,6 +778,13 @@ bgpq_expand(struct bgpq_expander* b)
strerror(errno));
exit(1);
};
if (setsockopt(fd, SOL_SOCKET, SO_LINGER, &sl, sizeof(struct linger))) {
sx_report(SX_ERROR,"Unable to set linger on socket: %s\n",
strerror(errno));
shutdown(fd, SHUT_RDWR);
close(fd);
exit(1);
};
err=connect(fd,rp->ai_addr,rp->ai_addrlen);
if(err) {
shutdown(fd,SHUT_RDWR);
@@ -906,6 +916,11 @@ bgpq_expand(struct bgpq_expander* b)
};
write(fd, "!q\n",3);
if (pipelining) {
int fl = fcntl(fd, F_GETFL);
fl &= ~O_NONBLOCK;
fcntl(fd, F_SETFL, fl);
};
shutdown(fd, SHUT_RDWR);
close(fd);
return 1;