98 static bool j1939_sk_queue_session(struct j1939_session *session)  in j1939_sk_queue_session()  argument
100 	struct j1939_sock *jsk = j1939_sk(session->sk);  in j1939_sk_queue_session()
105 	j1939_session_get(session);  in j1939_sk_queue_session()
106 	list_add_tail(&session->sk_session_queue_entry, &jsk->sk_session_queue);  in j1939_sk_queue_session()
116 	struct j1939_session *session = NULL;  in j1939_sk_get_incomplete_session()  local
120 		session = list_last_entry(&jsk->sk_session_queue,  in j1939_sk_get_incomplete_session()
123 		if (session->total_queued_size == session->total_message_size)  in j1939_sk_get_incomplete_session()
124 			session = NULL;  in j1939_sk_get_incomplete_session()
126 			j1939_session_get(session);  in j1939_sk_get_incomplete_session()
130 	return session;  in j1939_sk_get_incomplete_session()
136 	struct j1939_session *session, *tmp;  in j1939_sk_queue_drop_all()  local
140 	list_for_each_entry_safe(session, tmp, &jsk->sk_session_queue,  in j1939_sk_queue_drop_all()
142 		list_del_init(&session->sk_session_queue_entry);  in j1939_sk_queue_drop_all()
143 		session->err = err;  in j1939_sk_queue_drop_all()
144 		j1939_session_put(session);  in j1939_sk_queue_drop_all()
149 static void j1939_sk_queue_activate_next_locked(struct j1939_session *session)  in j1939_sk_queue_activate_next_locked()  argument
156 	if (!session->sk)  in j1939_sk_queue_activate_next_locked()
159 	jsk = j1939_sk(session->sk);  in j1939_sk_queue_activate_next_locked()
162 	err = session->err;  in j1939_sk_queue_activate_next_locked()
169 	if (first != session)  in j1939_sk_queue_activate_next_locked()
195 void j1939_sk_queue_activate_next(struct j1939_session *session)  in j1939_sk_queue_activate_next()  argument
199 	if (!session->sk)  in j1939_sk_queue_activate_next()
202 	jsk = j1939_sk(session->sk);  in j1939_sk_queue_activate_next()
205 	j1939_sk_queue_activate_next_locked(session);  in j1939_sk_queue_activate_next()
916 j1939_sk_get_timestamping_opt_stats(struct j1939_session *session)  in j1939_sk_get_timestamping_opt_stats()  argument
925 	if (session->skcb.addr.type == J1939_SIMPLE)  in j1939_sk_get_timestamping_opt_stats()
926 		size = session->total_message_size;  in j1939_sk_get_timestamping_opt_stats()
928 		size = min(session->pkt.tx_acked * 7,  in j1939_sk_get_timestamping_opt_stats()
929 			   session->total_message_size);  in j1939_sk_get_timestamping_opt_stats()
936 void j1939_sk_errqueue(struct j1939_session *session,  in j1939_sk_errqueue()  argument
939 	struct j1939_priv *priv = session->priv;  in j1939_sk_errqueue()
940 	struct sock *sk = session->sk;  in j1939_sk_errqueue()
956 	skb = j1939_sk_get_timestamping_opt_stats(session);  in j1939_sk_errqueue()
990 		serr->ee.ee_errno = session->err;  in j1939_sk_errqueue()
1001 		serr->ee.ee_data = session->tskey;  in j1939_sk_errqueue()
1003 	netdev_dbg(session->priv->ndev, "%s: 0x%p tskey: %i, state: %s\n",  in j1939_sk_errqueue()
1004 		   __func__, session, session->tskey, state);  in j1939_sk_errqueue()
1023 	struct j1939_session *session = j1939_sk_get_incomplete_session(jsk);  in j1939_sk_send_loop()  local
1028 	if (session &&  in j1939_sk_send_loop()
1029 	    session->total_message_size != session->total_queued_size + size) {  in j1939_sk_send_loop()
1030 		j1939_session_put(session);  in j1939_sk_send_loop()
1050 		if (!session) {  in j1939_sk_send_loop()
1055 			session = j1939_tp_send(priv, skb, size);  in j1939_sk_send_loop()
1056 			if (IS_ERR(session)) {  in j1939_sk_send_loop()
1057 				ret = PTR_ERR(session);  in j1939_sk_send_loop()
1060 			if (j1939_sk_queue_session(session)) {  in j1939_sk_send_loop()
1064 				if (!j1939_session_activate(session)) {  in j1939_sk_send_loop()
1065 					j1939_tp_schedule_txtimer(session, 0);  in j1939_sk_send_loop()
1068 					session->err = ret;  in j1939_sk_send_loop()
1075 			skcb->offset = session->total_queued_size;  in j1939_sk_send_loop()
1076 			j1939_session_skb_queue(session, skb);  in j1939_sk_send_loop()
1080 		session->total_queued_size += segment_size;  in j1939_sk_send_loop()
1102 	if (session)  in j1939_sk_send_loop()
1103 		j1939_session_put(session);  in j1939_sk_send_loop()