diff options
Diffstat (limited to 'net/ax25/ax25_timer.c')
| -rw-r--r-- | net/ax25/ax25_timer.c | 486 |
1 files changed, 19 insertions, 467 deletions
diff --git a/net/ax25/ax25_timer.c b/net/ax25/ax25_timer.c index f6ce6e00b..a99a02b4a 100644 --- a/net/ax25/ax25_timer.c +++ b/net/ax25/ax25_timer.c @@ -1,10 +1,10 @@ /* - * AX.25 release 033 + * AX.25 release 036 * * This is ALPHA test software. This code may break your machine, randomly fail to work with new * releases, misbehave and/or generally screw up. It might even work. * - * This code REQUIRES 1.2.1 or higher/ NET3.029 + * This code REQUIRES 2.1.15 or higher/ NET3.038 * * This module: * This module is free software; you can redistribute it and/or @@ -20,6 +20,10 @@ * AX.25 031 Joerg(DL1BKE) Added DAMA support * AX.25 032 Joerg(DL1BKE) Fixed DAMA timeout bug * AX.25 033 Jonathan(G4KLX) Modularisation functions. + * AX.25 035 Frederic(F1OAT) Support for pseudo-digipeating. + * AX.25 036 Jonathan(G4KLX) Split Standard and DAMA code into seperate files. + * Joerg(DL1BKE) Fixed DAMA Slave. We are *required* to start with + * standard AX.25 mode. */ #include <linux/config.h> @@ -48,37 +52,20 @@ static void ax25_timer(unsigned long); /* - * Linux set/reset timer routines + * Linux set timer */ void ax25_set_timer(ax25_cb *ax25) { unsigned long flags; - save_flags(flags); - cli(); + save_flags(flags); cli(); del_timer(&ax25->timer); restore_flags(flags); - ax25->timer.next = ax25->timer.prev = NULL; ax25->timer.data = (unsigned long)ax25; ax25->timer.function = &ax25_timer; + ax25->timer.expires = jiffies + (HZ / 10); - ax25->timer.expires = jiffies + 10; - add_timer(&ax25->timer); -} - -static void ax25_reset_timer(ax25_cb *ax25) -{ - unsigned long flags; - - save_flags(flags); - cli(); - del_timer(&ax25->timer); - restore_flags(flags); - - ax25->timer.data = (unsigned long)ax25; - ax25->timer.function = &ax25_timer; - ax25->timer.expires = jiffies + 10; add_timer(&ax25->timer); } @@ -92,456 +79,21 @@ static void ax25_timer(unsigned long param) { ax25_cb *ax25 = (ax25_cb *)param; - switch (ax25->state) { - case AX25_STATE_0: - /* Magic here: If we listen() and a new link dies before it - is accepted() it isn't 'dead' so doesn't get removed. */ - if (ax25->sk == NULL || ax25->sk->destroy || (ax25->sk->state == TCP_LISTEN && ax25->sk->dead)) { - del_timer(&ax25->timer); - ax25_destroy_socket(ax25); - return; - } - break; - - case AX25_STATE_3: - case AX25_STATE_4: - /* - * Check the state of the receive buffer. - */ - if (ax25->sk != NULL) { - if (ax25->sk->rmem_alloc < (ax25->sk->rcvbuf / 2) && (ax25->condition & OWN_RX_BUSY_CONDITION)) { - ax25->condition &= ~OWN_RX_BUSY_CONDITION; - if (!ax25->dama_slave) - ax25_send_control(ax25, RR, POLLOFF, C_RESPONSE); - ax25->condition &= ~ACK_PENDING_CONDITION; - break; - } - } - /* - * Check for frames to transmit. - */ - if (!ax25->dama_slave) - ax25_kick(ax25); - break; - - default: - break; - } - - if (ax25->t2timer > 0 && --ax25->t2timer == 0) { - if (ax25->state == AX25_STATE_3 || ax25->state == AX25_STATE_4) { - if (ax25->condition & ACK_PENDING_CONDITION) { - ax25->condition &= ~ACK_PENDING_CONDITION; - if (!ax25->dama_slave) - ax25_timeout_response(ax25); - } - } - } - - if (ax25->t3timer > 0 && --ax25->t3timer == 0) { - /* dl1bke 960114: T3 expires and we are in DAMA mode: */ - /* send a DISC and abort the connection */ - if (ax25->dama_slave) { - ax25_link_failed(&ax25->dest_addr, ax25->device); - ax25_clear_queues(ax25); - ax25_send_control(ax25, DISC, POLLON, C_COMMAND); - - ax25->state = AX25_STATE_0; - if (ax25->sk != NULL) { - if (ax25->sk->debug) - printk(KERN_DEBUG "AX.25 T3 Timeout\n"); - ax25->sk->state = TCP_CLOSE; - ax25->sk->err = ETIMEDOUT; - ax25->sk->shutdown |= SEND_SHUTDOWN; - if (!ax25->sk->dead) - ax25->sk->state_change(ax25->sk); - ax25->sk->dead = 1; - } - - ax25_reset_timer(ax25); - return; - } - - if (ax25->state == AX25_STATE_3) { - ax25->n2count = 0; - ax25_transmit_enquiry(ax25); - ax25->state = AX25_STATE_4; - } - ax25->t3timer = ax25->t3; - } - - if (ax25->idletimer > 0 && --ax25->idletimer == 0) { - /* dl1bke 960228: close the connection when IDLE expires */ - /* similar to DAMA T3 timeout but with */ - /* a "clean" disconnect of the connection */ - - ax25_clear_queues(ax25); - - ax25->n2count = 0; - if (!ax25->dama_slave) { - ax25->t3timer = 0; - ax25_send_control(ax25, DISC, POLLON, C_COMMAND); - } else { - ax25->t3timer = ax25->t3; - } - - /* state 1 or 2 should not happen, but... */ - - if (ax25->state == AX25_STATE_1 || ax25->state == AX25_STATE_2) - ax25->state = AX25_STATE_0; - else - ax25->state = AX25_STATE_2; - - ax25->t1timer = ax25->t1 = ax25_calculate_t1(ax25); - - if (ax25->sk != NULL) { - ax25->sk->state = TCP_CLOSE; - ax25->sk->err = 0; - ax25->sk->shutdown |= SEND_SHUTDOWN; - if (!ax25->sk->dead) - ax25->sk->state_change(ax25->sk); - ax25->sk->dead = 1; - ax25->sk->destroy = 1; - } - } - - /* dl1bke 960114: DAMA T1 timeouts are handled in ax25_dama_slave_transmit */ - /* nevertheless we have to re-enqueue the timer struct... */ - - if (ax25->t1timer == 0 || --ax25->t1timer > 0) { - ax25_reset_timer(ax25); - return; - } - - if (!ax25_dev_is_dama_slave(ax25->device)) { - if (ax25->dama_slave) - ax25->dama_slave = 0; - ax25_t1_timeout(ax25); - } -} - - -/* dl1bke 960114: The DAMA protocol requires to send data and SABM/DISC - * within the poll of any connected channel. Remember - * that we are not allowed to send anything unless we - * get polled by the Master. - * - * Thus we'll have to do parts of our T1 handling in - * ax25_enquiry_response(). - */ -void ax25_t1_timeout(ax25_cb * ax25) -{ - switch (ax25->state) { - case AX25_STATE_1: - if (ax25->n2count == ax25->n2) { - if (ax25->modulus == MODULUS) { - ax25_link_failed(&ax25->dest_addr, ax25->device); - ax25_clear_queues(ax25); - ax25->state = AX25_STATE_0; - if (ax25->sk != NULL) { - ax25->sk->state = TCP_CLOSE; - ax25->sk->err = ETIMEDOUT; - ax25->sk->shutdown |= SEND_SHUTDOWN; - if (!ax25->sk->dead) - ax25->sk->state_change(ax25->sk); - ax25->sk->dead = 1; - } - } else { - ax25->modulus = MODULUS; - ax25->window = ax25_dev_get_value(ax25->device, AX25_VALUES_WINDOW); - ax25->n2count = 0; - ax25_send_control(ax25, SABM, ax25_dev_is_dama_slave(ax25->device)? POLLOFF : POLLON, C_COMMAND); - } - } else { - ax25->n2count++; - if (ax25->modulus == MODULUS) { - ax25_send_control(ax25, SABM, ax25_dev_is_dama_slave(ax25->device)? POLLOFF : POLLON, C_COMMAND); - } else { - ax25_send_control(ax25, SABME, ax25_dev_is_dama_slave(ax25->device)? POLLOFF : POLLON, C_COMMAND); - } - } - break; - - case AX25_STATE_2: - if (ax25->n2count == ax25->n2) { - ax25_link_failed(&ax25->dest_addr, ax25->device); - ax25_clear_queues(ax25); - ax25->state = AX25_STATE_0; - ax25_send_control(ax25, DISC, POLLON, C_COMMAND); - - if (ax25->sk != NULL) { - ax25->sk->state = TCP_CLOSE; - ax25->sk->err = ETIMEDOUT; - ax25->sk->shutdown |= SEND_SHUTDOWN; - if (!ax25->sk->dead) - ax25->sk->state_change(ax25->sk); - ax25->sk->dead = 1; - } - } else { - ax25->n2count++; - if (!ax25_dev_is_dama_slave(ax25->device)) - ax25_send_control(ax25, DISC, POLLON, C_COMMAND); - } + switch (ax25->ax25_dev->values[AX25_VALUES_PROTOCOL]) { + case AX25_PROTO_STD_SIMPLEX: + case AX25_PROTO_STD_DUPLEX: + ax25_std_timer(ax25); break; - case AX25_STATE_3: - ax25->n2count = 1; - if (!ax25->dama_slave) - ax25_transmit_enquiry(ax25); - ax25->state = AX25_STATE_4; +#ifdef CONFIG_AX25_DAMA_SLAVE + case AX25_PROTO_DAMA_SLAVE: + if (ax25->ax25_dev->dama.slave) + ax25_ds_timer(ax25); + else + ax25_std_timer(ax25); break; - - case AX25_STATE_4: - if (ax25->n2count == ax25->n2) { - ax25_link_failed(&ax25->dest_addr, ax25->device); - ax25_clear_queues(ax25); - ax25_send_control(ax25, DM, POLLON, C_RESPONSE); - ax25->state = AX25_STATE_0; - if (ax25->sk != NULL) { - if (ax25->sk->debug) - printk(KERN_DEBUG "AX.25 link Failure\n"); - ax25->sk->state = TCP_CLOSE; - ax25->sk->err = ETIMEDOUT; - ax25->sk->shutdown |= SEND_SHUTDOWN; - if (!ax25->sk->dead) - ax25->sk->state_change(ax25->sk); - ax25->sk->dead = 1; - } - } else { - ax25->n2count++; - if (!ax25->dama_slave) - ax25_transmit_enquiry(ax25); - } - break; - } - - ax25->t1timer = ax25->t1 = ax25_calculate_t1(ax25); - - ax25_set_timer(ax25); -} - -/************************************************************************/ -/* Module support functions follow. */ -/************************************************************************/ - -static struct protocol_struct { - struct protocol_struct *next; - unsigned int pid; - int (*func)(struct sk_buff *, ax25_cb *); -} *protocol_list = NULL; - -static struct linkfail_struct { - struct linkfail_struct *next; - void (*func)(ax25_address *, struct device *); -} *linkfail_list = NULL; - -static struct listen_struct { - struct listen_struct *next; - ax25_address callsign; - struct device *dev; -} *listen_list = NULL; - -int ax25_protocol_register(unsigned int pid, int (*func)(struct sk_buff *, ax25_cb *)) -{ - struct protocol_struct *protocol; - unsigned long flags; - - if (pid == AX25_P_TEXT || pid == AX25_P_SEGMENT) - return 0; -#ifdef CONFIG_INET - if (pid == AX25_P_IP || pid == AX25_P_ARP) - return 0; #endif - if ((protocol = (struct protocol_struct *)kmalloc(sizeof(*protocol), GFP_ATOMIC)) == NULL) - return 0; - - protocol->pid = pid; - protocol->func = func; - - save_flags(flags); - cli(); - - protocol->next = protocol_list; - protocol_list = protocol; - - restore_flags(flags); - - return 1; -} - -void ax25_protocol_release(unsigned int pid) -{ - struct protocol_struct *s, *protocol = protocol_list; - unsigned long flags; - - if (protocol == NULL) - return; - - save_flags(flags); - cli(); - - if (protocol->pid == pid) { - protocol_list = protocol->next; - restore_flags(flags); - kfree_s(protocol, sizeof(struct protocol_struct)); - return; - } - - while (protocol != NULL && protocol->next != NULL) { - if (protocol->next->pid == pid) { - s = protocol->next; - protocol->next = protocol->next->next; - restore_flags(flags); - kfree_s(s, sizeof(struct protocol_struct)); - return; - } - - protocol = protocol->next; } - - restore_flags(flags); -} - -int ax25_linkfail_register(void (*func)(ax25_address *, struct device *)) -{ - struct linkfail_struct *linkfail; - unsigned long flags; - - if ((linkfail = (struct linkfail_struct *)kmalloc(sizeof(*linkfail), GFP_ATOMIC)) == NULL) - return 0; - - linkfail->func = func; - - save_flags(flags); - cli(); - - linkfail->next = linkfail_list; - linkfail_list = linkfail; - - restore_flags(flags); - - return 1; -} - -void ax25_linkfail_release(void (*func)(ax25_address *, struct device *)) -{ - struct linkfail_struct *s, *linkfail = linkfail_list; - unsigned long flags; - - if (linkfail == NULL) - return; - - save_flags(flags); - cli(); - - if (linkfail->func == func) { - linkfail_list = linkfail->next; - restore_flags(flags); - kfree_s(linkfail, sizeof(struct linkfail_struct)); - return; - } - - while (linkfail != NULL && linkfail->next != NULL) { - if (linkfail->next->func == func) { - s = linkfail->next; - linkfail->next = linkfail->next->next; - restore_flags(flags); - kfree_s(s, sizeof(struct linkfail_struct)); - return; - } - - linkfail = linkfail->next; - } - - restore_flags(flags); -} - -int ax25_listen_register(ax25_address *callsign, struct device *dev) -{ - struct listen_struct *listen; - unsigned long flags; - - if (ax25_listen_mine(callsign, dev)) - return 0; - - if ((listen = (struct listen_struct *)kmalloc(sizeof(*listen), GFP_ATOMIC)) == NULL) - return 0; - - listen->callsign = *callsign; - listen->dev = dev; - - save_flags(flags); - cli(); - - listen->next = listen_list; - listen_list = listen; - - restore_flags(flags); - - return 1; -} - -void ax25_listen_release(ax25_address *callsign, struct device *dev) -{ - struct listen_struct *s, *listen = listen_list; - unsigned long flags; - - if (listen == NULL) - return; - - save_flags(flags); - cli(); - - if (ax25cmp(&listen->callsign, callsign) == 0 && listen->dev == dev) { - listen_list = listen->next; - restore_flags(flags); - kfree_s(listen, sizeof(struct listen_struct)); - return; - } - - while (listen != NULL && listen->next != NULL) { - if (ax25cmp(&listen->next->callsign, callsign) == 0 && listen->next->dev == dev) { - s = listen->next; - listen->next = listen->next->next; - restore_flags(flags); - kfree_s(s, sizeof(struct listen_struct)); - return; - } - - listen = listen->next; - } - - restore_flags(flags); -} - -int (*ax25_protocol_function(unsigned int pid))(struct sk_buff *, ax25_cb *) -{ - struct protocol_struct *protocol; - - for (protocol = protocol_list; protocol != NULL; protocol = protocol->next) - if (protocol->pid == pid) - return protocol->func; - - return NULL; -} - -int ax25_listen_mine(ax25_address *callsign, struct device *dev) -{ - struct listen_struct *listen; - - for (listen = listen_list; listen != NULL; listen = listen->next) - if (ax25cmp(&listen->callsign, callsign) == 0 && (listen->dev == dev || listen->dev == NULL)) - return 1; - - return 0; -} - -void ax25_link_failed(ax25_address *callsign, struct device *dev) -{ - struct linkfail_struct *linkfail; - - for (linkfail = linkfail_list; linkfail != NULL; linkfail = linkfail->next) - (linkfail->func)(callsign, dev); } #endif |