socket.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839
  1. /*
  2. *
  3. * Author Karsten Keil <kkeil@novell.com>
  4. *
  5. * Copyright 2008 by Karsten Keil <kkeil@novell.com>
  6. *
  7. * This program is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License version 2 as
  9. * published by the Free Software Foundation.
  10. *
  11. * This program is distributed in the hope that it will be useful,
  12. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. * GNU General Public License for more details.
  15. *
  16. */
  17. #include <linux/mISDNif.h>
  18. #include <linux/slab.h>
  19. #include <linux/export.h>
  20. #include "core.h"
  21. static u_int *debug;
  22. static struct proto mISDN_proto = {
  23. .name = "misdn",
  24. .owner = THIS_MODULE,
  25. .obj_size = sizeof(struct mISDN_sock)
  26. };
  27. #define _pms(sk) ((struct mISDN_sock *)sk)
  28. static struct mISDN_sock_list data_sockets = {
  29. .lock = __RW_LOCK_UNLOCKED(data_sockets.lock)
  30. };
  31. static struct mISDN_sock_list base_sockets = {
  32. .lock = __RW_LOCK_UNLOCKED(base_sockets.lock)
  33. };
  34. #define L2_HEADER_LEN 4
  35. static inline struct sk_buff *
  36. _l2_alloc_skb(unsigned int len, gfp_t gfp_mask)
  37. {
  38. struct sk_buff *skb;
  39. skb = alloc_skb(len + L2_HEADER_LEN, gfp_mask);
  40. if (likely(skb))
  41. skb_reserve(skb, L2_HEADER_LEN);
  42. return skb;
  43. }
  44. static void
  45. mISDN_sock_link(struct mISDN_sock_list *l, struct sock *sk)
  46. {
  47. write_lock_bh(&l->lock);
  48. sk_add_node(sk, &l->head);
  49. write_unlock_bh(&l->lock);
  50. }
  51. static void mISDN_sock_unlink(struct mISDN_sock_list *l, struct sock *sk)
  52. {
  53. write_lock_bh(&l->lock);
  54. sk_del_node_init(sk);
  55. write_unlock_bh(&l->lock);
  56. }
  57. static int
  58. mISDN_send(struct mISDNchannel *ch, struct sk_buff *skb)
  59. {
  60. struct mISDN_sock *msk;
  61. int err;
  62. msk = container_of(ch, struct mISDN_sock, ch);
  63. if (*debug & DEBUG_SOCKET)
  64. printk(KERN_DEBUG "%s len %d %p\n", __func__, skb->len, skb);
  65. if (msk->sk.sk_state == MISDN_CLOSED)
  66. return -EUNATCH;
  67. __net_timestamp(skb);
  68. err = sock_queue_rcv_skb(&msk->sk, skb);
  69. if (err)
  70. printk(KERN_WARNING "%s: error %d\n", __func__, err);
  71. return err;
  72. }
  73. static int
  74. mISDN_ctrl(struct mISDNchannel *ch, u_int cmd, void *arg)
  75. {
  76. struct mISDN_sock *msk;
  77. msk = container_of(ch, struct mISDN_sock, ch);
  78. if (*debug & DEBUG_SOCKET)
  79. printk(KERN_DEBUG "%s(%p, %x, %p)\n", __func__, ch, cmd, arg);
  80. switch (cmd) {
  81. case CLOSE_CHANNEL:
  82. msk->sk.sk_state = MISDN_CLOSED;
  83. break;
  84. }
  85. return 0;
  86. }
  87. static inline void
  88. mISDN_sock_cmsg(struct sock *sk, struct msghdr *msg, struct sk_buff *skb)
  89. {
  90. struct timeval tv;
  91. if (_pms(sk)->cmask & MISDN_TIME_STAMP) {
  92. skb_get_timestamp(skb, &tv);
  93. put_cmsg(msg, SOL_MISDN, MISDN_TIME_STAMP, sizeof(tv), &tv);
  94. }
  95. }
  96. static int
  97. mISDN_sock_recvmsg(struct kiocb *iocb, struct socket *sock,
  98. struct msghdr *msg, size_t len, int flags)
  99. {
  100. struct sk_buff *skb;
  101. struct sock *sk = sock->sk;
  102. struct sockaddr_mISDN *maddr;
  103. int copied, err;
  104. if (*debug & DEBUG_SOCKET)
  105. printk(KERN_DEBUG "%s: len %d, flags %x ch.nr %d, proto %x\n",
  106. __func__, (int)len, flags, _pms(sk)->ch.nr,
  107. sk->sk_protocol);
  108. if (flags & (MSG_OOB))
  109. return -EOPNOTSUPP;
  110. if (sk->sk_state == MISDN_CLOSED)
  111. return 0;
  112. skb = skb_recv_datagram(sk, flags, flags & MSG_DONTWAIT, &err);
  113. if (!skb)
  114. return err;
  115. if (msg->msg_namelen >= sizeof(struct sockaddr_mISDN)) {
  116. msg->msg_namelen = sizeof(struct sockaddr_mISDN);
  117. maddr = (struct sockaddr_mISDN *)msg->msg_name;
  118. maddr->family = AF_ISDN;
  119. maddr->dev = _pms(sk)->dev->id;
  120. if ((sk->sk_protocol == ISDN_P_LAPD_TE) ||
  121. (sk->sk_protocol == ISDN_P_LAPD_NT)) {
  122. maddr->channel = (mISDN_HEAD_ID(skb) >> 16) & 0xff;
  123. maddr->tei = (mISDN_HEAD_ID(skb) >> 8) & 0xff;
  124. maddr->sapi = mISDN_HEAD_ID(skb) & 0xff;
  125. } else {
  126. maddr->channel = _pms(sk)->ch.nr;
  127. maddr->sapi = _pms(sk)->ch.addr & 0xFF;
  128. maddr->tei = (_pms(sk)->ch.addr >> 8) & 0xFF;
  129. }
  130. } else {
  131. if (msg->msg_namelen)
  132. printk(KERN_WARNING "%s: too small namelen %d\n",
  133. __func__, msg->msg_namelen);
  134. msg->msg_namelen = 0;
  135. }
  136. copied = skb->len + MISDN_HEADER_LEN;
  137. if (len < copied) {
  138. if (flags & MSG_PEEK)
  139. atomic_dec(&skb->users);
  140. else
  141. skb_queue_head(&sk->sk_receive_queue, skb);
  142. return -ENOSPC;
  143. }
  144. memcpy(skb_push(skb, MISDN_HEADER_LEN), mISDN_HEAD_P(skb),
  145. MISDN_HEADER_LEN);
  146. err = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, copied);
  147. mISDN_sock_cmsg(sk, msg, skb);
  148. skb_free_datagram(sk, skb);
  149. return err ? : copied;
  150. }
  151. static int
  152. mISDN_sock_sendmsg(struct kiocb *iocb, struct socket *sock,
  153. struct msghdr *msg, size_t len)
  154. {
  155. struct sock *sk = sock->sk;
  156. struct sk_buff *skb;
  157. int err = -ENOMEM;
  158. struct sockaddr_mISDN *maddr;
  159. if (*debug & DEBUG_SOCKET)
  160. printk(KERN_DEBUG "%s: len %d flags %x ch %d proto %x\n",
  161. __func__, (int)len, msg->msg_flags, _pms(sk)->ch.nr,
  162. sk->sk_protocol);
  163. if (msg->msg_flags & MSG_OOB)
  164. return -EOPNOTSUPP;
  165. if (msg->msg_flags & ~(MSG_DONTWAIT | MSG_NOSIGNAL | MSG_ERRQUEUE))
  166. return -EINVAL;
  167. if (len < MISDN_HEADER_LEN)
  168. return -EINVAL;
  169. if (sk->sk_state != MISDN_BOUND)
  170. return -EBADFD;
  171. lock_sock(sk);
  172. skb = _l2_alloc_skb(len, GFP_KERNEL);
  173. if (!skb)
  174. goto done;
  175. if (memcpy_fromiovec(skb_put(skb, len), msg->msg_iov, len)) {
  176. err = -EFAULT;
  177. goto done;
  178. }
  179. memcpy(mISDN_HEAD_P(skb), skb->data, MISDN_HEADER_LEN);
  180. skb_pull(skb, MISDN_HEADER_LEN);
  181. if (msg->msg_namelen >= sizeof(struct sockaddr_mISDN)) {
  182. /* if we have a address, we use it */
  183. maddr = (struct sockaddr_mISDN *)msg->msg_name;
  184. mISDN_HEAD_ID(skb) = maddr->channel;
  185. } else { /* use default for L2 messages */
  186. if ((sk->sk_protocol == ISDN_P_LAPD_TE) ||
  187. (sk->sk_protocol == ISDN_P_LAPD_NT))
  188. mISDN_HEAD_ID(skb) = _pms(sk)->ch.nr;
  189. }
  190. if (*debug & DEBUG_SOCKET)
  191. printk(KERN_DEBUG "%s: ID:%x\n",
  192. __func__, mISDN_HEAD_ID(skb));
  193. err = -ENODEV;
  194. if (!_pms(sk)->ch.peer)
  195. goto done;
  196. err = _pms(sk)->ch.recv(_pms(sk)->ch.peer, skb);
  197. if (err)
  198. goto done;
  199. else {
  200. skb = NULL;
  201. err = len;
  202. }
  203. done:
  204. if (skb)
  205. kfree_skb(skb);
  206. release_sock(sk);
  207. return err;
  208. }
  209. static int
  210. data_sock_release(struct socket *sock)
  211. {
  212. struct sock *sk = sock->sk;
  213. if (*debug & DEBUG_SOCKET)
  214. printk(KERN_DEBUG "%s(%p) sk=%p\n", __func__, sock, sk);
  215. if (!sk)
  216. return 0;
  217. switch (sk->sk_protocol) {
  218. case ISDN_P_TE_S0:
  219. case ISDN_P_NT_S0:
  220. case ISDN_P_TE_E1:
  221. case ISDN_P_NT_E1:
  222. if (sk->sk_state == MISDN_BOUND)
  223. delete_channel(&_pms(sk)->ch);
  224. else
  225. mISDN_sock_unlink(&data_sockets, sk);
  226. break;
  227. case ISDN_P_LAPD_TE:
  228. case ISDN_P_LAPD_NT:
  229. case ISDN_P_B_RAW:
  230. case ISDN_P_B_HDLC:
  231. case ISDN_P_B_X75SLP:
  232. case ISDN_P_B_L2DTMF:
  233. case ISDN_P_B_L2DSP:
  234. case ISDN_P_B_L2DSPHDLC:
  235. delete_channel(&_pms(sk)->ch);
  236. mISDN_sock_unlink(&data_sockets, sk);
  237. break;
  238. }
  239. lock_sock(sk);
  240. sock_orphan(sk);
  241. skb_queue_purge(&sk->sk_receive_queue);
  242. release_sock(sk);
  243. sock_put(sk);
  244. return 0;
  245. }
  246. static int
  247. data_sock_ioctl_bound(struct sock *sk, unsigned int cmd, void __user *p)
  248. {
  249. struct mISDN_ctrl_req cq;
  250. int err = -EINVAL, val[2];
  251. struct mISDNchannel *bchan, *next;
  252. lock_sock(sk);
  253. if (!_pms(sk)->dev) {
  254. err = -ENODEV;
  255. goto done;
  256. }
  257. switch (cmd) {
  258. case IMCTRLREQ:
  259. if (copy_from_user(&cq, p, sizeof(cq))) {
  260. err = -EFAULT;
  261. break;
  262. }
  263. if ((sk->sk_protocol & ~ISDN_P_B_MASK) == ISDN_P_B_START) {
  264. list_for_each_entry_safe(bchan, next,
  265. &_pms(sk)->dev->bchannels, list) {
  266. if (bchan->nr == cq.channel) {
  267. err = bchan->ctrl(bchan,
  268. CONTROL_CHANNEL, &cq);
  269. break;
  270. }
  271. }
  272. } else
  273. err = _pms(sk)->dev->D.ctrl(&_pms(sk)->dev->D,
  274. CONTROL_CHANNEL, &cq);
  275. if (err)
  276. break;
  277. if (copy_to_user(p, &cq, sizeof(cq)))
  278. err = -EFAULT;
  279. break;
  280. case IMCLEAR_L2:
  281. if (sk->sk_protocol != ISDN_P_LAPD_NT) {
  282. err = -EINVAL;
  283. break;
  284. }
  285. val[0] = cmd;
  286. if (get_user(val[1], (int __user *)p)) {
  287. err = -EFAULT;
  288. break;
  289. }
  290. err = _pms(sk)->dev->teimgr->ctrl(_pms(sk)->dev->teimgr,
  291. CONTROL_CHANNEL, val);
  292. break;
  293. case IMHOLD_L1:
  294. if (sk->sk_protocol != ISDN_P_LAPD_NT
  295. && sk->sk_protocol != ISDN_P_LAPD_TE) {
  296. err = -EINVAL;
  297. break;
  298. }
  299. val[0] = cmd;
  300. if (get_user(val[1], (int __user *)p)) {
  301. err = -EFAULT;
  302. break;
  303. }
  304. err = _pms(sk)->dev->teimgr->ctrl(_pms(sk)->dev->teimgr,
  305. CONTROL_CHANNEL, val);
  306. break;
  307. default:
  308. err = -EINVAL;
  309. break;
  310. }
  311. done:
  312. release_sock(sk);
  313. return err;
  314. }
  315. static int
  316. data_sock_ioctl(struct socket *sock, unsigned int cmd, unsigned long arg)
  317. {
  318. int err = 0, id;
  319. struct sock *sk = sock->sk;
  320. struct mISDNdevice *dev;
  321. struct mISDNversion ver;
  322. switch (cmd) {
  323. case IMGETVERSION:
  324. ver.major = MISDN_MAJOR_VERSION;
  325. ver.minor = MISDN_MINOR_VERSION;
  326. ver.release = MISDN_RELEASE;
  327. if (copy_to_user((void __user *)arg, &ver, sizeof(ver)))
  328. err = -EFAULT;
  329. break;
  330. case IMGETCOUNT:
  331. id = get_mdevice_count();
  332. if (put_user(id, (int __user *)arg))
  333. err = -EFAULT;
  334. break;
  335. case IMGETDEVINFO:
  336. if (get_user(id, (int __user *)arg)) {
  337. err = -EFAULT;
  338. break;
  339. }
  340. dev = get_mdevice(id);
  341. if (dev) {
  342. struct mISDN_devinfo di;
  343. memset(&di, 0, sizeof(di));
  344. di.id = dev->id;
  345. di.Dprotocols = dev->Dprotocols;
  346. di.Bprotocols = dev->Bprotocols | get_all_Bprotocols();
  347. di.protocol = dev->D.protocol;
  348. memcpy(di.channelmap, dev->channelmap,
  349. sizeof(di.channelmap));
  350. di.nrbchan = dev->nrbchan;
  351. strcpy(di.name, dev_name(&dev->dev));
  352. if (copy_to_user((void __user *)arg, &di, sizeof(di)))
  353. err = -EFAULT;
  354. } else
  355. err = -ENODEV;
  356. break;
  357. default:
  358. if (sk->sk_state == MISDN_BOUND)
  359. err = data_sock_ioctl_bound(sk, cmd,
  360. (void __user *)arg);
  361. else
  362. err = -ENOTCONN;
  363. }
  364. return err;
  365. }
  366. static int data_sock_setsockopt(struct socket *sock, int level, int optname,
  367. char __user *optval, unsigned int len)
  368. {
  369. struct sock *sk = sock->sk;
  370. int err = 0, opt = 0;
  371. if (*debug & DEBUG_SOCKET)
  372. printk(KERN_DEBUG "%s(%p, %d, %x, %p, %d)\n", __func__, sock,
  373. level, optname, optval, len);
  374. lock_sock(sk);
  375. switch (optname) {
  376. case MISDN_TIME_STAMP:
  377. if (get_user(opt, (int __user *)optval)) {
  378. err = -EFAULT;
  379. break;
  380. }
  381. if (opt)
  382. _pms(sk)->cmask |= MISDN_TIME_STAMP;
  383. else
  384. _pms(sk)->cmask &= ~MISDN_TIME_STAMP;
  385. break;
  386. default:
  387. err = -ENOPROTOOPT;
  388. break;
  389. }
  390. release_sock(sk);
  391. return err;
  392. }
  393. static int data_sock_getsockopt(struct socket *sock, int level, int optname,
  394. char __user *optval, int __user *optlen)
  395. {
  396. struct sock *sk = sock->sk;
  397. int len, opt;
  398. if (get_user(len, optlen))
  399. return -EFAULT;
  400. if (len != sizeof(char))
  401. return -EINVAL;
  402. switch (optname) {
  403. case MISDN_TIME_STAMP:
  404. if (_pms(sk)->cmask & MISDN_TIME_STAMP)
  405. opt = 1;
  406. else
  407. opt = 0;
  408. if (put_user(opt, optval))
  409. return -EFAULT;
  410. break;
  411. default:
  412. return -ENOPROTOOPT;
  413. }
  414. return 0;
  415. }
  416. static int
  417. data_sock_bind(struct socket *sock, struct sockaddr *addr, int addr_len)
  418. {
  419. struct sockaddr_mISDN *maddr = (struct sockaddr_mISDN *) addr;
  420. struct sock *sk = sock->sk;
  421. struct sock *csk;
  422. int err = 0;
  423. if (*debug & DEBUG_SOCKET)
  424. printk(KERN_DEBUG "%s(%p) sk=%p\n", __func__, sock, sk);
  425. if (addr_len != sizeof(struct sockaddr_mISDN))
  426. return -EINVAL;
  427. if (!maddr || maddr->family != AF_ISDN)
  428. return -EINVAL;
  429. lock_sock(sk);
  430. if (_pms(sk)->dev) {
  431. err = -EALREADY;
  432. goto done;
  433. }
  434. _pms(sk)->dev = get_mdevice(maddr->dev);
  435. if (!_pms(sk)->dev) {
  436. err = -ENODEV;
  437. goto done;
  438. }
  439. if (sk->sk_protocol < ISDN_P_B_START) {
  440. read_lock_bh(&data_sockets.lock);
  441. sk_for_each(csk, &data_sockets.head) {
  442. if (sk == csk)
  443. continue;
  444. if (_pms(csk)->dev != _pms(sk)->dev)
  445. continue;
  446. if (csk->sk_protocol >= ISDN_P_B_START)
  447. continue;
  448. if (IS_ISDN_P_TE(csk->sk_protocol)
  449. == IS_ISDN_P_TE(sk->sk_protocol))
  450. continue;
  451. read_unlock_bh(&data_sockets.lock);
  452. err = -EBUSY;
  453. goto done;
  454. }
  455. read_unlock_bh(&data_sockets.lock);
  456. }
  457. _pms(sk)->ch.send = mISDN_send;
  458. _pms(sk)->ch.ctrl = mISDN_ctrl;
  459. switch (sk->sk_protocol) {
  460. case ISDN_P_TE_S0:
  461. case ISDN_P_NT_S0:
  462. case ISDN_P_TE_E1:
  463. case ISDN_P_NT_E1:
  464. mISDN_sock_unlink(&data_sockets, sk);
  465. err = connect_layer1(_pms(sk)->dev, &_pms(sk)->ch,
  466. sk->sk_protocol, maddr);
  467. if (err)
  468. mISDN_sock_link(&data_sockets, sk);
  469. break;
  470. case ISDN_P_LAPD_TE:
  471. case ISDN_P_LAPD_NT:
  472. err = create_l2entity(_pms(sk)->dev, &_pms(sk)->ch,
  473. sk->sk_protocol, maddr);
  474. break;
  475. case ISDN_P_B_RAW:
  476. case ISDN_P_B_HDLC:
  477. case ISDN_P_B_X75SLP:
  478. case ISDN_P_B_L2DTMF:
  479. case ISDN_P_B_L2DSP:
  480. case ISDN_P_B_L2DSPHDLC:
  481. err = connect_Bstack(_pms(sk)->dev, &_pms(sk)->ch,
  482. sk->sk_protocol, maddr);
  483. break;
  484. default:
  485. err = -EPROTONOSUPPORT;
  486. }
  487. if (err)
  488. goto done;
  489. sk->sk_state = MISDN_BOUND;
  490. _pms(sk)->ch.protocol = sk->sk_protocol;
  491. done:
  492. release_sock(sk);
  493. return err;
  494. }
  495. static int
  496. data_sock_getname(struct socket *sock, struct sockaddr *addr,
  497. int *addr_len, int peer)
  498. {
  499. struct sockaddr_mISDN *maddr = (struct sockaddr_mISDN *) addr;
  500. struct sock *sk = sock->sk;
  501. if (!_pms(sk)->dev)
  502. return -EBADFD;
  503. lock_sock(sk);
  504. *addr_len = sizeof(*maddr);
  505. maddr->dev = _pms(sk)->dev->id;
  506. maddr->channel = _pms(sk)->ch.nr;
  507. maddr->sapi = _pms(sk)->ch.addr & 0xff;
  508. maddr->tei = (_pms(sk)->ch.addr >> 8) & 0xff;
  509. release_sock(sk);
  510. return 0;
  511. }
  512. static const struct proto_ops data_sock_ops = {
  513. .family = PF_ISDN,
  514. .owner = THIS_MODULE,
  515. .release = data_sock_release,
  516. .ioctl = data_sock_ioctl,
  517. .bind = data_sock_bind,
  518. .getname = data_sock_getname,
  519. .sendmsg = mISDN_sock_sendmsg,
  520. .recvmsg = mISDN_sock_recvmsg,
  521. .poll = datagram_poll,
  522. .listen = sock_no_listen,
  523. .shutdown = sock_no_shutdown,
  524. .setsockopt = data_sock_setsockopt,
  525. .getsockopt = data_sock_getsockopt,
  526. .connect = sock_no_connect,
  527. .socketpair = sock_no_socketpair,
  528. .accept = sock_no_accept,
  529. .mmap = sock_no_mmap
  530. };
  531. static int
  532. data_sock_create(struct net *net, struct socket *sock, int protocol)
  533. {
  534. struct sock *sk;
  535. if (sock->type != SOCK_DGRAM)
  536. return -ESOCKTNOSUPPORT;
  537. sk = sk_alloc(net, PF_ISDN, GFP_KERNEL, &mISDN_proto);
  538. if (!sk)
  539. return -ENOMEM;
  540. sock_init_data(sock, sk);
  541. sock->ops = &data_sock_ops;
  542. sock->state = SS_UNCONNECTED;
  543. sock_reset_flag(sk, SOCK_ZAPPED);
  544. sk->sk_protocol = protocol;
  545. sk->sk_state = MISDN_OPEN;
  546. mISDN_sock_link(&data_sockets, sk);
  547. return 0;
  548. }
  549. static int
  550. base_sock_release(struct socket *sock)
  551. {
  552. struct sock *sk = sock->sk;
  553. printk(KERN_DEBUG "%s(%p) sk=%p\n", __func__, sock, sk);
  554. if (!sk)
  555. return 0;
  556. mISDN_sock_unlink(&base_sockets, sk);
  557. sock_orphan(sk);
  558. sock_put(sk);
  559. return 0;
  560. }
  561. static int
  562. base_sock_ioctl(struct socket *sock, unsigned int cmd, unsigned long arg)
  563. {
  564. int err = 0, id;
  565. struct mISDNdevice *dev;
  566. struct mISDNversion ver;
  567. switch (cmd) {
  568. case IMGETVERSION:
  569. ver.major = MISDN_MAJOR_VERSION;
  570. ver.minor = MISDN_MINOR_VERSION;
  571. ver.release = MISDN_RELEASE;
  572. if (copy_to_user((void __user *)arg, &ver, sizeof(ver)))
  573. err = -EFAULT;
  574. break;
  575. case IMGETCOUNT:
  576. id = get_mdevice_count();
  577. if (put_user(id, (int __user *)arg))
  578. err = -EFAULT;
  579. break;
  580. case IMGETDEVINFO:
  581. if (get_user(id, (int __user *)arg)) {
  582. err = -EFAULT;
  583. break;
  584. }
  585. dev = get_mdevice(id);
  586. if (dev) {
  587. struct mISDN_devinfo di;
  588. memset(&di, 0, sizeof(di));
  589. di.id = dev->id;
  590. di.Dprotocols = dev->Dprotocols;
  591. di.Bprotocols = dev->Bprotocols | get_all_Bprotocols();
  592. di.protocol = dev->D.protocol;
  593. memcpy(di.channelmap, dev->channelmap,
  594. sizeof(di.channelmap));
  595. di.nrbchan = dev->nrbchan;
  596. strcpy(di.name, dev_name(&dev->dev));
  597. if (copy_to_user((void __user *)arg, &di, sizeof(di)))
  598. err = -EFAULT;
  599. } else
  600. err = -ENODEV;
  601. break;
  602. case IMSETDEVNAME:
  603. {
  604. struct mISDN_devrename dn;
  605. if (copy_from_user(&dn, (void __user *)arg,
  606. sizeof(dn))) {
  607. err = -EFAULT;
  608. break;
  609. }
  610. dev = get_mdevice(dn.id);
  611. if (dev)
  612. err = device_rename(&dev->dev, dn.name);
  613. else
  614. err = -ENODEV;
  615. }
  616. break;
  617. default:
  618. err = -EINVAL;
  619. }
  620. return err;
  621. }
  622. static int
  623. base_sock_bind(struct socket *sock, struct sockaddr *addr, int addr_len)
  624. {
  625. struct sockaddr_mISDN *maddr = (struct sockaddr_mISDN *) addr;
  626. struct sock *sk = sock->sk;
  627. int err = 0;
  628. if (!maddr || maddr->family != AF_ISDN)
  629. return -EINVAL;
  630. lock_sock(sk);
  631. if (_pms(sk)->dev) {
  632. err = -EALREADY;
  633. goto done;
  634. }
  635. _pms(sk)->dev = get_mdevice(maddr->dev);
  636. if (!_pms(sk)->dev) {
  637. err = -ENODEV;
  638. goto done;
  639. }
  640. sk->sk_state = MISDN_BOUND;
  641. done:
  642. release_sock(sk);
  643. return err;
  644. }
  645. static const struct proto_ops base_sock_ops = {
  646. .family = PF_ISDN,
  647. .owner = THIS_MODULE,
  648. .release = base_sock_release,
  649. .ioctl = base_sock_ioctl,
  650. .bind = base_sock_bind,
  651. .getname = sock_no_getname,
  652. .sendmsg = sock_no_sendmsg,
  653. .recvmsg = sock_no_recvmsg,
  654. .poll = sock_no_poll,
  655. .listen = sock_no_listen,
  656. .shutdown = sock_no_shutdown,
  657. .setsockopt = sock_no_setsockopt,
  658. .getsockopt = sock_no_getsockopt,
  659. .connect = sock_no_connect,
  660. .socketpair = sock_no_socketpair,
  661. .accept = sock_no_accept,
  662. .mmap = sock_no_mmap
  663. };
  664. static int
  665. base_sock_create(struct net *net, struct socket *sock, int protocol)
  666. {
  667. struct sock *sk;
  668. if (sock->type != SOCK_RAW)
  669. return -ESOCKTNOSUPPORT;
  670. sk = sk_alloc(net, PF_ISDN, GFP_KERNEL, &mISDN_proto);
  671. if (!sk)
  672. return -ENOMEM;
  673. sock_init_data(sock, sk);
  674. sock->ops = &base_sock_ops;
  675. sock->state = SS_UNCONNECTED;
  676. sock_reset_flag(sk, SOCK_ZAPPED);
  677. sk->sk_protocol = protocol;
  678. sk->sk_state = MISDN_OPEN;
  679. mISDN_sock_link(&base_sockets, sk);
  680. return 0;
  681. }
  682. static int
  683. mISDN_sock_create(struct net *net, struct socket *sock, int proto, int kern)
  684. {
  685. int err = -EPROTONOSUPPORT;
  686. switch (proto) {
  687. case ISDN_P_BASE:
  688. err = base_sock_create(net, sock, proto);
  689. break;
  690. case ISDN_P_TE_S0:
  691. case ISDN_P_NT_S0:
  692. case ISDN_P_TE_E1:
  693. case ISDN_P_NT_E1:
  694. case ISDN_P_LAPD_TE:
  695. case ISDN_P_LAPD_NT:
  696. case ISDN_P_B_RAW:
  697. case ISDN_P_B_HDLC:
  698. case ISDN_P_B_X75SLP:
  699. case ISDN_P_B_L2DTMF:
  700. case ISDN_P_B_L2DSP:
  701. case ISDN_P_B_L2DSPHDLC:
  702. err = data_sock_create(net, sock, proto);
  703. break;
  704. default:
  705. return err;
  706. }
  707. return err;
  708. }
  709. static const struct net_proto_family mISDN_sock_family_ops = {
  710. .owner = THIS_MODULE,
  711. .family = PF_ISDN,
  712. .create = mISDN_sock_create,
  713. };
  714. int
  715. misdn_sock_init(u_int *deb)
  716. {
  717. int err;
  718. debug = deb;
  719. err = sock_register(&mISDN_sock_family_ops);
  720. if (err)
  721. printk(KERN_ERR "%s: error(%d)\n", __func__, err);
  722. return err;
  723. }
  724. void
  725. misdn_sock_cleanup(void)
  726. {
  727. sock_unregister(PF_ISDN);
  728. }