socket.c 18 KB

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