Lines Matching refs:msg
645 struct sscop_msg *msg; in sscop_aasig() local
657 MSG_ALLOC(msg); in sscop_aasig()
658 if (msg == NULL) { in sscop_aasig()
667 msg->m = m; in sscop_aasig()
668 msg->rexmit = arg; in sscop_aasig()
669 sscop_signal(sscop, SIG_ESTAB_REQ, msg); in sscop_aasig()
673 msg->m = m; in sscop_aasig()
674 msg->rexmit = arg; in sscop_aasig()
675 sscop_signal(sscop, SIG_ESTAB_RESP, msg); in sscop_aasig()
679 msg->m = m; in sscop_aasig()
680 sscop_signal(sscop, SIG_RELEASE_REQ, msg); in sscop_aasig()
684 msg->m = m; in sscop_aasig()
685 sscop_signal(sscop, SIG_USER_DATA, msg); in sscop_aasig()
689 msg->m = m; in sscop_aasig()
690 sscop_signal(sscop, SIG_UDATA, msg); in sscop_aasig()
695 MSG_FREE(msg); in sscop_aasig()
700 msg->m = m; in sscop_aasig()
701 sscop_signal(sscop, SIG_SYNC_REQ, msg); in sscop_aasig()
706 MSG_FREE(msg); in sscop_aasig()
712 msg->rexmit = arg; in sscop_aasig()
713 sscop_signal(sscop, SIG_RETRIEVE, msg); in sscop_aasig()
728 MSG_FREE(msg); in sscop_aasig()
741 struct sscop_msg *msg; in sscop_maasig() local
753 MSG_ALLOC(msg); in sscop_maasig()
754 if (msg == NULL) { in sscop_maasig()
763 msg->m = m; in sscop_maasig()
764 sscop_signal(sscop, SIG_MDATA, msg); in sscop_maasig()
770 MSG_FREE(msg); in sscop_maasig()
782 struct sscop_msg *msg; in sscop_input() local
786 MSG_ALLOC(msg); in sscop_input()
787 if(msg == NULL) { in sscop_input()
793 msg->m = m; in sscop_input()
794 msg->rexmit = 0; in sscop_input()
831 sscop_signal(sscop, SIG_BGN, msg); in sscop_input()
841 sscop_signal(sscop, SIG_BGAK, msg); in sscop_input()
851 sscop_signal(sscop, SIG_END, msg); in sscop_input()
857 sscop_signal(sscop, SIG_ENDAK, msg); in sscop_input()
867 sscop_signal(sscop, SIG_BGREJ, msg); in sscop_input()
875 sscop_signal(sscop, SIG_SD, msg); in sscop_input()
883 sscop_signal(sscop, SIG_UD, msg); in sscop_input()
891 sscop_signal(sscop, SIG_MD, msg); in sscop_input()
897 sscop_signal(sscop, SIG_POLL, msg); in sscop_input()
905 sscop_signal(sscop, SIG_STAT, msg); in sscop_input()
915 sscop_signal(sscop, SIG_RS, msg); in sscop_input()
921 sscop_signal(sscop, SIG_RSAK, msg); in sscop_input()
927 sscop_signal(sscop, SIG_ER, msg); in sscop_input()
933 sscop_signal(sscop, SIG_ERAK, msg); in sscop_input()
939 sscop_signal(sscop, SIG_USTAT, msg); in sscop_input()
947 SSCOP_MSG_FREE(msg); in sscop_input()
1047 struct sscop_msg *msg; in m_prepare_retrieval() local
1053 MSGQ_FOREACH(msg, &sscop->xbuf) in m_prepare_retrieval()
1054 msg->rexmit = 0; in m_prepare_retrieval()
1066 struct sscop_msg *msg; in m_prepare_recovery() local
1072 MSGQ_FOREACH(msg, &sscop->xbuf) in m_prepare_recovery()
1073 msg->rexmit = 0; in m_prepare_recovery()
1098 struct sscop_msg *msg; in m_deliver_data() local
1101 if ((msg = MSGQ_GET(&sscop->rbuf)) == NULL) in m_deliver_data()
1109 sn = msg->seqno + 1; in m_deliver_data()
1110 AAL_DATA(sscop, SSCOP_DATA_indication, msg->m, msg->seqno); in m_deliver_data()
1111 MSG_FREE(msg); in m_deliver_data()
1113 while ((msg = MSGQ_GET(&sscop->rbuf)) != NULL) { in m_deliver_data()
1114 ASSERT(msg->seqno == sn); in m_deliver_data()
1117 AAL_DATA(sscop, SSCOP_DATA_indication, msg->m, msg->seqno); in m_deliver_data()
1118 MSG_FREE(msg); in m_deliver_data()
1176 m_detect_retransmission(struct sscop *sscop, struct sscop_msg *msg) in m_detect_retransmission() argument
1180 bgn.sscop_null = MBUF_TRAIL32(msg->m, -1); in m_detect_retransmission()
1720 sscop_idle_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_bgn() argument
1725 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_idle_bgn()
1728 bgn.sscop_null = MBUF_STRIP32(msg->m); in sscop_idle_bgn()
1731 if(m_detect_retransmission(sscop, msg)) { in sscop_idle_bgn()
1733 SSCOP_MSG_FREE(msg); in sscop_idle_bgn()
1736 (void)MBUF_STRIP32(msg->m); in sscop_idle_bgn()
1742 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_indication, msg, pdu.sscop_pl, 0); in sscop_idle_bgn()
1777 sscop_ignore_pdu(struct sscop *sscop __unused, struct sscop_msg *msg) in sscop_ignore_pdu() argument
1779 SSCOP_MSG_FREE(msg); in sscop_ignore_pdu()
1787 sscop_idle_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_end() argument
1789 SSCOP_MSG_FREE(msg); in sscop_idle_end()
1798 sscop_idle_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_er() argument
1800 SSCOP_MSG_FREE(msg); in sscop_idle_er()
1811 sscop_idle_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_bgrej() argument
1813 SSCOP_MSG_FREE(msg); in sscop_idle_bgrej()
1823 sscop_idle_poll(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_poll() argument
1825 SSCOP_MSG_FREE(msg); in sscop_idle_poll()
1836 sscop_idle_sd(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_sd() argument
1838 SSCOP_MSG_FREE(msg); in sscop_idle_sd()
1849 sscop_idle_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_bgak() argument
1851 SSCOP_MSG_FREE(msg); in sscop_idle_bgak()
1862 sscop_idle_erak(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_erak() argument
1864 SSCOP_MSG_FREE(msg); in sscop_idle_erak()
1875 sscop_idle_stat(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_stat() argument
1877 SSCOP_MSG_FREE(msg); in sscop_idle_stat()
1888 sscop_idle_ustat(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_ustat() argument
1890 SSCOP_MSG_FREE(msg); in sscop_idle_ustat()
1901 sscop_idle_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_rs() argument
1903 SSCOP_MSG_FREE(msg); in sscop_idle_rs()
1914 sscop_idle_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_idle_rsak() argument
1916 SSCOP_MSG_FREE(msg); in sscop_idle_rsak()
1943 sscop_outpend_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outpend_bgak() argument
1947 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outpend_bgak()
1948 (void)MBUF_STRIP32(msg->m); in sscop_outpend_bgak()
1953 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_confirm, msg, pdu.sscop_pl, 0); in sscop_outpend_bgak()
1965 sscop_outpend_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_outpend_bgrej() argument
1969 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outpend_bgrej()
1970 (void)MBUF_STRIP32(msg->m); in sscop_outpend_bgrej()
1974 AAL_UU_SIGNAL(sscop, SSCOP_RELEASE_indication, msg, pdu.sscop_pl, 0); in sscop_outpend_bgrej()
2023 sscop_outpend_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_outpend_bgn() argument
2027 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outpend_bgn()
2029 if(m_detect_retransmission(sscop, msg)) { in sscop_outpend_bgn()
2030 SSCOP_MSG_FREE(msg); in sscop_outpend_bgn()
2033 (void)MBUF_STRIP32(msg->m); in sscop_outpend_bgn()
2043 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_confirm, msg, pdu.sscop_pl, 0); in sscop_outpend_bgn()
2092 sscop_inpend_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_bgn() argument
2096 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_inpend_bgn()
2098 if(m_detect_retransmission(sscop, msg)) { in sscop_inpend_bgn()
2099 SSCOP_MSG_FREE(msg); in sscop_inpend_bgn()
2102 (void)MBUF_STRIP32(msg->m); in sscop_inpend_bgn()
2107 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_indication, msg, pdu.sscop_pl, 0); in sscop_inpend_bgn()
2115 sscop_inpend_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_er() argument
2118 SSCOP_MSG_FREE(msg); in sscop_inpend_er()
2126 sscop_inpend_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_endak() argument
2134 SSCOP_MSG_FREE(msg); in sscop_inpend_endak()
2142 sscop_inpend_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_bgak() argument
2146 SSCOP_MSG_FREE(msg); in sscop_inpend_bgak()
2154 sscop_inpend_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_bgrej() argument
2160 SSCOP_MSG_FREE(msg); in sscop_inpend_bgrej()
2170 sscop_inpend_sd(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_sd() argument
2174 SSCOP_MSG_FREE(msg); in sscop_inpend_sd()
2189 sscop_inpend_ustat(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_ustat() argument
2193 SSCOP_MSG_FREE(msg); in sscop_inpend_ustat()
2208 sscop_inpend_stat(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_stat() argument
2212 SSCOP_MSG_FREE(msg); in sscop_inpend_stat()
2227 sscop_inpend_poll(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_poll() argument
2231 SSCOP_MSG_FREE(msg); in sscop_inpend_poll()
2246 sscop_inpend_erak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_erak() argument
2248 SSCOP_MSG_FREE(msg); in sscop_inpend_erak()
2257 sscop_inpend_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_rs() argument
2259 SSCOP_MSG_FREE(msg); in sscop_inpend_rs()
2268 sscop_inpend_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_rsak() argument
2270 SSCOP_MSG_FREE(msg); in sscop_inpend_rsak()
2280 sscop_inpend_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_inpend_end() argument
2284 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_inpend_end()
2285 (void)MBUF_STRIP32(msg->m); in sscop_inpend_end()
2290 msg, pdu.sscop_pl, (u_int)pdu.sscop_s); in sscop_inpend_end()
2322 sscop_outdis_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_outdis_end() argument
2326 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outdis_end()
2327 (void)MBUF_STRIP32(msg->m); in sscop_outdis_end()
2332 AAL_UU_SIGNAL(sscop, SSCOP_RELEASE_confirm, msg, pdu.sscop_pl, 0); in sscop_outdis_end()
2343 sscop_outdis_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outdis_endak() argument
2347 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outdis_endak()
2348 (void)MBUF_STRIP32(msg->m); in sscop_outdis_endak()
2352 AAL_UU_SIGNAL(sscop, SSCOP_RELEASE_confirm, msg, pdu.sscop_pl, 0); in sscop_outdis_endak()
2380 sscop_outdis_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_outdis_bgn() argument
2384 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outdis_bgn()
2386 if(m_detect_retransmission(sscop, msg)) { in sscop_outdis_bgn()
2390 SSCOP_MSG_FREE(msg); in sscop_outdis_bgn()
2393 (void)MBUF_STRIP32(msg->m); in sscop_outdis_bgn()
2399 msg, pdu.sscop_pl, 0); in sscop_outdis_bgn()
2409 sscop_outsync_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_outsync_bgn() argument
2413 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outsync_bgn()
2415 if(m_detect_retransmission(sscop, msg)) { in sscop_outsync_bgn()
2418 SSCOP_MSG_FREE(msg); in sscop_outsync_bgn()
2420 (void)MBUF_STRIP32(msg->m); in sscop_outsync_bgn()
2426 msg, pdu.sscop_pl, 0); in sscop_outsync_bgn()
2436 sscop_outsync_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outsync_endak() argument
2438 SSCOP_MSG_FREE(msg); in sscop_outsync_endak()
2450 sscop_outsync_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_outsync_bgrej() argument
2452 SSCOP_MSG_FREE(msg); in sscop_outsync_bgrej()
2465 sscop_outsync_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_outsync_end() argument
2469 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outsync_end()
2470 (void)MBUF_STRIP32(msg->m); in sscop_outsync_end()
2474 AAL_UU_SIGNAL(sscop, SSCOP_RELEASE_indication, msg, pdu.sscop_pl, in sscop_outsync_end()
2483 sscop_outsync_cc(struct sscop *sscop, struct sscop_msg *msg __unused) in sscop_outsync_cc()
2519 sscop_outsync_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_outsync_rs() argument
2523 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outsync_rs()
2525 if(m_detect_retransmission(sscop, msg)) { in sscop_outsync_rs()
2526 SSCOP_MSG_FREE(msg); in sscop_outsync_rs()
2529 (void)MBUF_STRIP32(msg->m); in sscop_outsync_rs()
2535 AAL_UU_SIGNAL(sscop, SSCOP_RESYNC_confirm, msg, pdu.sscop_pl, 0); in sscop_outsync_rs()
2546 sscop_outsync_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outsync_rsak() argument
2550 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outsync_rsak()
2552 SSCOP_MSG_FREE(msg); in sscop_outsync_rsak()
2596 sscop_insync_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_endak() argument
2598 SSCOP_MSG_FREE(msg); in sscop_insync_endak()
2609 sscop_insync_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_bgrej() argument
2611 SSCOP_MSG_FREE(msg); in sscop_insync_bgrej()
2622 sscop_insync_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_end() argument
2626 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_insync_end()
2627 (void)MBUF_STRIP32(msg->m); in sscop_insync_end()
2631 msg, pdu.sscop_pl, (u_int)pdu.sscop_s); in sscop_insync_end()
2640 sscop_insync_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_er() argument
2642 SSCOP_MSG_FREE(msg); in sscop_insync_er()
2651 sscop_insync_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_bgn() argument
2655 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_insync_bgn()
2657 if(m_detect_retransmission(sscop, msg)) { in sscop_insync_bgn()
2659 SSCOP_MSG_FREE(msg); in sscop_insync_bgn()
2662 (void)MBUF_STRIP32(msg->m); in sscop_insync_bgn()
2666 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_indication, msg, pdu.sscop_pl, 0); in sscop_insync_bgn()
2676 sscop_insync_sd(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_sd() argument
2678 SSCOP_MSG_FREE(msg); in sscop_insync_sd()
2691 sscop_insync_poll(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_poll() argument
2693 SSCOP_MSG_FREE(msg); in sscop_insync_poll()
2706 sscop_insync_stat(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_stat() argument
2708 SSCOP_MSG_FREE(msg); in sscop_insync_stat()
2721 sscop_insync_ustat(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_ustat() argument
2723 SSCOP_MSG_FREE(msg); in sscop_insync_ustat()
2736 sscop_insync_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_bgak() argument
2739 SSCOP_MSG_FREE(msg); in sscop_insync_bgak()
2747 sscop_insync_erak(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_erak() argument
2750 SSCOP_MSG_FREE(msg); in sscop_insync_erak()
2758 sscop_insync_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_rs() argument
2762 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_insync_rs()
2764 if(m_detect_retransmission(sscop, msg)) { in sscop_insync_rs()
2765 SSCOP_MSG_FREE(msg); in sscop_insync_rs()
2768 SSCOP_MSG_FREE(msg); in sscop_insync_rs()
2777 sscop_insync_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_insync_rsak() argument
2780 SSCOP_MSG_FREE(msg); in sscop_insync_rsak()
2789 sscop_outrec_userdata(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_userdata() argument
2792 MSGQ_APPEND(&sscop->xq, msg); in sscop_outrec_userdata()
2793 sscop_signal(sscop, SIG_PDU_Q, msg); in sscop_outrec_userdata()
2795 SSCOP_MSG_FREE(msg); in sscop_outrec_userdata()
2804 sscop_outrec_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_bgak() argument
2808 SSCOP_MSG_FREE(msg); in sscop_outrec_bgak()
2816 sscop_outrec_erak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_erak() argument
2820 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outrec_erak()
2830 SSCOP_MSG_FREE(msg); in sscop_outrec_erak()
2838 sscop_outrec_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_end() argument
2842 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outrec_end()
2843 (void)MBUF_STRIP32(msg->m); in sscop_outrec_end()
2848 msg, pdu.sscop_pl, (u_int)pdu.sscop_s); in sscop_outrec_end()
2860 sscop_outrec_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_endak() argument
2869 SSCOP_MSG_FREE(msg); in sscop_outrec_endak()
2877 sscop_outrec_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_bgrej() argument
2886 SSCOP_MSG_FREE(msg); in sscop_outrec_bgrej()
2953 sscop_outrec_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_bgn() argument
2957 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outrec_bgn()
2959 if(m_detect_retransmission(sscop, msg)) { in sscop_outrec_bgn()
2961 SSCOP_MSG_FREE(msg); in sscop_outrec_bgn()
2963 (void)MBUF_STRIP32(msg->m); in sscop_outrec_bgn()
2969 msg, pdu.sscop_pl, 0); in sscop_outrec_bgn()
2981 sscop_outrec_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_er() argument
2985 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outrec_er()
2987 if(m_detect_retransmission(sscop, msg)) { in sscop_outrec_er()
3001 SSCOP_MSG_FREE(msg); in sscop_outrec_er()
3009 sscop_outrec_pduq(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_pduq() argument
3011 sscop_save_signal(sscop, SIG_PDU_Q, msg); in sscop_outrec_pduq()
3019 sscop_outrec_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_rsak() argument
3021 SSCOP_MSG_FREE(msg); in sscop_outrec_rsak()
3030 sscop_outrec_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_outrec_rs() argument
3034 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_outrec_rs()
3036 if(m_detect_retransmission(sscop, msg)) { in sscop_outrec_rs()
3037 SSCOP_MSG_FREE(msg); in sscop_outrec_rs()
3041 (void)MBUF_STRIP32(msg->m); in sscop_outrec_rs()
3045 AAL_UU_SIGNAL(sscop, SSCOP_RESYNC_indication, msg, pdu.sscop_pl, 0); in sscop_outrec_rs()
3055 sscop_rec_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_bgak() argument
3059 SSCOP_MSG_FREE(msg); in sscop_rec_bgak()
3068 sscop_rec_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_end() argument
3072 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_rec_end()
3073 (void)MBUF_STRIP32(msg->m); in sscop_rec_end()
3077 msg, pdu.sscop_pl, (u_int)pdu.sscop_s); in sscop_rec_end()
3087 sscop_rec_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_endak() argument
3092 SSCOP_MSG_FREE(msg); in sscop_rec_endak()
3100 sscop_rec_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_bgrej() argument
3105 SSCOP_MSG_FREE(msg); in sscop_rec_bgrej()
3129 sscop_rec_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_rsak() argument
3132 SSCOP_MSG_FREE(msg); in sscop_rec_rsak()
3141 sscop_rec_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_rs() argument
3145 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_rec_rs()
3147 if(m_detect_retransmission(sscop, msg)) { in sscop_rec_rs()
3148 SSCOP_MSG_FREE(msg); in sscop_rec_rs()
3152 (void)MBUF_STRIP32(msg->m); in sscop_rec_rs()
3155 AAL_UU_SIGNAL(sscop, SSCOP_RESYNC_indication, msg, pdu.sscop_pl, 0); in sscop_rec_rs()
3200 sscop_rec_pduq(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_pduq() argument
3202 sscop_save_signal(sscop, SIG_PDU_Q, msg); in sscop_rec_pduq()
3210 sscop_rec_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_er() argument
3214 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_rec_er()
3216 if(m_detect_retransmission(sscop, msg)) { in sscop_rec_er()
3221 SSCOP_MSG_FREE(msg); in sscop_rec_er()
3230 sscop_rec_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_bgn() argument
3234 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_rec_bgn()
3236 if(m_detect_retransmission(sscop, msg)) { in sscop_rec_bgn()
3238 SSCOP_MSG_FREE(msg); in sscop_rec_bgn()
3241 (void)MBUF_STRIP32(msg->m); in sscop_rec_bgn()
3245 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_indication, msg, pdu.sscop_pl, 0); in sscop_rec_bgn()
3255 sscop_rec_stat(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_stat() argument
3262 SSCOP_MSG_FREE(msg); in sscop_rec_stat()
3270 sscop_rec_ustat(struct sscop *sscop, struct sscop_msg *msg) in sscop_rec_ustat() argument
3277 SSCOP_MSG_FREE(msg); in sscop_rec_ustat()
3303 sscop_inrec_pduq(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_pduq() argument
3305 sscop_save_signal(sscop, SIG_PDU_Q, msg); in sscop_inrec_pduq()
3330 sscop_inrec_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_end() argument
3334 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_inrec_end()
3335 (void)MBUF_STRIP32(msg->m); in sscop_inrec_end()
3339 msg, pdu.sscop_pl, (u_int)pdu.sscop_s); in sscop_inrec_end()
3368 sscop_inrec_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_endak() argument
3372 SSCOP_MSG_FREE(msg); in sscop_inrec_endak()
3381 sscop_inrec_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_bgrej() argument
3385 SSCOP_MSG_FREE(msg); in sscop_inrec_bgrej()
3394 sscop_inrec_ustat(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_ustat() argument
3400 SSCOP_MSG_FREE(msg); in sscop_inrec_ustat()
3409 sscop_inrec_stat(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_stat() argument
3415 SSCOP_MSG_FREE(msg); in sscop_inrec_stat()
3424 sscop_inrec_poll(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_poll() argument
3430 SSCOP_MSG_FREE(msg); in sscop_inrec_poll()
3439 sscop_inrec_sd(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_sd() argument
3445 SSCOP_MSG_FREE(msg); in sscop_inrec_sd()
3454 sscop_inrec_rsak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_rsak() argument
3456 SSCOP_MSG_FREE(msg); in sscop_inrec_rsak()
3465 sscop_inrec_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_rs() argument
3469 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_inrec_rs()
3471 if(m_detect_retransmission(sscop, msg)) { in sscop_inrec_rs()
3472 SSCOP_MSG_FREE(msg); in sscop_inrec_rs()
3476 (void)MBUF_STRIP32(msg->m); in sscop_inrec_rs()
3479 AAL_UU_SIGNAL(sscop, SSCOP_RESYNC_indication, msg, pdu.sscop_pl, 0); in sscop_inrec_rs()
3489 sscop_inrec_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_er() argument
3493 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_inrec_er()
3495 if(!m_detect_retransmission(sscop, msg)) { in sscop_inrec_er()
3499 SSCOP_MSG_FREE(msg); in sscop_inrec_er()
3508 sscop_inrec_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_bgn() argument
3512 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_inrec_bgn()
3514 if(m_detect_retransmission(sscop, msg)) { in sscop_inrec_bgn()
3516 SSCOP_MSG_FREE(msg); in sscop_inrec_bgn()
3519 (void)MBUF_STRIP32(msg->m); in sscop_inrec_bgn()
3523 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_indication, msg, pdu.sscop_pl, 0); in sscop_inrec_bgn()
3534 sscop_inrec_bgak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_bgak() argument
3537 SSCOP_MSG_FREE(msg); in sscop_inrec_bgak()
3546 sscop_inrec_erak(struct sscop *sscop, struct sscop_msg *msg) in sscop_inrec_erak() argument
3549 SSCOP_MSG_FREE(msg); in sscop_inrec_erak()
3596 sscop_ready_er(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_er() argument
3600 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_er()
3602 if(m_detect_retransmission(sscop, msg)) { in sscop_ready_er()
3616 SSCOP_MSG_FREE(msg); in sscop_ready_er()
3624 sscop_ready_bgn(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_bgn() argument
3628 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_bgn()
3630 if(m_detect_retransmission(sscop, msg)) { in sscop_ready_bgn()
3633 SSCOP_MSG_FREE(msg); in sscop_ready_bgn()
3636 (void)MBUF_STRIP32(msg->m); in sscop_ready_bgn()
3642 AAL_UU_SIGNAL(sscop, SSCOP_ESTABLISH_indication, msg, pdu.sscop_pl, 0); in sscop_ready_bgn()
3654 sscop_ready_endak(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_endak() argument
3660 SSCOP_MSG_FREE(msg); in sscop_ready_endak()
3669 sscop_ready_bgrej(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_bgrej() argument
3675 SSCOP_MSG_FREE(msg); in sscop_ready_bgrej()
3684 sscop_ready_rs(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_rs() argument
3688 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_rs()
3690 if(m_detect_retransmission(sscop, msg)) { in sscop_ready_rs()
3691 SSCOP_MSG_FREE(msg); in sscop_ready_rs()
3696 (void)MBUF_STRIP32(msg->m); in sscop_ready_rs()
3700 AAL_UU_SIGNAL(sscop, SSCOP_RESYNC_indication, msg, pdu.sscop_pl, 0); in sscop_ready_rs()
3711 sscop_ready_end(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_end() argument
3715 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_end()
3716 (void)MBUF_STRIP32(msg->m); in sscop_ready_end()
3721 msg, pdu.sscop_pl, (u_int)pdu.sscop_s); in sscop_ready_end()
3785 sscop_ready_userdata(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_userdata() argument
3787 MSGQ_APPEND(&sscop->xq, msg); in sscop_ready_userdata()
3789 sscop_signal(sscop, SIG_PDU_Q, msg); in sscop_ready_userdata()
3799 struct sscop_msg *msg; in sscop_ready_pduq() local
3802 TAILQ_FOREACH(msg, &sscop->xbuf, link) in sscop_ready_pduq()
3803 if(msg->rexmit) in sscop_ready_pduq()
3805 ASSERT(msg != NULL); in sscop_ready_pduq()
3806 msg->rexmit = 0; in sscop_ready_pduq()
3808 send_sd(sscop, msg->m, msg->seqno); in sscop_ready_pduq()
3809 msg->poll_seqno = sscop->vt_ps; in sscop_ready_pduq()
3826 msg = MSGQ_GET(&sscop->xq); in sscop_ready_pduq()
3827 msg->seqno = sscop->vt_s; in sscop_ready_pduq()
3828 send_sd(sscop, msg->m, msg->seqno); in sscop_ready_pduq()
3829 msg->poll_seqno = sscop->vt_ps; in sscop_ready_pduq()
3831 MSGQ_APPEND(&sscop->xbuf, msg); in sscop_ready_pduq()
3885 sscop_ready_sd(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_sd() argument
3890 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_sd()
3891 msg->seqno = pdu.sscop_ns; in sscop_ready_sd()
3894 MBUF_UNPAD(msg->m, pdu.sscop_pl); in sscop_ready_sd()
3896 if(msg->seqno >= sscop->vr_mr) { in sscop_ready_sd()
3902 SSCOP_MSG_FREE(msg); in sscop_ready_sd()
3906 if(msg->seqno == sscop->vr_r) { in sscop_ready_sd()
3907 if(msg->seqno == sscop->vr_h) { in sscop_ready_sd()
3908 sscop->vr_r = msg->seqno + 1; in sscop_ready_sd()
3909 sscop->vr_h = msg->seqno + 1; in sscop_ready_sd()
3912 msg->m, msg->seqno); in sscop_ready_sd()
3913 msg->m = NULL; in sscop_ready_sd()
3914 SSCOP_MSG_FREE(msg); in sscop_ready_sd()
3920 msg->m, msg->seqno); in sscop_ready_sd()
3921 msg->m = NULL; in sscop_ready_sd()
3922 SSCOP_MSG_FREE(msg); in sscop_ready_sd()
3925 if((msg = MSGQ_PEEK(&sscop->rbuf)) == NULL) in sscop_ready_sd()
3927 sn = msg->seqno; in sscop_ready_sd()
3931 msg = MSGQ_GET(&sscop->rbuf); in sscop_ready_sd()
3939 if(msg->seqno == sscop->vr_h) { in sscop_ready_sd()
3940 QINSERT(&sscop->rbuf, msg); in sscop_ready_sd()
3944 if(sscop->vr_h < msg->seqno) { in sscop_ready_sd()
3945 QINSERT(&sscop->rbuf, msg); in sscop_ready_sd()
3946 send_ustat(sscop, sscop->vr_h, msg->seqno, -1); in sscop_ready_sd()
3947 sscop->vr_h = msg->seqno + 1; in sscop_ready_sd()
3951 if(QFIND(&sscop->rbuf, msg->seqno) == NULL) { in sscop_ready_sd()
3952 QINSERT(&sscop->rbuf, msg); in sscop_ready_sd()
3957 SSCOP_MSG_FREE(msg); in sscop_ready_sd()
3967 sscop_ready_poll(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_poll() argument
3974 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_poll()
3975 seqno.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_poll()
3978 SSCOP_MSG_FREE(msg); in sscop_ready_poll()
3991 SSCOP_MSG_FREE(msg); in sscop_ready_poll()
4044 sscop_ready_ustat(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_ustat() argument
4050 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_ustat()
4051 nmr.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_ustat()
4052 sq2.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_ustat()
4053 sq1.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_ustat()
4055 SSCOP_MSG_FREE(msg); in sscop_ready_ustat()
4072 while((msg = MSGQ_PEEK(&sscop->xbuf)) != NULL && msg->seqno < (u_int)pdu.sscop_ns) { in sscop_ready_ustat()
4073 ASSERT(msg->seqno >= sscop->vt_a); in sscop_ready_ustat()
4074 MSGQ_REMOVE(&sscop->xbuf, msg); in sscop_ready_ustat()
4075 SSCOP_MSG_FREE(msg); in sscop_ready_ustat()
4104 if((msg = QFIND(&sscop->xbuf, sq1.sscop_n)) == NULL) { in sscop_ready_ustat()
4114 if(!msg->rexmit) { in sscop_ready_ustat()
4115 msg->rexmit = 1; in sscop_ready_ustat()
4117 sscop_signal(sscop, SIG_PDU_Q, msg); in sscop_ready_ustat()
4139 sscop_ready_stat(struct sscop *sscop, struct sscop_msg *msg) in sscop_ready_stat() argument
4146 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_stat()
4147 nmr.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_stat()
4148 nps.sscop_null = MBUF_STRIP32(msg->m); in sscop_ready_stat()
4150 len = MBUF_LEN(msg->m) / 4; in sscop_ready_stat()
4154 SSCOP_MSG_FREE(msg); in sscop_ready_stat()
4173 SSCOP_MSG_FREE(msg); in sscop_ready_stat()
4202 seq1 = MBUF_GET32(msg->m); in sscop_ready_stat()
4212 seq2 = MBUF_GET32(msg->m); in sscop_ready_stat()
4242 sscop_signal(sscop, SIG_PDU_Q, msg); in sscop_ready_stat()
4249 seq2 = MBUF_GET32(msg->m); in sscop_ready_stat()
4277 SSCOP_MSG_FREE(msg); in sscop_ready_stat()
4311 sscop_udata_req(struct sscop *sscop, struct sscop_msg *msg) in sscop_udata_req() argument
4313 MSGQ_APPEND(&sscop->uxq, msg); in sscop_udata_req()
4314 sscop_signal(sscop, SIG_UPDU_Q, msg); in sscop_udata_req()
4322 sscop_mdata_req(struct sscop *sscop, struct sscop_msg *msg) in sscop_mdata_req() argument
4324 MSGQ_APPEND(&sscop->mxq, msg); in sscop_mdata_req()
4325 sscop_signal(sscop, SIG_MPDU_Q, msg); in sscop_mdata_req()
4335 struct sscop_msg *msg; in sscop_upduq() local
4339 while((msg = MSGQ_GET(&sscop->uxq)) != NULL) { in sscop_upduq()
4340 send_ud(sscop, msg->m); in sscop_upduq()
4341 msg->m = NULL; in sscop_upduq()
4342 SSCOP_MSG_FREE(msg); in sscop_upduq()
4353 struct sscop_msg *msg; in sscop_mpduq() local
4357 while((msg = MSGQ_GET(&sscop->mxq)) != NULL) { in sscop_mpduq()
4358 send_md(sscop, msg->m); in sscop_mpduq()
4359 msg->m = NULL; in sscop_mpduq()
4360 SSCOP_MSG_FREE(msg); in sscop_mpduq()
4369 sscop_md(struct sscop *sscop, struct sscop_msg *msg) in sscop_md() argument
4373 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_md()
4375 MBUF_UNPAD(msg->m, pdu.sscop_pl); in sscop_md()
4377 MAAL_DATA(sscop, msg->m); in sscop_md()
4378 msg->m = NULL; in sscop_md()
4379 SSCOP_MSG_FREE(msg); in sscop_md()
4387 sscop_ud(struct sscop *sscop, struct sscop_msg *msg) in sscop_ud() argument
4391 pdu.sscop_null = MBUF_STRIP32(msg->m); in sscop_ud()
4393 MBUF_UNPAD(msg->m, pdu.sscop_pl); in sscop_ud()
4395 AAL_DATA(sscop, SSCOP_UDATA_indication, msg->m, 0); in sscop_ud()
4396 msg->m = NULL; in sscop_ud()
4397 SSCOP_MSG_FREE(msg); in sscop_ud()
4410 sscop_retrieve(struct sscop *sscop, struct sscop_msg *msg) in sscop_retrieve() argument
4412 m_data_retrieval(sscop, msg->rexmit); in sscop_retrieve()
4413 SSCOP_MSG_FREE(msg); in sscop_retrieve()
4794 sig_exec(struct sscop *sscop, u_int sig, struct sscop_msg *msg) in sig_exec() argument
4806 SSCOP_MSG_FREE(msg); in sig_exec()
4813 (*func)(sscop, msg); in sig_exec()
4831 sscop_signal(struct sscop *sscop, u_int sig, struct sscop_msg *msg) in sscop_signal() argument
4842 SSCOP_MSG_FREE(msg); in sscop_signal()
4846 s->msg = msg; in sscop_signal()
4886 if(sig_exec(sscop, s->sig, s->msg)) { in handle_sigs()
4907 sscop_save_signal(struct sscop *sscop, u_int sig, struct sscop_msg *msg) in sscop_save_signal() argument
4914 SSCOP_MSG_FREE(msg); in sscop_save_signal()
4918 s->msg = msg; in sscop_save_signal()