99 static bool j1939_sk_queue_session(struct j1939_session *session)  in j1939_sk_queue_session()  argument
101 	struct j1939_sock *jsk = j1939_sk(session->sk);  in j1939_sk_queue_session()
106 	j1939_session_get(session);  in j1939_sk_queue_session()
107 	list_add_tail(&session->sk_session_queue_entry, &jsk->sk_session_queue);  in j1939_sk_queue_session()
117 	struct j1939_session *session = NULL;  in j1939_sk_get_incomplete_session()  local
121 		session = list_last_entry(&jsk->sk_session_queue,  in j1939_sk_get_incomplete_session()
124 		if (session->total_queued_size == session->total_message_size)  in j1939_sk_get_incomplete_session()
125 			session = NULL;  in j1939_sk_get_incomplete_session()
127 			j1939_session_get(session);  in j1939_sk_get_incomplete_session()
131 	return session;  in j1939_sk_get_incomplete_session()
137 	struct j1939_session *session, *tmp;  in j1939_sk_queue_drop_all()  local
141 	list_for_each_entry_safe(session, tmp, &jsk->sk_session_queue,  in j1939_sk_queue_drop_all()
143 		list_del_init(&session->sk_session_queue_entry);  in j1939_sk_queue_drop_all()
144 		session->err = err;  in j1939_sk_queue_drop_all()
145 		j1939_session_put(session);  in j1939_sk_queue_drop_all()
150 static void j1939_sk_queue_activate_next_locked(struct j1939_session *session)  in j1939_sk_queue_activate_next_locked()  argument
157 	if (!session->sk)  in j1939_sk_queue_activate_next_locked()
160 	jsk = j1939_sk(session->sk);  in j1939_sk_queue_activate_next_locked()
163 	err = session->err;  in j1939_sk_queue_activate_next_locked()
170 	if (first != session)  in j1939_sk_queue_activate_next_locked()
199 void j1939_sk_queue_activate_next(struct j1939_session *session)  in j1939_sk_queue_activate_next()  argument
203 	if (!session->sk)  in j1939_sk_queue_activate_next()
206 	jsk = j1939_sk(session->sk);  in j1939_sk_queue_activate_next()
209 	j1939_sk_queue_activate_next_locked(session);  in j1939_sk_queue_activate_next()
962 j1939_sk_get_timestamping_opt_stats(struct j1939_session *session,  in j1939_sk_get_timestamping_opt_stats()  argument
972 	if (session->skcb.addr.type == J1939_SIMPLE)  in j1939_sk_get_timestamping_opt_stats()
973 		size = session->total_message_size;  in j1939_sk_get_timestamping_opt_stats()
975 		size = min(session->pkt.tx_acked * 7,  in j1939_sk_get_timestamping_opt_stats()
976 			   session->total_message_size);  in j1939_sk_get_timestamping_opt_stats()
981 			    session->total_message_size);  in j1939_sk_get_timestamping_opt_stats()
983 			    session->skcb.addr.pgn);  in j1939_sk_get_timestamping_opt_stats()
985 				  session->skcb.addr.src_name, J1939_NLA_PAD);  in j1939_sk_get_timestamping_opt_stats()
987 				  session->skcb.addr.dst_name, J1939_NLA_PAD);  in j1939_sk_get_timestamping_opt_stats()
989 			   session->skcb.addr.sa);  in j1939_sk_get_timestamping_opt_stats()
991 			   session->skcb.addr.da);  in j1939_sk_get_timestamping_opt_stats()
1000 static void __j1939_sk_errqueue(struct j1939_session *session, struct sock *sk,  in __j1939_sk_errqueue()  argument
1003 	struct j1939_priv *priv = session->priv;  in __j1939_sk_errqueue()
1040 	skb = j1939_sk_get_timestamping_opt_stats(session, type);  in __j1939_sk_errqueue()
1064 		serr->ee.ee_errno = session->err;  in __j1939_sk_errqueue()
1082 		serr->ee.ee_errno = session->err;  in __j1939_sk_errqueue()
1091 		serr->ee.ee_data = session->tskey;  in __j1939_sk_errqueue()
1093 	netdev_dbg(session->priv->ndev, "%s: 0x%p tskey: %i, state: %s\n",  in __j1939_sk_errqueue()
1094 		   __func__, session, session->tskey, state);  in __j1939_sk_errqueue()
1101 void j1939_sk_errqueue(struct j1939_session *session,  in j1939_sk_errqueue()  argument
1104 	struct j1939_priv *priv = session->priv;  in j1939_sk_errqueue()
1107 	if (session->sk) {  in j1939_sk_errqueue()
1109 		__j1939_sk_errqueue(session, session->sk, type);  in j1939_sk_errqueue()
1116 		if (j1939_sk_recv_match_one(jsk, &session->skcb))  in j1939_sk_errqueue()
1117 			__j1939_sk_errqueue(session, &jsk->sk, type);  in j1939_sk_errqueue()
1139 	struct j1939_session *session = j1939_sk_get_incomplete_session(jsk);  in j1939_sk_send_loop()  local
1144 	if (session &&  in j1939_sk_send_loop()
1145 	    session->total_message_size != session->total_queued_size + size) {  in j1939_sk_send_loop()
1146 		j1939_session_put(session);  in j1939_sk_send_loop()
1166 		if (!session) {  in j1939_sk_send_loop()
1171 			session = j1939_tp_send(priv, skb, size);  in j1939_sk_send_loop()
1172 			if (IS_ERR(session)) {  in j1939_sk_send_loop()
1173 				ret = PTR_ERR(session);  in j1939_sk_send_loop()
1176 			if (j1939_sk_queue_session(session)) {  in j1939_sk_send_loop()
1180 				if (!j1939_session_activate(session)) {  in j1939_sk_send_loop()
1181 					j1939_tp_schedule_txtimer(session, 0);  in j1939_sk_send_loop()
1184 					session->err = ret;  in j1939_sk_send_loop()
1191 			skcb->offset = session->total_queued_size;  in j1939_sk_send_loop()
1192 			j1939_session_skb_queue(session, skb);  in j1939_sk_send_loop()
1196 		session->total_queued_size += segment_size;  in j1939_sk_send_loop()
1218 	if (session)  in j1939_sk_send_loop()
1219 		j1939_session_put(session);  in j1939_sk_send_loop()