Function unix_ss_create

unix-stream-server.c:33–89

}

int unix_ss_create(const char *path,
		   const struct unix_stream_listen_opts *opts,
		   long timeout_ms,
		   struct unix_ss_socket **new_server_socket)
{
	struct lock_file lock = LOCK_INIT;
	int fd_socket;
	struct unix_ss_socket *server_socket;

	*new_server_socket = NULL;

	if (timeout_ms < 0)
		timeout_ms = DEFAULT_LOCK_TIMEOUT;

	/*
	 * Create a lock at "<path>.lock" if we can.
	 */
	if (hold_lock_file_for_update_timeout(&lock, path, 0, timeout_ms) < 0)
		return -1;

	/*
	 * If another server is listening on "<path>" give up.  We do not
	 * want to create a socket and steal future connections from them.
	 */
	if (is_another_server_alive(path, opts)) {
		rollback_lock_file(&lock);
		errno = EADDRINUSE;
		return -2;
	}

	/*
	 * Create and bind to a Unix domain socket at "<path>".
	 */
	fd_socket = unix_stream_listen(path, opts);
	if (fd_socket < 0) {
		int saved_errno = errno;
		rollback_lock_file(&lock);
		errno = saved_errno;
		return -1;
	}

	server_socket = xcalloc(1, sizeof(*server_socket));
	server_socket->path_socket = strdup(path);
	server_socket->fd_socket = fd_socket;
	lstat(path, &server_socket->st_socket);

	*new_server_socket = server_socket;

	/*
	 * Always rollback (just delete) "<path>.lock" because we already created
	 * "<path>" as a socket and do not want to commit_lock to do the atomic
	 * rename trick.
	 */
	rollback_lock_file(&lock);

	return 0;
}