97 static bool j1939_sk_queue_session(struct j1939_session *session)  in j1939_sk_queue_session()  argument
99 	struct j1939_sock *jsk = j1939_sk(session->sk);  in j1939_sk_queue_session()
104 	j1939_session_get(session);  in j1939_sk_queue_session()
105 	list_add_tail(&session->sk_session_queue_entry, &jsk->sk_session_queue);  in j1939_sk_queue_session()
115 	struct j1939_session *session = NULL;  in j1939_sk_get_incomplete_session()  local
119 		session = list_last_entry(&jsk->sk_session_queue,  in j1939_sk_get_incomplete_session()
122 		if (session->total_queued_size == session->total_message_size)  in j1939_sk_get_incomplete_session()
123 			session = NULL;  in j1939_sk_get_incomplete_session()
125 			j1939_session_get(session);  in j1939_sk_get_incomplete_session()
129 	return session;  in j1939_sk_get_incomplete_session()
135 	struct j1939_session *session, *tmp;  in j1939_sk_queue_drop_all()  local
139 	list_for_each_entry_safe(session, tmp, &jsk->sk_session_queue,  in j1939_sk_queue_drop_all()
141 		list_del_init(&session->sk_session_queue_entry);  in j1939_sk_queue_drop_all()
142 		session->err = err;  in j1939_sk_queue_drop_all()
143 		j1939_session_put(session);  in j1939_sk_queue_drop_all()
148 static void j1939_sk_queue_activate_next_locked(struct j1939_session *session)  in j1939_sk_queue_activate_next_locked()  argument
155 	if (!session->sk)  in j1939_sk_queue_activate_next_locked()
158 	jsk = j1939_sk(session->sk);  in j1939_sk_queue_activate_next_locked()
161 	err = session->err;  in j1939_sk_queue_activate_next_locked()
168 	if (first != session)  in j1939_sk_queue_activate_next_locked()
194 void j1939_sk_queue_activate_next(struct j1939_session *session)  in j1939_sk_queue_activate_next()  argument
198 	if (!session->sk)  in j1939_sk_queue_activate_next()
201 	jsk = j1939_sk(session->sk);  in j1939_sk_queue_activate_next()
204 	j1939_sk_queue_activate_next_locked(session);  in j1939_sk_queue_activate_next()
894 j1939_sk_get_timestamping_opt_stats(struct j1939_session *session)  in j1939_sk_get_timestamping_opt_stats()  argument
903 	if (session->skcb.addr.type == J1939_SIMPLE)  in j1939_sk_get_timestamping_opt_stats()
904 		size = session->total_message_size;  in j1939_sk_get_timestamping_opt_stats()
906 		size = min(session->pkt.tx_acked * 7,  in j1939_sk_get_timestamping_opt_stats()
907 			   session->total_message_size);  in j1939_sk_get_timestamping_opt_stats()
914 void j1939_sk_errqueue(struct j1939_session *session,  in j1939_sk_errqueue()  argument
917 	struct j1939_priv *priv = session->priv;  in j1939_sk_errqueue()
918 	struct sock *sk = session->sk;  in j1939_sk_errqueue()
934 	skb = j1939_sk_get_timestamping_opt_stats(session);  in j1939_sk_errqueue()
968 		serr->ee.ee_errno = session->err;  in j1939_sk_errqueue()
979 		serr->ee.ee_data = session->tskey;  in j1939_sk_errqueue()
981 	netdev_dbg(session->priv->ndev, "%s: 0x%p tskey: %i, state: %s\n",  in j1939_sk_errqueue()
982 		   __func__, session, session->tskey, state);  in j1939_sk_errqueue()
1001 	struct j1939_session *session = j1939_sk_get_incomplete_session(jsk);  in j1939_sk_send_loop()  local
1006 	if (session &&  in j1939_sk_send_loop()
1007 	    session->total_message_size != session->total_queued_size + size) {  in j1939_sk_send_loop()
1008 		j1939_session_put(session);  in j1939_sk_send_loop()
1028 		if (!session) {  in j1939_sk_send_loop()
1033 			session = j1939_tp_send(priv, skb, size);  in j1939_sk_send_loop()
1034 			if (IS_ERR(session)) {  in j1939_sk_send_loop()
1035 				ret = PTR_ERR(session);  in j1939_sk_send_loop()
1038 			if (j1939_sk_queue_session(session)) {  in j1939_sk_send_loop()
1042 				if (!j1939_session_activate(session)) {  in j1939_sk_send_loop()
1043 					j1939_tp_schedule_txtimer(session, 0);  in j1939_sk_send_loop()
1046 					session->err = ret;  in j1939_sk_send_loop()
1053 			skcb->offset = session->total_queued_size;  in j1939_sk_send_loop()
1054 			j1939_session_skb_queue(session, skb);  in j1939_sk_send_loop()
1058 		session->total_queued_size += segment_size;  in j1939_sk_send_loop()
1080 	if (session)  in j1939_sk_send_loop()
1081 		j1939_session_put(session);  in j1939_sk_send_loop()