^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) // SPDX-License-Identifier: GPL-2.0-or-later
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) * Copyright (C) Jonathan Naylor G4KLX (g4klx@g4klx.demon.co.uk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) * Copyright (C) Joerg Reuter DL1BKE (jreuter@yaina.de)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) #include <linux/errno.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8) #include <linux/types.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) #include <linux/socket.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #include <linux/in.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) #include <linux/kernel.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include <linux/timer.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/string.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) #include <linux/sockios.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <linux/net.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) #include <net/ax25.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include <linux/inet.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18) #include <linux/netdevice.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) #include <linux/skbuff.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) #include <net/sock.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) #include <net/tcp_states.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) #include <linux/uaccess.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) #include <linux/fcntl.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) #include <linux/mm.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) #include <linux/interrupt.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28) * State machine for state 1, Awaiting Connection State.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) * The handling of the timer(s) is in file ax25_ds_timer.c.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) * Handling of state 0 and connection release is in ax25.c.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) static int ax25_ds_state1_machine(ax25_cb *ax25, struct sk_buff *skb, int frametype, int pf, int type)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) switch (frametype) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) case AX25_SABM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) ax25->modulus = AX25_MODULUS;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) ax25->window = ax25->ax25_dev->values[AX25_VALUES_WINDOW];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) ax25_send_control(ax25, AX25_UA, pf, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41) case AX25_SABME:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) ax25->modulus = AX25_EMODULUS;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) ax25->window = ax25->ax25_dev->values[AX25_VALUES_EWINDOW];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) ax25_send_control(ax25, AX25_UA, pf, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47) case AX25_DISC:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) ax25_send_control(ax25, AX25_DM, pf, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51) case AX25_UA:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) ax25_calculate_rtt(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) ax25_stop_t1timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) ax25_start_t3timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) ax25_start_idletimer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) ax25->vs = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) ax25->va = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) ax25->vr = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) ax25->state = AX25_STATE_3;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) ax25->n2count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) if (ax25->sk != NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) bh_lock_sock(ax25->sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) ax25->sk->sk_state = TCP_ESTABLISHED;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) * For WAIT_SABM connections we will produce an accept
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) * ready socket here
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) if (!sock_flag(ax25->sk, SOCK_DEAD))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) ax25->sk->sk_state_change(ax25->sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) bh_unlock_sock(ax25->sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72) ax25_dama_on(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) /* according to DK4EG's spec we are required to
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75) * send a RR RESPONSE FINAL NR=0.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78) ax25_std_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) case AX25_DM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) if (pf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83) ax25_disconnect(ax25, ECONNREFUSED);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86) default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87) if (pf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88) ax25_send_control(ax25, AX25_SABM, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96) * State machine for state 2, Awaiting Release State.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) * The handling of the timer(s) is in file ax25_ds_timer.c
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98) * Handling of state 0 and connection release is in ax25.c.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) static int ax25_ds_state2_machine(ax25_cb *ax25, struct sk_buff *skb, int frametype, int pf, int type)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) switch (frametype) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) case AX25_SABM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) case AX25_SABME:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) ax25_send_control(ax25, AX25_DISC, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) ax25_dama_off(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) case AX25_DISC:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) ax25_send_control(ax25, AX25_UA, pf, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) ax25_dama_off(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) ax25_disconnect(ax25, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) case AX25_DM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) case AX25_UA:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) if (pf) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) ax25_dama_off(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) ax25_disconnect(ax25, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) case AX25_I:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) case AX25_REJ:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) case AX25_RNR:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) case AX25_RR:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) if (pf) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) ax25_send_control(ax25, AX25_DISC, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) ax25_dama_off(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) return 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) * State machine for state 3, Connected State.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142) * The handling of the timer(s) is in file ax25_timer.c
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) * Handling of state 0 and connection release is in ax25.c.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) static int ax25_ds_state3_machine(ax25_cb *ax25, struct sk_buff *skb, int frametype, int ns, int nr, int pf, int type)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) int queued = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) switch (frametype) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) case AX25_SABM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) case AX25_SABME:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) if (frametype == AX25_SABM) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) ax25->modulus = AX25_MODULUS;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) ax25->window = ax25->ax25_dev->values[AX25_VALUES_WINDOW];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) ax25->modulus = AX25_EMODULUS;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) ax25->window = ax25->ax25_dev->values[AX25_VALUES_EWINDOW];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) ax25_send_control(ax25, AX25_UA, pf, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) ax25_stop_t1timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) ax25_start_t3timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) ax25_start_idletimer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) ax25->condition = 0x00;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) ax25->vs = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) ax25->va = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) ax25->vr = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) ax25_requeue_frames(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) ax25_dama_on(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) case AX25_DISC:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) ax25_send_control(ax25, AX25_UA, pf, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) ax25_dama_off(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) ax25_disconnect(ax25, 0);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) case AX25_DM:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178) ax25_dama_off(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179) ax25_disconnect(ax25, ECONNRESET);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) case AX25_RR:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) case AX25_RNR:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184) if (frametype == AX25_RR)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) ax25->condition &= ~AX25_COND_PEER_RX_BUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186) else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) ax25->condition |= AX25_COND_PEER_RX_BUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) if (ax25_validate_nr(ax25, nr)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) if (ax25_check_iframes_acked(ax25, nr))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) ax25->n2count=0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192) if (type == AX25_COMMAND && pf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) ax25_ds_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) ax25_ds_nr_error_recovery(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) ax25->state = AX25_STATE_1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) case AX25_REJ:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) ax25->condition &= ~AX25_COND_PEER_RX_BUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) if (ax25_validate_nr(ax25, nr)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204) if (ax25->va != nr)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) ax25->n2count=0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) ax25_frames_acked(ax25, nr);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) ax25_calculate_rtt(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209) ax25_stop_t1timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) ax25_start_t3timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211) ax25_requeue_frames(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) if (type == AX25_COMMAND && pf)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) ax25_ds_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216) ax25_ds_nr_error_recovery(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) ax25->state = AX25_STATE_1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) case AX25_I:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) if (!ax25_validate_nr(ax25, nr)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) ax25_ds_nr_error_recovery(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) ax25->state = AX25_STATE_1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) if (ax25->condition & AX25_COND_PEER_RX_BUSY) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) ax25_frames_acked(ax25, nr);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) ax25->n2count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231) if (ax25_check_iframes_acked(ax25, nr))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) ax25->n2count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234) if (ax25->condition & AX25_COND_OWN_RX_BUSY) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) if (pf) ax25_ds_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) if (ns == ax25->vr) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239) ax25->vr = (ax25->vr + 1) % ax25->modulus;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240) queued = ax25_rx_iframe(ax25, skb);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) if (ax25->condition & AX25_COND_OWN_RX_BUSY)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) ax25->vr = ns; /* ax25->vr - 1 */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) ax25->condition &= ~AX25_COND_REJECT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) if (pf) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245) ax25_ds_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) if (!(ax25->condition & AX25_COND_ACK_PENDING)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) ax25->condition |= AX25_COND_ACK_PENDING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249) ax25_start_t2timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) if (ax25->condition & AX25_COND_REJECT) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254) if (pf) ax25_ds_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) ax25->condition |= AX25_COND_REJECT;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257) ax25_ds_enquiry_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) ax25->condition &= ~AX25_COND_ACK_PENDING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) case AX25_FRMR:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) case AX25_ILLEGAL:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) ax25_ds_establish_data_link(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) ax25->state = AX25_STATE_1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 268)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 269) default:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 270) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 271) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 272)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 273) return queued;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 274) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 275)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 276) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 277) * Higher level upcall for a LAPB frame
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 278) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 279) int ax25_ds_frame_in(ax25_cb *ax25, struct sk_buff *skb, int type)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 280) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 281) int queued = 0, frametype, ns, nr, pf;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 282)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 283) frametype = ax25_decode(ax25, skb, &ns, &nr, &pf);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 284)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 285) switch (ax25->state) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 286) case AX25_STATE_1:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 287) queued = ax25_ds_state1_machine(ax25, skb, frametype, pf, type);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 288) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 289) case AX25_STATE_2:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 290) queued = ax25_ds_state2_machine(ax25, skb, frametype, pf, type);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 291) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 292) case AX25_STATE_3:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 293) queued = ax25_ds_state3_machine(ax25, skb, frametype, ns, nr, pf, type);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 294) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 295) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 296)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 297) return queued;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 298) }