projects
/
fio.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Remember to close sockets on error
[fio.git]
/
engines
/
net.c
diff --git
a/engines/net.c
b/engines/net.c
index faa08d5f6741b10641c36f12de933f88406846fe..d6821a4092e7898aa0fea956a6069931fde3a8b2 100644
(file)
--- a/
engines/net.c
+++ b/
engines/net.c
@@
-389,6
+389,7
@@
static int fio_netio_connect(struct thread_data *td, struct fio_file *f)
if (connect(f->fd, (struct sockaddr *) &nd->addr, len) < 0) {
td_verror(td, errno, "connect");
if (connect(f->fd, (struct sockaddr *) &nd->addr, len) < 0) {
td_verror(td, errno, "connect");
+ close(f->fd);
return 1;
}
} else {
return 1;
}
} else {
@@
-399,6
+400,7
@@
static int fio_netio_connect(struct thread_data *td, struct fio_file *f)
if (connect(f->fd, (struct sockaddr *) addr, len) < 0) {
td_verror(td, errno, "connect");
if (connect(f->fd, (struct sockaddr *) addr, len) < 0) {
td_verror(td, errno, "connect");
+ close(f->fd);
return 1;
}
}
return 1;
}
}
@@
-543,6
+545,7
@@
static int fio_netio_setup_listen_unix(struct thread_data *td, const char *path)
if (bind(fd, (struct sockaddr *) addr, len) < 0) {
log_err("fio: bind: %s\n", strerror(errno));
if (bind(fd, (struct sockaddr *) addr, len) < 0) {
log_err("fio: bind: %s\n", strerror(errno));
+ close(fd);
return -1;
}
return -1;
}