/*
|
/*
|
* NET/ROM release 007
|
* NET/ROM release 007
|
*
|
*
|
* This code REQUIRES 2.1.15 or higher/ NET3.038
|
* This code REQUIRES 2.1.15 or higher/ NET3.038
|
*
|
*
|
* This module:
|
* This module:
|
* This module is free software; you can redistribute it and/or
|
* This module is free software; you can redistribute it and/or
|
* modify it under the terms of the GNU General Public License
|
* modify it under the terms of the GNU General Public License
|
* as published by the Free Software Foundation; either version
|
* as published by the Free Software Foundation; either version
|
* 2 of the License, or (at your option) any later version.
|
* 2 of the License, or (at your option) any later version.
|
*
|
*
|
* Most of this code is based on the SDL diagrams published in the 7th
|
* Most of this code is based on the SDL diagrams published in the 7th
|
* ARRL Computer Networking Conference papers. The diagrams have mistakes
|
* ARRL Computer Networking Conference papers. The diagrams have mistakes
|
* in them, but are mostly correct. Before you modify the code could you
|
* in them, but are mostly correct. Before you modify the code could you
|
* read the SDL diagrams as the code is not obvious and probably very
|
* read the SDL diagrams as the code is not obvious and probably very
|
* easy to break;
|
* easy to break;
|
*
|
*
|
* History
|
* History
|
* NET/ROM 001 Jonathan(G4KLX) Cloned from ax25_in.c
|
* NET/ROM 001 Jonathan(G4KLX) Cloned from ax25_in.c
|
* NET/ROM 003 Jonathan(G4KLX) Added NET/ROM fragment reception.
|
* NET/ROM 003 Jonathan(G4KLX) Added NET/ROM fragment reception.
|
* Darryl(G7LED) Added missing INFO with NAK case, optimized
|
* Darryl(G7LED) Added missing INFO with NAK case, optimized
|
* INFOACK handling, removed reconnect on error.
|
* INFOACK handling, removed reconnect on error.
|
* NET/ROM 006 Jonathan(G4KLX) Hdrincl removal changes.
|
* NET/ROM 006 Jonathan(G4KLX) Hdrincl removal changes.
|
* NET/ROM 007 Jonathan(G4KLX) New timer architecture.
|
* NET/ROM 007 Jonathan(G4KLX) New timer architecture.
|
*/
|
*/
|
|
|
#include <linux/errno.h>
|
#include <linux/errno.h>
|
#include <linux/types.h>
|
#include <linux/types.h>
|
#include <linux/socket.h>
|
#include <linux/socket.h>
|
#include <linux/in.h>
|
#include <linux/in.h>
|
#include <linux/kernel.h>
|
#include <linux/kernel.h>
|
#include <linux/sched.h>
|
#include <linux/sched.h>
|
#include <linux/timer.h>
|
#include <linux/timer.h>
|
#include <linux/string.h>
|
#include <linux/string.h>
|
#include <linux/sockios.h>
|
#include <linux/sockios.h>
|
#include <linux/net.h>
|
#include <linux/net.h>
|
#include <net/ax25.h>
|
#include <net/ax25.h>
|
#include <linux/inet.h>
|
#include <linux/inet.h>
|
#include <linux/netdevice.h>
|
#include <linux/netdevice.h>
|
#include <linux/skbuff.h>
|
#include <linux/skbuff.h>
|
#include <net/sock.h>
|
#include <net/sock.h>
|
#include <net/ip.h> /* For ip_rcv */
|
#include <net/ip.h> /* For ip_rcv */
|
#include <asm/uaccess.h>
|
#include <asm/uaccess.h>
|
#include <asm/system.h>
|
#include <asm/system.h>
|
#include <linux/fcntl.h>
|
#include <linux/fcntl.h>
|
#include <linux/mm.h>
|
#include <linux/mm.h>
|
#include <linux/interrupt.h>
|
#include <linux/interrupt.h>
|
#include <net/netrom.h>
|
#include <net/netrom.h>
|
|
|
static int nr_queue_rx_frame(struct sock *sk, struct sk_buff *skb, int more)
|
static int nr_queue_rx_frame(struct sock *sk, struct sk_buff *skb, int more)
|
{
|
{
|
struct sk_buff *skbo, *skbn = skb;
|
struct sk_buff *skbo, *skbn = skb;
|
|
|
skb_pull(skb, NR_NETWORK_LEN + NR_TRANSPORT_LEN);
|
skb_pull(skb, NR_NETWORK_LEN + NR_TRANSPORT_LEN);
|
|
|
nr_start_idletimer(sk);
|
nr_start_idletimer(sk);
|
|
|
if (more) {
|
if (more) {
|
sk->protinfo.nr->fraglen += skb->len;
|
sk->protinfo.nr->fraglen += skb->len;
|
skb_queue_tail(&sk->protinfo.nr->frag_queue, skb);
|
skb_queue_tail(&sk->protinfo.nr->frag_queue, skb);
|
return 0;
|
return 0;
|
}
|
}
|
|
|
if (!more && sk->protinfo.nr->fraglen > 0) { /* End of fragment */
|
if (!more && sk->protinfo.nr->fraglen > 0) { /* End of fragment */
|
sk->protinfo.nr->fraglen += skb->len;
|
sk->protinfo.nr->fraglen += skb->len;
|
skb_queue_tail(&sk->protinfo.nr->frag_queue, skb);
|
skb_queue_tail(&sk->protinfo.nr->frag_queue, skb);
|
|
|
if ((skbn = alloc_skb(sk->protinfo.nr->fraglen, GFP_ATOMIC)) == NULL)
|
if ((skbn = alloc_skb(sk->protinfo.nr->fraglen, GFP_ATOMIC)) == NULL)
|
return 1;
|
return 1;
|
|
|
skbn->h.raw = skbn->data;
|
skbn->h.raw = skbn->data;
|
|
|
while ((skbo = skb_dequeue(&sk->protinfo.nr->frag_queue)) != NULL) {
|
while ((skbo = skb_dequeue(&sk->protinfo.nr->frag_queue)) != NULL) {
|
memcpy(skb_put(skbn, skbo->len), skbo->data, skbo->len);
|
memcpy(skb_put(skbn, skbo->len), skbo->data, skbo->len);
|
kfree_skb(skbo);
|
kfree_skb(skbo);
|
}
|
}
|
|
|
sk->protinfo.nr->fraglen = 0;
|
sk->protinfo.nr->fraglen = 0;
|
}
|
}
|
|
|
return sock_queue_rcv_skb(sk, skbn);
|
return sock_queue_rcv_skb(sk, skbn);
|
}
|
}
|
|
|
/*
|
/*
|
* State machine for state 1, Awaiting Connection State.
|
* State machine for state 1, Awaiting Connection State.
|
* The handling of the timer(s) is in file nr_timer.c.
|
* The handling of the timer(s) is in file nr_timer.c.
|
* Handling of state 0 and connection release is in netrom.c.
|
* Handling of state 0 and connection release is in netrom.c.
|
*/
|
*/
|
static int nr_state1_machine(struct sock *sk, struct sk_buff *skb, int frametype)
|
static int nr_state1_machine(struct sock *sk, struct sk_buff *skb, int frametype)
|
{
|
{
|
switch (frametype) {
|
switch (frametype) {
|
|
|
case NR_CONNACK:
|
case NR_CONNACK:
|
nr_stop_t1timer(sk);
|
nr_stop_t1timer(sk);
|
nr_start_idletimer(sk);
|
nr_start_idletimer(sk);
|
sk->protinfo.nr->your_index = skb->data[17];
|
sk->protinfo.nr->your_index = skb->data[17];
|
sk->protinfo.nr->your_id = skb->data[18];
|
sk->protinfo.nr->your_id = skb->data[18];
|
sk->protinfo.nr->vs = 0;
|
sk->protinfo.nr->vs = 0;
|
sk->protinfo.nr->va = 0;
|
sk->protinfo.nr->va = 0;
|
sk->protinfo.nr->vr = 0;
|
sk->protinfo.nr->vr = 0;
|
sk->protinfo.nr->vl = 0;
|
sk->protinfo.nr->vl = 0;
|
sk->protinfo.nr->state = NR_STATE_3;
|
sk->protinfo.nr->state = NR_STATE_3;
|
sk->protinfo.nr->n2count = 0;
|
sk->protinfo.nr->n2count = 0;
|
sk->protinfo.nr->window = skb->data[20];
|
sk->protinfo.nr->window = skb->data[20];
|
sk->state = TCP_ESTABLISHED;
|
sk->state = TCP_ESTABLISHED;
|
if (!sk->dead)
|
if (!sk->dead)
|
sk->state_change(sk);
|
sk->state_change(sk);
|
break;
|
break;
|
|
|
case NR_CONNACK | NR_CHOKE_FLAG:
|
case NR_CONNACK | NR_CHOKE_FLAG:
|
nr_disconnect(sk, ECONNREFUSED);
|
nr_disconnect(sk, ECONNREFUSED);
|
break;
|
break;
|
|
|
default:
|
default:
|
break;
|
break;
|
}
|
}
|
|
|
return 0;
|
return 0;
|
}
|
}
|
|
|
/*
|
/*
|
* State machine for state 2, Awaiting Release State.
|
* State machine for state 2, Awaiting Release State.
|
* The handling of the timer(s) is in file nr_timer.c
|
* The handling of the timer(s) is in file nr_timer.c
|
* Handling of state 0 and connection release is in netrom.c.
|
* Handling of state 0 and connection release is in netrom.c.
|
*/
|
*/
|
static int nr_state2_machine(struct sock *sk, struct sk_buff *skb, int frametype)
|
static int nr_state2_machine(struct sock *sk, struct sk_buff *skb, int frametype)
|
{
|
{
|
switch (frametype) {
|
switch (frametype) {
|
|
|
case NR_CONNACK | NR_CHOKE_FLAG:
|
case NR_CONNACK | NR_CHOKE_FLAG:
|
nr_disconnect(sk, ECONNRESET);
|
nr_disconnect(sk, ECONNRESET);
|
break;
|
break;
|
|
|
case NR_DISCREQ:
|
case NR_DISCREQ:
|
nr_write_internal(sk, NR_DISCACK);
|
nr_write_internal(sk, NR_DISCACK);
|
|
|
case NR_DISCACK:
|
case NR_DISCACK:
|
nr_disconnect(sk, 0);
|
nr_disconnect(sk, 0);
|
break;
|
break;
|
|
|
default:
|
default:
|
break;
|
break;
|
}
|
}
|
|
|
return 0;
|
return 0;
|
}
|
}
|
|
|
/*
|
/*
|
* State machine for state 3, Connected State.
|
* State machine for state 3, Connected State.
|
* The handling of the timer(s) is in file nr_timer.c
|
* The handling of the timer(s) is in file nr_timer.c
|
* Handling of state 0 and connection release is in netrom.c.
|
* Handling of state 0 and connection release is in netrom.c.
|
*/
|
*/
|
static int nr_state3_machine(struct sock *sk, struct sk_buff *skb, int frametype)
|
static int nr_state3_machine(struct sock *sk, struct sk_buff *skb, int frametype)
|
{
|
{
|
struct sk_buff_head temp_queue;
|
struct sk_buff_head temp_queue;
|
struct sk_buff *skbn;
|
struct sk_buff *skbn;
|
unsigned short save_vr;
|
unsigned short save_vr;
|
unsigned short nr, ns;
|
unsigned short nr, ns;
|
int queued = 0;
|
int queued = 0;
|
|
|
nr = skb->data[18];
|
nr = skb->data[18];
|
ns = skb->data[17];
|
ns = skb->data[17];
|
|
|
switch (frametype) {
|
switch (frametype) {
|
|
|
case NR_CONNREQ:
|
case NR_CONNREQ:
|
nr_write_internal(sk, NR_CONNACK);
|
nr_write_internal(sk, NR_CONNACK);
|
break;
|
break;
|
|
|
case NR_DISCREQ:
|
case NR_DISCREQ:
|
nr_write_internal(sk, NR_DISCACK);
|
nr_write_internal(sk, NR_DISCACK);
|
nr_disconnect(sk, 0);
|
nr_disconnect(sk, 0);
|
break;
|
break;
|
|
|
case NR_CONNACK | NR_CHOKE_FLAG:
|
case NR_CONNACK | NR_CHOKE_FLAG:
|
case NR_DISCACK:
|
case NR_DISCACK:
|
nr_disconnect(sk, ECONNRESET);
|
nr_disconnect(sk, ECONNRESET);
|
break;
|
break;
|
|
|
case NR_INFOACK:
|
case NR_INFOACK:
|
case NR_INFOACK | NR_CHOKE_FLAG:
|
case NR_INFOACK | NR_CHOKE_FLAG:
|
case NR_INFOACK | NR_NAK_FLAG:
|
case NR_INFOACK | NR_NAK_FLAG:
|
case NR_INFOACK | NR_NAK_FLAG | NR_CHOKE_FLAG:
|
case NR_INFOACK | NR_NAK_FLAG | NR_CHOKE_FLAG:
|
if (frametype & NR_CHOKE_FLAG) {
|
if (frametype & NR_CHOKE_FLAG) {
|
sk->protinfo.nr->condition |= NR_COND_PEER_RX_BUSY;
|
sk->protinfo.nr->condition |= NR_COND_PEER_RX_BUSY;
|
nr_start_t4timer(sk);
|
nr_start_t4timer(sk);
|
} else {
|
} else {
|
sk->protinfo.nr->condition &= ~NR_COND_PEER_RX_BUSY;
|
sk->protinfo.nr->condition &= ~NR_COND_PEER_RX_BUSY;
|
nr_stop_t4timer(sk);
|
nr_stop_t4timer(sk);
|
}
|
}
|
if (!nr_validate_nr(sk, nr)) {
|
if (!nr_validate_nr(sk, nr)) {
|
break;
|
break;
|
}
|
}
|
if (frametype & NR_NAK_FLAG) {
|
if (frametype & NR_NAK_FLAG) {
|
nr_frames_acked(sk, nr);
|
nr_frames_acked(sk, nr);
|
nr_send_nak_frame(sk);
|
nr_send_nak_frame(sk);
|
} else {
|
} else {
|
if (sk->protinfo.nr->condition & NR_COND_PEER_RX_BUSY) {
|
if (sk->protinfo.nr->condition & NR_COND_PEER_RX_BUSY) {
|
nr_frames_acked(sk, nr);
|
nr_frames_acked(sk, nr);
|
} else {
|
} else {
|
nr_check_iframes_acked(sk, nr);
|
nr_check_iframes_acked(sk, nr);
|
}
|
}
|
}
|
}
|
break;
|
break;
|
|
|
case NR_INFO:
|
case NR_INFO:
|
case NR_INFO | NR_NAK_FLAG:
|
case NR_INFO | NR_NAK_FLAG:
|
case NR_INFO | NR_CHOKE_FLAG:
|
case NR_INFO | NR_CHOKE_FLAG:
|
case NR_INFO | NR_MORE_FLAG:
|
case NR_INFO | NR_MORE_FLAG:
|
case NR_INFO | NR_NAK_FLAG | NR_CHOKE_FLAG:
|
case NR_INFO | NR_NAK_FLAG | NR_CHOKE_FLAG:
|
case NR_INFO | NR_CHOKE_FLAG | NR_MORE_FLAG:
|
case NR_INFO | NR_CHOKE_FLAG | NR_MORE_FLAG:
|
case NR_INFO | NR_NAK_FLAG | NR_MORE_FLAG:
|
case NR_INFO | NR_NAK_FLAG | NR_MORE_FLAG:
|
case NR_INFO | NR_NAK_FLAG | NR_CHOKE_FLAG | NR_MORE_FLAG:
|
case NR_INFO | NR_NAK_FLAG | NR_CHOKE_FLAG | NR_MORE_FLAG:
|
if (frametype & NR_CHOKE_FLAG) {
|
if (frametype & NR_CHOKE_FLAG) {
|
sk->protinfo.nr->condition |= NR_COND_PEER_RX_BUSY;
|
sk->protinfo.nr->condition |= NR_COND_PEER_RX_BUSY;
|
nr_start_t4timer(sk);
|
nr_start_t4timer(sk);
|
} else {
|
} else {
|
sk->protinfo.nr->condition &= ~NR_COND_PEER_RX_BUSY;
|
sk->protinfo.nr->condition &= ~NR_COND_PEER_RX_BUSY;
|
nr_stop_t4timer(sk);
|
nr_stop_t4timer(sk);
|
}
|
}
|
if (nr_validate_nr(sk, nr)) {
|
if (nr_validate_nr(sk, nr)) {
|
if (frametype & NR_NAK_FLAG) {
|
if (frametype & NR_NAK_FLAG) {
|
nr_frames_acked(sk, nr);
|
nr_frames_acked(sk, nr);
|
nr_send_nak_frame(sk);
|
nr_send_nak_frame(sk);
|
} else {
|
} else {
|
if (sk->protinfo.nr->condition & NR_COND_PEER_RX_BUSY) {
|
if (sk->protinfo.nr->condition & NR_COND_PEER_RX_BUSY) {
|
nr_frames_acked(sk, nr);
|
nr_frames_acked(sk, nr);
|
} else {
|
} else {
|
nr_check_iframes_acked(sk, nr);
|
nr_check_iframes_acked(sk, nr);
|
}
|
}
|
}
|
}
|
}
|
}
|
queued = 1;
|
queued = 1;
|
skb_queue_head(&sk->protinfo.nr->reseq_queue, skb);
|
skb_queue_head(&sk->protinfo.nr->reseq_queue, skb);
|
if (sk->protinfo.nr->condition & NR_COND_OWN_RX_BUSY)
|
if (sk->protinfo.nr->condition & NR_COND_OWN_RX_BUSY)
|
break;
|
break;
|
skb_queue_head_init(&temp_queue);
|
skb_queue_head_init(&temp_queue);
|
do {
|
do {
|
save_vr = sk->protinfo.nr->vr;
|
save_vr = sk->protinfo.nr->vr;
|
while ((skbn = skb_dequeue(&sk->protinfo.nr->reseq_queue)) != NULL) {
|
while ((skbn = skb_dequeue(&sk->protinfo.nr->reseq_queue)) != NULL) {
|
ns = skbn->data[17];
|
ns = skbn->data[17];
|
if (ns == sk->protinfo.nr->vr) {
|
if (ns == sk->protinfo.nr->vr) {
|
if (nr_queue_rx_frame(sk, skbn, frametype & NR_MORE_FLAG) == 0) {
|
if (nr_queue_rx_frame(sk, skbn, frametype & NR_MORE_FLAG) == 0) {
|
sk->protinfo.nr->vr = (sk->protinfo.nr->vr + 1) % NR_MODULUS;
|
sk->protinfo.nr->vr = (sk->protinfo.nr->vr + 1) % NR_MODULUS;
|
} else {
|
} else {
|
sk->protinfo.nr->condition |= NR_COND_OWN_RX_BUSY;
|
sk->protinfo.nr->condition |= NR_COND_OWN_RX_BUSY;
|
skb_queue_tail(&temp_queue, skbn);
|
skb_queue_tail(&temp_queue, skbn);
|
}
|
}
|
} else if (nr_in_rx_window(sk, ns)) {
|
} else if (nr_in_rx_window(sk, ns)) {
|
skb_queue_tail(&temp_queue, skbn);
|
skb_queue_tail(&temp_queue, skbn);
|
} else {
|
} else {
|
kfree_skb(skbn);
|
kfree_skb(skbn);
|
}
|
}
|
}
|
}
|
while ((skbn = skb_dequeue(&temp_queue)) != NULL) {
|
while ((skbn = skb_dequeue(&temp_queue)) != NULL) {
|
skb_queue_tail(&sk->protinfo.nr->reseq_queue, skbn);
|
skb_queue_tail(&sk->protinfo.nr->reseq_queue, skbn);
|
}
|
}
|
} while (save_vr != sk->protinfo.nr->vr);
|
} while (save_vr != sk->protinfo.nr->vr);
|
/*
|
/*
|
* Window is full, ack it immediately.
|
* Window is full, ack it immediately.
|
*/
|
*/
|
if (((sk->protinfo.nr->vl + sk->protinfo.nr->window) % NR_MODULUS) == sk->protinfo.nr->vr) {
|
if (((sk->protinfo.nr->vl + sk->protinfo.nr->window) % NR_MODULUS) == sk->protinfo.nr->vr) {
|
nr_enquiry_response(sk);
|
nr_enquiry_response(sk);
|
} else {
|
} else {
|
if (!(sk->protinfo.nr->condition & NR_COND_ACK_PENDING)) {
|
if (!(sk->protinfo.nr->condition & NR_COND_ACK_PENDING)) {
|
sk->protinfo.nr->condition |= NR_COND_ACK_PENDING;
|
sk->protinfo.nr->condition |= NR_COND_ACK_PENDING;
|
nr_start_t2timer(sk);
|
nr_start_t2timer(sk);
|
}
|
}
|
}
|
}
|
break;
|
break;
|
|
|
default:
|
default:
|
break;
|
break;
|
}
|
}
|
|
|
return queued;
|
return queued;
|
}
|
}
|
|
|
/* Higher level upcall for a LAPB frame */
|
/* Higher level upcall for a LAPB frame */
|
int nr_process_rx_frame(struct sock *sk, struct sk_buff *skb)
|
int nr_process_rx_frame(struct sock *sk, struct sk_buff *skb)
|
{
|
{
|
int queued = 0, frametype;
|
int queued = 0, frametype;
|
|
|
if (sk->protinfo.nr->state == NR_STATE_0)
|
if (sk->protinfo.nr->state == NR_STATE_0)
|
return 0;
|
return 0;
|
|
|
frametype = skb->data[19];
|
frametype = skb->data[19];
|
|
|
switch (sk->protinfo.nr->state) {
|
switch (sk->protinfo.nr->state) {
|
case NR_STATE_1:
|
case NR_STATE_1:
|
queued = nr_state1_machine(sk, skb, frametype);
|
queued = nr_state1_machine(sk, skb, frametype);
|
break;
|
break;
|
case NR_STATE_2:
|
case NR_STATE_2:
|
queued = nr_state2_machine(sk, skb, frametype);
|
queued = nr_state2_machine(sk, skb, frametype);
|
break;
|
break;
|
case NR_STATE_3:
|
case NR_STATE_3:
|
queued = nr_state3_machine(sk, skb, frametype);
|
queued = nr_state3_machine(sk, skb, frametype);
|
break;
|
break;
|
}
|
}
|
|
|
nr_kick(sk);
|
nr_kick(sk);
|
|
|
return queued;
|
return queued;
|
}
|
}
|
|
|
