llcp_core.c 36 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699
  1. // SPDX-License-Identifier: GPL-2.0-or-later
  2. /*
  3. * Copyright (C) 2011 Intel Corporation. All rights reserved.
  4. * Copyright (C) 2014 Marvell International Ltd.
  5. */
  6. #define pr_fmt(fmt) "llcp: %s: " fmt, __func__
  7. #include <linux/init.h>
  8. #include <linux/kernel.h>
  9. #include <linux/list.h>
  10. #include <linux/nfc.h>
  11. #include "nfc.h"
  12. #include "llcp.h"
  13. static u8 llcp_magic[3] = {0x46, 0x66, 0x6d};
  14. static LIST_HEAD(llcp_devices);
  15. /* Protects llcp_devices list */
  16. static DEFINE_SPINLOCK(llcp_devices_lock);
  17. static void nfc_llcp_rx_skb(struct nfc_llcp_local *local, struct sk_buff *skb);
  18. void nfc_llcp_sock_link(struct llcp_sock_list *l, struct sock *sk)
  19. {
  20. write_lock(&l->lock);
  21. sk_add_node(sk, &l->head);
  22. write_unlock(&l->lock);
  23. }
  24. void nfc_llcp_sock_unlink(struct llcp_sock_list *l, struct sock *sk)
  25. {
  26. write_lock(&l->lock);
  27. sk_del_node_init(sk);
  28. write_unlock(&l->lock);
  29. }
  30. void nfc_llcp_socket_remote_param_init(struct nfc_llcp_sock *sock)
  31. {
  32. sock->remote_rw = LLCP_DEFAULT_RW;
  33. sock->remote_miu = LLCP_MAX_MIU + 1;
  34. }
  35. static void nfc_llcp_socket_purge(struct nfc_llcp_sock *sock)
  36. {
  37. struct nfc_llcp_local *local = sock->local;
  38. struct sk_buff *s, *tmp;
  39. skb_queue_purge(&sock->tx_queue);
  40. skb_queue_purge(&sock->tx_pending_queue);
  41. if (local == NULL)
  42. return;
  43. /* Search for local pending SKBs that are related to this socket */
  44. skb_queue_walk_safe(&local->tx_queue, s, tmp) {
  45. if (s->sk != &sock->sk)
  46. continue;
  47. skb_unlink(s, &local->tx_queue);
  48. kfree_skb(s);
  49. }
  50. }
  51. static void nfc_llcp_socket_release(struct nfc_llcp_local *local, bool device,
  52. int err)
  53. {
  54. struct sock *sk;
  55. struct hlist_node *tmp;
  56. struct nfc_llcp_sock *llcp_sock;
  57. skb_queue_purge(&local->tx_queue);
  58. write_lock(&local->sockets.lock);
  59. sk_for_each_safe(sk, tmp, &local->sockets.head) {
  60. llcp_sock = nfc_llcp_sock(sk);
  61. bh_lock_sock(sk);
  62. nfc_llcp_socket_purge(llcp_sock);
  63. if (sk->sk_state == LLCP_CONNECTED)
  64. nfc_put_device(llcp_sock->dev);
  65. if (sk->sk_state == LLCP_LISTEN) {
  66. struct nfc_llcp_sock *lsk, *n;
  67. struct sock *accept_sk;
  68. list_for_each_entry_safe(lsk, n,
  69. &llcp_sock->accept_queue,
  70. accept_queue) {
  71. accept_sk = &lsk->sk;
  72. bh_lock_sock(accept_sk);
  73. nfc_llcp_accept_unlink(accept_sk);
  74. if (err)
  75. accept_sk->sk_err = err;
  76. accept_sk->sk_state = LLCP_CLOSED;
  77. accept_sk->sk_state_change(sk);
  78. bh_unlock_sock(accept_sk);
  79. }
  80. }
  81. if (err)
  82. sk->sk_err = err;
  83. sk->sk_state = LLCP_CLOSED;
  84. sk->sk_state_change(sk);
  85. bh_unlock_sock(sk);
  86. sk_del_node_init(sk);
  87. }
  88. write_unlock(&local->sockets.lock);
  89. /* If we still have a device, we keep the RAW sockets alive */
  90. if (device == true)
  91. return;
  92. write_lock(&local->raw_sockets.lock);
  93. sk_for_each_safe(sk, tmp, &local->raw_sockets.head) {
  94. llcp_sock = nfc_llcp_sock(sk);
  95. bh_lock_sock(sk);
  96. nfc_llcp_socket_purge(llcp_sock);
  97. if (err)
  98. sk->sk_err = err;
  99. sk->sk_state = LLCP_CLOSED;
  100. sk->sk_state_change(sk);
  101. bh_unlock_sock(sk);
  102. sk_del_node_init(sk);
  103. }
  104. write_unlock(&local->raw_sockets.lock);
  105. }
  106. static struct nfc_llcp_local *nfc_llcp_local_get(struct nfc_llcp_local *local)
  107. {
  108. /* Since using nfc_llcp_local may result in usage of nfc_dev, whenever
  109. * we hold a reference to local, we also need to hold a reference to
  110. * the device to avoid UAF.
  111. */
  112. if (!nfc_get_device(local->dev->idx))
  113. return NULL;
  114. kref_get(&local->ref);
  115. return local;
  116. }
  117. static void local_cleanup(struct nfc_llcp_local *local)
  118. {
  119. nfc_llcp_socket_release(local, false, ENXIO);
  120. timer_delete_sync(&local->link_timer);
  121. skb_queue_purge(&local->tx_queue);
  122. cancel_work_sync(&local->tx_work);
  123. cancel_work_sync(&local->rx_work);
  124. cancel_work_sync(&local->timeout_work);
  125. kfree_skb(local->rx_pending);
  126. local->rx_pending = NULL;
  127. timer_delete_sync(&local->sdreq_timer);
  128. cancel_work_sync(&local->sdreq_timeout_work);
  129. nfc_llcp_free_sdp_tlv_list(&local->pending_sdreqs);
  130. }
  131. static void local_release(struct kref *ref)
  132. {
  133. struct nfc_llcp_local *local;
  134. local = container_of(ref, struct nfc_llcp_local, ref);
  135. local_cleanup(local);
  136. kfree(local);
  137. }
  138. int nfc_llcp_local_put(struct nfc_llcp_local *local)
  139. {
  140. struct nfc_dev *dev;
  141. int ret;
  142. if (local == NULL)
  143. return 0;
  144. dev = local->dev;
  145. ret = kref_put(&local->ref, local_release);
  146. nfc_put_device(dev);
  147. return ret;
  148. }
  149. static struct nfc_llcp_sock *nfc_llcp_sock_get(struct nfc_llcp_local *local,
  150. u8 ssap, u8 dsap)
  151. {
  152. struct sock *sk;
  153. struct nfc_llcp_sock *llcp_sock, *tmp_sock;
  154. pr_debug("ssap dsap %d %d\n", ssap, dsap);
  155. if (ssap == 0 && dsap == 0)
  156. return NULL;
  157. read_lock(&local->sockets.lock);
  158. llcp_sock = NULL;
  159. sk_for_each(sk, &local->sockets.head) {
  160. tmp_sock = nfc_llcp_sock(sk);
  161. if (tmp_sock->ssap == ssap && tmp_sock->dsap == dsap) {
  162. llcp_sock = tmp_sock;
  163. sock_hold(&llcp_sock->sk);
  164. break;
  165. }
  166. }
  167. read_unlock(&local->sockets.lock);
  168. return llcp_sock;
  169. }
  170. static void nfc_llcp_sock_put(struct nfc_llcp_sock *sock)
  171. {
  172. sock_put(&sock->sk);
  173. }
  174. static void nfc_llcp_timeout_work(struct work_struct *work)
  175. {
  176. struct nfc_llcp_local *local = container_of(work, struct nfc_llcp_local,
  177. timeout_work);
  178. nfc_dep_link_down(local->dev);
  179. }
  180. static void nfc_llcp_symm_timer(struct timer_list *t)
  181. {
  182. struct nfc_llcp_local *local = timer_container_of(local, t,
  183. link_timer);
  184. pr_err("SYMM timeout\n");
  185. schedule_work(&local->timeout_work);
  186. }
  187. static void nfc_llcp_sdreq_timeout_work(struct work_struct *work)
  188. {
  189. unsigned long time;
  190. HLIST_HEAD(nl_sdres_list);
  191. struct hlist_node *n;
  192. struct nfc_llcp_sdp_tlv *sdp;
  193. struct nfc_llcp_local *local = container_of(work, struct nfc_llcp_local,
  194. sdreq_timeout_work);
  195. mutex_lock(&local->sdreq_lock);
  196. time = jiffies - msecs_to_jiffies(3 * local->remote_lto);
  197. hlist_for_each_entry_safe(sdp, n, &local->pending_sdreqs, node) {
  198. if (time_after(sdp->time, time))
  199. continue;
  200. sdp->sap = LLCP_SDP_UNBOUND;
  201. hlist_del(&sdp->node);
  202. hlist_add_head(&sdp->node, &nl_sdres_list);
  203. }
  204. if (!hlist_empty(&local->pending_sdreqs))
  205. mod_timer(&local->sdreq_timer,
  206. jiffies + msecs_to_jiffies(3 * local->remote_lto));
  207. mutex_unlock(&local->sdreq_lock);
  208. if (!hlist_empty(&nl_sdres_list))
  209. nfc_genl_llc_send_sdres(local->dev, &nl_sdres_list);
  210. }
  211. static void nfc_llcp_sdreq_timer(struct timer_list *t)
  212. {
  213. struct nfc_llcp_local *local = timer_container_of(local, t,
  214. sdreq_timer);
  215. schedule_work(&local->sdreq_timeout_work);
  216. }
  217. struct nfc_llcp_local *nfc_llcp_find_local(struct nfc_dev *dev)
  218. {
  219. struct nfc_llcp_local *local;
  220. struct nfc_llcp_local *res = NULL;
  221. spin_lock(&llcp_devices_lock);
  222. list_for_each_entry(local, &llcp_devices, list)
  223. if (local->dev == dev) {
  224. res = nfc_llcp_local_get(local);
  225. break;
  226. }
  227. spin_unlock(&llcp_devices_lock);
  228. return res;
  229. }
  230. static struct nfc_llcp_local *nfc_llcp_remove_local(struct nfc_dev *dev)
  231. {
  232. struct nfc_llcp_local *local, *tmp;
  233. spin_lock(&llcp_devices_lock);
  234. list_for_each_entry_safe(local, tmp, &llcp_devices, list)
  235. if (local->dev == dev) {
  236. spin_lock(&local->tx_queue.lock);
  237. list_del_init(&local->list);
  238. spin_unlock(&local->tx_queue.lock);
  239. spin_unlock(&llcp_devices_lock);
  240. return local;
  241. }
  242. spin_unlock(&llcp_devices_lock);
  243. pr_warn("Shutting down device not found\n");
  244. return NULL;
  245. }
  246. static char *wks[] = {
  247. NULL,
  248. NULL, /* SDP */
  249. "urn:nfc:sn:ip",
  250. "urn:nfc:sn:obex",
  251. "urn:nfc:sn:snep",
  252. };
  253. static int nfc_llcp_wks_sap(const char *service_name, size_t service_name_len)
  254. {
  255. int sap, num_wks;
  256. pr_debug("%s\n", service_name);
  257. if (service_name == NULL)
  258. return -EINVAL;
  259. num_wks = ARRAY_SIZE(wks);
  260. for (sap = 0; sap < num_wks; sap++) {
  261. if (wks[sap] == NULL)
  262. continue;
  263. if (strncmp(wks[sap], service_name, service_name_len) == 0)
  264. return sap;
  265. }
  266. return -EINVAL;
  267. }
  268. static
  269. struct nfc_llcp_sock *nfc_llcp_sock_from_sn(struct nfc_llcp_local *local,
  270. const u8 *sn, size_t sn_len,
  271. bool needref)
  272. {
  273. struct sock *sk;
  274. struct nfc_llcp_sock *llcp_sock, *tmp_sock;
  275. pr_debug("sn %zd %p\n", sn_len, sn);
  276. if (sn == NULL || sn_len == 0)
  277. return NULL;
  278. read_lock(&local->sockets.lock);
  279. llcp_sock = NULL;
  280. sk_for_each(sk, &local->sockets.head) {
  281. tmp_sock = nfc_llcp_sock(sk);
  282. pr_debug("llcp sock %p\n", tmp_sock);
  283. if (tmp_sock->sk.sk_type == SOCK_STREAM &&
  284. tmp_sock->sk.sk_state != LLCP_LISTEN)
  285. continue;
  286. if (tmp_sock->sk.sk_type == SOCK_DGRAM &&
  287. tmp_sock->sk.sk_state != LLCP_BOUND)
  288. continue;
  289. if (tmp_sock->service_name == NULL ||
  290. tmp_sock->service_name_len == 0)
  291. continue;
  292. if (tmp_sock->service_name_len != sn_len)
  293. continue;
  294. if (memcmp(sn, tmp_sock->service_name, sn_len) == 0) {
  295. llcp_sock = tmp_sock;
  296. if (needref)
  297. sock_hold(&llcp_sock->sk);
  298. break;
  299. }
  300. }
  301. read_unlock(&local->sockets.lock);
  302. pr_debug("Found llcp sock %p\n", llcp_sock);
  303. return llcp_sock;
  304. }
  305. u8 nfc_llcp_get_sdp_ssap(struct nfc_llcp_local *local,
  306. struct nfc_llcp_sock *sock)
  307. {
  308. mutex_lock(&local->sdp_lock);
  309. if (sock->service_name != NULL && sock->service_name_len > 0) {
  310. int ssap = nfc_llcp_wks_sap(sock->service_name,
  311. sock->service_name_len);
  312. if (ssap > 0) {
  313. pr_debug("WKS %d\n", ssap);
  314. /* This is a WKS, let's check if it's free */
  315. if (test_bit(ssap, &local->local_wks)) {
  316. mutex_unlock(&local->sdp_lock);
  317. return LLCP_SAP_MAX;
  318. }
  319. set_bit(ssap, &local->local_wks);
  320. mutex_unlock(&local->sdp_lock);
  321. return ssap;
  322. }
  323. /*
  324. * Check if there already is a non WKS socket bound
  325. * to this service name.
  326. */
  327. if (nfc_llcp_sock_from_sn(local, sock->service_name,
  328. sock->service_name_len,
  329. false) != NULL) {
  330. mutex_unlock(&local->sdp_lock);
  331. return LLCP_SAP_MAX;
  332. }
  333. mutex_unlock(&local->sdp_lock);
  334. return LLCP_SDP_UNBOUND;
  335. } else if (sock->ssap != 0 && sock->ssap < LLCP_WKS_NUM_SAP) {
  336. if (!test_bit(sock->ssap, &local->local_wks)) {
  337. set_bit(sock->ssap, &local->local_wks);
  338. mutex_unlock(&local->sdp_lock);
  339. return sock->ssap;
  340. }
  341. }
  342. mutex_unlock(&local->sdp_lock);
  343. return LLCP_SAP_MAX;
  344. }
  345. u8 nfc_llcp_get_local_ssap(struct nfc_llcp_local *local)
  346. {
  347. u8 local_ssap;
  348. mutex_lock(&local->sdp_lock);
  349. local_ssap = find_first_zero_bit(&local->local_sap, LLCP_LOCAL_NUM_SAP);
  350. if (local_ssap == LLCP_LOCAL_NUM_SAP) {
  351. mutex_unlock(&local->sdp_lock);
  352. return LLCP_SAP_MAX;
  353. }
  354. set_bit(local_ssap, &local->local_sap);
  355. mutex_unlock(&local->sdp_lock);
  356. return local_ssap + LLCP_LOCAL_SAP_OFFSET;
  357. }
  358. void nfc_llcp_put_ssap(struct nfc_llcp_local *local, u8 ssap)
  359. {
  360. u8 local_ssap;
  361. unsigned long *sdp;
  362. if (ssap < LLCP_WKS_NUM_SAP) {
  363. local_ssap = ssap;
  364. sdp = &local->local_wks;
  365. } else if (ssap < LLCP_LOCAL_NUM_SAP) {
  366. atomic_t *client_cnt;
  367. local_ssap = ssap - LLCP_WKS_NUM_SAP;
  368. sdp = &local->local_sdp;
  369. client_cnt = &local->local_sdp_cnt[local_ssap];
  370. pr_debug("%d clients\n", atomic_read(client_cnt));
  371. mutex_lock(&local->sdp_lock);
  372. if (atomic_dec_and_test(client_cnt)) {
  373. struct nfc_llcp_sock *l_sock;
  374. pr_debug("No more clients for SAP %d\n", ssap);
  375. clear_bit(local_ssap, sdp);
  376. /* Find the listening sock and set it back to UNBOUND */
  377. l_sock = nfc_llcp_sock_get(local, ssap, LLCP_SAP_SDP);
  378. if (l_sock) {
  379. l_sock->ssap = LLCP_SDP_UNBOUND;
  380. nfc_llcp_sock_put(l_sock);
  381. }
  382. }
  383. mutex_unlock(&local->sdp_lock);
  384. return;
  385. } else if (ssap < LLCP_MAX_SAP) {
  386. local_ssap = ssap - LLCP_LOCAL_NUM_SAP;
  387. sdp = &local->local_sap;
  388. } else {
  389. return;
  390. }
  391. mutex_lock(&local->sdp_lock);
  392. clear_bit(local_ssap, sdp);
  393. mutex_unlock(&local->sdp_lock);
  394. }
  395. static u8 nfc_llcp_reserve_sdp_ssap(struct nfc_llcp_local *local)
  396. {
  397. u8 ssap;
  398. mutex_lock(&local->sdp_lock);
  399. ssap = find_first_zero_bit(&local->local_sdp, LLCP_SDP_NUM_SAP);
  400. if (ssap == LLCP_SDP_NUM_SAP) {
  401. mutex_unlock(&local->sdp_lock);
  402. return LLCP_SAP_MAX;
  403. }
  404. pr_debug("SDP ssap %d\n", LLCP_WKS_NUM_SAP + ssap);
  405. set_bit(ssap, &local->local_sdp);
  406. mutex_unlock(&local->sdp_lock);
  407. return LLCP_WKS_NUM_SAP + ssap;
  408. }
  409. static int nfc_llcp_build_gb(struct nfc_llcp_local *local)
  410. {
  411. u8 *gb_cur, version, version_length;
  412. u8 lto_length, wks_length, miux_length;
  413. const u8 *version_tlv = NULL, *lto_tlv = NULL,
  414. *wks_tlv = NULL, *miux_tlv = NULL;
  415. __be16 wks = cpu_to_be16(local->local_wks);
  416. u8 gb_len = 0;
  417. int ret = 0;
  418. version = LLCP_VERSION_11;
  419. version_tlv = nfc_llcp_build_tlv(LLCP_TLV_VERSION, &version,
  420. 1, &version_length);
  421. if (!version_tlv) {
  422. ret = -ENOMEM;
  423. goto out;
  424. }
  425. gb_len += version_length;
  426. lto_tlv = nfc_llcp_build_tlv(LLCP_TLV_LTO, &local->lto, 1, &lto_length);
  427. if (!lto_tlv) {
  428. ret = -ENOMEM;
  429. goto out;
  430. }
  431. gb_len += lto_length;
  432. pr_debug("Local wks 0x%lx\n", local->local_wks);
  433. wks_tlv = nfc_llcp_build_tlv(LLCP_TLV_WKS, (u8 *)&wks, 2, &wks_length);
  434. if (!wks_tlv) {
  435. ret = -ENOMEM;
  436. goto out;
  437. }
  438. gb_len += wks_length;
  439. miux_tlv = nfc_llcp_build_tlv(LLCP_TLV_MIUX, (u8 *)&local->miux, 0,
  440. &miux_length);
  441. if (!miux_tlv) {
  442. ret = -ENOMEM;
  443. goto out;
  444. }
  445. gb_len += miux_length;
  446. gb_len += ARRAY_SIZE(llcp_magic);
  447. if (gb_len > NFC_MAX_GT_LEN) {
  448. ret = -EINVAL;
  449. goto out;
  450. }
  451. gb_cur = local->gb;
  452. memcpy(gb_cur, llcp_magic, ARRAY_SIZE(llcp_magic));
  453. gb_cur += ARRAY_SIZE(llcp_magic);
  454. memcpy(gb_cur, version_tlv, version_length);
  455. gb_cur += version_length;
  456. memcpy(gb_cur, lto_tlv, lto_length);
  457. gb_cur += lto_length;
  458. memcpy(gb_cur, wks_tlv, wks_length);
  459. gb_cur += wks_length;
  460. memcpy(gb_cur, miux_tlv, miux_length);
  461. gb_cur += miux_length;
  462. local->gb_len = gb_len;
  463. out:
  464. kfree(version_tlv);
  465. kfree(lto_tlv);
  466. kfree(wks_tlv);
  467. kfree(miux_tlv);
  468. return ret;
  469. }
  470. u8 *nfc_llcp_general_bytes(struct nfc_dev *dev, size_t *general_bytes_len)
  471. {
  472. struct nfc_llcp_local *local;
  473. local = nfc_llcp_find_local(dev);
  474. if (local == NULL) {
  475. *general_bytes_len = 0;
  476. return NULL;
  477. }
  478. nfc_llcp_build_gb(local);
  479. *general_bytes_len = local->gb_len;
  480. nfc_llcp_local_put(local);
  481. return local->gb;
  482. }
  483. int nfc_llcp_set_remote_gb(struct nfc_dev *dev, const u8 *gb, u8 gb_len)
  484. {
  485. struct nfc_llcp_local *local;
  486. int err;
  487. if (gb_len < 3 || gb_len > NFC_MAX_GT_LEN)
  488. return -EINVAL;
  489. local = nfc_llcp_find_local(dev);
  490. if (local == NULL) {
  491. pr_err("No LLCP device\n");
  492. return -ENODEV;
  493. }
  494. memset(local->remote_gb, 0, NFC_MAX_GT_LEN);
  495. memcpy(local->remote_gb, gb, gb_len);
  496. local->remote_gb_len = gb_len;
  497. if (memcmp(local->remote_gb, llcp_magic, 3)) {
  498. pr_err("MAC does not support LLCP\n");
  499. err = -EINVAL;
  500. goto out;
  501. }
  502. err = nfc_llcp_parse_gb_tlv(local,
  503. &local->remote_gb[3],
  504. local->remote_gb_len - 3);
  505. out:
  506. nfc_llcp_local_put(local);
  507. return err;
  508. }
  509. static u8 nfc_llcp_dsap(const struct sk_buff *pdu)
  510. {
  511. return (pdu->data[0] & 0xfc) >> 2;
  512. }
  513. static u8 nfc_llcp_ptype(const struct sk_buff *pdu)
  514. {
  515. return ((pdu->data[0] & 0x03) << 2) | ((pdu->data[1] & 0xc0) >> 6);
  516. }
  517. static u8 nfc_llcp_ssap(const struct sk_buff *pdu)
  518. {
  519. return pdu->data[1] & 0x3f;
  520. }
  521. static u8 nfc_llcp_ns(const struct sk_buff *pdu)
  522. {
  523. return pdu->data[2] >> 4;
  524. }
  525. static u8 nfc_llcp_nr(const struct sk_buff *pdu)
  526. {
  527. return pdu->data[2] & 0xf;
  528. }
  529. static void nfc_llcp_set_nrns(struct nfc_llcp_sock *sock, struct sk_buff *pdu)
  530. {
  531. pdu->data[2] = (sock->send_n << 4) | (sock->recv_n);
  532. sock->send_n = (sock->send_n + 1) % 16;
  533. sock->recv_ack_n = (sock->recv_n - 1) % 16;
  534. }
  535. void nfc_llcp_send_to_raw_sock(struct nfc_llcp_local *local,
  536. struct sk_buff *skb, u8 direction)
  537. {
  538. struct sk_buff *skb_copy = NULL, *nskb;
  539. struct sock *sk;
  540. u8 *data;
  541. read_lock(&local->raw_sockets.lock);
  542. sk_for_each(sk, &local->raw_sockets.head) {
  543. if (sk->sk_state != LLCP_BOUND)
  544. continue;
  545. if (skb_copy == NULL) {
  546. skb_copy = __pskb_copy_fclone(skb, NFC_RAW_HEADER_SIZE,
  547. GFP_ATOMIC, true);
  548. if (skb_copy == NULL)
  549. continue;
  550. data = skb_push(skb_copy, NFC_RAW_HEADER_SIZE);
  551. data[0] = local->dev ? local->dev->idx : 0xFF;
  552. data[1] = direction & 0x01;
  553. data[1] |= (RAW_PAYLOAD_LLCP << 1);
  554. }
  555. nskb = skb_clone(skb_copy, GFP_ATOMIC);
  556. if (!nskb)
  557. continue;
  558. if (sock_queue_rcv_skb(sk, nskb))
  559. kfree_skb(nskb);
  560. }
  561. read_unlock(&local->raw_sockets.lock);
  562. kfree_skb(skb_copy);
  563. }
  564. static void nfc_llcp_tx_work(struct work_struct *work)
  565. {
  566. struct nfc_llcp_local *local = container_of(work, struct nfc_llcp_local,
  567. tx_work);
  568. struct sk_buff *skb;
  569. struct sock *sk;
  570. struct nfc_llcp_sock *llcp_sock;
  571. skb = skb_dequeue(&local->tx_queue);
  572. if (skb != NULL) {
  573. sk = skb->sk;
  574. llcp_sock = nfc_llcp_sock(sk);
  575. if (llcp_sock == NULL && nfc_llcp_ptype(skb) == LLCP_PDU_I) {
  576. kfree_skb(skb);
  577. nfc_llcp_send_symm(local->dev);
  578. } else if (llcp_sock && !llcp_sock->remote_ready) {
  579. skb_queue_head(&local->tx_queue, skb);
  580. nfc_llcp_send_symm(local->dev);
  581. } else {
  582. struct sk_buff *copy_skb = NULL;
  583. u8 ptype = nfc_llcp_ptype(skb);
  584. int ret;
  585. pr_debug("Sending pending skb\n");
  586. print_hex_dump_debug("LLCP Tx: ", DUMP_PREFIX_OFFSET,
  587. 16, 1, skb->data, skb->len, true);
  588. if (ptype == LLCP_PDU_I)
  589. copy_skb = skb_copy(skb, GFP_ATOMIC);
  590. __net_timestamp(skb);
  591. nfc_llcp_send_to_raw_sock(local, skb,
  592. NFC_DIRECTION_TX);
  593. ret = nfc_data_exchange(local->dev, local->target_idx,
  594. skb, nfc_llcp_recv, local);
  595. if (ret) {
  596. kfree_skb(copy_skb);
  597. goto out;
  598. }
  599. if (ptype == LLCP_PDU_I && copy_skb)
  600. skb_queue_tail(&llcp_sock->tx_pending_queue,
  601. copy_skb);
  602. }
  603. } else {
  604. nfc_llcp_send_symm(local->dev);
  605. }
  606. out:
  607. mod_timer(&local->link_timer,
  608. jiffies + msecs_to_jiffies(2 * local->remote_lto));
  609. }
  610. static struct nfc_llcp_sock *nfc_llcp_connecting_sock_get(struct nfc_llcp_local *local,
  611. u8 ssap)
  612. {
  613. struct sock *sk;
  614. struct nfc_llcp_sock *llcp_sock;
  615. read_lock(&local->connecting_sockets.lock);
  616. sk_for_each(sk, &local->connecting_sockets.head) {
  617. llcp_sock = nfc_llcp_sock(sk);
  618. if (llcp_sock->ssap == ssap) {
  619. sock_hold(&llcp_sock->sk);
  620. goto out;
  621. }
  622. }
  623. llcp_sock = NULL;
  624. out:
  625. read_unlock(&local->connecting_sockets.lock);
  626. return llcp_sock;
  627. }
  628. static struct nfc_llcp_sock *nfc_llcp_sock_get_sn(struct nfc_llcp_local *local,
  629. const u8 *sn, size_t sn_len)
  630. {
  631. return nfc_llcp_sock_from_sn(local, sn, sn_len, true);
  632. }
  633. static const u8 *nfc_llcp_connect_sn(const struct sk_buff *skb, size_t *sn_len)
  634. {
  635. u8 type, length;
  636. const u8 *tlv = &skb->data[2];
  637. size_t tlv_array_len = skb->len - LLCP_HEADER_SIZE, offset = 0;
  638. while (offset < tlv_array_len) {
  639. type = tlv[0];
  640. length = tlv[1];
  641. pr_debug("type 0x%x length %d\n", type, length);
  642. if (type == LLCP_TLV_SN) {
  643. *sn_len = length;
  644. return &tlv[2];
  645. }
  646. offset += length + 2;
  647. tlv += length + 2;
  648. }
  649. return NULL;
  650. }
  651. static void nfc_llcp_recv_ui(struct nfc_llcp_local *local,
  652. struct sk_buff *skb)
  653. {
  654. struct nfc_llcp_sock *llcp_sock;
  655. struct nfc_llcp_ui_cb *ui_cb;
  656. u8 dsap, ssap;
  657. dsap = nfc_llcp_dsap(skb);
  658. ssap = nfc_llcp_ssap(skb);
  659. ui_cb = nfc_llcp_ui_skb_cb(skb);
  660. ui_cb->dsap = dsap;
  661. ui_cb->ssap = ssap;
  662. pr_debug("%d %d\n", dsap, ssap);
  663. /* We're looking for a bound socket, not a client one */
  664. llcp_sock = nfc_llcp_sock_get(local, dsap, LLCP_SAP_SDP);
  665. if (llcp_sock == NULL || llcp_sock->sk.sk_type != SOCK_DGRAM)
  666. return;
  667. /* There is no sequence with UI frames */
  668. skb_pull(skb, LLCP_HEADER_SIZE);
  669. if (!sock_queue_rcv_skb(&llcp_sock->sk, skb)) {
  670. /*
  671. * UI frames will be freed from the socket layer, so we
  672. * need to keep them alive until someone receives them.
  673. */
  674. skb_get(skb);
  675. } else {
  676. pr_err("Receive queue is full\n");
  677. }
  678. nfc_llcp_sock_put(llcp_sock);
  679. }
  680. static void nfc_llcp_recv_connect(struct nfc_llcp_local *local,
  681. const struct sk_buff *skb)
  682. {
  683. struct sock *new_sk, *parent;
  684. struct nfc_llcp_sock *sock, *new_sock;
  685. u8 dsap, ssap, reason;
  686. dsap = nfc_llcp_dsap(skb);
  687. ssap = nfc_llcp_ssap(skb);
  688. pr_debug("%d %d\n", dsap, ssap);
  689. if (dsap != LLCP_SAP_SDP) {
  690. sock = nfc_llcp_sock_get(local, dsap, LLCP_SAP_SDP);
  691. if (sock == NULL || sock->sk.sk_state != LLCP_LISTEN) {
  692. reason = LLCP_DM_NOBOUND;
  693. goto fail;
  694. }
  695. } else {
  696. const u8 *sn;
  697. size_t sn_len;
  698. sn = nfc_llcp_connect_sn(skb, &sn_len);
  699. if (sn == NULL) {
  700. reason = LLCP_DM_NOBOUND;
  701. goto fail;
  702. }
  703. pr_debug("Service name length %zu\n", sn_len);
  704. sock = nfc_llcp_sock_get_sn(local, sn, sn_len);
  705. if (sock == NULL) {
  706. reason = LLCP_DM_NOBOUND;
  707. goto fail;
  708. }
  709. }
  710. lock_sock(&sock->sk);
  711. parent = &sock->sk;
  712. if (sk_acceptq_is_full(parent)) {
  713. reason = LLCP_DM_REJ;
  714. release_sock(&sock->sk);
  715. sock_put(&sock->sk);
  716. goto fail;
  717. }
  718. if (sock->ssap == LLCP_SDP_UNBOUND) {
  719. u8 ssap = nfc_llcp_reserve_sdp_ssap(local);
  720. pr_debug("First client, reserving %d\n", ssap);
  721. if (ssap == LLCP_SAP_MAX) {
  722. reason = LLCP_DM_REJ;
  723. release_sock(&sock->sk);
  724. sock_put(&sock->sk);
  725. goto fail;
  726. }
  727. sock->ssap = ssap;
  728. }
  729. new_sk = nfc_llcp_sock_alloc(NULL, parent->sk_type, GFP_ATOMIC, 0);
  730. if (new_sk == NULL) {
  731. reason = LLCP_DM_REJ;
  732. release_sock(&sock->sk);
  733. sock_put(&sock->sk);
  734. goto fail;
  735. }
  736. new_sock = nfc_llcp_sock(new_sk);
  737. new_sock->local = nfc_llcp_local_get(local);
  738. if (!new_sock->local) {
  739. reason = LLCP_DM_REJ;
  740. sock_put(&new_sock->sk);
  741. release_sock(&sock->sk);
  742. sock_put(&sock->sk);
  743. goto fail;
  744. }
  745. new_sock->dev = local->dev;
  746. new_sock->rw = sock->rw;
  747. new_sock->miux = sock->miux;
  748. new_sock->nfc_protocol = sock->nfc_protocol;
  749. new_sock->dsap = ssap;
  750. new_sock->target_idx = local->target_idx;
  751. new_sock->parent = parent;
  752. new_sock->ssap = sock->ssap;
  753. if (sock->ssap < LLCP_LOCAL_NUM_SAP && sock->ssap >= LLCP_WKS_NUM_SAP) {
  754. atomic_t *client_count;
  755. pr_debug("reserved_ssap %d for %p\n", sock->ssap, new_sock);
  756. client_count =
  757. &local->local_sdp_cnt[sock->ssap - LLCP_WKS_NUM_SAP];
  758. atomic_inc(client_count);
  759. new_sock->reserved_ssap = sock->ssap;
  760. }
  761. nfc_llcp_parse_connection_tlv(new_sock, &skb->data[LLCP_HEADER_SIZE],
  762. skb->len - LLCP_HEADER_SIZE);
  763. pr_debug("new sock %p sk %p\n", new_sock, &new_sock->sk);
  764. nfc_llcp_sock_link(&local->sockets, new_sk);
  765. nfc_llcp_accept_enqueue(&sock->sk, new_sk);
  766. nfc_get_device(local->dev->idx);
  767. new_sk->sk_state = LLCP_CONNECTED;
  768. /* Wake the listening processes */
  769. parent->sk_data_ready(parent);
  770. /* Send CC */
  771. nfc_llcp_send_cc(new_sock);
  772. release_sock(&sock->sk);
  773. sock_put(&sock->sk);
  774. return;
  775. fail:
  776. /* Send DM */
  777. nfc_llcp_send_dm(local, dsap, ssap, reason);
  778. }
  779. int nfc_llcp_queue_i_frames(struct nfc_llcp_sock *sock)
  780. {
  781. int nr_frames = 0;
  782. struct nfc_llcp_local *local = sock->local;
  783. pr_debug("Remote ready %d tx queue len %d remote rw %d",
  784. sock->remote_ready, skb_queue_len(&sock->tx_pending_queue),
  785. sock->remote_rw);
  786. /* Try to queue some I frames for transmission */
  787. while (sock->remote_ready &&
  788. skb_queue_len(&sock->tx_pending_queue) < sock->remote_rw) {
  789. struct sk_buff *pdu;
  790. pdu = skb_dequeue(&sock->tx_queue);
  791. if (pdu == NULL)
  792. break;
  793. /* Update N(S)/N(R) */
  794. nfc_llcp_set_nrns(sock, pdu);
  795. skb_queue_tail(&local->tx_queue, pdu);
  796. nr_frames++;
  797. }
  798. return nr_frames;
  799. }
  800. static void nfc_llcp_recv_hdlc(struct nfc_llcp_local *local,
  801. struct sk_buff *skb)
  802. {
  803. struct nfc_llcp_sock *llcp_sock;
  804. struct sock *sk;
  805. u8 dsap, ssap, ptype, ns, nr;
  806. ptype = nfc_llcp_ptype(skb);
  807. dsap = nfc_llcp_dsap(skb);
  808. ssap = nfc_llcp_ssap(skb);
  809. ns = nfc_llcp_ns(skb);
  810. nr = nfc_llcp_nr(skb);
  811. pr_debug("%d %d R %d S %d\n", dsap, ssap, nr, ns);
  812. llcp_sock = nfc_llcp_sock_get(local, dsap, ssap);
  813. if (llcp_sock == NULL) {
  814. nfc_llcp_send_dm(local, dsap, ssap, LLCP_DM_NOCONN);
  815. return;
  816. }
  817. sk = &llcp_sock->sk;
  818. lock_sock(sk);
  819. if (sk->sk_state == LLCP_CLOSED) {
  820. release_sock(sk);
  821. nfc_llcp_sock_put(llcp_sock);
  822. }
  823. /* Pass the payload upstream */
  824. if (ptype == LLCP_PDU_I) {
  825. pr_debug("I frame, queueing on %p\n", &llcp_sock->sk);
  826. if (ns == llcp_sock->recv_n)
  827. llcp_sock->recv_n = (llcp_sock->recv_n + 1) % 16;
  828. else
  829. pr_err("Received out of sequence I PDU\n");
  830. skb_pull(skb, LLCP_HEADER_SIZE + LLCP_SEQUENCE_SIZE);
  831. if (!sock_queue_rcv_skb(&llcp_sock->sk, skb)) {
  832. /*
  833. * I frames will be freed from the socket layer, so we
  834. * need to keep them alive until someone receives them.
  835. */
  836. skb_get(skb);
  837. } else {
  838. pr_err("Receive queue is full\n");
  839. }
  840. }
  841. /* Remove skbs from the pending queue */
  842. if (llcp_sock->send_ack_n != nr) {
  843. struct sk_buff *s, *tmp;
  844. u8 n;
  845. llcp_sock->send_ack_n = nr;
  846. /* Remove and free all skbs until ns == nr */
  847. skb_queue_walk_safe(&llcp_sock->tx_pending_queue, s, tmp) {
  848. n = nfc_llcp_ns(s);
  849. skb_unlink(s, &llcp_sock->tx_pending_queue);
  850. kfree_skb(s);
  851. if (n == nr)
  852. break;
  853. }
  854. /* Re-queue the remaining skbs for transmission */
  855. skb_queue_reverse_walk_safe(&llcp_sock->tx_pending_queue,
  856. s, tmp) {
  857. skb_unlink(s, &llcp_sock->tx_pending_queue);
  858. skb_queue_head(&local->tx_queue, s);
  859. }
  860. }
  861. if (ptype == LLCP_PDU_RR)
  862. llcp_sock->remote_ready = true;
  863. else if (ptype == LLCP_PDU_RNR)
  864. llcp_sock->remote_ready = false;
  865. if (nfc_llcp_queue_i_frames(llcp_sock) == 0 && ptype == LLCP_PDU_I)
  866. nfc_llcp_send_rr(llcp_sock);
  867. release_sock(sk);
  868. nfc_llcp_sock_put(llcp_sock);
  869. }
  870. static void nfc_llcp_recv_disc(struct nfc_llcp_local *local,
  871. const struct sk_buff *skb)
  872. {
  873. struct nfc_llcp_sock *llcp_sock;
  874. struct sock *sk;
  875. u8 dsap, ssap;
  876. dsap = nfc_llcp_dsap(skb);
  877. ssap = nfc_llcp_ssap(skb);
  878. if ((dsap == 0) && (ssap == 0)) {
  879. pr_debug("Connection termination");
  880. nfc_dep_link_down(local->dev);
  881. return;
  882. }
  883. llcp_sock = nfc_llcp_sock_get(local, dsap, ssap);
  884. if (llcp_sock == NULL) {
  885. nfc_llcp_send_dm(local, dsap, ssap, LLCP_DM_NOCONN);
  886. return;
  887. }
  888. sk = &llcp_sock->sk;
  889. lock_sock(sk);
  890. nfc_llcp_socket_purge(llcp_sock);
  891. if (sk->sk_state == LLCP_CLOSED) {
  892. release_sock(sk);
  893. nfc_llcp_sock_put(llcp_sock);
  894. }
  895. if (sk->sk_state == LLCP_CONNECTED) {
  896. nfc_put_device(local->dev);
  897. sk->sk_state = LLCP_CLOSED;
  898. sk->sk_state_change(sk);
  899. }
  900. nfc_llcp_send_dm(local, dsap, ssap, LLCP_DM_DISC);
  901. release_sock(sk);
  902. nfc_llcp_sock_put(llcp_sock);
  903. }
  904. static void nfc_llcp_recv_cc(struct nfc_llcp_local *local,
  905. const struct sk_buff *skb)
  906. {
  907. struct nfc_llcp_sock *llcp_sock;
  908. struct sock *sk;
  909. u8 dsap, ssap;
  910. dsap = nfc_llcp_dsap(skb);
  911. ssap = nfc_llcp_ssap(skb);
  912. llcp_sock = nfc_llcp_connecting_sock_get(local, dsap);
  913. if (llcp_sock == NULL) {
  914. pr_err("Invalid CC\n");
  915. nfc_llcp_send_dm(local, dsap, ssap, LLCP_DM_NOCONN);
  916. return;
  917. }
  918. sk = &llcp_sock->sk;
  919. /* Unlink from connecting and link to the client array */
  920. nfc_llcp_sock_unlink(&local->connecting_sockets, sk);
  921. nfc_llcp_sock_link(&local->sockets, sk);
  922. llcp_sock->dsap = ssap;
  923. nfc_llcp_parse_connection_tlv(llcp_sock, &skb->data[LLCP_HEADER_SIZE],
  924. skb->len - LLCP_HEADER_SIZE);
  925. sk->sk_state = LLCP_CONNECTED;
  926. sk->sk_state_change(sk);
  927. nfc_llcp_sock_put(llcp_sock);
  928. }
  929. static void nfc_llcp_recv_dm(struct nfc_llcp_local *local,
  930. const struct sk_buff *skb)
  931. {
  932. struct nfc_llcp_sock *llcp_sock;
  933. struct sock *sk;
  934. u8 dsap, ssap, reason;
  935. dsap = nfc_llcp_dsap(skb);
  936. ssap = nfc_llcp_ssap(skb);
  937. reason = skb->data[2];
  938. pr_debug("%d %d reason %d\n", ssap, dsap, reason);
  939. switch (reason) {
  940. case LLCP_DM_NOBOUND:
  941. case LLCP_DM_REJ:
  942. llcp_sock = nfc_llcp_connecting_sock_get(local, dsap);
  943. break;
  944. default:
  945. llcp_sock = nfc_llcp_sock_get(local, dsap, ssap);
  946. break;
  947. }
  948. if (llcp_sock == NULL) {
  949. pr_debug("Already closed\n");
  950. return;
  951. }
  952. sk = &llcp_sock->sk;
  953. sk->sk_err = ENXIO;
  954. sk->sk_state = LLCP_CLOSED;
  955. sk->sk_state_change(sk);
  956. nfc_llcp_sock_put(llcp_sock);
  957. }
  958. static void nfc_llcp_recv_snl(struct nfc_llcp_local *local,
  959. const struct sk_buff *skb)
  960. {
  961. struct nfc_llcp_sock *llcp_sock;
  962. u8 dsap, ssap, type, length, tid, sap;
  963. const u8 *tlv;
  964. u16 tlv_len, offset;
  965. const char *service_name;
  966. size_t service_name_len;
  967. struct nfc_llcp_sdp_tlv *sdp;
  968. HLIST_HEAD(llc_sdres_list);
  969. size_t sdres_tlvs_len;
  970. HLIST_HEAD(nl_sdres_list);
  971. dsap = nfc_llcp_dsap(skb);
  972. ssap = nfc_llcp_ssap(skb);
  973. pr_debug("%d %d\n", dsap, ssap);
  974. if (dsap != LLCP_SAP_SDP || ssap != LLCP_SAP_SDP) {
  975. pr_err("Wrong SNL SAP\n");
  976. return;
  977. }
  978. tlv = &skb->data[LLCP_HEADER_SIZE];
  979. tlv_len = skb->len - LLCP_HEADER_SIZE;
  980. offset = 0;
  981. sdres_tlvs_len = 0;
  982. while (offset < tlv_len) {
  983. type = tlv[0];
  984. length = tlv[1];
  985. switch (type) {
  986. case LLCP_TLV_SDREQ:
  987. tid = tlv[2];
  988. service_name = (char *) &tlv[3];
  989. service_name_len = length - 1;
  990. pr_debug("Looking for %.16s\n", service_name);
  991. if (service_name_len == strlen("urn:nfc:sn:sdp") &&
  992. !strncmp(service_name, "urn:nfc:sn:sdp",
  993. service_name_len)) {
  994. sap = 1;
  995. goto add_snl;
  996. }
  997. llcp_sock = nfc_llcp_sock_from_sn(local, service_name,
  998. service_name_len,
  999. true);
  1000. if (!llcp_sock) {
  1001. sap = 0;
  1002. goto add_snl;
  1003. }
  1004. /*
  1005. * We found a socket but its ssap has not been reserved
  1006. * yet. We need to assign it for good and send a reply.
  1007. * The ssap will be freed when the socket is closed.
  1008. */
  1009. if (llcp_sock->ssap == LLCP_SDP_UNBOUND) {
  1010. atomic_t *client_count;
  1011. sap = nfc_llcp_reserve_sdp_ssap(local);
  1012. pr_debug("Reserving %d\n", sap);
  1013. if (sap == LLCP_SAP_MAX) {
  1014. sap = 0;
  1015. nfc_llcp_sock_put(llcp_sock);
  1016. goto add_snl;
  1017. }
  1018. client_count =
  1019. &local->local_sdp_cnt[sap -
  1020. LLCP_WKS_NUM_SAP];
  1021. atomic_inc(client_count);
  1022. llcp_sock->ssap = sap;
  1023. llcp_sock->reserved_ssap = sap;
  1024. } else {
  1025. sap = llcp_sock->ssap;
  1026. }
  1027. pr_debug("%p %d\n", llcp_sock, sap);
  1028. nfc_llcp_sock_put(llcp_sock);
  1029. add_snl:
  1030. sdp = nfc_llcp_build_sdres_tlv(tid, sap);
  1031. if (sdp == NULL)
  1032. goto exit;
  1033. sdres_tlvs_len += sdp->tlv_len;
  1034. hlist_add_head(&sdp->node, &llc_sdres_list);
  1035. break;
  1036. case LLCP_TLV_SDRES:
  1037. mutex_lock(&local->sdreq_lock);
  1038. pr_debug("LLCP_TLV_SDRES: searching tid %d\n", tlv[2]);
  1039. hlist_for_each_entry(sdp, &local->pending_sdreqs, node) {
  1040. if (sdp->tid != tlv[2])
  1041. continue;
  1042. sdp->sap = tlv[3];
  1043. pr_debug("Found: uri=%s, sap=%d\n",
  1044. sdp->uri, sdp->sap);
  1045. hlist_del(&sdp->node);
  1046. hlist_add_head(&sdp->node, &nl_sdres_list);
  1047. break;
  1048. }
  1049. mutex_unlock(&local->sdreq_lock);
  1050. break;
  1051. default:
  1052. pr_err("Invalid SNL tlv value 0x%x\n", type);
  1053. break;
  1054. }
  1055. offset += length + 2;
  1056. tlv += length + 2;
  1057. }
  1058. exit:
  1059. if (!hlist_empty(&nl_sdres_list))
  1060. nfc_genl_llc_send_sdres(local->dev, &nl_sdres_list);
  1061. if (!hlist_empty(&llc_sdres_list))
  1062. nfc_llcp_send_snl_sdres(local, &llc_sdres_list, sdres_tlvs_len);
  1063. }
  1064. static void nfc_llcp_recv_agf(struct nfc_llcp_local *local, struct sk_buff *skb)
  1065. {
  1066. u8 ptype;
  1067. u16 pdu_len;
  1068. struct sk_buff *new_skb;
  1069. if (skb->len <= LLCP_HEADER_SIZE) {
  1070. pr_err("Malformed AGF PDU\n");
  1071. return;
  1072. }
  1073. skb_pull(skb, LLCP_HEADER_SIZE);
  1074. while (skb->len > LLCP_AGF_PDU_HEADER_SIZE) {
  1075. pdu_len = skb->data[0] << 8 | skb->data[1];
  1076. skb_pull(skb, LLCP_AGF_PDU_HEADER_SIZE);
  1077. if (pdu_len < LLCP_HEADER_SIZE || pdu_len > skb->len) {
  1078. pr_err("Malformed AGF PDU\n");
  1079. return;
  1080. }
  1081. ptype = nfc_llcp_ptype(skb);
  1082. if (ptype == LLCP_PDU_SYMM || ptype == LLCP_PDU_AGF)
  1083. goto next;
  1084. new_skb = nfc_alloc_recv_skb(pdu_len, GFP_KERNEL);
  1085. if (new_skb == NULL) {
  1086. pr_err("Could not allocate PDU\n");
  1087. return;
  1088. }
  1089. skb_put_data(new_skb, skb->data, pdu_len);
  1090. nfc_llcp_rx_skb(local, new_skb);
  1091. kfree_skb(new_skb);
  1092. next:
  1093. skb_pull(skb, pdu_len);
  1094. }
  1095. }
  1096. static void nfc_llcp_rx_skb(struct nfc_llcp_local *local, struct sk_buff *skb)
  1097. {
  1098. u8 dsap, ssap, ptype;
  1099. ptype = nfc_llcp_ptype(skb);
  1100. dsap = nfc_llcp_dsap(skb);
  1101. ssap = nfc_llcp_ssap(skb);
  1102. pr_debug("ptype 0x%x dsap 0x%x ssap 0x%x\n", ptype, dsap, ssap);
  1103. if (ptype != LLCP_PDU_SYMM)
  1104. print_hex_dump_debug("LLCP Rx: ", DUMP_PREFIX_OFFSET, 16, 1,
  1105. skb->data, skb->len, true);
  1106. switch (ptype) {
  1107. case LLCP_PDU_SYMM:
  1108. pr_debug("SYMM\n");
  1109. break;
  1110. case LLCP_PDU_UI:
  1111. pr_debug("UI\n");
  1112. nfc_llcp_recv_ui(local, skb);
  1113. break;
  1114. case LLCP_PDU_CONNECT:
  1115. pr_debug("CONNECT\n");
  1116. nfc_llcp_recv_connect(local, skb);
  1117. break;
  1118. case LLCP_PDU_DISC:
  1119. pr_debug("DISC\n");
  1120. nfc_llcp_recv_disc(local, skb);
  1121. break;
  1122. case LLCP_PDU_CC:
  1123. pr_debug("CC\n");
  1124. nfc_llcp_recv_cc(local, skb);
  1125. break;
  1126. case LLCP_PDU_DM:
  1127. pr_debug("DM\n");
  1128. nfc_llcp_recv_dm(local, skb);
  1129. break;
  1130. case LLCP_PDU_SNL:
  1131. pr_debug("SNL\n");
  1132. nfc_llcp_recv_snl(local, skb);
  1133. break;
  1134. case LLCP_PDU_I:
  1135. case LLCP_PDU_RR:
  1136. case LLCP_PDU_RNR:
  1137. pr_debug("I frame\n");
  1138. nfc_llcp_recv_hdlc(local, skb);
  1139. break;
  1140. case LLCP_PDU_AGF:
  1141. pr_debug("AGF frame\n");
  1142. nfc_llcp_recv_agf(local, skb);
  1143. break;
  1144. }
  1145. }
  1146. static void nfc_llcp_rx_work(struct work_struct *work)
  1147. {
  1148. struct nfc_llcp_local *local = container_of(work, struct nfc_llcp_local,
  1149. rx_work);
  1150. struct sk_buff *skb;
  1151. skb = local->rx_pending;
  1152. if (skb == NULL) {
  1153. pr_debug("No pending SKB\n");
  1154. return;
  1155. }
  1156. __net_timestamp(skb);
  1157. nfc_llcp_send_to_raw_sock(local, skb, NFC_DIRECTION_RX);
  1158. nfc_llcp_rx_skb(local, skb);
  1159. schedule_work(&local->tx_work);
  1160. kfree_skb(local->rx_pending);
  1161. local->rx_pending = NULL;
  1162. }
  1163. static void __nfc_llcp_recv(struct nfc_llcp_local *local, struct sk_buff *skb)
  1164. {
  1165. local->rx_pending = skb;
  1166. timer_delete(&local->link_timer);
  1167. schedule_work(&local->rx_work);
  1168. }
  1169. void nfc_llcp_recv(void *data, struct sk_buff *skb, int err)
  1170. {
  1171. struct nfc_llcp_local *local = (struct nfc_llcp_local *) data;
  1172. if (err < 0) {
  1173. pr_err("LLCP PDU receive err %d\n", err);
  1174. return;
  1175. }
  1176. __nfc_llcp_recv(local, skb);
  1177. }
  1178. int nfc_llcp_data_received(struct nfc_dev *dev, struct sk_buff *skb)
  1179. {
  1180. struct nfc_llcp_local *local;
  1181. local = nfc_llcp_find_local(dev);
  1182. if (local == NULL) {
  1183. kfree_skb(skb);
  1184. return -ENODEV;
  1185. }
  1186. __nfc_llcp_recv(local, skb);
  1187. nfc_llcp_local_put(local);
  1188. return 0;
  1189. }
  1190. void nfc_llcp_mac_is_down(struct nfc_dev *dev)
  1191. {
  1192. struct nfc_llcp_local *local;
  1193. local = nfc_llcp_find_local(dev);
  1194. if (local == NULL)
  1195. return;
  1196. local->remote_miu = LLCP_DEFAULT_MIU;
  1197. local->remote_lto = LLCP_DEFAULT_LTO;
  1198. /* Close and purge all existing sockets */
  1199. nfc_llcp_socket_release(local, true, 0);
  1200. nfc_llcp_local_put(local);
  1201. }
  1202. void nfc_llcp_mac_is_up(struct nfc_dev *dev, u32 target_idx,
  1203. u8 comm_mode, u8 rf_mode)
  1204. {
  1205. struct nfc_llcp_local *local;
  1206. pr_debug("rf mode %d\n", rf_mode);
  1207. local = nfc_llcp_find_local(dev);
  1208. if (local == NULL)
  1209. return;
  1210. local->target_idx = target_idx;
  1211. local->comm_mode = comm_mode;
  1212. local->rf_mode = rf_mode;
  1213. if (rf_mode == NFC_RF_INITIATOR) {
  1214. pr_debug("Queueing Tx work\n");
  1215. schedule_work(&local->tx_work);
  1216. } else {
  1217. mod_timer(&local->link_timer,
  1218. jiffies + msecs_to_jiffies(local->remote_lto));
  1219. }
  1220. nfc_llcp_local_put(local);
  1221. }
  1222. int nfc_llcp_register_device(struct nfc_dev *ndev)
  1223. {
  1224. struct nfc_llcp_local *local;
  1225. local = kzalloc_obj(struct nfc_llcp_local);
  1226. if (local == NULL)
  1227. return -ENOMEM;
  1228. /* As we are going to initialize local's refcount, we need to get the
  1229. * nfc_dev to avoid UAF, otherwise there is no point in continuing.
  1230. * See nfc_llcp_local_get().
  1231. */
  1232. local->dev = nfc_get_device(ndev->idx);
  1233. if (!local->dev) {
  1234. kfree(local);
  1235. return -ENODEV;
  1236. }
  1237. INIT_LIST_HEAD(&local->list);
  1238. kref_init(&local->ref);
  1239. mutex_init(&local->sdp_lock);
  1240. timer_setup(&local->link_timer, nfc_llcp_symm_timer, 0);
  1241. skb_queue_head_init(&local->tx_queue);
  1242. INIT_WORK(&local->tx_work, nfc_llcp_tx_work);
  1243. local->rx_pending = NULL;
  1244. INIT_WORK(&local->rx_work, nfc_llcp_rx_work);
  1245. INIT_WORK(&local->timeout_work, nfc_llcp_timeout_work);
  1246. rwlock_init(&local->sockets.lock);
  1247. rwlock_init(&local->connecting_sockets.lock);
  1248. rwlock_init(&local->raw_sockets.lock);
  1249. local->lto = 150; /* 1500 ms */
  1250. local->rw = LLCP_MAX_RW;
  1251. local->miux = cpu_to_be16(LLCP_MAX_MIUX);
  1252. local->local_wks = 0x1; /* LLC Link Management */
  1253. nfc_llcp_build_gb(local);
  1254. local->remote_miu = LLCP_DEFAULT_MIU;
  1255. local->remote_lto = LLCP_DEFAULT_LTO;
  1256. mutex_init(&local->sdreq_lock);
  1257. INIT_HLIST_HEAD(&local->pending_sdreqs);
  1258. timer_setup(&local->sdreq_timer, nfc_llcp_sdreq_timer, 0);
  1259. INIT_WORK(&local->sdreq_timeout_work, nfc_llcp_sdreq_timeout_work);
  1260. spin_lock(&llcp_devices_lock);
  1261. list_add(&local->list, &llcp_devices);
  1262. spin_unlock(&llcp_devices_lock);
  1263. return 0;
  1264. }
  1265. void nfc_llcp_unregister_device(struct nfc_dev *dev)
  1266. {
  1267. struct nfc_llcp_local *local = nfc_llcp_remove_local(dev);
  1268. if (local == NULL) {
  1269. pr_debug("No such device\n");
  1270. return;
  1271. }
  1272. local_cleanup(local);
  1273. nfc_llcp_local_put(local);
  1274. }
  1275. int __init nfc_llcp_init(void)
  1276. {
  1277. return nfc_llcp_sock_init();
  1278. }
  1279. void nfc_llcp_exit(void)
  1280. {
  1281. nfc_llcp_sock_exit();
  1282. }