123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103 |
- #include <linux/net.h>
- #include <linux/socket.h>
- #include <linux/skbuff.h>
- #include <linux/netdevice.h>
- #include <linux/timer.h>
- #include <linux/spinlock.h>
- #include <net/sock.h>
- #include <linux/atomic.h>
- #include <linux/jiffies.h>
- #include <net/flow.h>
- #include <net/dn.h>
- #define SLOW_INTERVAL (HZ/2)
- static void dn_slow_timer(unsigned long arg);
- void dn_start_slow_timer(struct sock *sk)
- {
- setup_timer(&sk->sk_timer, dn_slow_timer, (unsigned long)sk);
- sk_reset_timer(sk, &sk->sk_timer, jiffies + SLOW_INTERVAL);
- }
- void dn_stop_slow_timer(struct sock *sk)
- {
- sk_stop_timer(sk, &sk->sk_timer);
- }
- static void dn_slow_timer(unsigned long arg)
- {
- struct sock *sk = (struct sock *)arg;
- struct dn_scp *scp = DN_SK(sk);
- bh_lock_sock(sk);
- if (sock_owned_by_user(sk)) {
- sk_reset_timer(sk, &sk->sk_timer, jiffies + HZ / 10);
- goto out;
- }
-
- if (scp->persist && scp->persist_fxn) {
- if (scp->persist <= SLOW_INTERVAL) {
- scp->persist = 0;
- if (scp->persist_fxn(sk))
- goto out;
- } else {
- scp->persist -= SLOW_INTERVAL;
- }
- }
-
- if (scp->keepalive && scp->keepalive_fxn && (scp->state == DN_RUN)) {
- if (time_after_eq(jiffies, scp->stamp + scp->keepalive))
- scp->keepalive_fxn(sk);
- }
- sk_reset_timer(sk, &sk->sk_timer, jiffies + SLOW_INTERVAL);
- out:
- bh_unlock_sock(sk);
- sock_put(sk);
- }
|