lapbether.c
上传用户:lgb322
上传日期:2013-02-24
资源大小:30529k
文件大小:12k
源码类别:

嵌入式Linux

开发平台:

Unix_Linux

  1. /*
  2.  * "LAPB via ethernet" driver release 001
  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.  * This is a "pseudo" network driver to allow LAPB over Ethernet.
  13.  *
  14.  * This driver can use any ethernet destination address, and can be 
  15.  * limited to accept frames from one dedicated ethernet card only.
  16.  *
  17.  * History
  18.  * LAPBETH 001 Jonathan Naylor Cloned from bpqether.c
  19.  * 2000-10-29 Henner Eisen lapb_data_indication() return status.
  20.  * 2000-11-14 Henner Eisen dev_hold/put, NETDEV_GOING_DOWN support
  21.  */
  22. #include <linux/errno.h>
  23. #include <linux/types.h>
  24. #include <linux/socket.h>
  25. #include <linux/in.h>
  26. #include <linux/kernel.h>
  27. #include <linux/string.h>
  28. #include <linux/net.h>
  29. #include <linux/inet.h>
  30. #include <linux/netdevice.h>
  31. #include <linux/if_arp.h>
  32. #include <linux/skbuff.h>
  33. #include <net/sock.h>
  34. #include <asm/segment.h>
  35. #include <asm/system.h>
  36. #include <asm/uaccess.h>
  37. #include <linux/mm.h>
  38. #include <linux/interrupt.h>
  39. #include <linux/notifier.h>
  40. #include <linux/proc_fs.h>
  41. #include <linux/stat.h>
  42. #include <linux/netfilter.h>
  43. #include <linux/module.h>
  44. #include <linux/lapb.h>
  45. #include <linux/init.h>
  46. static char bcast_addr[6] = {0xFF,0xFF,0xFF,0xFF,0xFF,0xFF};
  47. /* If this number is made larger, check that the temporary string buffer
  48.  * in lapbeth_new_device is large enough to store the probe device name.*/
  49. #define MAXLAPBDEV 100
  50. static struct lapbethdev {
  51. struct lapbethdev *next;
  52. char   ethname[14]; /* ether device name */
  53. struct net_device *ethdev; /* link to ethernet device */
  54. struct net_device axdev; /* lapbeth device (lapb#) */
  55. struct net_device_stats stats; /* some statistics */
  56. } *lapbeth_devices /* = NULL initially */;
  57. /* ------------------------------------------------------------------------ */
  58. /*
  59.  * Get the LAPB device for the ethernet device
  60.  */
  61. static inline struct net_device *lapbeth_get_x25_dev(struct net_device *dev)
  62. {
  63. struct lapbethdev *lapbeth;
  64. for (lapbeth = lapbeth_devices; lapbeth != NULL; lapbeth = lapbeth->next)
  65. if (lapbeth->ethdev == dev)
  66. return &lapbeth->axdev;
  67. return NULL;
  68. }
  69. static inline int dev_is_ethdev(struct net_device *dev)
  70. {
  71. return (
  72. dev->type == ARPHRD_ETHER
  73. && strncmp(dev->name, "dummy", 5)
  74. );
  75. }
  76. /*
  77.  * Sanity check: remove all devices that ceased to exists and
  78.  * return '1' if the given LAPB device was affected.
  79.  */
  80. static int lapbeth_check_devices(struct net_device *dev)
  81. {
  82. struct lapbethdev *lapbeth, *lapbeth_prev, *lapbeth_next;
  83. int result = 0;
  84. unsigned long flags;
  85. save_flags(flags);
  86. cli();
  87. lapbeth_prev = NULL;
  88. for (lapbeth = lapbeth_devices; lapbeth != NULL; lapbeth = lapbeth_next) {
  89. lapbeth_next = lapbeth->next;
  90. if (!dev_get(lapbeth->ethname)) {
  91. if (lapbeth_prev)
  92. lapbeth_prev->next = lapbeth->next;
  93. else
  94. lapbeth_devices = lapbeth->next;
  95. if (&lapbeth->axdev == dev)
  96. result = 1;
  97. unregister_netdev(&lapbeth->axdev);
  98. dev_put(lapbeth->ethdev);
  99. kfree(lapbeth);
  100. }
  101. else
  102. lapbeth_prev = lapbeth;
  103. }
  104. restore_flags(flags);
  105. return result;
  106. }
  107. /* ------------------------------------------------------------------------ */
  108. /*
  109.  * Receive a LAPB frame via an ethernet interface.
  110.  */
  111. static int lapbeth_rcv(struct sk_buff *skb, struct net_device *dev, struct packet_type *ptype)
  112. {
  113. int len, err;
  114. struct lapbethdev *lapbeth;
  115. skb->sk = NULL; /* Initially we don't know who it's for */
  116. dev = lapbeth_get_x25_dev(dev);
  117. if (dev == NULL || !netif_running(dev)) {
  118. kfree_skb(skb);
  119. return 0;
  120. }
  121. lapbeth = (struct lapbethdev *) dev->priv;
  122. lapbeth->stats.rx_packets++;
  123. len = skb->data[0] + skb->data[1] * 256;
  124. skb_pull(skb, 2); /* Remove the length bytes */
  125. skb_trim(skb, len); /* Set the length of the data */
  126. if ((err = lapb_data_received(lapbeth, skb)) != LAPB_OK) {
  127. kfree_skb(skb);
  128. printk(KERN_DEBUG "lapbether: lapb_data_received err - %dn", err);
  129. }
  130. return 0;
  131. }
  132. static int lapbeth_data_indication(void *token, struct sk_buff *skb)
  133. {
  134. struct lapbethdev *lapbeth = (struct lapbethdev *) token;
  135. unsigned char *ptr;
  136. ptr  = skb_push(skb, 1);
  137. *ptr = 0x00;
  138. skb->dev      = &lapbeth->axdev;
  139. skb->protocol = htons(ETH_P_X25);
  140. skb->mac.raw  = skb->data;
  141. skb->pkt_type = PACKET_HOST;
  142. return netif_rx(skb);
  143. }
  144. /*
  145.  * Send a LAPB frame via an ethernet interface
  146.  */
  147. static int lapbeth_xmit(struct sk_buff *skb, struct net_device *dev)
  148. {
  149. struct lapbethdev *lapbeth = (struct lapbethdev *) dev->priv;
  150. int err;
  151. /*
  152.  * Just to be *really* sure not to send anything if the interface
  153.  * is down, the ethernet device may have gone.
  154.  */
  155. if (!netif_running(dev)) {
  156. lapbeth_check_devices(dev);
  157. kfree_skb(skb);
  158. return -ENODEV;
  159. }
  160. switch (skb->data[0]) {
  161. case 0x00:
  162. break;
  163. case 0x01:
  164. if ((err = lapb_connect_request(lapbeth)) != LAPB_OK)
  165. printk(KERN_ERR "lapbeth: lapb_connect_request error - %dn", err);
  166. kfree_skb(skb);
  167. return 0;
  168. case 0x02:
  169. if ((err = lapb_disconnect_request(lapbeth)) != LAPB_OK)
  170. printk(KERN_ERR "lapbeth: lapb_disconnect_request err - %dn", err);
  171. kfree_skb(skb);
  172. return 0;
  173. default:
  174. kfree_skb(skb);
  175. return 0;
  176. }
  177. skb_pull(skb, 1);
  178. if ((err = lapb_data_request(lapbeth, skb)) != LAPB_OK) {
  179. printk(KERN_ERR "lapbeth: lapb_data_request error - %dn", err);
  180. kfree_skb(skb);
  181. return -ENOMEM;
  182. }
  183. return 0;
  184. }
  185. static void lapbeth_data_transmit(void *token, struct sk_buff *skb)
  186. {
  187. struct lapbethdev *lapbeth = (struct lapbethdev *) token;
  188. unsigned char *ptr;
  189. struct net_device *dev;
  190. int size;
  191. skb->protocol = htons(ETH_P_X25);
  192. size = skb->len;
  193. ptr = skb_push(skb, 2);
  194. *ptr++ = size % 256;
  195. *ptr++ = size / 256;
  196. lapbeth->stats.tx_packets++;
  197. skb->dev = dev = lapbeth->ethdev;
  198. dev->hard_header(skb, dev, ETH_P_DEC, bcast_addr, NULL, 0);
  199. dev_queue_xmit(skb);
  200. }
  201. static void lapbeth_connected(void *token, int reason)
  202. {
  203. struct lapbethdev *lapbeth = (struct lapbethdev *) token;
  204. struct sk_buff *skb;
  205. unsigned char *ptr;
  206. if ((skb = dev_alloc_skb(1)) == NULL) {
  207. printk(KERN_ERR "lapbeth: out of memoryn");
  208. return;
  209. }
  210. ptr  = skb_put(skb, 1);
  211. *ptr = 0x01;
  212. skb->dev      = &lapbeth->axdev;
  213. skb->protocol = htons(ETH_P_X25);
  214. skb->mac.raw  = skb->data;
  215. skb->pkt_type = PACKET_HOST;
  216. netif_rx(skb);
  217. }
  218. static void lapbeth_disconnected(void *token, int reason)
  219. {
  220. struct lapbethdev *lapbeth = (struct lapbethdev *) token;
  221. struct sk_buff *skb;
  222. unsigned char *ptr;
  223. if ((skb = dev_alloc_skb(1)) == NULL) {
  224. printk(KERN_ERR "lapbeth: out of memoryn");
  225. return;
  226. }
  227. ptr  = skb_put(skb, 1);
  228. *ptr = 0x02;
  229. skb->dev      = &lapbeth->axdev;
  230. skb->protocol = htons(ETH_P_X25);
  231. skb->mac.raw  = skb->data;
  232. skb->pkt_type = PACKET_HOST;
  233. netif_rx(skb);
  234. }
  235. /*
  236.  * Statistics
  237.  */
  238. static struct net_device_stats *lapbeth_get_stats(struct net_device *dev)
  239. {
  240. struct lapbethdev *lapbeth = (struct lapbethdev *) dev->priv;
  241. return &lapbeth->stats;
  242. }
  243. /*
  244.  * Set AX.25 callsign
  245.  */
  246. static int lapbeth_set_mac_address(struct net_device *dev, void *addr)
  247. {
  248.     struct sockaddr *sa = (struct sockaddr *) addr;
  249.     memcpy(dev->dev_addr, sa->sa_data, dev->addr_len);
  250.     return 0;
  251. }
  252. /*
  253.  * open/close a device
  254.  */
  255. static int lapbeth_open(struct net_device *dev)
  256. {
  257. struct lapb_register_struct lapbeth_callbacks;
  258. struct lapbethdev *lapbeth;
  259. int err;
  260. if (lapbeth_check_devices(dev))
  261. return -ENODEV; /* oops, it's gone */
  262. lapbeth = (struct lapbethdev *) dev->priv;
  263. lapbeth_callbacks.connect_confirmation    = lapbeth_connected;
  264. lapbeth_callbacks.connect_indication      = lapbeth_connected;
  265. lapbeth_callbacks.disconnect_confirmation = lapbeth_disconnected;
  266. lapbeth_callbacks.disconnect_indication   = lapbeth_disconnected;
  267. lapbeth_callbacks.data_indication         = lapbeth_data_indication;
  268. lapbeth_callbacks.data_transmit           = lapbeth_data_transmit;
  269. if ((err = lapb_register(lapbeth, &lapbeth_callbacks)) != LAPB_OK) {
  270. printk(KERN_ERR "lapbeth: lapb_register error - %dn", err);
  271. return -ENODEV;
  272. }
  273. netif_start_queue(dev);
  274. return 0;
  275. }
  276. static int lapbeth_close(struct net_device *dev)
  277. {
  278. struct lapbethdev *lapbeth = (struct lapbethdev *) dev->priv;
  279. int err;
  280. netif_stop_queue(dev);
  281. if ((err = lapb_unregister(lapbeth)) != LAPB_OK)
  282. printk(KERN_ERR "lapbeth: lapb_unregister error - %dn", err);
  283. return 0;
  284. }
  285. /* ------------------------------------------------------------------------ */
  286. /*
  287.  * Setup a new device.
  288.  */
  289. static int lapbeth_new_device(struct net_device *dev)
  290. {
  291. int k;
  292. unsigned char buf[14];
  293. struct lapbethdev *lapbeth, *lapbeth2;
  294. if ((lapbeth = kmalloc(sizeof(struct lapbethdev), GFP_KERNEL)) == NULL)
  295. return -ENOMEM;
  296. memset(lapbeth, 0, sizeof(struct lapbethdev));
  297. dev_hold(dev);
  298. lapbeth->ethdev = dev;
  299. lapbeth->ethname[sizeof(lapbeth->ethname)-1] = '';
  300. strncpy(lapbeth->ethname, dev->name, sizeof(lapbeth->ethname)-1);
  301. dev = &lapbeth->axdev;
  302. SET_MODULE_OWNER(dev);
  303. for (k = 0; k < MAXLAPBDEV; k++) {
  304. struct net_device *odev;
  305. sprintf(buf, "lapb%d", k);
  306. if ((odev = __dev_get_by_name(buf)) == NULL || lapbeth_check_devices(odev))
  307. break;
  308. }
  309. if (k == MAXLAPBDEV) {
  310. dev_put(dev);
  311. kfree(lapbeth);
  312. return -ENODEV;
  313. }
  314. dev->priv = (void *)lapbeth; /* pointer back */
  315. strcpy(dev->name, buf);
  316. if (register_netdev(dev) != 0) {
  317. dev_put(dev);
  318. kfree(lapbeth);
  319.                 return -EIO;
  320.         }
  321. dev->hard_start_xmit = lapbeth_xmit;
  322. dev->open      = lapbeth_open;
  323. dev->stop      = lapbeth_close;
  324. dev->set_mac_address = lapbeth_set_mac_address;
  325. dev->get_stats      = lapbeth_get_stats;
  326. dev->type            = ARPHRD_X25;
  327. dev->hard_header_len = 3;
  328. dev->mtu             = 1000;
  329. dev->addr_len        = 0;
  330. cli();
  331. if (lapbeth_devices == NULL) {
  332. lapbeth_devices = lapbeth;
  333. } else {
  334. for (lapbeth2 = lapbeth_devices; lapbeth2->next != NULL; lapbeth2 = lapbeth2->next);
  335. lapbeth2->next = lapbeth;
  336. }
  337. sti();
  338. return 0;
  339. }
  340. /*
  341.  * Handle device status changes.
  342.  */
  343. static int lapbeth_device_event(struct notifier_block *this, unsigned long event, void *ptr)
  344. {
  345. struct net_device *dev = (struct net_device *) ptr;
  346. if (!dev_is_ethdev(dev))
  347. return NOTIFY_DONE;
  348. lapbeth_check_devices(NULL);
  349. switch (event) {
  350. case NETDEV_UP: /* new ethernet device -> new LAPB interface */
  351. if (lapbeth_get_x25_dev(dev) == NULL)
  352. lapbeth_new_device(dev);
  353. break;
  354. case NETDEV_GOING_DOWN:
  355. case NETDEV_DOWN: /* ethernet device closed -> close LAPB interface */
  356. if ((dev = lapbeth_get_x25_dev(dev)) != NULL)
  357. dev_close(dev);
  358. break;
  359. default:
  360. break;
  361. }
  362. return NOTIFY_DONE;
  363. }
  364. /* ------------------------------------------------------------------------ */
  365. static struct packet_type lapbeth_packet_type = {
  366. type: __constant_htons(ETH_P_DEC),
  367. func: lapbeth_rcv,
  368. };
  369. static struct notifier_block lapbeth_dev_notifier = {
  370. notifier_call: lapbeth_device_event,
  371. };
  372. static char banner[] __initdata = KERN_INFO "LAPB Ethernet driver version 0.01n";
  373. static int __init lapbeth_init_driver(void)
  374. {
  375. struct net_device *dev;
  376. dev_add_pack(&lapbeth_packet_type);
  377. register_netdevice_notifier(&lapbeth_dev_notifier);
  378. printk(banner);
  379. read_lock_bh(&dev_base_lock);
  380. for (dev = dev_base; dev != NULL; dev = dev->next) {
  381. if (dev_is_ethdev(dev)) {
  382. read_unlock_bh(&dev_base_lock);
  383. lapbeth_new_device(dev);
  384. read_lock_bh(&dev_base_lock);
  385. }
  386. }
  387. read_unlock_bh(&dev_base_lock);
  388. return 0;
  389. }
  390. module_init(lapbeth_init_driver);
  391. static void __exit lapbeth_cleanup_driver(void)
  392. {
  393. struct lapbethdev *lapbeth;
  394. dev_remove_pack(&lapbeth_packet_type);
  395. unregister_netdevice_notifier(&lapbeth_dev_notifier);
  396. for (lapbeth = lapbeth_devices; lapbeth != NULL; lapbeth = lapbeth->next)
  397. unregister_netdev(&lapbeth->axdev);
  398. }
  399. module_exit(lapbeth_cleanup_driver);
  400. EXPORT_NO_SYMBOLS;
  401. MODULE_AUTHOR("Jonathan Naylor <g4klx@g4klx.demon.co.uk>");
  402. MODULE_DESCRIPTION("The unofficial LAPB over Ethernet driver");
  403. MODULE_LICENSE("GPL");