| 136 | } |
| 137 | |
| 138 | int |
| 139 | socket_bind(auto_file& fd, const socket_args& args, std::string& err_r) |
| 140 | { |
| 141 | fd.reset(socket(args.family, args.socktype, args.protocol)); |
| 142 | if (fd.get() < 0) { |
| 143 | return errno_string("socket", errno, err_r); |
| 144 | } |
| 145 | if (args.reuseaddr) { |
| 146 | if (args.family == AF_UNIX) { |
| 147 | const sockaddr_un *const ap = |
| 148 | reinterpret_cast<const sockaddr_un *>(&args.addr); |
| 149 | if (unlink(ap->sun_path) != 0 && errno != ENOENT) { |
| 150 | return errno_string("unlink uds", errno, err_r); |
| 151 | } |
| 152 | } else { |
| 153 | int v = 1; |
| 154 | if (setsockopt(fd.get(), SOL_SOCKET, SO_REUSEADDR, &v, sizeof(v)) != 0) { |
| 155 | return errno_string("setsockopt SO_REUSEADDR", errno, err_r); |
| 156 | } |
| 157 | } |
| 158 | } |
| 159 | if (bind(fd.get(), reinterpret_cast<const sockaddr *>(&args.addr), |
| 160 | args.addrlen) != 0) { |
| 161 | return errno_string("bind", errno, err_r); |
| 162 | } |
| 163 | if (listen(fd.get(), args.listen_backlog) != 0) { |
| 164 | return errno_string("listen", errno, err_r); |
| 165 | } |
| 166 | if (args.nonblocking && fcntl(fd.get(), F_SETFL, O_NONBLOCK) != 0) { |
| 167 | return errno_string("fcntl O_NONBLOCK", errno, err_r); |
| 168 | } |
| 169 | return 0; |
| 170 | } |
| 171 | |
| 172 | int |
| 173 | socket_accept(int listen_fd, auto_file& fd, const socket_args& args, |
no test coverage detected