mkiss.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911
  1. /*
  2. * This program is free software; you can distribute it and/or modify it
  3. * under the terms of the GNU General Public License (Version 2) as
  4. * published by the Free Software Foundation.
  5. *
  6. * This program is distributed in the hope it will be useful, but WITHOUT
  7. * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  8. * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
  9. * for more details.
  10. *
  11. * You should have received a copy of the GNU General Public License along
  12. * with this program; if not, write to the Free Software Foundation, Inc.,
  13. * 59 Temple Place - Suite 330, Boston MA 02111-1307, USA.
  14. *
  15. * Copyright (C) Hans Alblas PE1AYX <hans@esrac.ele.tue.nl>
  16. * Copyright (C) 2004, 05 Ralf Baechle DL5RB <ralf@linux-mips.org>
  17. */
  18. #include <linux/config.h>
  19. #include <linux/module.h>
  20. #include <asm/system.h>
  21. #include <linux/bitops.h>
  22. #include <asm/uaccess.h>
  23. #include <linux/string.h>
  24. #include <linux/mm.h>
  25. #include <linux/interrupt.h>
  26. #include <linux/in.h>
  27. #include <linux/inet.h>
  28. #include <linux/tty.h>
  29. #include <linux/errno.h>
  30. #include <linux/netdevice.h>
  31. #include <linux/major.h>
  32. #include <linux/init.h>
  33. #include <linux/rtnetlink.h>
  34. #include <linux/etherdevice.h>
  35. #include <linux/skbuff.h>
  36. #include <linux/if_arp.h>
  37. #include <linux/jiffies.h>
  38. #include <net/ax25.h>
  39. #ifdef CONFIG_INET
  40. #include <linux/ip.h>
  41. #include <linux/tcp.h>
  42. #endif
  43. #define AX_MTU 236
  44. /* SLIP/KISS protocol characters. */
  45. #define END 0300 /* indicates end of frame */
  46. #define ESC 0333 /* indicates byte stuffing */
  47. #define ESC_END 0334 /* ESC ESC_END means END 'data' */
  48. #define ESC_ESC 0335 /* ESC ESC_ESC means ESC 'data' */
  49. struct mkiss {
  50. struct tty_struct *tty; /* ptr to TTY structure */
  51. struct net_device *dev; /* easy for intr handling */
  52. /* These are pointers to the malloc()ed frame buffers. */
  53. spinlock_t buflock;/* lock for rbuf and xbuf */
  54. unsigned char *rbuff; /* receiver buffer */
  55. int rcount; /* received chars counter */
  56. unsigned char *xbuff; /* transmitter buffer */
  57. unsigned char *xhead; /* pointer to next byte to XMIT */
  58. int xleft; /* bytes left in XMIT queue */
  59. struct net_device_stats stats;
  60. /* Detailed SLIP statistics. */
  61. int mtu; /* Our mtu (to spot changes!) */
  62. int buffsize; /* Max buffers sizes */
  63. unsigned long flags; /* Flag values/ mode etc */
  64. /* long req'd: used by set_bit --RR */
  65. #define AXF_INUSE 0 /* Channel in use */
  66. #define AXF_ESCAPE 1 /* ESC received */
  67. #define AXF_ERROR 2 /* Parity, etc. error */
  68. #define AXF_KEEPTEST 3 /* Keepalive test flag */
  69. #define AXF_OUTWAIT 4 /* is outpacket was flag */
  70. int mode;
  71. int crcmode; /* MW: for FlexNet, SMACK etc. */
  72. #define CRC_MODE_NONE 0
  73. #define CRC_MODE_FLEX 1
  74. #define CRC_MODE_SMACK 2
  75. atomic_t refcnt;
  76. struct semaphore dead_sem;
  77. };
  78. /*---------------------------------------------------------------------------*/
  79. static const unsigned short crc_flex_table[] = {
  80. 0x0f87, 0x1e0e, 0x2c95, 0x3d1c, 0x49a3, 0x582a, 0x6ab1, 0x7b38,
  81. 0x83cf, 0x9246, 0xa0dd, 0xb154, 0xc5eb, 0xd462, 0xe6f9, 0xf770,
  82. 0x1f06, 0x0e8f, 0x3c14, 0x2d9d, 0x5922, 0x48ab, 0x7a30, 0x6bb9,
  83. 0x934e, 0x82c7, 0xb05c, 0xa1d5, 0xd56a, 0xc4e3, 0xf678, 0xe7f1,
  84. 0x2e85, 0x3f0c, 0x0d97, 0x1c1e, 0x68a1, 0x7928, 0x4bb3, 0x5a3a,
  85. 0xa2cd, 0xb344, 0x81df, 0x9056, 0xe4e9, 0xf560, 0xc7fb, 0xd672,
  86. 0x3e04, 0x2f8d, 0x1d16, 0x0c9f, 0x7820, 0x69a9, 0x5b32, 0x4abb,
  87. 0xb24c, 0xa3c5, 0x915e, 0x80d7, 0xf468, 0xe5e1, 0xd77a, 0xc6f3,
  88. 0x4d83, 0x5c0a, 0x6e91, 0x7f18, 0x0ba7, 0x1a2e, 0x28b5, 0x393c,
  89. 0xc1cb, 0xd042, 0xe2d9, 0xf350, 0x87ef, 0x9666, 0xa4fd, 0xb574,
  90. 0x5d02, 0x4c8b, 0x7e10, 0x6f99, 0x1b26, 0x0aaf, 0x3834, 0x29bd,
  91. 0xd14a, 0xc0c3, 0xf258, 0xe3d1, 0x976e, 0x86e7, 0xb47c, 0xa5f5,
  92. 0x6c81, 0x7d08, 0x4f93, 0x5e1a, 0x2aa5, 0x3b2c, 0x09b7, 0x183e,
  93. 0xe0c9, 0xf140, 0xc3db, 0xd252, 0xa6ed, 0xb764, 0x85ff, 0x9476,
  94. 0x7c00, 0x6d89, 0x5f12, 0x4e9b, 0x3a24, 0x2bad, 0x1936, 0x08bf,
  95. 0xf048, 0xe1c1, 0xd35a, 0xc2d3, 0xb66c, 0xa7e5, 0x957e, 0x84f7,
  96. 0x8b8f, 0x9a06, 0xa89d, 0xb914, 0xcdab, 0xdc22, 0xeeb9, 0xff30,
  97. 0x07c7, 0x164e, 0x24d5, 0x355c, 0x41e3, 0x506a, 0x62f1, 0x7378,
  98. 0x9b0e, 0x8a87, 0xb81c, 0xa995, 0xdd2a, 0xcca3, 0xfe38, 0xefb1,
  99. 0x1746, 0x06cf, 0x3454, 0x25dd, 0x5162, 0x40eb, 0x7270, 0x63f9,
  100. 0xaa8d, 0xbb04, 0x899f, 0x9816, 0xeca9, 0xfd20, 0xcfbb, 0xde32,
  101. 0x26c5, 0x374c, 0x05d7, 0x145e, 0x60e1, 0x7168, 0x43f3, 0x527a,
  102. 0xba0c, 0xab85, 0x991e, 0x8897, 0xfc28, 0xeda1, 0xdf3a, 0xceb3,
  103. 0x3644, 0x27cd, 0x1556, 0x04df, 0x7060, 0x61e9, 0x5372, 0x42fb,
  104. 0xc98b, 0xd802, 0xea99, 0xfb10, 0x8faf, 0x9e26, 0xacbd, 0xbd34,
  105. 0x45c3, 0x544a, 0x66d1, 0x7758, 0x03e7, 0x126e, 0x20f5, 0x317c,
  106. 0xd90a, 0xc883, 0xfa18, 0xeb91, 0x9f2e, 0x8ea7, 0xbc3c, 0xadb5,
  107. 0x5542, 0x44cb, 0x7650, 0x67d9, 0x1366, 0x02ef, 0x3074, 0x21fd,
  108. 0xe889, 0xf900, 0xcb9b, 0xda12, 0xaead, 0xbf24, 0x8dbf, 0x9c36,
  109. 0x64c1, 0x7548, 0x47d3, 0x565a, 0x22e5, 0x336c, 0x01f7, 0x107e,
  110. 0xf808, 0xe981, 0xdb1a, 0xca93, 0xbe2c, 0xafa5, 0x9d3e, 0x8cb7,
  111. 0x7440, 0x65c9, 0x5752, 0x46db, 0x3264, 0x23ed, 0x1176, 0x00ff
  112. };
  113. static unsigned short calc_crc_flex(unsigned char *cp, int size)
  114. {
  115. unsigned short crc = 0xffff;
  116. while (size--)
  117. crc = (crc << 8) ^ crc_flex_table[((crc >> 8) ^ *cp++) & 0xff];
  118. return crc;
  119. }
  120. static int check_crc_flex(unsigned char *cp, int size)
  121. {
  122. unsigned short crc = 0xffff;
  123. if (size < 3)
  124. return -1;
  125. while (size--)
  126. crc = (crc << 8) ^ crc_flex_table[((crc >> 8) ^ *cp++) & 0xff];
  127. if ((crc & 0xffff) != 0x7070)
  128. return -1;
  129. return 0;
  130. }
  131. /*
  132. * Standard encapsulation
  133. */
  134. static int kiss_esc(unsigned char *s, unsigned char *d, int len)
  135. {
  136. unsigned char *ptr = d;
  137. unsigned char c;
  138. /*
  139. * Send an initial END character to flush out any data that may have
  140. * accumulated in the receiver due to line noise.
  141. */
  142. *ptr++ = END;
  143. while (len-- > 0) {
  144. switch (c = *s++) {
  145. case END:
  146. *ptr++ = ESC;
  147. *ptr++ = ESC_END;
  148. break;
  149. case ESC:
  150. *ptr++ = ESC;
  151. *ptr++ = ESC_ESC;
  152. break;
  153. default:
  154. *ptr++ = c;
  155. break;
  156. }
  157. }
  158. *ptr++ = END;
  159. return ptr - d;
  160. }
  161. /*
  162. * MW:
  163. * OK its ugly, but tell me a better solution without copying the
  164. * packet to a temporary buffer :-)
  165. */
  166. static int kiss_esc_crc(unsigned char *s, unsigned char *d, unsigned short crc,
  167. int len)
  168. {
  169. unsigned char *ptr = d;
  170. unsigned char c=0;
  171. *ptr++ = END;
  172. while (len > 0) {
  173. if (len > 2)
  174. c = *s++;
  175. else if (len > 1)
  176. c = crc >> 8;
  177. else if (len > 0)
  178. c = crc & 0xff;
  179. len--;
  180. switch (c) {
  181. case END:
  182. *ptr++ = ESC;
  183. *ptr++ = ESC_END;
  184. break;
  185. case ESC:
  186. *ptr++ = ESC;
  187. *ptr++ = ESC_ESC;
  188. break;
  189. default:
  190. *ptr++ = c;
  191. break;
  192. }
  193. }
  194. *ptr++ = END;
  195. return ptr - d;
  196. }
  197. /* Send one completely decapsulated AX.25 packet to the AX.25 layer. */
  198. static void ax_bump(struct mkiss *ax)
  199. {
  200. struct sk_buff *skb;
  201. int count;
  202. spin_lock_bh(&ax->buflock);
  203. if (ax->rbuff[0] > 0x0f) {
  204. if (ax->rbuff[0] & 0x20) {
  205. ax->crcmode = CRC_MODE_FLEX;
  206. if (check_crc_flex(ax->rbuff, ax->rcount) < 0) {
  207. ax->stats.rx_errors++;
  208. return;
  209. }
  210. ax->rcount -= 2;
  211. /* dl9sau bugfix: the trailling two bytes flexnet crc
  212. * will not be passed to the kernel. thus we have
  213. * to correct the kissparm signature, because it
  214. * indicates a crc but there's none
  215. */
  216. *ax->rbuff &= ~0x20;
  217. }
  218. }
  219. spin_unlock_bh(&ax->buflock);
  220. count = ax->rcount;
  221. if ((skb = dev_alloc_skb(count)) == NULL) {
  222. printk(KERN_ERR "mkiss: %s: memory squeeze, dropping packet.\n",
  223. ax->dev->name);
  224. ax->stats.rx_dropped++;
  225. return;
  226. }
  227. spin_lock_bh(&ax->buflock);
  228. memcpy(skb_put(skb,count), ax->rbuff, count);
  229. spin_unlock_bh(&ax->buflock);
  230. skb->protocol = ax25_type_trans(skb, ax->dev);
  231. netif_rx(skb);
  232. ax->dev->last_rx = jiffies;
  233. ax->stats.rx_packets++;
  234. ax->stats.rx_bytes += count;
  235. }
  236. static void kiss_unesc(struct mkiss *ax, unsigned char s)
  237. {
  238. switch (s) {
  239. case END:
  240. /* drop keeptest bit = VSV */
  241. if (test_bit(AXF_KEEPTEST, &ax->flags))
  242. clear_bit(AXF_KEEPTEST, &ax->flags);
  243. if (!test_and_clear_bit(AXF_ERROR, &ax->flags) && (ax->rcount > 2))
  244. ax_bump(ax);
  245. clear_bit(AXF_ESCAPE, &ax->flags);
  246. ax->rcount = 0;
  247. return;
  248. case ESC:
  249. set_bit(AXF_ESCAPE, &ax->flags);
  250. return;
  251. case ESC_ESC:
  252. if (test_and_clear_bit(AXF_ESCAPE, &ax->flags))
  253. s = ESC;
  254. break;
  255. case ESC_END:
  256. if (test_and_clear_bit(AXF_ESCAPE, &ax->flags))
  257. s = END;
  258. break;
  259. }
  260. spin_lock_bh(&ax->buflock);
  261. if (!test_bit(AXF_ERROR, &ax->flags)) {
  262. if (ax->rcount < ax->buffsize) {
  263. ax->rbuff[ax->rcount++] = s;
  264. spin_unlock_bh(&ax->buflock);
  265. return;
  266. }
  267. ax->stats.rx_over_errors++;
  268. set_bit(AXF_ERROR, &ax->flags);
  269. }
  270. spin_unlock_bh(&ax->buflock);
  271. }
  272. static int ax_set_mac_address(struct net_device *dev, void *addr)
  273. {
  274. struct sockaddr_ax25 *sa = addr;
  275. spin_lock_irq(&dev->xmit_lock);
  276. memcpy(dev->dev_addr, &sa->sax25_call, AX25_ADDR_LEN);
  277. spin_unlock_irq(&dev->xmit_lock);
  278. return 0;
  279. }
  280. /*---------------------------------------------------------------------------*/
  281. static void ax_changedmtu(struct mkiss *ax)
  282. {
  283. struct net_device *dev = ax->dev;
  284. unsigned char *xbuff, *rbuff, *oxbuff, *orbuff;
  285. int len;
  286. len = dev->mtu * 2;
  287. /*
  288. * allow for arrival of larger UDP packets, even if we say not to
  289. * also fixes a bug in which SunOS sends 512-byte packets even with
  290. * an MSS of 128
  291. */
  292. if (len < 576 * 2)
  293. len = 576 * 2;
  294. xbuff = kmalloc(len + 4, GFP_ATOMIC);
  295. rbuff = kmalloc(len + 4, GFP_ATOMIC);
  296. if (xbuff == NULL || rbuff == NULL) {
  297. printk(KERN_ERR "mkiss: %s: unable to grow ax25 buffers, "
  298. "MTU change cancelled.\n",
  299. ax->dev->name);
  300. dev->mtu = ax->mtu;
  301. if (xbuff != NULL)
  302. kfree(xbuff);
  303. if (rbuff != NULL)
  304. kfree(rbuff);
  305. return;
  306. }
  307. spin_lock_bh(&ax->buflock);
  308. oxbuff = ax->xbuff;
  309. ax->xbuff = xbuff;
  310. orbuff = ax->rbuff;
  311. ax->rbuff = rbuff;
  312. if (ax->xleft) {
  313. if (ax->xleft <= len) {
  314. memcpy(ax->xbuff, ax->xhead, ax->xleft);
  315. } else {
  316. ax->xleft = 0;
  317. ax->stats.tx_dropped++;
  318. }
  319. }
  320. ax->xhead = ax->xbuff;
  321. if (ax->rcount) {
  322. if (ax->rcount <= len) {
  323. memcpy(ax->rbuff, orbuff, ax->rcount);
  324. } else {
  325. ax->rcount = 0;
  326. ax->stats.rx_over_errors++;
  327. set_bit(AXF_ERROR, &ax->flags);
  328. }
  329. }
  330. ax->mtu = dev->mtu + 73;
  331. ax->buffsize = len;
  332. spin_unlock_bh(&ax->buflock);
  333. kfree(oxbuff);
  334. kfree(orbuff);
  335. }
  336. /* Encapsulate one AX.25 packet and stuff into a TTY queue. */
  337. static void ax_encaps(struct net_device *dev, unsigned char *icp, int len)
  338. {
  339. struct mkiss *ax = netdev_priv(dev);
  340. unsigned char *p;
  341. int actual, count;
  342. if (ax->mtu != ax->dev->mtu + 73) /* Someone has been ifconfigging */
  343. ax_changedmtu(ax);
  344. if (len > ax->mtu) { /* Sigh, shouldn't occur BUT ... */
  345. len = ax->mtu;
  346. printk(KERN_ERR "mkiss: %s: truncating oversized transmit packet!\n", ax->dev->name);
  347. ax->stats.tx_dropped++;
  348. netif_start_queue(dev);
  349. return;
  350. }
  351. p = icp;
  352. spin_lock_bh(&ax->buflock);
  353. switch (ax->crcmode) {
  354. unsigned short crc;
  355. case CRC_MODE_FLEX:
  356. *p |= 0x20;
  357. crc = calc_crc_flex(p, len);
  358. count = kiss_esc_crc(p, (unsigned char *)ax->xbuff, crc, len+2);
  359. break;
  360. default:
  361. count = kiss_esc(p, (unsigned char *)ax->xbuff, len);
  362. break;
  363. }
  364. set_bit(TTY_DO_WRITE_WAKEUP, &ax->tty->flags);
  365. actual = ax->tty->driver->write(ax->tty, ax->xbuff, count);
  366. ax->stats.tx_packets++;
  367. ax->stats.tx_bytes += actual;
  368. ax->dev->trans_start = jiffies;
  369. ax->xleft = count - actual;
  370. ax->xhead = ax->xbuff + actual;
  371. spin_unlock_bh(&ax->buflock);
  372. }
  373. /* Encapsulate an AX.25 packet and kick it into a TTY queue. */
  374. static int ax_xmit(struct sk_buff *skb, struct net_device *dev)
  375. {
  376. struct mkiss *ax = netdev_priv(dev);
  377. if (!netif_running(dev)) {
  378. printk(KERN_ERR "mkiss: %s: xmit call when iface is down\n", dev->name);
  379. return 1;
  380. }
  381. if (netif_queue_stopped(dev)) {
  382. /*
  383. * May be we must check transmitter timeout here ?
  384. * 14 Oct 1994 Dmitry Gorodchanin.
  385. */
  386. if (time_before(jiffies, dev->trans_start + 20 * HZ)) {
  387. /* 20 sec timeout not reached */
  388. return 1;
  389. }
  390. printk(KERN_ERR "mkiss: %s: transmit timed out, %s?\n", dev->name,
  391. (ax->tty->driver->chars_in_buffer(ax->tty) || ax->xleft) ?
  392. "bad line quality" : "driver error");
  393. ax->xleft = 0;
  394. clear_bit(TTY_DO_WRITE_WAKEUP, &ax->tty->flags);
  395. netif_start_queue(dev);
  396. }
  397. /* We were not busy, so we are now... :-) */
  398. if (skb != NULL) {
  399. netif_stop_queue(dev);
  400. ax_encaps(dev, skb->data, skb->len);
  401. kfree_skb(skb);
  402. }
  403. return 0;
  404. }
  405. static int ax_open_dev(struct net_device *dev)
  406. {
  407. struct mkiss *ax = netdev_priv(dev);
  408. if (ax->tty == NULL)
  409. return -ENODEV;
  410. return 0;
  411. }
  412. #if defined(CONFIG_AX25) || defined(CONFIG_AX25_MODULE)
  413. /* Return the frame type ID */
  414. static int ax_header(struct sk_buff *skb, struct net_device *dev, unsigned short type,
  415. void *daddr, void *saddr, unsigned len)
  416. {
  417. #ifdef CONFIG_INET
  418. if (type != htons(ETH_P_AX25))
  419. return ax25_hard_header(skb, dev, type, daddr, saddr, len);
  420. #endif
  421. return 0;
  422. }
  423. static int ax_rebuild_header(struct sk_buff *skb)
  424. {
  425. #ifdef CONFIG_INET
  426. return ax25_rebuild_header(skb);
  427. #else
  428. return 0;
  429. #endif
  430. }
  431. #endif /* CONFIG_{AX25,AX25_MODULE} */
  432. /* Open the low-level part of the AX25 channel. Easy! */
  433. static int ax_open(struct net_device *dev)
  434. {
  435. struct mkiss *ax = netdev_priv(dev);
  436. unsigned long len;
  437. if (ax->tty == NULL)
  438. return -ENODEV;
  439. /*
  440. * Allocate the frame buffers:
  441. *
  442. * rbuff Receive buffer.
  443. * xbuff Transmit buffer.
  444. */
  445. len = dev->mtu * 2;
  446. /*
  447. * allow for arrival of larger UDP packets, even if we say not to
  448. * also fixes a bug in which SunOS sends 512-byte packets even with
  449. * an MSS of 128
  450. */
  451. if (len < 576 * 2)
  452. len = 576 * 2;
  453. if ((ax->rbuff = kmalloc(len + 4, GFP_KERNEL)) == NULL)
  454. goto norbuff;
  455. if ((ax->xbuff = kmalloc(len + 4, GFP_KERNEL)) == NULL)
  456. goto noxbuff;
  457. ax->mtu = dev->mtu + 73;
  458. ax->buffsize = len;
  459. ax->rcount = 0;
  460. ax->xleft = 0;
  461. ax->flags &= (1 << AXF_INUSE); /* Clear ESCAPE & ERROR flags */
  462. spin_lock_init(&ax->buflock);
  463. return 0;
  464. noxbuff:
  465. kfree(ax->rbuff);
  466. norbuff:
  467. return -ENOMEM;
  468. }
  469. /* Close the low-level part of the AX25 channel. Easy! */
  470. static int ax_close(struct net_device *dev)
  471. {
  472. struct mkiss *ax = netdev_priv(dev);
  473. if (ax->tty)
  474. clear_bit(TTY_DO_WRITE_WAKEUP, &ax->tty->flags);
  475. netif_stop_queue(dev);
  476. return 0;
  477. }
  478. static struct net_device_stats *ax_get_stats(struct net_device *dev)
  479. {
  480. struct mkiss *ax = netdev_priv(dev);
  481. return &ax->stats;
  482. }
  483. static void ax_setup(struct net_device *dev)
  484. {
  485. static char ax25_bcast[AX25_ADDR_LEN] =
  486. {'Q'<<1,'S'<<1,'T'<<1,' '<<1,' '<<1,' '<<1,'0'<<1};
  487. static char ax25_test[AX25_ADDR_LEN] =
  488. {'L'<<1,'I'<<1,'N'<<1,'U'<<1,'X'<<1,' '<<1,'1'<<1};
  489. /* Finish setting up the DEVICE info. */
  490. dev->mtu = AX_MTU;
  491. dev->hard_start_xmit = ax_xmit;
  492. dev->open = ax_open_dev;
  493. dev->stop = ax_close;
  494. dev->get_stats = ax_get_stats;
  495. dev->set_mac_address = ax_set_mac_address;
  496. dev->hard_header_len = 0;
  497. dev->addr_len = 0;
  498. dev->type = ARPHRD_AX25;
  499. dev->tx_queue_len = 10;
  500. dev->hard_header = ax_header;
  501. dev->rebuild_header = ax_rebuild_header;
  502. memcpy(dev->broadcast, ax25_bcast, AX25_ADDR_LEN);
  503. memcpy(dev->dev_addr, ax25_test, AX25_ADDR_LEN);
  504. dev->flags = IFF_BROADCAST | IFF_MULTICAST;
  505. }
  506. /*
  507. * We have a potential race on dereferencing tty->disc_data, because the tty
  508. * layer provides no locking at all - thus one cpu could be running
  509. * sixpack_receive_buf while another calls sixpack_close, which zeroes
  510. * tty->disc_data and frees the memory that sixpack_receive_buf is using. The
  511. * best way to fix this is to use a rwlock in the tty struct, but for now we
  512. * use a single global rwlock for all ttys in ppp line discipline.
  513. */
  514. static rwlock_t disc_data_lock = RW_LOCK_UNLOCKED;
  515. static struct mkiss *mkiss_get(struct tty_struct *tty)
  516. {
  517. struct mkiss *ax;
  518. read_lock(&disc_data_lock);
  519. ax = tty->disc_data;
  520. if (ax)
  521. atomic_inc(&ax->refcnt);
  522. read_unlock(&disc_data_lock);
  523. return ax;
  524. }
  525. static void mkiss_put(struct mkiss *ax)
  526. {
  527. if (atomic_dec_and_test(&ax->refcnt))
  528. up(&ax->dead_sem);
  529. }
  530. static int mkiss_open(struct tty_struct *tty)
  531. {
  532. struct net_device *dev;
  533. struct mkiss *ax;
  534. int err;
  535. if (!capable(CAP_NET_ADMIN))
  536. return -EPERM;
  537. dev = alloc_netdev(sizeof(struct mkiss), "ax%d", ax_setup);
  538. if (!dev) {
  539. err = -ENOMEM;
  540. goto out;
  541. }
  542. ax = netdev_priv(dev);
  543. ax->dev = dev;
  544. spin_lock_init(&ax->buflock);
  545. atomic_set(&ax->refcnt, 1);
  546. init_MUTEX_LOCKED(&ax->dead_sem);
  547. ax->tty = tty;
  548. tty->disc_data = ax;
  549. if (tty->driver->flush_buffer)
  550. tty->driver->flush_buffer(tty);
  551. /* Restore default settings */
  552. dev->type = ARPHRD_AX25;
  553. /* Perform the low-level AX25 initialization. */
  554. if ((err = ax_open(ax->dev))) {
  555. goto out_free_netdev;
  556. }
  557. if (register_netdev(dev))
  558. goto out_free_buffers;
  559. netif_start_queue(dev);
  560. /* Done. We have linked the TTY line to a channel. */
  561. return 0;
  562. out_free_buffers:
  563. kfree(ax->rbuff);
  564. kfree(ax->xbuff);
  565. out_free_netdev:
  566. free_netdev(dev);
  567. out:
  568. return err;
  569. }
  570. static void mkiss_close(struct tty_struct *tty)
  571. {
  572. struct mkiss *ax;
  573. write_lock(&disc_data_lock);
  574. ax = tty->disc_data;
  575. tty->disc_data = NULL;
  576. write_unlock(&disc_data_lock);
  577. if (ax == 0)
  578. return;
  579. /*
  580. * We have now ensured that nobody can start using ap from now on, but
  581. * we have to wait for all existing users to finish.
  582. */
  583. if (!atomic_dec_and_test(&ax->refcnt))
  584. down(&ax->dead_sem);
  585. unregister_netdev(ax->dev);
  586. /* Free all AX25 frame buffers. */
  587. kfree(ax->rbuff);
  588. kfree(ax->xbuff);
  589. ax->tty = NULL;
  590. }
  591. /* Perform I/O control on an active ax25 channel. */
  592. static int mkiss_ioctl(struct tty_struct *tty, struct file *file,
  593. unsigned int cmd, unsigned long arg)
  594. {
  595. struct mkiss *ax = mkiss_get(tty);
  596. struct net_device *dev = ax->dev;
  597. unsigned int tmp, err;
  598. /* First make sure we're connected. */
  599. if (ax == NULL)
  600. return -ENXIO;
  601. switch (cmd) {
  602. case SIOCGIFNAME:
  603. err = copy_to_user((void __user *) arg, ax->dev->name,
  604. strlen(ax->dev->name) + 1) ? -EFAULT : 0;
  605. break;
  606. case SIOCGIFENCAP:
  607. err = put_user(4, (int __user *) arg);
  608. break;
  609. case SIOCSIFENCAP:
  610. if (get_user(tmp, (int __user *) arg)) {
  611. err = -EFAULT;
  612. break;
  613. }
  614. ax->mode = tmp;
  615. dev->addr_len = AX25_ADDR_LEN;
  616. dev->hard_header_len = AX25_KISS_HEADER_LEN +
  617. AX25_MAX_HEADER_LEN + 3;
  618. dev->type = ARPHRD_AX25;
  619. err = 0;
  620. break;
  621. case SIOCSIFHWADDR: {
  622. char addr[AX25_ADDR_LEN];
  623. printk(KERN_INFO "In SIOCSIFHWADDR");
  624. if (copy_from_user(&addr,
  625. (void __user *) arg, AX25_ADDR_LEN)) {
  626. err = -EFAULT;
  627. break;
  628. }
  629. spin_lock_irq(&dev->xmit_lock);
  630. memcpy(dev->dev_addr, addr, AX25_ADDR_LEN);
  631. spin_unlock_irq(&dev->xmit_lock);
  632. err = 0;
  633. break;
  634. }
  635. default:
  636. err = -ENOIOCTLCMD;
  637. }
  638. mkiss_put(ax);
  639. return err;
  640. }
  641. /*
  642. * Handle the 'receiver data ready' interrupt.
  643. * This function is called by the 'tty_io' module in the kernel when
  644. * a block of data has been received, which can now be decapsulated
  645. * and sent on to the AX.25 layer for further processing.
  646. */
  647. static void mkiss_receive_buf(struct tty_struct *tty, const unsigned char *cp,
  648. char *fp, int count)
  649. {
  650. struct mkiss *ax = mkiss_get(tty);
  651. if (!ax)
  652. return;
  653. /*
  654. * Argh! mtu change time! - costs us the packet part received
  655. * at the change
  656. */
  657. if (ax->mtu != ax->dev->mtu + 73)
  658. ax_changedmtu(ax);
  659. /* Read the characters out of the buffer */
  660. while (count--) {
  661. if (fp != NULL && *fp++) {
  662. if (!test_and_set_bit(AXF_ERROR, &ax->flags))
  663. ax->stats.rx_errors++;
  664. cp++;
  665. continue;
  666. }
  667. kiss_unesc(ax, *cp++);
  668. }
  669. mkiss_put(ax);
  670. if (test_and_clear_bit(TTY_THROTTLED, &tty->flags)
  671. && tty->driver->unthrottle)
  672. tty->driver->unthrottle(tty);
  673. }
  674. static int mkiss_receive_room(struct tty_struct *tty)
  675. {
  676. return 65536; /* We can handle an infinite amount of data. :-) */
  677. }
  678. /*
  679. * Called by the driver when there's room for more data. If we have
  680. * more packets to send, we send them here.
  681. */
  682. static void mkiss_write_wakeup(struct tty_struct *tty)
  683. {
  684. struct mkiss *ax = mkiss_get(tty);
  685. int actual;
  686. if (!ax)
  687. return;
  688. if (ax->xleft <= 0) {
  689. /* Now serial buffer is almost free & we can start
  690. * transmission of another packet
  691. */
  692. clear_bit(TTY_DO_WRITE_WAKEUP, &tty->flags);
  693. netif_wake_queue(ax->dev);
  694. goto out;
  695. }
  696. actual = tty->driver->write(tty, ax->xhead, ax->xleft);
  697. ax->xleft -= actual;
  698. ax->xhead += actual;
  699. out:
  700. mkiss_put(ax);
  701. }
  702. static struct tty_ldisc ax_ldisc = {
  703. .magic = TTY_LDISC_MAGIC,
  704. .name = "mkiss",
  705. .open = mkiss_open,
  706. .close = mkiss_close,
  707. .ioctl = mkiss_ioctl,
  708. .receive_buf = mkiss_receive_buf,
  709. .receive_room = mkiss_receive_room,
  710. .write_wakeup = mkiss_write_wakeup
  711. };
  712. static char banner[] __initdata = KERN_INFO \
  713. "mkiss: AX.25 Multikiss, Hans Albas PE1AYX\n";
  714. static char msg_regfail[] __initdata = KERN_ERR \
  715. "mkiss: can't register line discipline (err = %d)\n";
  716. static int __init mkiss_init_driver(void)
  717. {
  718. int status;
  719. printk(banner);
  720. if ((status = tty_register_ldisc(N_AX25, &ax_ldisc)) != 0)
  721. printk(msg_regfail);
  722. return status;
  723. }
  724. static const char msg_unregfail[] __exitdata = KERN_ERR \
  725. "mkiss: can't unregister line discipline (err = %d)\n";
  726. static void __exit mkiss_exit_driver(void)
  727. {
  728. int ret;
  729. if ((ret = tty_unregister_ldisc(N_AX25)))
  730. printk(msg_unregfail, ret);
  731. }
  732. MODULE_AUTHOR("Ralf Baechle DL5RB <ralf@linux-mips.org>");
  733. MODULE_DESCRIPTION("KISS driver for AX.25 over TTYs");
  734. MODULE_LICENSE("GPL");
  735. MODULE_ALIAS_LDISC(N_AX25);
  736. module_init(mkiss_init_driver);
  737. module_exit(mkiss_exit_driver);