^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) Alan Cox GW4PTS (alan@lxorguk.ukuu.org.uk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5) * Copyright (C) Jonathan Naylor G4KLX (g4klx@g4klx.demon.co.uk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) * Copyright (C) Joerg Reuter DL1BKE (jreuter@yaina.de)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) * Copyright (C) Frederic Rible F1OAT (frible@teaser.fr)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) #include <linux/errno.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #include <linux/types.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) #include <linux/socket.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include <linux/in.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/kernel.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) #include <linux/timer.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <linux/string.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16) #include <linux/sockios.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include <linux/net.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18) #include <net/ax25.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) #include <linux/inet.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) #include <linux/netdevice.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) #include <linux/skbuff.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22) #include <net/sock.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) #include <net/tcp_states.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) #include <linux/uaccess.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) #include <linux/fcntl.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26) #include <linux/mm.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) #include <linux/interrupt.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) void ax25_std_heartbeat_expiry(ax25_cb *ax25)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) struct sock *sk = ax25->sk;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) if (sk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) bh_lock_sock(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) switch (ax25->state) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) case AX25_STATE_0:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) case AX25_STATE_2:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) /* Magic here: If we listen() and a new link dies before it
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) is accepted() it isn't 'dead' so doesn't get removed. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41) if (!sk || sock_flag(sk, SOCK_DESTROY) ||
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) (sk->sk_state == TCP_LISTEN &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) sock_flag(sk, SOCK_DEAD))) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) if (sk) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) sock_hold(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) ax25_destroy_socket(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47) bh_unlock_sock(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) /* Ungrab socket and destroy it */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) sock_put(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) } else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51) ax25_destroy_socket(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52) return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) case AX25_STATE_3:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) case AX25_STATE_4:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) * Check the state of the receive buffer.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) if (sk != NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) if (atomic_read(&sk->sk_rmem_alloc) <
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) (sk->sk_rcvbuf >> 1) &&
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) (ax25->condition & AX25_COND_OWN_RX_BUSY)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) ax25->condition &= ~AX25_COND_OWN_RX_BUSY;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) ax25->condition &= ~AX25_COND_ACK_PENDING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) ax25_send_control(ax25, AX25_RR, AX25_POLLOFF, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73) if (sk)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74) bh_unlock_sock(sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) ax25_start_heartbeat(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) void ax25_std_t2timer_expiry(ax25_cb *ax25)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) if (ax25->condition & AX25_COND_ACK_PENDING) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) ax25->condition &= ~AX25_COND_ACK_PENDING;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83) ax25_std_timeout_response(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87) void ax25_std_t3timer_expiry(ax25_cb *ax25)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) ax25->n2count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) ax25_std_transmit_enquiry(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91) ax25->state = AX25_STATE_4;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94) void ax25_std_idletimer_expiry(ax25_cb *ax25)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96) ax25_clear_queues(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98) ax25->n2count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) ax25_send_control(ax25, AX25_DISC, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) ax25->state = AX25_STATE_2;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) ax25_calculate_t1(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) ax25_start_t1timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) ax25_stop_t2timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) ax25_stop_t3timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) if (ax25->sk != NULL) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108) bh_lock_sock(ax25->sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) ax25->sk->sk_state = TCP_CLOSE;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) ax25->sk->sk_err = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) ax25->sk->sk_shutdown |= SEND_SHUTDOWN;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) if (!sock_flag(ax25->sk, SOCK_DEAD)) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) ax25->sk->sk_state_change(ax25->sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) sock_set_flag(ax25->sk, SOCK_DEAD);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) bh_unlock_sock(ax25->sk);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) void ax25_std_t1timer_expiry(ax25_cb *ax25)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) switch (ax25->state) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) case AX25_STATE_1:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) if (ax25->n2count == ax25->n2) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) if (ax25->modulus == AX25_MODULUS) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) ax25_disconnect(ax25, ETIMEDOUT);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129) ax25->modulus = AX25_MODULUS;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) ax25->window = ax25->ax25_dev->values[AX25_VALUES_WINDOW];
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) ax25->n2count = 0;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) ax25_send_control(ax25, AX25_SABM, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) ax25->n2count++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) if (ax25->modulus == AX25_MODULUS)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) ax25_send_control(ax25, AX25_SABM, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) ax25_send_control(ax25, AX25_SABME, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) case AX25_STATE_2:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) if (ax25->n2count == ax25->n2) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) ax25_send_control(ax25, AX25_DISC, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146) if (!sock_flag(ax25->sk, SOCK_DESTROY))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) ax25_disconnect(ax25, ETIMEDOUT);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) ax25->n2count++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) ax25_send_control(ax25, AX25_DISC, AX25_POLLON, AX25_COMMAND);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) case AX25_STATE_3:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) ax25->n2count = 1;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) ax25_std_transmit_enquiry(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158) ax25->state = AX25_STATE_4;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) case AX25_STATE_4:
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162) if (ax25->n2count == ax25->n2) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) ax25_send_control(ax25, AX25_DM, AX25_POLLON, AX25_RESPONSE);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) ax25_disconnect(ax25, ETIMEDOUT);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) return;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) } else {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) ax25->n2count++;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168) ax25_std_transmit_enquiry(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) break;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) ax25_calculate_t1(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174) ax25_start_t1timer(ax25);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) }
Orange Pi5 kernel
Deprecated Linux kernel 5.10.110 for OrangePi 5/5B/5+ boards
3 Commits
0 Branches
0 Tags