smc_clc.c 37 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366
  1. // SPDX-License-Identifier: GPL-2.0
  2. /*
  3. * Shared Memory Communications over RDMA (SMC-R) and RoCE
  4. *
  5. * CLC (connection layer control) handshake over initial TCP socket to
  6. * prepare for RDMA traffic
  7. *
  8. * Copyright IBM Corp. 2016, 2018
  9. *
  10. * Author(s): Ursula Braun <ubraun@linux.vnet.ibm.com>
  11. */
  12. #include <linux/in.h>
  13. #include <linux/inetdevice.h>
  14. #include <linux/if_ether.h>
  15. #include <linux/sched/signal.h>
  16. #include <linux/utsname.h>
  17. #include <linux/ctype.h>
  18. #include <net/addrconf.h>
  19. #include <net/sock.h>
  20. #include <net/tcp.h>
  21. #include "smc.h"
  22. #include "smc_core.h"
  23. #include "smc_clc.h"
  24. #include "smc_ib.h"
  25. #include "smc_ism.h"
  26. #include "smc_netlink.h"
  27. #define SMCR_CLC_ACCEPT_CONFIRM_LEN 68
  28. #define SMCD_CLC_ACCEPT_CONFIRM_LEN 48
  29. #define SMCD_CLC_ACCEPT_CONFIRM_LEN_V2 78
  30. #define SMCR_CLC_ACCEPT_CONFIRM_LEN_V2 108
  31. #define SMC_CLC_RECV_BUF_LEN 100
  32. /* eye catcher "SMCR" EBCDIC for CLC messages */
  33. static const char SMC_EYECATCHER[4] = {'\xe2', '\xd4', '\xc3', '\xd9'};
  34. /* eye catcher "SMCD" EBCDIC for CLC messages */
  35. static const char SMCD_EYECATCHER[4] = {'\xe2', '\xd4', '\xc3', '\xc4'};
  36. static u8 smc_hostname[SMC_MAX_HOSTNAME_LEN];
  37. struct smc_clc_eid_table {
  38. rwlock_t lock;
  39. struct list_head list;
  40. u8 ueid_cnt;
  41. u8 seid_enabled;
  42. };
  43. static struct smc_clc_eid_table smc_clc_eid_table;
  44. struct smc_clc_eid_entry {
  45. struct list_head list;
  46. u8 eid[SMC_MAX_EID_LEN];
  47. };
  48. /* The size of a user EID is 32 characters.
  49. * Valid characters should be (single-byte character set) A-Z, 0-9, '.' and '-'.
  50. * Blanks should only be used to pad to the expected size.
  51. * First character must be alphanumeric.
  52. */
  53. static bool smc_clc_ueid_valid(char *ueid)
  54. {
  55. char *end = ueid + SMC_MAX_EID_LEN;
  56. while (--end >= ueid && isspace(*end))
  57. ;
  58. if (end < ueid)
  59. return false;
  60. if (!isalnum(*ueid) || islower(*ueid))
  61. return false;
  62. while (ueid <= end) {
  63. if ((!isalnum(*ueid) || islower(*ueid)) && *ueid != '.' &&
  64. *ueid != '-')
  65. return false;
  66. ueid++;
  67. }
  68. return true;
  69. }
  70. static int smc_clc_ueid_add(char *ueid)
  71. {
  72. struct smc_clc_eid_entry *new_ueid, *tmp_ueid;
  73. int rc;
  74. if (!smc_clc_ueid_valid(ueid))
  75. return -EINVAL;
  76. /* add a new ueid entry to the ueid table if there isn't one */
  77. new_ueid = kzalloc(sizeof(*new_ueid), GFP_KERNEL);
  78. if (!new_ueid)
  79. return -ENOMEM;
  80. memcpy(new_ueid->eid, ueid, SMC_MAX_EID_LEN);
  81. write_lock(&smc_clc_eid_table.lock);
  82. if (smc_clc_eid_table.ueid_cnt >= SMC_MAX_UEID) {
  83. rc = -ERANGE;
  84. goto err_out;
  85. }
  86. list_for_each_entry(tmp_ueid, &smc_clc_eid_table.list, list) {
  87. if (!memcmp(tmp_ueid->eid, ueid, SMC_MAX_EID_LEN)) {
  88. rc = -EEXIST;
  89. goto err_out;
  90. }
  91. }
  92. list_add_tail(&new_ueid->list, &smc_clc_eid_table.list);
  93. smc_clc_eid_table.ueid_cnt++;
  94. write_unlock(&smc_clc_eid_table.lock);
  95. return 0;
  96. err_out:
  97. write_unlock(&smc_clc_eid_table.lock);
  98. kfree(new_ueid);
  99. return rc;
  100. }
  101. int smc_clc_ueid_count(void)
  102. {
  103. int count;
  104. read_lock(&smc_clc_eid_table.lock);
  105. count = smc_clc_eid_table.ueid_cnt;
  106. read_unlock(&smc_clc_eid_table.lock);
  107. return count;
  108. }
  109. int smc_nl_add_ueid(struct sk_buff *skb, struct genl_info *info)
  110. {
  111. struct nlattr *nla_ueid = info->attrs[SMC_NLA_EID_TABLE_ENTRY];
  112. char *ueid;
  113. if (!nla_ueid || nla_len(nla_ueid) != SMC_MAX_EID_LEN + 1)
  114. return -EINVAL;
  115. ueid = (char *)nla_data(nla_ueid);
  116. return smc_clc_ueid_add(ueid);
  117. }
  118. /* remove one or all ueid entries from the table */
  119. static int smc_clc_ueid_remove(char *ueid)
  120. {
  121. struct smc_clc_eid_entry *lst_ueid, *tmp_ueid;
  122. int rc = -ENOENT;
  123. /* remove table entry */
  124. write_lock(&smc_clc_eid_table.lock);
  125. list_for_each_entry_safe(lst_ueid, tmp_ueid, &smc_clc_eid_table.list,
  126. list) {
  127. if (!ueid || !memcmp(lst_ueid->eid, ueid, SMC_MAX_EID_LEN)) {
  128. list_del(&lst_ueid->list);
  129. smc_clc_eid_table.ueid_cnt--;
  130. kfree(lst_ueid);
  131. rc = 0;
  132. }
  133. }
  134. #if IS_ENABLED(CONFIG_S390)
  135. if (!rc && !smc_clc_eid_table.ueid_cnt) {
  136. smc_clc_eid_table.seid_enabled = 1;
  137. rc = -EAGAIN; /* indicate success and enabling of seid */
  138. }
  139. #endif
  140. write_unlock(&smc_clc_eid_table.lock);
  141. return rc;
  142. }
  143. int smc_nl_remove_ueid(struct sk_buff *skb, struct genl_info *info)
  144. {
  145. struct nlattr *nla_ueid = info->attrs[SMC_NLA_EID_TABLE_ENTRY];
  146. char *ueid;
  147. if (!nla_ueid || nla_len(nla_ueid) != SMC_MAX_EID_LEN + 1)
  148. return -EINVAL;
  149. ueid = (char *)nla_data(nla_ueid);
  150. return smc_clc_ueid_remove(ueid);
  151. }
  152. int smc_nl_flush_ueid(struct sk_buff *skb, struct genl_info *info)
  153. {
  154. smc_clc_ueid_remove(NULL);
  155. return 0;
  156. }
  157. static int smc_nl_ueid_dumpinfo(struct sk_buff *skb, u32 portid, u32 seq,
  158. u32 flags, char *ueid)
  159. {
  160. char ueid_str[SMC_MAX_EID_LEN + 1];
  161. void *hdr;
  162. hdr = genlmsg_put(skb, portid, seq, &smc_gen_nl_family,
  163. flags, SMC_NETLINK_DUMP_UEID);
  164. if (!hdr)
  165. return -ENOMEM;
  166. memcpy(ueid_str, ueid, SMC_MAX_EID_LEN);
  167. ueid_str[SMC_MAX_EID_LEN] = 0;
  168. if (nla_put_string(skb, SMC_NLA_EID_TABLE_ENTRY, ueid_str)) {
  169. genlmsg_cancel(skb, hdr);
  170. return -EMSGSIZE;
  171. }
  172. genlmsg_end(skb, hdr);
  173. return 0;
  174. }
  175. static int _smc_nl_ueid_dump(struct sk_buff *skb, u32 portid, u32 seq,
  176. int start_idx)
  177. {
  178. struct smc_clc_eid_entry *lst_ueid;
  179. int idx = 0;
  180. read_lock(&smc_clc_eid_table.lock);
  181. list_for_each_entry(lst_ueid, &smc_clc_eid_table.list, list) {
  182. if (idx++ < start_idx)
  183. continue;
  184. if (smc_nl_ueid_dumpinfo(skb, portid, seq, NLM_F_MULTI,
  185. lst_ueid->eid)) {
  186. --idx;
  187. break;
  188. }
  189. }
  190. read_unlock(&smc_clc_eid_table.lock);
  191. return idx;
  192. }
  193. int smc_nl_dump_ueid(struct sk_buff *skb, struct netlink_callback *cb)
  194. {
  195. struct smc_nl_dmp_ctx *cb_ctx = smc_nl_dmp_ctx(cb);
  196. int idx;
  197. idx = _smc_nl_ueid_dump(skb, NETLINK_CB(cb->skb).portid,
  198. cb->nlh->nlmsg_seq, cb_ctx->pos[0]);
  199. cb_ctx->pos[0] = idx;
  200. return skb->len;
  201. }
  202. int smc_nl_dump_seid(struct sk_buff *skb, struct netlink_callback *cb)
  203. {
  204. struct smc_nl_dmp_ctx *cb_ctx = smc_nl_dmp_ctx(cb);
  205. char seid_str[SMC_MAX_EID_LEN + 1];
  206. u8 seid_enabled;
  207. void *hdr;
  208. u8 *seid;
  209. if (cb_ctx->pos[0])
  210. return skb->len;
  211. hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid, cb->nlh->nlmsg_seq,
  212. &smc_gen_nl_family, NLM_F_MULTI,
  213. SMC_NETLINK_DUMP_SEID);
  214. if (!hdr)
  215. return -ENOMEM;
  216. if (!smc_ism_is_v2_capable())
  217. goto end;
  218. smc_ism_get_system_eid(&seid);
  219. memcpy(seid_str, seid, SMC_MAX_EID_LEN);
  220. seid_str[SMC_MAX_EID_LEN] = 0;
  221. if (nla_put_string(skb, SMC_NLA_SEID_ENTRY, seid_str))
  222. goto err;
  223. read_lock(&smc_clc_eid_table.lock);
  224. seid_enabled = smc_clc_eid_table.seid_enabled;
  225. read_unlock(&smc_clc_eid_table.lock);
  226. if (nla_put_u8(skb, SMC_NLA_SEID_ENABLED, seid_enabled))
  227. goto err;
  228. end:
  229. genlmsg_end(skb, hdr);
  230. cb_ctx->pos[0]++;
  231. return skb->len;
  232. err:
  233. genlmsg_cancel(skb, hdr);
  234. return -EMSGSIZE;
  235. }
  236. int smc_nl_enable_seid(struct sk_buff *skb, struct genl_info *info)
  237. {
  238. #if IS_ENABLED(CONFIG_S390)
  239. write_lock(&smc_clc_eid_table.lock);
  240. smc_clc_eid_table.seid_enabled = 1;
  241. write_unlock(&smc_clc_eid_table.lock);
  242. return 0;
  243. #else
  244. return -EOPNOTSUPP;
  245. #endif
  246. }
  247. int smc_nl_disable_seid(struct sk_buff *skb, struct genl_info *info)
  248. {
  249. int rc = 0;
  250. #if IS_ENABLED(CONFIG_S390)
  251. write_lock(&smc_clc_eid_table.lock);
  252. if (!smc_clc_eid_table.ueid_cnt)
  253. rc = -ENOENT;
  254. else
  255. smc_clc_eid_table.seid_enabled = 0;
  256. write_unlock(&smc_clc_eid_table.lock);
  257. #else
  258. rc = -EOPNOTSUPP;
  259. #endif
  260. return rc;
  261. }
  262. static bool _smc_clc_match_ueid(u8 *peer_ueid)
  263. {
  264. struct smc_clc_eid_entry *tmp_ueid;
  265. list_for_each_entry(tmp_ueid, &smc_clc_eid_table.list, list) {
  266. if (!memcmp(tmp_ueid->eid, peer_ueid, SMC_MAX_EID_LEN))
  267. return true;
  268. }
  269. return false;
  270. }
  271. bool smc_clc_match_eid(u8 *negotiated_eid,
  272. struct smc_clc_v2_extension *smc_v2_ext,
  273. u8 *peer_eid, u8 *local_eid)
  274. {
  275. bool match = false;
  276. int i;
  277. negotiated_eid[0] = 0;
  278. read_lock(&smc_clc_eid_table.lock);
  279. if (peer_eid && local_eid &&
  280. smc_clc_eid_table.seid_enabled &&
  281. smc_v2_ext->hdr.flag.seid &&
  282. !memcmp(peer_eid, local_eid, SMC_MAX_EID_LEN)) {
  283. memcpy(negotiated_eid, peer_eid, SMC_MAX_EID_LEN);
  284. match = true;
  285. goto out;
  286. }
  287. for (i = 0; i < smc_v2_ext->hdr.eid_cnt; i++) {
  288. if (_smc_clc_match_ueid(smc_v2_ext->user_eids[i])) {
  289. memcpy(negotiated_eid, smc_v2_ext->user_eids[i],
  290. SMC_MAX_EID_LEN);
  291. match = true;
  292. goto out;
  293. }
  294. }
  295. out:
  296. read_unlock(&smc_clc_eid_table.lock);
  297. return match;
  298. }
  299. /* check arriving CLC proposal */
  300. static bool smc_clc_msg_prop_valid(struct smc_clc_msg_proposal *pclc)
  301. {
  302. struct smc_clc_msg_proposal_prefix *pclc_prfx;
  303. struct smc_clc_smcd_v2_extension *smcd_v2_ext;
  304. struct smc_clc_msg_hdr *hdr = &pclc->hdr;
  305. struct smc_clc_v2_extension *v2_ext;
  306. pclc_prfx = smc_clc_proposal_get_prefix(pclc);
  307. if (!pclc_prfx ||
  308. pclc_prfx->ipv6_prefixes_cnt > SMC_CLC_MAX_V6_PREFIX)
  309. return false;
  310. if (hdr->version == SMC_V1) {
  311. if (hdr->typev1 == SMC_TYPE_N)
  312. return false;
  313. if (ntohs(hdr->length) !=
  314. sizeof(*pclc) + ntohs(pclc->iparea_offset) +
  315. sizeof(*pclc_prfx) +
  316. pclc_prfx->ipv6_prefixes_cnt *
  317. sizeof(struct smc_clc_ipv6_prefix) +
  318. sizeof(struct smc_clc_msg_trail))
  319. return false;
  320. } else {
  321. v2_ext = smc_get_clc_v2_ext(pclc);
  322. if ((hdr->typev2 != SMC_TYPE_N &&
  323. (!v2_ext || v2_ext->hdr.eid_cnt > SMC_CLC_MAX_UEID)) ||
  324. (smcd_indicated(hdr->typev2) &&
  325. v2_ext->hdr.ism_gid_cnt > SMCD_CLC_MAX_V2_GID_ENTRIES))
  326. return false;
  327. if (ntohs(hdr->length) !=
  328. sizeof(*pclc) +
  329. sizeof(struct smc_clc_msg_smcd) +
  330. (hdr->typev1 != SMC_TYPE_N ?
  331. sizeof(*pclc_prfx) +
  332. pclc_prfx->ipv6_prefixes_cnt *
  333. sizeof(struct smc_clc_ipv6_prefix) : 0) +
  334. (hdr->typev2 != SMC_TYPE_N ?
  335. sizeof(*v2_ext) +
  336. v2_ext->hdr.eid_cnt * SMC_MAX_EID_LEN : 0) +
  337. (smcd_indicated(hdr->typev2) ?
  338. sizeof(*smcd_v2_ext) + v2_ext->hdr.ism_gid_cnt *
  339. sizeof(struct smc_clc_smcd_gid_chid) :
  340. 0) +
  341. sizeof(struct smc_clc_msg_trail))
  342. return false;
  343. }
  344. return true;
  345. }
  346. /* check arriving CLC accept or confirm */
  347. static bool
  348. smc_clc_msg_acc_conf_valid(struct smc_clc_msg_accept_confirm *clc)
  349. {
  350. struct smc_clc_msg_hdr *hdr = &clc->hdr;
  351. if (hdr->typev1 != SMC_TYPE_R && hdr->typev1 != SMC_TYPE_D)
  352. return false;
  353. if (hdr->version == SMC_V1) {
  354. if ((hdr->typev1 == SMC_TYPE_R &&
  355. ntohs(hdr->length) != SMCR_CLC_ACCEPT_CONFIRM_LEN) ||
  356. (hdr->typev1 == SMC_TYPE_D &&
  357. ntohs(hdr->length) != SMCD_CLC_ACCEPT_CONFIRM_LEN))
  358. return false;
  359. } else {
  360. if (hdr->typev1 == SMC_TYPE_D &&
  361. ntohs(hdr->length) < SMCD_CLC_ACCEPT_CONFIRM_LEN_V2)
  362. return false;
  363. if (hdr->typev1 == SMC_TYPE_R &&
  364. ntohs(hdr->length) < SMCR_CLC_ACCEPT_CONFIRM_LEN_V2)
  365. return false;
  366. }
  367. return true;
  368. }
  369. /* check arriving CLC decline */
  370. static bool
  371. smc_clc_msg_decl_valid(struct smc_clc_msg_decline *dclc)
  372. {
  373. struct smc_clc_msg_hdr *hdr = &dclc->hdr;
  374. if (hdr->version == SMC_V1) {
  375. if (ntohs(hdr->length) != sizeof(struct smc_clc_msg_decline))
  376. return false;
  377. } else {
  378. if (ntohs(hdr->length) != sizeof(struct smc_clc_msg_decline_v2))
  379. return false;
  380. }
  381. return true;
  382. }
  383. static int smc_clc_fill_fce_v2x(struct smc_clc_first_contact_ext_v2x *fce_v2x,
  384. struct smc_init_info *ini)
  385. {
  386. int ret = sizeof(*fce_v2x);
  387. memset(fce_v2x, 0, sizeof(*fce_v2x));
  388. fce_v2x->fce_v2_base.os_type = SMC_CLC_OS_LINUX;
  389. fce_v2x->fce_v2_base.release = ini->release_nr;
  390. memcpy(fce_v2x->fce_v2_base.hostname,
  391. smc_hostname, sizeof(smc_hostname));
  392. if (ini->is_smcd && ini->release_nr < SMC_RELEASE_1) {
  393. ret = sizeof(struct smc_clc_first_contact_ext);
  394. goto out;
  395. }
  396. if (ini->release_nr >= SMC_RELEASE_1) {
  397. if (!ini->is_smcd) {
  398. fce_v2x->max_conns = ini->max_conns;
  399. fce_v2x->max_links = ini->max_links;
  400. }
  401. fce_v2x->feature_mask = htons(ini->feature_mask);
  402. }
  403. out:
  404. return ret;
  405. }
  406. /* check if received message has a correct header length and contains valid
  407. * heading and trailing eyecatchers
  408. */
  409. static bool smc_clc_msg_hdr_valid(struct smc_clc_msg_hdr *clcm, bool check_trl)
  410. {
  411. struct smc_clc_msg_accept_confirm *clc;
  412. struct smc_clc_msg_proposal *pclc;
  413. struct smc_clc_msg_decline *dclc;
  414. struct smc_clc_msg_trail *trl;
  415. if (memcmp(clcm->eyecatcher, SMC_EYECATCHER, sizeof(SMC_EYECATCHER)) &&
  416. memcmp(clcm->eyecatcher, SMCD_EYECATCHER, sizeof(SMCD_EYECATCHER)))
  417. return false;
  418. switch (clcm->type) {
  419. case SMC_CLC_PROPOSAL:
  420. pclc = (struct smc_clc_msg_proposal *)clcm;
  421. if (!smc_clc_msg_prop_valid(pclc))
  422. return false;
  423. trl = (struct smc_clc_msg_trail *)
  424. ((u8 *)pclc + ntohs(pclc->hdr.length) - sizeof(*trl));
  425. break;
  426. case SMC_CLC_ACCEPT:
  427. case SMC_CLC_CONFIRM:
  428. clc = (struct smc_clc_msg_accept_confirm *)clcm;
  429. if (!smc_clc_msg_acc_conf_valid(clc))
  430. return false;
  431. trl = (struct smc_clc_msg_trail *)
  432. ((u8 *)clc + ntohs(clc->hdr.length) - sizeof(*trl));
  433. break;
  434. case SMC_CLC_DECLINE:
  435. dclc = (struct smc_clc_msg_decline *)clcm;
  436. if (!smc_clc_msg_decl_valid(dclc))
  437. return false;
  438. check_trl = false;
  439. break;
  440. default:
  441. return false;
  442. }
  443. if (check_trl &&
  444. memcmp(trl->eyecatcher, SMC_EYECATCHER, sizeof(SMC_EYECATCHER)) &&
  445. memcmp(trl->eyecatcher, SMCD_EYECATCHER, sizeof(SMCD_EYECATCHER)))
  446. return false;
  447. return true;
  448. }
  449. /* find ipv4 addr on device and get the prefix len, fill CLC proposal msg */
  450. static int smc_clc_prfx_set4_rcu(struct dst_entry *dst, __be32 ipv4,
  451. struct smc_clc_msg_proposal_prefix *prop)
  452. {
  453. struct in_device *in_dev = __in_dev_get_rcu(dst->dev);
  454. const struct in_ifaddr *ifa;
  455. if (!in_dev)
  456. return -ENODEV;
  457. in_dev_for_each_ifa_rcu(ifa, in_dev) {
  458. if (!inet_ifa_match(ipv4, ifa))
  459. continue;
  460. prop->prefix_len = inet_mask_len(ifa->ifa_mask);
  461. prop->outgoing_subnet = ifa->ifa_address & ifa->ifa_mask;
  462. /* prop->ipv6_prefixes_cnt = 0; already done by memset before */
  463. return 0;
  464. }
  465. return -ENOENT;
  466. }
  467. /* fill CLC proposal msg with ipv6 prefixes from device */
  468. static int smc_clc_prfx_set6_rcu(struct dst_entry *dst,
  469. struct smc_clc_msg_proposal_prefix *prop,
  470. struct smc_clc_ipv6_prefix *ipv6_prfx)
  471. {
  472. #if IS_ENABLED(CONFIG_IPV6)
  473. struct inet6_dev *in6_dev = __in6_dev_get(dst->dev);
  474. struct inet6_ifaddr *ifa;
  475. int cnt = 0;
  476. if (!in6_dev)
  477. return -ENODEV;
  478. /* use a maximum of 8 IPv6 prefixes from device */
  479. list_for_each_entry(ifa, &in6_dev->addr_list, if_list) {
  480. if (ipv6_addr_type(&ifa->addr) & IPV6_ADDR_LINKLOCAL)
  481. continue;
  482. ipv6_addr_prefix(&ipv6_prfx[cnt].prefix,
  483. &ifa->addr, ifa->prefix_len);
  484. ipv6_prfx[cnt].prefix_len = ifa->prefix_len;
  485. cnt++;
  486. if (cnt == SMC_CLC_MAX_V6_PREFIX)
  487. break;
  488. }
  489. prop->ipv6_prefixes_cnt = cnt;
  490. if (cnt)
  491. return 0;
  492. #endif
  493. return -ENOENT;
  494. }
  495. /* retrieve and set prefixes in CLC proposal msg */
  496. static int smc_clc_prfx_set(struct socket *clcsock,
  497. struct smc_clc_msg_proposal_prefix *prop,
  498. struct smc_clc_ipv6_prefix *ipv6_prfx)
  499. {
  500. struct dst_entry *dst = sk_dst_get(clcsock->sk);
  501. struct sockaddr_storage addrs;
  502. struct sockaddr_in6 *addr6;
  503. struct sockaddr_in *addr;
  504. int rc = -ENOENT;
  505. if (!dst) {
  506. rc = -ENOTCONN;
  507. goto out;
  508. }
  509. if (!dst->dev) {
  510. rc = -ENODEV;
  511. goto out_rel;
  512. }
  513. /* get address to which the internal TCP socket is bound */
  514. if (kernel_getsockname(clcsock, (struct sockaddr *)&addrs) < 0)
  515. goto out_rel;
  516. /* analyze IP specific data of net_device belonging to TCP socket */
  517. addr6 = (struct sockaddr_in6 *)&addrs;
  518. rcu_read_lock();
  519. if (addrs.ss_family == PF_INET) {
  520. /* IPv4 */
  521. addr = (struct sockaddr_in *)&addrs;
  522. rc = smc_clc_prfx_set4_rcu(dst, addr->sin_addr.s_addr, prop);
  523. } else if (ipv6_addr_v4mapped(&addr6->sin6_addr)) {
  524. /* mapped IPv4 address - peer is IPv4 only */
  525. rc = smc_clc_prfx_set4_rcu(dst, addr6->sin6_addr.s6_addr32[3],
  526. prop);
  527. } else {
  528. /* IPv6 */
  529. rc = smc_clc_prfx_set6_rcu(dst, prop, ipv6_prfx);
  530. }
  531. rcu_read_unlock();
  532. out_rel:
  533. dst_release(dst);
  534. out:
  535. return rc;
  536. }
  537. /* match ipv4 addrs of dev against addr in CLC proposal */
  538. static int smc_clc_prfx_match4_rcu(struct net_device *dev,
  539. struct smc_clc_msg_proposal_prefix *prop)
  540. {
  541. struct in_device *in_dev = __in_dev_get_rcu(dev);
  542. const struct in_ifaddr *ifa;
  543. if (!in_dev)
  544. return -ENODEV;
  545. in_dev_for_each_ifa_rcu(ifa, in_dev) {
  546. if (prop->prefix_len == inet_mask_len(ifa->ifa_mask) &&
  547. inet_ifa_match(prop->outgoing_subnet, ifa))
  548. return 0;
  549. }
  550. return -ENOENT;
  551. }
  552. /* match ipv6 addrs of dev against addrs in CLC proposal */
  553. static int smc_clc_prfx_match6_rcu(struct net_device *dev,
  554. struct smc_clc_msg_proposal_prefix *prop)
  555. {
  556. #if IS_ENABLED(CONFIG_IPV6)
  557. struct inet6_dev *in6_dev = __in6_dev_get(dev);
  558. struct smc_clc_ipv6_prefix *ipv6_prfx;
  559. struct inet6_ifaddr *ifa;
  560. int i, max;
  561. if (!in6_dev)
  562. return -ENODEV;
  563. /* ipv6 prefix list starts behind smc_clc_msg_proposal_prefix */
  564. ipv6_prfx = (struct smc_clc_ipv6_prefix *)((u8 *)prop + sizeof(*prop));
  565. max = min_t(u8, prop->ipv6_prefixes_cnt, SMC_CLC_MAX_V6_PREFIX);
  566. list_for_each_entry(ifa, &in6_dev->addr_list, if_list) {
  567. if (ipv6_addr_type(&ifa->addr) & IPV6_ADDR_LINKLOCAL)
  568. continue;
  569. for (i = 0; i < max; i++) {
  570. if (ifa->prefix_len == ipv6_prfx[i].prefix_len &&
  571. ipv6_prefix_equal(&ifa->addr, &ipv6_prfx[i].prefix,
  572. ifa->prefix_len))
  573. return 0;
  574. }
  575. }
  576. #endif
  577. return -ENOENT;
  578. }
  579. /* check if proposed prefixes match one of our device prefixes */
  580. int smc_clc_prfx_match(struct socket *clcsock,
  581. struct smc_clc_msg_proposal_prefix *prop)
  582. {
  583. struct dst_entry *dst = sk_dst_get(clcsock->sk);
  584. int rc;
  585. if (!dst) {
  586. rc = -ENOTCONN;
  587. goto out;
  588. }
  589. if (!dst->dev) {
  590. rc = -ENODEV;
  591. goto out_rel;
  592. }
  593. rcu_read_lock();
  594. if (!prop->ipv6_prefixes_cnt)
  595. rc = smc_clc_prfx_match4_rcu(dst->dev, prop);
  596. else
  597. rc = smc_clc_prfx_match6_rcu(dst->dev, prop);
  598. rcu_read_unlock();
  599. out_rel:
  600. dst_release(dst);
  601. out:
  602. return rc;
  603. }
  604. /* Wait for data on the tcp-socket, analyze received data
  605. * Returns:
  606. * 0 if success and it was not a decline that we received.
  607. * SMC_CLC_DECL_REPLY if decline received for fallback w/o another decl send.
  608. * clcsock error, -EINTR, -ECONNRESET, -EPROTO otherwise.
  609. */
  610. int smc_clc_wait_msg(struct smc_sock *smc, void *buf, int buflen,
  611. u8 expected_type, unsigned long timeout)
  612. {
  613. long rcvtimeo = smc->clcsock->sk->sk_rcvtimeo;
  614. struct sock *clc_sk = smc->clcsock->sk;
  615. struct smc_clc_msg_hdr *clcm = buf;
  616. struct msghdr msg = {NULL, 0};
  617. int reason_code = 0;
  618. struct kvec vec = {buf, buflen};
  619. int len, datlen, recvlen;
  620. bool check_trl = true;
  621. int krflags;
  622. /* peek the first few bytes to determine length of data to receive
  623. * so we don't consume any subsequent CLC message or payload data
  624. * in the TCP byte stream
  625. */
  626. /*
  627. * Caller must make sure that buflen is no less than
  628. * sizeof(struct smc_clc_msg_hdr)
  629. */
  630. krflags = MSG_PEEK | MSG_WAITALL;
  631. clc_sk->sk_rcvtimeo = timeout;
  632. iov_iter_kvec(&msg.msg_iter, ITER_DEST, &vec, 1,
  633. sizeof(struct smc_clc_msg_hdr));
  634. len = sock_recvmsg(smc->clcsock, &msg, krflags);
  635. if (signal_pending(current)) {
  636. reason_code = -EINTR;
  637. clc_sk->sk_err = EINTR;
  638. smc->sk.sk_err = EINTR;
  639. goto out;
  640. }
  641. if (clc_sk->sk_err) {
  642. reason_code = -clc_sk->sk_err;
  643. if (clc_sk->sk_err == EAGAIN &&
  644. expected_type == SMC_CLC_DECLINE)
  645. clc_sk->sk_err = 0; /* reset for fallback usage */
  646. else
  647. smc->sk.sk_err = clc_sk->sk_err;
  648. goto out;
  649. }
  650. if (!len) { /* peer has performed orderly shutdown */
  651. smc->sk.sk_err = ECONNRESET;
  652. reason_code = -ECONNRESET;
  653. goto out;
  654. }
  655. if (len < 0) {
  656. if (len != -EAGAIN || expected_type != SMC_CLC_DECLINE)
  657. smc->sk.sk_err = -len;
  658. reason_code = len;
  659. goto out;
  660. }
  661. datlen = ntohs(clcm->length);
  662. if ((len < sizeof(struct smc_clc_msg_hdr)) ||
  663. (clcm->version < SMC_V1) ||
  664. ((clcm->type != SMC_CLC_DECLINE) &&
  665. (clcm->type != expected_type))) {
  666. smc->sk.sk_err = EPROTO;
  667. reason_code = -EPROTO;
  668. goto out;
  669. }
  670. /* receive the complete CLC message */
  671. memset(&msg, 0, sizeof(struct msghdr));
  672. if (datlen > buflen) {
  673. check_trl = false;
  674. recvlen = buflen;
  675. } else {
  676. recvlen = datlen;
  677. }
  678. iov_iter_kvec(&msg.msg_iter, ITER_DEST, &vec, 1, recvlen);
  679. krflags = MSG_WAITALL;
  680. len = sock_recvmsg(smc->clcsock, &msg, krflags);
  681. if (len < recvlen || !smc_clc_msg_hdr_valid(clcm, check_trl)) {
  682. smc->sk.sk_err = EPROTO;
  683. reason_code = -EPROTO;
  684. goto out;
  685. }
  686. datlen -= len;
  687. while (datlen) {
  688. u8 tmp[SMC_CLC_RECV_BUF_LEN];
  689. vec.iov_base = &tmp;
  690. vec.iov_len = SMC_CLC_RECV_BUF_LEN;
  691. /* receive remaining proposal message */
  692. recvlen = datlen > SMC_CLC_RECV_BUF_LEN ?
  693. SMC_CLC_RECV_BUF_LEN : datlen;
  694. iov_iter_kvec(&msg.msg_iter, ITER_DEST, &vec, 1, recvlen);
  695. len = sock_recvmsg(smc->clcsock, &msg, krflags);
  696. if (len < recvlen) {
  697. smc->sk.sk_err = EPROTO;
  698. reason_code = -EPROTO;
  699. goto out;
  700. }
  701. datlen -= len;
  702. }
  703. if (clcm->type == SMC_CLC_DECLINE) {
  704. struct smc_clc_msg_decline *dclc;
  705. dclc = (struct smc_clc_msg_decline *)clcm;
  706. reason_code = SMC_CLC_DECL_PEERDECL;
  707. smc->peer_diagnosis = ntohl(dclc->peer_diagnosis);
  708. if (((struct smc_clc_msg_decline *)buf)->hdr.typev2 &
  709. SMC_FIRST_CONTACT_MASK) {
  710. smc->conn.lgr->sync_err = 1;
  711. smc_lgr_terminate_sched(smc->conn.lgr);
  712. }
  713. }
  714. out:
  715. clc_sk->sk_rcvtimeo = rcvtimeo;
  716. return reason_code;
  717. }
  718. /* send CLC DECLINE message across internal TCP socket */
  719. int smc_clc_send_decline(struct smc_sock *smc, u32 peer_diag_info, u8 version)
  720. {
  721. struct smc_clc_msg_decline *dclc_v1;
  722. struct smc_clc_msg_decline_v2 dclc;
  723. struct msghdr msg;
  724. int len, send_len;
  725. struct kvec vec;
  726. dclc_v1 = (struct smc_clc_msg_decline *)&dclc;
  727. memset(&dclc, 0, sizeof(dclc));
  728. memcpy(dclc.hdr.eyecatcher, SMC_EYECATCHER, sizeof(SMC_EYECATCHER));
  729. dclc.hdr.type = SMC_CLC_DECLINE;
  730. dclc.hdr.version = version;
  731. dclc.os_type = version == SMC_V1 ? 0 : SMC_CLC_OS_LINUX;
  732. dclc.hdr.typev2 = (peer_diag_info == SMC_CLC_DECL_SYNCERR) ?
  733. SMC_FIRST_CONTACT_MASK : 0;
  734. if ((!smc_conn_lgr_valid(&smc->conn) || !smc->conn.lgr->is_smcd) &&
  735. smc_ib_is_valid_local_systemid())
  736. memcpy(dclc.id_for_peer, local_systemid,
  737. sizeof(local_systemid));
  738. dclc.peer_diagnosis = htonl(peer_diag_info);
  739. if (version == SMC_V1) {
  740. memcpy(dclc_v1->trl.eyecatcher, SMC_EYECATCHER,
  741. sizeof(SMC_EYECATCHER));
  742. send_len = sizeof(*dclc_v1);
  743. } else {
  744. memcpy(dclc.trl.eyecatcher, SMC_EYECATCHER,
  745. sizeof(SMC_EYECATCHER));
  746. send_len = sizeof(dclc);
  747. }
  748. dclc.hdr.length = htons(send_len);
  749. memset(&msg, 0, sizeof(msg));
  750. vec.iov_base = &dclc;
  751. vec.iov_len = send_len;
  752. len = kernel_sendmsg(smc->clcsock, &msg, &vec, 1, send_len);
  753. if (len < 0 || len < send_len)
  754. len = -EPROTO;
  755. return len > 0 ? 0 : len;
  756. }
  757. /* send CLC PROPOSAL message across internal TCP socket */
  758. int smc_clc_send_proposal(struct smc_sock *smc, struct smc_init_info *ini)
  759. {
  760. struct smc_clc_smcd_v2_extension *smcd_v2_ext;
  761. struct smc_clc_msg_proposal_prefix *pclc_prfx;
  762. struct smc_clc_msg_proposal *pclc_base;
  763. struct smc_clc_smcd_gid_chid *gidchids;
  764. struct smc_clc_msg_proposal_area *pclc;
  765. struct smc_clc_ipv6_prefix *ipv6_prfx;
  766. struct net *net = sock_net(&smc->sk);
  767. struct smc_clc_v2_extension *v2_ext;
  768. struct smc_clc_msg_smcd *pclc_smcd;
  769. struct smc_clc_msg_trail *trl;
  770. struct smcd_dev *smcd;
  771. int len, i, plen, rc;
  772. int reason_code = 0;
  773. struct kvec vec[8];
  774. struct msghdr msg;
  775. pclc = kzalloc(sizeof(*pclc), GFP_KERNEL);
  776. if (!pclc)
  777. return -ENOMEM;
  778. pclc_base = &pclc->pclc_base;
  779. pclc_smcd = &pclc->pclc_smcd;
  780. pclc_prfx = &pclc->pclc_prfx;
  781. ipv6_prfx = pclc->pclc_prfx_ipv6;
  782. v2_ext = container_of(&pclc->pclc_v2_ext,
  783. struct smc_clc_v2_extension, fixed);
  784. smcd_v2_ext = container_of(&pclc->pclc_smcd_v2_ext,
  785. struct smc_clc_smcd_v2_extension, fixed);
  786. gidchids = pclc->pclc_gidchids;
  787. trl = &pclc->pclc_trl;
  788. pclc_base->hdr.version = SMC_V2;
  789. pclc_base->hdr.typev1 = ini->smc_type_v1;
  790. pclc_base->hdr.typev2 = ini->smc_type_v2;
  791. plen = sizeof(*pclc_base) + sizeof(*pclc_smcd) + sizeof(*trl);
  792. /* retrieve ip prefixes for CLC proposal msg */
  793. if (ini->smc_type_v1 != SMC_TYPE_N) {
  794. rc = smc_clc_prfx_set(smc->clcsock, pclc_prfx, ipv6_prfx);
  795. if (rc) {
  796. if (ini->smc_type_v2 == SMC_TYPE_N) {
  797. kfree(pclc);
  798. return SMC_CLC_DECL_CNFERR;
  799. }
  800. pclc_base->hdr.typev1 = SMC_TYPE_N;
  801. } else {
  802. pclc_base->iparea_offset = htons(sizeof(*pclc_smcd));
  803. plen += sizeof(*pclc_prfx) +
  804. pclc_prfx->ipv6_prefixes_cnt *
  805. sizeof(ipv6_prfx[0]);
  806. }
  807. }
  808. /* build SMC Proposal CLC message */
  809. memcpy(pclc_base->hdr.eyecatcher, SMC_EYECATCHER,
  810. sizeof(SMC_EYECATCHER));
  811. pclc_base->hdr.type = SMC_CLC_PROPOSAL;
  812. if (smcr_indicated(ini->smc_type_v1)) {
  813. /* add SMC-R specifics */
  814. memcpy(pclc_base->lcl.id_for_peer, local_systemid,
  815. sizeof(local_systemid));
  816. memcpy(pclc_base->lcl.gid, ini->ib_gid, SMC_GID_SIZE);
  817. memcpy(pclc_base->lcl.mac, &ini->ib_dev->mac[ini->ib_port - 1],
  818. ETH_ALEN);
  819. }
  820. if (smcd_indicated(ini->smc_type_v1)) {
  821. struct smcd_gid smcd_gid;
  822. /* add SMC-D specifics */
  823. if (ini->ism_dev[0]) {
  824. smcd = ini->ism_dev[0];
  825. smcd->ops->get_local_gid(smcd, &smcd_gid);
  826. pclc_smcd->ism.gid = htonll(smcd_gid.gid);
  827. pclc_smcd->ism.chid =
  828. htons(smc_ism_get_chid(ini->ism_dev[0]));
  829. }
  830. }
  831. if (ini->smc_type_v2 == SMC_TYPE_N) {
  832. pclc_smcd->v2_ext_offset = 0;
  833. } else {
  834. struct smc_clc_eid_entry *ueident;
  835. u16 v2_ext_offset;
  836. v2_ext->hdr.flag.release = SMC_RELEASE;
  837. v2_ext_offset = sizeof(*pclc_smcd) -
  838. offsetofend(struct smc_clc_msg_smcd, v2_ext_offset);
  839. if (ini->smc_type_v1 != SMC_TYPE_N)
  840. v2_ext_offset += sizeof(*pclc_prfx) +
  841. pclc_prfx->ipv6_prefixes_cnt *
  842. sizeof(ipv6_prfx[0]);
  843. pclc_smcd->v2_ext_offset = htons(v2_ext_offset);
  844. plen += sizeof(*v2_ext);
  845. v2_ext->feature_mask = htons(SMC_FEATURE_MASK);
  846. read_lock(&smc_clc_eid_table.lock);
  847. v2_ext->hdr.eid_cnt = smc_clc_eid_table.ueid_cnt;
  848. plen += smc_clc_eid_table.ueid_cnt * SMC_MAX_EID_LEN;
  849. i = 0;
  850. list_for_each_entry(ueident, &smc_clc_eid_table.list, list) {
  851. memcpy(v2_ext->user_eids[i++], ueident->eid,
  852. sizeof(ueident->eid));
  853. }
  854. read_unlock(&smc_clc_eid_table.lock);
  855. }
  856. if (smcd_indicated(ini->smc_type_v2)) {
  857. struct smcd_gid smcd_gid;
  858. u8 *eid = NULL;
  859. int entry = 0;
  860. v2_ext->hdr.flag.seid = smc_clc_eid_table.seid_enabled;
  861. v2_ext->hdr.smcd_v2_ext_offset = htons(sizeof(*v2_ext) -
  862. offsetofend(struct smc_clnt_opts_area_hdr,
  863. smcd_v2_ext_offset) +
  864. v2_ext->hdr.eid_cnt * SMC_MAX_EID_LEN);
  865. smc_ism_get_system_eid(&eid);
  866. if (eid && v2_ext->hdr.flag.seid)
  867. memcpy(smcd_v2_ext->system_eid, eid, SMC_MAX_EID_LEN);
  868. plen += sizeof(*smcd_v2_ext);
  869. if (ini->ism_offered_cnt) {
  870. for (i = 1; i <= ini->ism_offered_cnt; i++) {
  871. smcd = ini->ism_dev[i];
  872. smcd->ops->get_local_gid(smcd, &smcd_gid);
  873. gidchids[entry].chid =
  874. htons(smc_ism_get_chid(ini->ism_dev[i]));
  875. gidchids[entry].gid = htonll(smcd_gid.gid);
  876. if (smc_ism_is_emulated(smcd)) {
  877. /* an Emulated-ISM device takes two
  878. * entries. CHID of the second entry
  879. * repeats that of the first entry.
  880. */
  881. gidchids[entry + 1].chid =
  882. gidchids[entry].chid;
  883. gidchids[entry + 1].gid =
  884. htonll(smcd_gid.gid_ext);
  885. entry++;
  886. }
  887. entry++;
  888. }
  889. plen += entry * sizeof(struct smc_clc_smcd_gid_chid);
  890. }
  891. v2_ext->hdr.ism_gid_cnt = entry;
  892. }
  893. if (smcr_indicated(ini->smc_type_v2)) {
  894. memcpy(v2_ext->roce, ini->smcrv2.ib_gid_v2, SMC_GID_SIZE);
  895. v2_ext->max_conns = net->smc.sysctl_max_conns_per_lgr;
  896. v2_ext->max_links = net->smc.sysctl_max_links_per_lgr;
  897. }
  898. pclc_base->hdr.length = htons(plen);
  899. memcpy(trl->eyecatcher, SMC_EYECATCHER, sizeof(SMC_EYECATCHER));
  900. /* send SMC Proposal CLC message */
  901. memset(&msg, 0, sizeof(msg));
  902. i = 0;
  903. vec[i].iov_base = pclc_base;
  904. vec[i++].iov_len = sizeof(*pclc_base);
  905. vec[i].iov_base = pclc_smcd;
  906. vec[i++].iov_len = sizeof(*pclc_smcd);
  907. if (ini->smc_type_v1 != SMC_TYPE_N) {
  908. vec[i].iov_base = pclc_prfx;
  909. vec[i++].iov_len = sizeof(*pclc_prfx);
  910. if (pclc_prfx->ipv6_prefixes_cnt > 0) {
  911. vec[i].iov_base = ipv6_prfx;
  912. vec[i++].iov_len = pclc_prfx->ipv6_prefixes_cnt *
  913. sizeof(ipv6_prfx[0]);
  914. }
  915. }
  916. if (ini->smc_type_v2 != SMC_TYPE_N) {
  917. vec[i].iov_base = v2_ext;
  918. vec[i++].iov_len = sizeof(*v2_ext) +
  919. (v2_ext->hdr.eid_cnt * SMC_MAX_EID_LEN);
  920. if (smcd_indicated(ini->smc_type_v2)) {
  921. vec[i].iov_base = smcd_v2_ext;
  922. vec[i++].iov_len = sizeof(*smcd_v2_ext);
  923. if (ini->ism_offered_cnt) {
  924. vec[i].iov_base = gidchids;
  925. vec[i++].iov_len = v2_ext->hdr.ism_gid_cnt *
  926. sizeof(struct smc_clc_smcd_gid_chid);
  927. }
  928. }
  929. }
  930. vec[i].iov_base = trl;
  931. vec[i++].iov_len = sizeof(*trl);
  932. /* due to the few bytes needed for clc-handshake this cannot block */
  933. len = kernel_sendmsg(smc->clcsock, &msg, vec, i, plen);
  934. if (len < 0) {
  935. smc->sk.sk_err = smc->clcsock->sk->sk_err;
  936. reason_code = -smc->sk.sk_err;
  937. } else if (len < ntohs(pclc_base->hdr.length)) {
  938. reason_code = -ENETUNREACH;
  939. smc->sk.sk_err = -reason_code;
  940. }
  941. kfree(pclc);
  942. return reason_code;
  943. }
  944. static void
  945. smcd_clc_prep_confirm_accept(struct smc_connection *conn,
  946. struct smc_clc_msg_accept_confirm *clc,
  947. int first_contact, u8 version,
  948. u8 *eid, struct smc_init_info *ini,
  949. int *fce_len,
  950. struct smc_clc_first_contact_ext_v2x *fce_v2x,
  951. struct smc_clc_msg_trail *trl)
  952. {
  953. struct smcd_dev *smcd = conn->lgr->smcd;
  954. struct smcd_gid smcd_gid;
  955. u16 chid;
  956. int len;
  957. /* SMC-D specific settings */
  958. memcpy(clc->hdr.eyecatcher, SMCD_EYECATCHER,
  959. sizeof(SMCD_EYECATCHER));
  960. smcd->ops->get_local_gid(smcd, &smcd_gid);
  961. clc->hdr.typev1 = SMC_TYPE_D;
  962. clc->d0.gid = htonll(smcd_gid.gid);
  963. clc->d0.token = htonll(conn->rmb_desc->token);
  964. clc->d0.dmbe_size = conn->rmbe_size_comp;
  965. clc->d0.dmbe_idx = 0;
  966. memcpy(&clc->d0.linkid, conn->lgr->id, SMC_LGR_ID_SIZE);
  967. if (version == SMC_V1) {
  968. clc->hdr.length = htons(SMCD_CLC_ACCEPT_CONFIRM_LEN);
  969. } else {
  970. chid = smc_ism_get_chid(smcd);
  971. clc->d1.chid = htons(chid);
  972. if (eid && eid[0])
  973. memcpy(clc->d1.eid, eid, SMC_MAX_EID_LEN);
  974. if (__smc_ism_is_emulated(chid))
  975. clc->d1.gid_ext = htonll(smcd_gid.gid_ext);
  976. len = SMCD_CLC_ACCEPT_CONFIRM_LEN_V2;
  977. if (first_contact) {
  978. *fce_len = smc_clc_fill_fce_v2x(fce_v2x, ini);
  979. len += *fce_len;
  980. }
  981. clc->hdr.length = htons(len);
  982. }
  983. memcpy(trl->eyecatcher, SMCD_EYECATCHER,
  984. sizeof(SMCD_EYECATCHER));
  985. }
  986. static void
  987. smcr_clc_prep_confirm_accept(struct smc_connection *conn,
  988. struct smc_clc_msg_accept_confirm *clc,
  989. int first_contact, u8 version,
  990. u8 *eid, struct smc_init_info *ini,
  991. int *fce_len,
  992. struct smc_clc_first_contact_ext_v2x *fce_v2x,
  993. struct smc_clc_fce_gid_ext *gle,
  994. struct smc_clc_msg_trail *trl)
  995. {
  996. struct smc_link *link = conn->lnk;
  997. int len;
  998. /* SMC-R specific settings */
  999. memcpy(clc->hdr.eyecatcher, SMC_EYECATCHER,
  1000. sizeof(SMC_EYECATCHER));
  1001. clc->hdr.typev1 = SMC_TYPE_R;
  1002. memcpy(clc->r0.lcl.id_for_peer, local_systemid,
  1003. sizeof(local_systemid));
  1004. memcpy(&clc->r0.lcl.gid, link->gid, SMC_GID_SIZE);
  1005. memcpy(&clc->r0.lcl.mac, &link->smcibdev->mac[link->ibport - 1],
  1006. ETH_ALEN);
  1007. hton24(clc->r0.qpn, link->roce_qp->qp_num);
  1008. clc->r0.rmb_rkey =
  1009. htonl(conn->rmb_desc->mr[link->link_idx]->rkey);
  1010. clc->r0.rmbe_idx = 1; /* for now: 1 RMB = 1 RMBE */
  1011. clc->r0.rmbe_alert_token = htonl(conn->alert_token_local);
  1012. switch (clc->hdr.type) {
  1013. case SMC_CLC_ACCEPT:
  1014. clc->r0.qp_mtu = link->path_mtu;
  1015. break;
  1016. case SMC_CLC_CONFIRM:
  1017. clc->r0.qp_mtu = min(link->path_mtu, link->peer_mtu);
  1018. break;
  1019. }
  1020. clc->r0.rmbe_size = conn->rmbe_size_comp;
  1021. clc->r0.rmb_dma_addr = conn->rmb_desc->is_vm ?
  1022. cpu_to_be64((uintptr_t)conn->rmb_desc->cpu_addr) :
  1023. cpu_to_be64((u64)sg_dma_address
  1024. (conn->rmb_desc->sgt[link->link_idx].sgl));
  1025. hton24(clc->r0.psn, link->psn_initial);
  1026. if (version == SMC_V1) {
  1027. clc->hdr.length = htons(SMCR_CLC_ACCEPT_CONFIRM_LEN);
  1028. } else {
  1029. if (eid && eid[0])
  1030. memcpy(clc->r1.eid, eid, SMC_MAX_EID_LEN);
  1031. len = SMCR_CLC_ACCEPT_CONFIRM_LEN_V2;
  1032. if (first_contact) {
  1033. *fce_len = smc_clc_fill_fce_v2x(fce_v2x, ini);
  1034. len += *fce_len;
  1035. fce_v2x->fce_v2_base.v2_direct =
  1036. !link->lgr->uses_gateway;
  1037. if (clc->hdr.type == SMC_CLC_CONFIRM) {
  1038. memset(gle, 0, sizeof(*gle));
  1039. gle->gid_cnt = ini->smcrv2.gidlist.len;
  1040. len += sizeof(*gle);
  1041. len += gle->gid_cnt * sizeof(gle->gid[0]);
  1042. }
  1043. }
  1044. clc->hdr.length = htons(len);
  1045. }
  1046. memcpy(trl->eyecatcher, SMC_EYECATCHER, sizeof(SMC_EYECATCHER));
  1047. }
  1048. /* build and send CLC CONFIRM / ACCEPT message */
  1049. static int smc_clc_send_confirm_accept(struct smc_sock *smc,
  1050. struct smc_clc_msg_accept_confirm *clc,
  1051. int first_contact, u8 version,
  1052. u8 *eid, struct smc_init_info *ini)
  1053. {
  1054. struct smc_clc_first_contact_ext_v2x fce_v2x;
  1055. struct smc_connection *conn = &smc->conn;
  1056. struct smc_clc_fce_gid_ext gle;
  1057. struct smc_clc_msg_trail trl;
  1058. int i, fce_len;
  1059. struct kvec vec[5];
  1060. struct msghdr msg;
  1061. /* send SMC Confirm CLC msg */
  1062. clc->hdr.version = version; /* SMC version */
  1063. if (first_contact)
  1064. clc->hdr.typev2 |= SMC_FIRST_CONTACT_MASK;
  1065. if (conn->lgr->is_smcd)
  1066. smcd_clc_prep_confirm_accept(conn, clc, first_contact,
  1067. version, eid, ini, &fce_len,
  1068. &fce_v2x, &trl);
  1069. else
  1070. smcr_clc_prep_confirm_accept(conn, clc, first_contact,
  1071. version, eid, ini, &fce_len,
  1072. &fce_v2x, &gle, &trl);
  1073. memset(&msg, 0, sizeof(msg));
  1074. i = 0;
  1075. vec[i].iov_base = clc;
  1076. if (version > SMC_V1)
  1077. vec[i++].iov_len = (clc->hdr.typev1 == SMC_TYPE_D ?
  1078. SMCD_CLC_ACCEPT_CONFIRM_LEN_V2 :
  1079. SMCR_CLC_ACCEPT_CONFIRM_LEN_V2) -
  1080. sizeof(trl);
  1081. else
  1082. vec[i++].iov_len = (clc->hdr.typev1 == SMC_TYPE_D ?
  1083. SMCD_CLC_ACCEPT_CONFIRM_LEN :
  1084. SMCR_CLC_ACCEPT_CONFIRM_LEN) -
  1085. sizeof(trl);
  1086. if (version > SMC_V1 && first_contact) {
  1087. vec[i].iov_base = &fce_v2x;
  1088. vec[i++].iov_len = fce_len;
  1089. if (!conn->lgr->is_smcd) {
  1090. if (clc->hdr.type == SMC_CLC_CONFIRM) {
  1091. vec[i].iov_base = &gle;
  1092. vec[i++].iov_len = sizeof(gle);
  1093. vec[i].iov_base = &ini->smcrv2.gidlist.list;
  1094. vec[i++].iov_len = gle.gid_cnt *
  1095. sizeof(gle.gid[0]);
  1096. }
  1097. }
  1098. }
  1099. vec[i].iov_base = &trl;
  1100. vec[i++].iov_len = sizeof(trl);
  1101. return kernel_sendmsg(smc->clcsock, &msg, vec, 1,
  1102. ntohs(clc->hdr.length));
  1103. }
  1104. /* send CLC CONFIRM message across internal TCP socket */
  1105. int smc_clc_send_confirm(struct smc_sock *smc, bool clnt_first_contact,
  1106. u8 version, u8 *eid, struct smc_init_info *ini)
  1107. {
  1108. struct smc_clc_msg_accept_confirm cclc;
  1109. int reason_code = 0;
  1110. int len;
  1111. /* send SMC Confirm CLC msg */
  1112. memset(&cclc, 0, sizeof(cclc));
  1113. cclc.hdr.type = SMC_CLC_CONFIRM;
  1114. len = smc_clc_send_confirm_accept(smc, &cclc, clnt_first_contact,
  1115. version, eid, ini);
  1116. if (len < ntohs(cclc.hdr.length)) {
  1117. if (len >= 0) {
  1118. reason_code = -ENETUNREACH;
  1119. smc->sk.sk_err = -reason_code;
  1120. } else {
  1121. smc->sk.sk_err = smc->clcsock->sk->sk_err;
  1122. reason_code = -smc->sk.sk_err;
  1123. }
  1124. }
  1125. return reason_code;
  1126. }
  1127. /* send CLC ACCEPT message across internal TCP socket */
  1128. int smc_clc_send_accept(struct smc_sock *new_smc, bool srv_first_contact,
  1129. u8 version, u8 *negotiated_eid, struct smc_init_info *ini)
  1130. {
  1131. struct smc_clc_msg_accept_confirm aclc;
  1132. int len;
  1133. memset(&aclc, 0, sizeof(aclc));
  1134. aclc.hdr.type = SMC_CLC_ACCEPT;
  1135. len = smc_clc_send_confirm_accept(new_smc, &aclc, srv_first_contact,
  1136. version, negotiated_eid, ini);
  1137. if (len < ntohs(aclc.hdr.length))
  1138. len = len >= 0 ? -EPROTO : -new_smc->clcsock->sk->sk_err;
  1139. return len > 0 ? 0 : len;
  1140. }
  1141. int smc_clc_srv_v2x_features_validate(struct smc_sock *smc,
  1142. struct smc_clc_msg_proposal *pclc,
  1143. struct smc_init_info *ini)
  1144. {
  1145. struct smc_clc_v2_extension *pclc_v2_ext;
  1146. struct net *net = sock_net(&smc->sk);
  1147. ini->max_conns = SMC_CONN_PER_LGR_MAX;
  1148. ini->max_links = SMC_LINKS_ADD_LNK_MAX;
  1149. ini->feature_mask = SMC_FEATURE_MASK;
  1150. if ((!(ini->smcd_version & SMC_V2) && !(ini->smcr_version & SMC_V2)) ||
  1151. ini->release_nr < SMC_RELEASE_1)
  1152. return 0;
  1153. pclc_v2_ext = smc_get_clc_v2_ext(pclc);
  1154. if (!pclc_v2_ext)
  1155. return SMC_CLC_DECL_NOV2EXT;
  1156. if (ini->smcr_version & SMC_V2) {
  1157. ini->max_conns = min_t(u8, pclc_v2_ext->max_conns,
  1158. net->smc.sysctl_max_conns_per_lgr);
  1159. if (ini->max_conns < SMC_CONN_PER_LGR_MIN)
  1160. return SMC_CLC_DECL_MAXCONNERR;
  1161. ini->max_links = min_t(u8, pclc_v2_ext->max_links,
  1162. net->smc.sysctl_max_links_per_lgr);
  1163. if (ini->max_links < SMC_LINKS_ADD_LNK_MIN)
  1164. return SMC_CLC_DECL_MAXLINKERR;
  1165. }
  1166. return 0;
  1167. }
  1168. int smc_clc_clnt_v2x_features_validate(struct smc_clc_first_contact_ext *fce,
  1169. struct smc_init_info *ini)
  1170. {
  1171. struct smc_clc_first_contact_ext_v2x *fce_v2x =
  1172. (struct smc_clc_first_contact_ext_v2x *)fce;
  1173. if (ini->release_nr < SMC_RELEASE_1)
  1174. return 0;
  1175. if (!ini->is_smcd) {
  1176. if (fce_v2x->max_conns < SMC_CONN_PER_LGR_MIN)
  1177. return SMC_CLC_DECL_MAXCONNERR;
  1178. ini->max_conns = fce_v2x->max_conns;
  1179. if (fce_v2x->max_links > SMC_LINKS_ADD_LNK_MAX ||
  1180. fce_v2x->max_links < SMC_LINKS_ADD_LNK_MIN)
  1181. return SMC_CLC_DECL_MAXLINKERR;
  1182. ini->max_links = fce_v2x->max_links;
  1183. }
  1184. /* common supplemental features of server and client */
  1185. ini->feature_mask = ntohs(fce_v2x->feature_mask) & SMC_FEATURE_MASK;
  1186. return 0;
  1187. }
  1188. int smc_clc_v2x_features_confirm_check(struct smc_clc_msg_accept_confirm *cclc,
  1189. struct smc_init_info *ini)
  1190. {
  1191. struct smc_clc_first_contact_ext *fce =
  1192. smc_get_clc_first_contact_ext(cclc, ini->is_smcd);
  1193. struct smc_clc_first_contact_ext_v2x *fce_v2x =
  1194. (struct smc_clc_first_contact_ext_v2x *)fce;
  1195. if (cclc->hdr.version == SMC_V1 ||
  1196. !(cclc->hdr.typev2 & SMC_FIRST_CONTACT_MASK))
  1197. return 0;
  1198. if (ini->release_nr != fce->release)
  1199. return SMC_CLC_DECL_RELEASEERR;
  1200. if (fce->release < SMC_RELEASE_1)
  1201. return 0;
  1202. if (!ini->is_smcd) {
  1203. if (fce_v2x->max_conns != ini->max_conns)
  1204. return SMC_CLC_DECL_MAXCONNERR;
  1205. if (fce_v2x->max_links != ini->max_links)
  1206. return SMC_CLC_DECL_MAXLINKERR;
  1207. }
  1208. /* common supplemental features returned by client */
  1209. ini->feature_mask = ntohs(fce_v2x->feature_mask);
  1210. return 0;
  1211. }
  1212. void smc_clc_get_hostname(u8 **host)
  1213. {
  1214. *host = &smc_hostname[0];
  1215. }
  1216. void __init smc_clc_init(void)
  1217. {
  1218. struct new_utsname *u;
  1219. memset(smc_hostname, _S, sizeof(smc_hostname)); /* ASCII blanks */
  1220. u = utsname();
  1221. memcpy(smc_hostname, u->nodename,
  1222. min_t(size_t, strlen(u->nodename), sizeof(smc_hostname)));
  1223. INIT_LIST_HEAD(&smc_clc_eid_table.list);
  1224. rwlock_init(&smc_clc_eid_table.lock);
  1225. smc_clc_eid_table.ueid_cnt = 0;
  1226. #if IS_ENABLED(CONFIG_S390)
  1227. smc_clc_eid_table.seid_enabled = 1;
  1228. #else
  1229. smc_clc_eid_table.seid_enabled = 0;
  1230. #endif
  1231. }
  1232. void smc_clc_exit(void)
  1233. {
  1234. smc_clc_ueid_remove(NULL);
  1235. }