Method accept

lib_acl_cpp/src/stream/server_socket.cpp:159–204

}

socket_stream* server_socket::accept(int timeout /* = 0 */,
	bool* etimed /* = NULL */)
{
	if (etimed) {
		*etimed = false;
	}

	if (fd_ == ACL_SOCKET_INVALID) {
		logger_error("server socket not opened!");
		return NULL;
	}

	// if ((open_flag_ & ACL_NON_BLOCKING) && timeout > 0)
	if (timeout > 0) {
		if (acl_read_wait(fd_, timeout) == -1) {
			if (etimed) {
				*etimed = true;
			}
			return NULL;
		}
	}

	ACL_SOCKET fd = acl_accept(fd_, NULL, 0, NULL);
	if (fd == ACL_SOCKET_INVALID) {
		if (open_flag_ & ACL_NON_BLOCKING) {
			logger_error("accept error %s", last_serror());
		} else if (last_error() != ACL_EAGAIN
			&& last_error() != ACL_EWOULDBLOCK) {

			logger_error("accept error %s", last_serror());
		}
		return NULL;
	}

	socket_stream* client = NEW socket_stream();
	if (client->open(fd) == false) {
		logger_error("create socket_stream error!");
		return NULL;
	}

	if (!unix_sock_) {
		acl_tcp_set_nodelay(fd);
	}

	return client;
}

void server_socket::set_tcp_defer_accept(int timeout)
{