Lines Matching refs:pkt
331 offset_start = session->pkt.tx_acked * 7; in j1939_session_skb_drop_old()
404 offset_start = session->pkt.dpo * 7; in j1939_session_skb_get()
720 dat[3] = session->pkt.total; in j1939_session_tx_rts()
731 session->pkt.tx = 0; in j1939_session_tx_rts()
760 unsigned int pkt; in j1939_session_tx_dpo() local
767 session->pkt.dpo = session->pkt.tx_acked; in j1939_session_tx_dpo()
768 pkt = session->pkt.dpo; in j1939_session_tx_dpo()
769 dat[1] = session->pkt.last - session->pkt.tx_acked; in j1939_session_tx_dpo()
770 dat[2] = (pkt >> 0); in j1939_session_tx_dpo()
771 dat[3] = (pkt >> 8); in j1939_session_tx_dpo()
772 dat[4] = (pkt >> 16); in j1939_session_tx_dpo()
780 session->pkt.tx = session->pkt.tx_acked; in j1939_session_tx_dpo()
798 se_skb = j1939_session_skb_get_by_offset(session, session->pkt.tx * 7); in j1939_session_tx_dat()
808 pkt_end = session->pkt.total; in j1939_session_tx_dat()
810 pkt_end = session->pkt.last; in j1939_session_tx_dat()
812 while (session->pkt.tx < pkt_end) { in j1939_session_tx_dat()
813 dat[0] = session->pkt.tx - session->pkt.dpo + 1; in j1939_session_tx_dat()
814 offset = (session->pkt.tx * 7) - skcb->offset; in j1939_session_tx_dat()
822 __func__, session, skcb->offset, se_skb->len , session->pkt.tx); in j1939_session_tx_dat()
845 session->pkt.tx++; in j1939_session_tx_dat()
849 if (session->pkt.tx < session->pkt.total && pdelay) { in j1939_session_tx_dat()
909 unsigned int pkt, len; in j1939_session_tx_cts() local
916 len = session->pkt.total - session->pkt.rx; in j1939_session_tx_cts()
917 len = min3(len, session->pkt.block, j1939_tp_block ?: 255); in j1939_session_tx_cts()
921 pkt = session->pkt.rx + 1; in j1939_session_tx_cts()
924 dat[2] = (pkt >> 0); in j1939_session_tx_cts()
925 dat[3] = (pkt >> 8); in j1939_session_tx_cts()
926 dat[4] = (pkt >> 16); in j1939_session_tx_cts()
930 dat[2] = session->pkt.rx + 1; in j1939_session_tx_cts()
972 dat[3] = session->pkt.total; in j1939_session_tx_eoma()
1018 if (session->pkt.rx >= session->pkt.total) { in j1939_xtp_txnext_receiver()
1020 } else if (session->pkt.rx >= session->pkt.last) { in j1939_xtp_txnext_receiver()
1376 session->pkt.tx_acked = session->pkt.total; in j1939_xtp_rx_eoma_one()
1402 unsigned int pkt; in j1939_xtp_rx_cts_one() local
1418 pkt = j1939_etp_ctl_to_packet(dat); in j1939_xtp_rx_cts_one()
1420 pkt = dat[2]; in j1939_xtp_rx_cts_one()
1422 if (!pkt) in j1939_xtp_rx_cts_one()
1424 else if (dat[1] > session->pkt.block /* 0xff for etp */) in j1939_xtp_rx_cts_one()
1428 session->pkt.tx_acked = pkt - 1; in j1939_xtp_rx_cts_one()
1430 session->pkt.last = session->pkt.tx_acked + dat[1]; in j1939_xtp_rx_cts_one()
1431 if (session->pkt.last > session->pkt.total) in j1939_xtp_rx_cts_one()
1433 session->pkt.last = session->pkt.total; in j1939_xtp_rx_cts_one()
1435 session->pkt.tx = session->pkt.tx_acked; in j1939_xtp_rx_cts_one()
1441 if (session->pkt.tx_acked) in j1939_xtp_rx_cts_one()
1623 session->pkt.total = (len + 6) / 7; in j1939_xtp_rx_rts_session_new()
1624 session->pkt.block = 0xff; in j1939_xtp_rx_rts_session_new()
1626 if (dat[3] != session->pkt.total) in j1939_xtp_rx_rts_session_new()
1628 __func__, session, session->pkt.total, in j1939_xtp_rx_rts_session_new()
1630 session->pkt.total = dat[3]; in j1939_xtp_rx_rts_session_new()
1631 session->pkt.block = min(dat[3], dat[4]); in j1939_xtp_rx_rts_session_new()
1634 session->pkt.rx = 0; in j1939_xtp_rx_rts_session_new()
1635 session->pkt.tx = 0; in j1939_xtp_rx_rts_session_new()
1756 session->pkt.dpo = j1939_etp_ctl_to_packet(skb->data); in j1939_xtp_rx_dpo_one()
1821 packet = (dat[0] - 1 + session->pkt.dpo); in j1939_xtp_rx_dat_one()
1822 if (packet > session->pkt.total || in j1939_xtp_rx_dat_one()
1823 (session->pkt.rx + 1) > session->pkt.total) { in j1939_xtp_rx_dat_one()
1862 if (packet == session->pkt.rx) in j1939_xtp_rx_dat_one()
1863 session->pkt.rx++; in j1939_xtp_rx_dat_one()
1867 if (session->pkt.rx >= session->pkt.total) in j1939_xtp_rx_dat_one()
1873 if (session->pkt.rx >= session->pkt.last) in j1939_xtp_rx_dat_one()
1989 session->pkt.total = (size + 6) / 7; in j1939_tp_send()
1990 session->pkt.block = skcb->addr.type == J1939_ETP ? 255 : in j1939_tp_send()
1991 min(j1939_tp_block ?: 255, session->pkt.total); in j1939_tp_send()
1995 session->pkt.last = session->pkt.total; in j1939_tp_send()