2 * This program is free software; you can redistribute it and/or modify
3 * it under the terms of the GNU General Public License as published by
4 * the Free Software Foundation; either version 2 of the License, or
5 * (at your option) any later version.
7 * Copyright (C) Jonathan Naylor G4KLX (g4klx@g4klx.demon.co.uk)
8 * Copyright (C) Joerg Reuter DL1BKE (jreuter@yaina.de)
10 #include <linux/errno.h>
11 #include <linux/types.h>
12 #include <linux/socket.h>
13 #include <linux/spinlock.h>
15 #include <linux/kernel.h>
16 #include <linux/jiffies.h>
17 #include <linux/timer.h>
18 #include <linux/string.h>
19 #include <linux/sockios.h>
20 #include <linux/net.h>
21 #include <net/tcp_states.h>
23 #include <linux/inet.h>
24 #include <linux/netdevice.h>
25 #include <linux/skbuff.h>
27 #include <asm/uaccess.h>
28 #include <asm/system.h>
29 #include <linux/fcntl.h>
31 #include <linux/interrupt.h>
33 static void ax25_ds_timeout(unsigned long);
36 * Add DAMA slave timeout timer to timer list.
37 * Unlike the connection based timers the timeout function gets
38 * triggered every second. Please note that NET_AX25_DAMA_SLAVE_TIMEOUT
39 * (aka /proc/sys/net/ax25/{dev}/dama_slave_timeout) is still in
43 void ax25_ds_setup_timer(ax25_dev
*ax25_dev
)
45 setup_timer(&ax25_dev
->dama
.slave_timer
, ax25_ds_timeout
,
46 (unsigned long)ax25_dev
);
49 void ax25_ds_del_timer(ax25_dev
*ax25_dev
)
52 del_timer(&ax25_dev
->dama
.slave_timer
);
55 void ax25_ds_set_timer(ax25_dev
*ax25_dev
)
57 if (ax25_dev
== NULL
) /* paranoia */
60 ax25_dev
->dama
.slave_timeout
=
61 msecs_to_jiffies(ax25_dev
->values
[AX25_VALUES_DS_TIMEOUT
]) / 10;
62 mod_timer(&ax25_dev
->dama
.slave_timer
, jiffies
+ HZ
);
67 * Silently discard all (slave) connections in case our master forgot us...
70 static void ax25_ds_timeout(unsigned long arg
)
72 ax25_dev
*ax25_dev
= (struct ax25_dev
*) arg
;
74 struct hlist_node
*node
;
76 if (ax25_dev
== NULL
|| !ax25_dev
->dama
.slave
)
79 if (!ax25_dev
->dama
.slave_timeout
|| --ax25_dev
->dama
.slave_timeout
) {
80 ax25_ds_set_timer(ax25_dev
);
84 spin_lock(&ax25_list_lock
);
85 ax25_for_each(ax25
, node
, &ax25_list
) {
86 if (ax25
->ax25_dev
!= ax25_dev
|| !(ax25
->condition
& AX25_COND_DAMA_MODE
))
89 ax25_send_control(ax25
, AX25_DISC
, AX25_POLLON
, AX25_COMMAND
);
90 ax25_disconnect(ax25
, ETIMEDOUT
);
92 spin_unlock(&ax25_list_lock
);
94 ax25_dev_dama_off(ax25_dev
);
97 void ax25_ds_heartbeat_expiry(ax25_cb
*ax25
)
99 struct sock
*sk
=ax25
->sk
;
104 switch (ax25
->state
) {
107 /* Magic here: If we listen() and a new link dies before it
108 is accepted() it isn't 'dead' so doesn't get removed. */
109 if (!sk
|| sock_flag(sk
, SOCK_DESTROY
) ||
110 (sk
->sk_state
== TCP_LISTEN
&&
111 sock_flag(sk
, SOCK_DEAD
))) {
114 ax25_destroy_socket(ax25
);
118 ax25_destroy_socket(ax25
);
125 * Check the state of the receive buffer.
128 if (atomic_read(&sk
->sk_rmem_alloc
) <
129 (sk
->sk_rcvbuf
>> 1) &&
130 (ax25
->condition
& AX25_COND_OWN_RX_BUSY
)) {
131 ax25
->condition
&= ~AX25_COND_OWN_RX_BUSY
;
132 ax25
->condition
&= ~AX25_COND_ACK_PENDING
;
142 ax25_start_heartbeat(ax25
);
145 /* dl1bke 960114: T3 works much like the IDLE timeout, but
146 * gets reloaded with every frame for this
149 void ax25_ds_t3timer_expiry(ax25_cb
*ax25
)
151 ax25_send_control(ax25
, AX25_DISC
, AX25_POLLON
, AX25_COMMAND
);
153 ax25_disconnect(ax25
, ETIMEDOUT
);
156 /* dl1bke 960228: close the connection when IDLE expires.
157 * unlike T3 this timer gets reloaded only on
160 void ax25_ds_idletimer_expiry(ax25_cb
*ax25
)
162 ax25_clear_queues(ax25
);
165 ax25
->state
= AX25_STATE_2
;
167 ax25_calculate_t1(ax25
);
168 ax25_start_t1timer(ax25
);
169 ax25_stop_t3timer(ax25
);
171 if (ax25
->sk
!= NULL
) {
172 bh_lock_sock(ax25
->sk
);
173 ax25
->sk
->sk_state
= TCP_CLOSE
;
174 ax25
->sk
->sk_err
= 0;
175 ax25
->sk
->sk_shutdown
|= SEND_SHUTDOWN
;
176 if (!sock_flag(ax25
->sk
, SOCK_DEAD
)) {
177 ax25
->sk
->sk_state_change(ax25
->sk
);
178 sock_set_flag(ax25
->sk
, SOCK_DEAD
);
180 bh_unlock_sock(ax25
->sk
);
184 /* dl1bke 960114: The DAMA protocol requires to send data and SABM/DISC
185 * within the poll of any connected channel. Remember
186 * that we are not allowed to send anything unless we
187 * get polled by the Master.
189 * Thus we'll have to do parts of our T1 handling in
190 * ax25_enquiry_response().
192 void ax25_ds_t1_timeout(ax25_cb
*ax25
)
194 switch (ax25
->state
) {
196 if (ax25
->n2count
== ax25
->n2
) {
197 if (ax25
->modulus
== AX25_MODULUS
) {
198 ax25_disconnect(ax25
, ETIMEDOUT
);
201 ax25
->modulus
= AX25_MODULUS
;
202 ax25
->window
= ax25
->ax25_dev
->values
[AX25_VALUES_WINDOW
];
204 ax25_send_control(ax25
, AX25_SABM
, AX25_POLLOFF
, AX25_COMMAND
);
208 if (ax25
->modulus
== AX25_MODULUS
)
209 ax25_send_control(ax25
, AX25_SABM
, AX25_POLLOFF
, AX25_COMMAND
);
211 ax25_send_control(ax25
, AX25_SABME
, AX25_POLLOFF
, AX25_COMMAND
);
216 if (ax25
->n2count
== ax25
->n2
) {
217 ax25_send_control(ax25
, AX25_DISC
, AX25_POLLON
, AX25_COMMAND
);
218 ax25_disconnect(ax25
, ETIMEDOUT
);
226 if (ax25
->n2count
== ax25
->n2
) {
227 ax25_send_control(ax25
, AX25_DM
, AX25_POLLON
, AX25_RESPONSE
);
228 ax25_disconnect(ax25
, ETIMEDOUT
);
236 ax25_calculate_t1(ax25
);
237 ax25_start_t1timer(ax25
);
This page took 0.034793 seconds and 5 git commands to generate.