nr_in.c
上传用户:jlfgdled
上传日期:2013-04-10
资源大小:33168k
文件大小:8k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*
  2.  * NET/ROM release 007
  3.  *
  4.  * This code REQUIRES 2.1.15 or higher/ NET3.038
  5.  *
  6.  * This module:
  7.  * This module is free software; you can redistribute it and/or
  8.  * modify it under the terms of the GNU General Public License
  9.  * as published by the Free Software Foundation; either version
  10.  * 2 of the License, or (at your option) any later version.
  11.  *
  12.  * Most of this code is based on the SDL diagrams published in the 7th
  13.  * ARRL Computer Networking Conference papers. The diagrams have mistakes
  14.  * in them, but are mostly correct. Before you modify the code could you
  15.  * read the SDL diagrams as the code is not obvious and probably very
  16.  * easy to break;
  17.  *
  18.  * History
  19.  * NET/ROM 001 Jonathan(G4KLX) Cloned from ax25_in.c
  20.  * NET/ROM 003 Jonathan(G4KLX) Added NET/ROM fragment reception.
  21.  * Darryl(G7LED) Added missing INFO with NAK case, optimized
  22.  * INFOACK handling, removed reconnect on error.
  23.  * NET/ROM 006 Jonathan(G4KLX) Hdrincl removal changes.
  24.  * NET/ROM 007 Jonathan(G4KLX) New timer architecture.
  25.  */
  26. #include <linux/errno.h>
  27. #include <linux/types.h>
  28. #include <linux/socket.h>
  29. #include <linux/in.h>
  30. #include <linux/kernel.h>
  31. #include <linux/sched.h>
  32. #include <linux/timer.h>
  33. #include <linux/string.h>
  34. #include <linux/sockios.h>
  35. #include <linux/net.h>
  36. #include <net/ax25.h>
  37. #include <linux/inet.h>
  38. #include <linux/netdevice.h>
  39. #include <linux/skbuff.h>
  40. #include <net/sock.h>
  41. #include <net/ip.h> /* For ip_rcv */
  42. #include <asm/uaccess.h>
  43. #include <asm/system.h>
  44. #include <linux/fcntl.h>
  45. #include <linux/mm.h>
  46. #include <linux/interrupt.h>
  47. #include <net/netrom.h>
  48. static int nr_queue_rx_frame(struct sock *sk, struct sk_buff *skb, int more)
  49. {
  50. struct sk_buff *skbo, *skbn = skb;
  51. skb_pull(skb, NR_NETWORK_LEN + NR_TRANSPORT_LEN);
  52. nr_start_idletimer(sk);
  53. if (more) {
  54. sk->protinfo.nr->fraglen += skb->len;
  55. skb_queue_tail(&sk->protinfo.nr->frag_queue, skb);
  56. return 0;
  57. }
  58. if (!more && sk->protinfo.nr->fraglen > 0) { /* End of fragment */
  59. sk->protinfo.nr->fraglen += skb->len;
  60. skb_queue_tail(&sk->protinfo.nr->frag_queue, skb);
  61. if ((skbn = alloc_skb(sk->protinfo.nr->fraglen, GFP_ATOMIC)) == NULL)
  62. return 1;
  63. skbn->h.raw = skbn->data;
  64. while ((skbo = skb_dequeue(&sk->protinfo.nr->frag_queue)) != NULL) {
  65. memcpy(skb_put(skbn, skbo->len), skbo->data, skbo->len);
  66. kfree_skb(skbo);
  67. }
  68. sk->protinfo.nr->fraglen = 0;
  69. }
  70. return sock_queue_rcv_skb(sk, skbn);
  71. }
  72. /*
  73.  * State machine for state 1, Awaiting Connection State.
  74.  * The handling of the timer(s) is in file nr_timer.c.
  75.  * Handling of state 0 and connection release is in netrom.c.
  76.  */
  77. static int nr_state1_machine(struct sock *sk, struct sk_buff *skb, int frametype)
  78. {
  79. switch (frametype) {
  80. case NR_CONNACK:
  81. nr_stop_t1timer(sk);
  82. nr_start_idletimer(sk);
  83. sk->protinfo.nr->your_index = skb->data[17];
  84. sk->protinfo.nr->your_id    = skb->data[18];
  85. sk->protinfo.nr->vs         = 0;
  86. sk->protinfo.nr->va         = 0;
  87. sk->protinfo.nr->vr         = 0;
  88. sk->protinfo.nr->vl     = 0;
  89. sk->protinfo.nr->state      = NR_STATE_3;
  90. sk->protinfo.nr->n2count    = 0;
  91. sk->protinfo.nr->window     = skb->data[20];
  92. sk->state                   = TCP_ESTABLISHED;
  93. if (!sk->dead)
  94. sk->state_change(sk);
  95. break;
  96. case NR_CONNACK | NR_CHOKE_FLAG:
  97. nr_disconnect(sk, ECONNREFUSED);
  98. break;
  99. default:
  100. break;
  101. }
  102. return 0;
  103. }
  104. /*
  105.  * State machine for state 2, Awaiting Release State.
  106.  * The handling of the timer(s) is in file nr_timer.c
  107.  * Handling of state 0 and connection release is in netrom.c.
  108.  */
  109. static int nr_state2_machine(struct sock *sk, struct sk_buff *skb, int frametype)
  110. {
  111. switch (frametype) {
  112. case NR_CONNACK | NR_CHOKE_FLAG:
  113. nr_disconnect(sk, ECONNRESET);
  114. break;
  115. case NR_DISCREQ:
  116. nr_write_internal(sk, NR_DISCACK);
  117. case NR_DISCACK:
  118. nr_disconnect(sk, 0);
  119. break;
  120. default:
  121. break;
  122. }
  123. return 0;
  124. }
  125. /*
  126.  * State machine for state 3, Connected State.
  127.  * The handling of the timer(s) is in file nr_timer.c
  128.  * Handling of state 0 and connection release is in netrom.c.
  129.  */
  130. static int nr_state3_machine(struct sock *sk, struct sk_buff *skb, int frametype)
  131. {
  132. struct sk_buff_head temp_queue;
  133. struct sk_buff *skbn;
  134. unsigned short save_vr;
  135. unsigned short nr, ns;
  136. int queued = 0;
  137. nr = skb->data[18];
  138. ns = skb->data[17];
  139. switch (frametype) {
  140. case NR_CONNREQ:
  141. nr_write_internal(sk, NR_CONNACK);
  142. break;
  143. case NR_DISCREQ:
  144. nr_write_internal(sk, NR_DISCACK);
  145. nr_disconnect(sk, 0);
  146. break;
  147. case NR_CONNACK | NR_CHOKE_FLAG:
  148. case NR_DISCACK:
  149. nr_disconnect(sk, ECONNRESET);
  150. break;
  151. case NR_INFOACK:
  152. case NR_INFOACK | NR_CHOKE_FLAG:
  153. case NR_INFOACK | NR_NAK_FLAG:
  154. case NR_INFOACK | NR_NAK_FLAG | NR_CHOKE_FLAG:
  155. if (frametype & NR_CHOKE_FLAG) {
  156. sk->protinfo.nr->condition |= NR_COND_PEER_RX_BUSY;
  157. nr_start_t4timer(sk);
  158. } else {
  159. sk->protinfo.nr->condition &= ~NR_COND_PEER_RX_BUSY;
  160. nr_stop_t4timer(sk);
  161. }
  162. if (!nr_validate_nr(sk, nr)) {
  163. break;
  164. }
  165. if (frametype & NR_NAK_FLAG) {
  166. nr_frames_acked(sk, nr);
  167. nr_send_nak_frame(sk);
  168. } else {
  169. if (sk->protinfo.nr->condition & NR_COND_PEER_RX_BUSY) {
  170. nr_frames_acked(sk, nr);
  171. } else {
  172. nr_check_iframes_acked(sk, nr);
  173. }
  174. }
  175. break;
  176. case NR_INFO:
  177. case NR_INFO | NR_NAK_FLAG:
  178. case NR_INFO | NR_CHOKE_FLAG:
  179. case NR_INFO | NR_MORE_FLAG:
  180. case NR_INFO | NR_NAK_FLAG | NR_CHOKE_FLAG:
  181. case NR_INFO | NR_CHOKE_FLAG | NR_MORE_FLAG:
  182. case NR_INFO | NR_NAK_FLAG | NR_MORE_FLAG:
  183. case NR_INFO | NR_NAK_FLAG | NR_CHOKE_FLAG | NR_MORE_FLAG:
  184. if (frametype & NR_CHOKE_FLAG) {
  185. sk->protinfo.nr->condition |= NR_COND_PEER_RX_BUSY;
  186. nr_start_t4timer(sk);
  187. } else {
  188. sk->protinfo.nr->condition &= ~NR_COND_PEER_RX_BUSY;
  189. nr_stop_t4timer(sk);
  190. }
  191. if (nr_validate_nr(sk, nr)) {
  192. if (frametype & NR_NAK_FLAG) {
  193. nr_frames_acked(sk, nr);
  194. nr_send_nak_frame(sk);
  195. } else {
  196. if (sk->protinfo.nr->condition & NR_COND_PEER_RX_BUSY) {
  197. nr_frames_acked(sk, nr);
  198. } else {
  199. nr_check_iframes_acked(sk, nr);
  200. }
  201. }
  202. }
  203. queued = 1;
  204. skb_queue_head(&sk->protinfo.nr->reseq_queue, skb);
  205. if (sk->protinfo.nr->condition & NR_COND_OWN_RX_BUSY)
  206. break;
  207. skb_queue_head_init(&temp_queue);
  208. do {
  209. save_vr = sk->protinfo.nr->vr;
  210. while ((skbn = skb_dequeue(&sk->protinfo.nr->reseq_queue)) != NULL) {
  211. ns = skbn->data[17];
  212. if (ns == sk->protinfo.nr->vr) {
  213. if (nr_queue_rx_frame(sk, skbn, frametype & NR_MORE_FLAG) == 0) {
  214. sk->protinfo.nr->vr = (sk->protinfo.nr->vr + 1) % NR_MODULUS;
  215. } else {
  216. sk->protinfo.nr->condition |= NR_COND_OWN_RX_BUSY;
  217. skb_queue_tail(&temp_queue, skbn);
  218. }
  219. } else if (nr_in_rx_window(sk, ns)) {
  220. skb_queue_tail(&temp_queue, skbn);
  221. } else {
  222. kfree_skb(skbn);
  223. }
  224. }
  225. while ((skbn = skb_dequeue(&temp_queue)) != NULL) {
  226. skb_queue_tail(&sk->protinfo.nr->reseq_queue, skbn);
  227. }
  228. } while (save_vr != sk->protinfo.nr->vr);
  229. /*
  230.  * Window is full, ack it immediately.
  231.  */
  232. if (((sk->protinfo.nr->vl + sk->protinfo.nr->window) % NR_MODULUS) == sk->protinfo.nr->vr) {
  233. nr_enquiry_response(sk);
  234. } else {
  235. if (!(sk->protinfo.nr->condition & NR_COND_ACK_PENDING)) {
  236. sk->protinfo.nr->condition |= NR_COND_ACK_PENDING;
  237. nr_start_t2timer(sk);
  238. }
  239. }
  240. break;
  241. default:
  242. break;
  243. }
  244. return queued;
  245. }
  246. /* Higher level upcall for a LAPB frame */
  247. int nr_process_rx_frame(struct sock *sk, struct sk_buff *skb)
  248. {
  249. int queued = 0, frametype;
  250. if (sk->protinfo.nr->state == NR_STATE_0)
  251. return 0;
  252. frametype = skb->data[19];
  253. switch (sk->protinfo.nr->state) {
  254. case NR_STATE_1:
  255. queued = nr_state1_machine(sk, skb, frametype);
  256. break;
  257. case NR_STATE_2:
  258. queued = nr_state2_machine(sk, skb, frametype);
  259. break;
  260. case NR_STATE_3:
  261. queued = nr_state3_machine(sk, skb, frametype);
  262. break;
  263. }
  264. nr_kick(sk);
  265. return queued;
  266. }