net/unix/af_unix.c

127  *    each socket state is protected by separate spinlock.
607 	int state;
612 	/* Clear state */
619 	state = sk->sk_state;
655 		if (state == TCP_LISTEN)
1011 	sock->state = SS_UNCONNECTED;
1405 		 *	1003.1g breaking connected state with AF_UNSPEC
1493 	   If we will make it after state is locked,
1521 	/* Latch state of peer */
1551 	/* Latch our state.
1553 	   It is tricky place. We need to grab our state lock and cannot
1557 	   state. other is TCP_LISTEN, if sk is TCP_LISTEN we
1560 	   Well, and we have to recheck the state after socket locked.
1630 	sock->state	= SS_CONNECTED;
1675 	socka->state  = SS_CONNECTED;
1676 	sockb->state  = SS_CONNECTED;
1707 	/* If socket state is TCP_LISTEN it cannot change (for now...),
1726 	newsock->state = SS_CONNECTED;
2080 			 * is clearing @other. Never change state to TCP_CLOSE
2556 	unsigned int state = TASK_INTERRUPTIBLE | freezable * TASK_FREEZABLE;
2563 		prepare_to_wait(sk_sleep(sk), &wait, state);
2607 static int unix_stream_recv_urg(struct unix_stream_read_state *state)
2609 	struct socket *sock = state->socket;
2626 	if (!(state->flags & MSG_PEEK))
2632 	chunk = state->recv_actor(oob_skb, 0, chunk, state);
2634 	if (!(state->flags & MSG_PEEK))
2644 	state->msg->msg_flags |= MSG_OOB;
2689 static int unix_stream_read_generic(struct unix_stream_read_state *state,
2693 	struct socket *sock = state->socket;
2697 	int flags = state->flags;
2704 	size_t size = state->size;
2715 		err = unix_stream_recv_urg(state);
2818 		if (state->msg && state->msg->msg_name) {
2820 					 state->msg->msg_name);
2821 			unix_copy_addr(state->msg, skb->sk);
2824 							      state->msg->msg_name,
2825 							      &state->msg->msg_namelen);
2832 		chunk = state->recv_actor(skb, skip, chunk, state);
2899 	if (state->msg)
2900 		scm_recv_unix(sock, state->msg, &scm, flags);
2909 				  struct unix_stream_read_state *state)
2914 				    state->msg, chunk);
2921 	struct unix_stream_read_state state = {
2929 	return unix_stream_read_generic(&state, true);
2935 	struct unix_stream_read_state state = {
2950 	return unix_stream_read_generic(&state, true);
2955 				    struct unix_stream_read_state *state)
2957 	return skb_splice_bits(skb, state->socket->sk,
2959 			       state->pipe, chunk, state->splice_flags);
2966 	struct unix_stream_read_state state = {
2979 		state.flags = MSG_DONTWAIT;
2981 	return unix_stream_read_generic(&state, false);