qeth_l2_main.c 35 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345
  1. /*
  2. * Copyright IBM Corp. 2007, 2009
  3. * Author(s): Utz Bacher <utz.bacher@de.ibm.com>,
  4. * Frank Pavlic <fpavlic@de.ibm.com>,
  5. * Thomas Spatzier <tspat@de.ibm.com>,
  6. * Frank Blaschka <frank.blaschka@de.ibm.com>
  7. */
  8. #define KMSG_COMPONENT "qeth"
  9. #define pr_fmt(fmt) KMSG_COMPONENT ": " fmt
  10. #include <linux/module.h>
  11. #include <linux/moduleparam.h>
  12. #include <linux/string.h>
  13. #include <linux/errno.h>
  14. #include <linux/kernel.h>
  15. #include <linux/slab.h>
  16. #include <linux/etherdevice.h>
  17. #include <linux/mii.h>
  18. #include <linux/ip.h>
  19. #include <linux/list.h>
  20. #include "qeth_core.h"
  21. static int qeth_l2_set_offline(struct ccwgroup_device *);
  22. static int qeth_l2_stop(struct net_device *);
  23. static int qeth_l2_send_delmac(struct qeth_card *, __u8 *);
  24. static int qeth_l2_send_setdelmac(struct qeth_card *, __u8 *,
  25. enum qeth_ipa_cmds,
  26. int (*reply_cb) (struct qeth_card *,
  27. struct qeth_reply*,
  28. unsigned long));
  29. static void qeth_l2_set_multicast_list(struct net_device *);
  30. static int qeth_l2_recover(void *);
  31. static int qeth_l2_do_ioctl(struct net_device *dev, struct ifreq *rq, int cmd)
  32. {
  33. struct qeth_card *card = dev->ml_priv;
  34. struct mii_ioctl_data *mii_data;
  35. int rc = 0;
  36. if (!card)
  37. return -ENODEV;
  38. if ((card->state != CARD_STATE_UP) &&
  39. (card->state != CARD_STATE_SOFTSETUP))
  40. return -ENODEV;
  41. if (card->info.type == QETH_CARD_TYPE_OSN)
  42. return -EPERM;
  43. switch (cmd) {
  44. case SIOC_QETH_ADP_SET_SNMP_CONTROL:
  45. rc = qeth_snmp_command(card, rq->ifr_ifru.ifru_data);
  46. break;
  47. case SIOC_QETH_GET_CARD_TYPE:
  48. if ((card->info.type == QETH_CARD_TYPE_OSD ||
  49. card->info.type == QETH_CARD_TYPE_OSM ||
  50. card->info.type == QETH_CARD_TYPE_OSX) &&
  51. !card->info.guestlan)
  52. return 1;
  53. return 0;
  54. break;
  55. case SIOCGMIIPHY:
  56. mii_data = if_mii(rq);
  57. mii_data->phy_id = 0;
  58. break;
  59. case SIOCGMIIREG:
  60. mii_data = if_mii(rq);
  61. if (mii_data->phy_id != 0)
  62. rc = -EINVAL;
  63. else
  64. mii_data->val_out = qeth_mdio_read(dev,
  65. mii_data->phy_id, mii_data->reg_num);
  66. break;
  67. case SIOC_QETH_QUERY_OAT:
  68. rc = qeth_query_oat_command(card, rq->ifr_ifru.ifru_data);
  69. break;
  70. default:
  71. rc = -EOPNOTSUPP;
  72. }
  73. if (rc)
  74. QETH_CARD_TEXT_(card, 2, "ioce%d", rc);
  75. return rc;
  76. }
  77. static int qeth_l2_verify_dev(struct net_device *dev)
  78. {
  79. struct qeth_card *card;
  80. unsigned long flags;
  81. int rc = 0;
  82. read_lock_irqsave(&qeth_core_card_list.rwlock, flags);
  83. list_for_each_entry(card, &qeth_core_card_list.list, list) {
  84. if (card->dev == dev) {
  85. rc = QETH_REAL_CARD;
  86. break;
  87. }
  88. }
  89. read_unlock_irqrestore(&qeth_core_card_list.rwlock, flags);
  90. return rc;
  91. }
  92. static struct net_device *qeth_l2_netdev_by_devno(unsigned char *read_dev_no)
  93. {
  94. struct qeth_card *card;
  95. struct net_device *ndev;
  96. __u16 temp_dev_no;
  97. unsigned long flags;
  98. struct ccw_dev_id read_devid;
  99. ndev = NULL;
  100. memcpy(&temp_dev_no, read_dev_no, 2);
  101. read_lock_irqsave(&qeth_core_card_list.rwlock, flags);
  102. list_for_each_entry(card, &qeth_core_card_list.list, list) {
  103. ccw_device_get_id(CARD_RDEV(card), &read_devid);
  104. if (read_devid.devno == temp_dev_no) {
  105. ndev = card->dev;
  106. break;
  107. }
  108. }
  109. read_unlock_irqrestore(&qeth_core_card_list.rwlock, flags);
  110. return ndev;
  111. }
  112. static int qeth_l2_send_setgroupmac_cb(struct qeth_card *card,
  113. struct qeth_reply *reply,
  114. unsigned long data)
  115. {
  116. struct qeth_ipa_cmd *cmd;
  117. __u8 *mac;
  118. QETH_CARD_TEXT(card, 2, "L2Sgmacb");
  119. cmd = (struct qeth_ipa_cmd *) data;
  120. mac = &cmd->data.setdelmac.mac[0];
  121. /* MAC already registered, needed in couple/uncouple case */
  122. if (cmd->hdr.return_code == IPA_RC_L2_DUP_MAC) {
  123. QETH_DBF_MESSAGE(2, "Group MAC %pM already existing on %s \n",
  124. mac, QETH_CARD_IFNAME(card));
  125. cmd->hdr.return_code = 0;
  126. }
  127. if (cmd->hdr.return_code)
  128. QETH_DBF_MESSAGE(2, "Could not set group MAC %pM on %s: %x\n",
  129. mac, QETH_CARD_IFNAME(card), cmd->hdr.return_code);
  130. return 0;
  131. }
  132. static int qeth_l2_send_setgroupmac(struct qeth_card *card, __u8 *mac)
  133. {
  134. QETH_CARD_TEXT(card, 2, "L2Sgmac");
  135. return qeth_l2_send_setdelmac(card, mac, IPA_CMD_SETGMAC,
  136. qeth_l2_send_setgroupmac_cb);
  137. }
  138. static int qeth_l2_send_delgroupmac_cb(struct qeth_card *card,
  139. struct qeth_reply *reply,
  140. unsigned long data)
  141. {
  142. struct qeth_ipa_cmd *cmd;
  143. __u8 *mac;
  144. QETH_CARD_TEXT(card, 2, "L2Dgmacb");
  145. cmd = (struct qeth_ipa_cmd *) data;
  146. mac = &cmd->data.setdelmac.mac[0];
  147. if (cmd->hdr.return_code)
  148. QETH_DBF_MESSAGE(2, "Could not delete group MAC %pM on %s: %x\n",
  149. mac, QETH_CARD_IFNAME(card), cmd->hdr.return_code);
  150. return 0;
  151. }
  152. static int qeth_l2_send_delgroupmac(struct qeth_card *card, __u8 *mac)
  153. {
  154. QETH_CARD_TEXT(card, 2, "L2Dgmac");
  155. return qeth_l2_send_setdelmac(card, mac, IPA_CMD_DELGMAC,
  156. qeth_l2_send_delgroupmac_cb);
  157. }
  158. static void qeth_l2_add_mc(struct qeth_card *card, __u8 *mac, int vmac)
  159. {
  160. struct qeth_mc_mac *mc;
  161. int rc;
  162. mc = kmalloc(sizeof(struct qeth_mc_mac), GFP_ATOMIC);
  163. if (!mc)
  164. return;
  165. memcpy(mc->mc_addr, mac, OSA_ADDR_LEN);
  166. mc->mc_addrlen = OSA_ADDR_LEN;
  167. mc->is_vmac = vmac;
  168. if (vmac) {
  169. rc = qeth_l2_send_setdelmac(card, mac, IPA_CMD_SETVMAC,
  170. NULL);
  171. } else {
  172. rc = qeth_l2_send_setgroupmac(card, mac);
  173. }
  174. if (!rc)
  175. list_add_tail(&mc->list, &card->mc_list);
  176. else
  177. kfree(mc);
  178. }
  179. static void qeth_l2_del_all_mc(struct qeth_card *card, int del)
  180. {
  181. struct qeth_mc_mac *mc, *tmp;
  182. spin_lock_bh(&card->mclock);
  183. list_for_each_entry_safe(mc, tmp, &card->mc_list, list) {
  184. if (del) {
  185. if (mc->is_vmac)
  186. qeth_l2_send_setdelmac(card, mc->mc_addr,
  187. IPA_CMD_DELVMAC, NULL);
  188. else
  189. qeth_l2_send_delgroupmac(card, mc->mc_addr);
  190. }
  191. list_del(&mc->list);
  192. kfree(mc);
  193. }
  194. spin_unlock_bh(&card->mclock);
  195. }
  196. static inline int qeth_l2_get_cast_type(struct qeth_card *card,
  197. struct sk_buff *skb)
  198. {
  199. if (card->info.type == QETH_CARD_TYPE_OSN)
  200. return RTN_UNSPEC;
  201. if (is_broadcast_ether_addr(skb->data))
  202. return RTN_BROADCAST;
  203. if (is_multicast_ether_addr(skb->data))
  204. return RTN_MULTICAST;
  205. return RTN_UNSPEC;
  206. }
  207. static void qeth_l2_fill_header(struct qeth_card *card, struct qeth_hdr *hdr,
  208. struct sk_buff *skb, int ipv, int cast_type)
  209. {
  210. struct vlan_ethhdr *veth = (struct vlan_ethhdr *)skb_mac_header(skb);
  211. memset(hdr, 0, sizeof(struct qeth_hdr));
  212. hdr->hdr.l2.id = QETH_HEADER_TYPE_LAYER2;
  213. /* set byte byte 3 to casting flags */
  214. if (cast_type == RTN_MULTICAST)
  215. hdr->hdr.l2.flags[2] |= QETH_LAYER2_FLAG_MULTICAST;
  216. else if (cast_type == RTN_BROADCAST)
  217. hdr->hdr.l2.flags[2] |= QETH_LAYER2_FLAG_BROADCAST;
  218. else
  219. hdr->hdr.l2.flags[2] |= QETH_LAYER2_FLAG_UNICAST;
  220. hdr->hdr.l2.pkt_length = skb->len-QETH_HEADER_SIZE;
  221. /* VSWITCH relies on the VLAN
  222. * information to be present in
  223. * the QDIO header */
  224. if (veth->h_vlan_proto == __constant_htons(ETH_P_8021Q)) {
  225. hdr->hdr.l2.flags[2] |= QETH_LAYER2_FLAG_VLAN;
  226. hdr->hdr.l2.vlan_id = ntohs(veth->h_vlan_TCI);
  227. }
  228. }
  229. static int qeth_l2_send_setdelvlan_cb(struct qeth_card *card,
  230. struct qeth_reply *reply, unsigned long data)
  231. {
  232. struct qeth_ipa_cmd *cmd;
  233. QETH_CARD_TEXT(card, 2, "L2sdvcb");
  234. cmd = (struct qeth_ipa_cmd *) data;
  235. if (cmd->hdr.return_code) {
  236. QETH_DBF_MESSAGE(2, "Error in processing VLAN %i on %s: 0x%x. "
  237. "Continuing\n", cmd->data.setdelvlan.vlan_id,
  238. QETH_CARD_IFNAME(card), cmd->hdr.return_code);
  239. QETH_CARD_TEXT_(card, 2, "L2VL%4x", cmd->hdr.command);
  240. QETH_CARD_TEXT_(card, 2, "err%d", cmd->hdr.return_code);
  241. }
  242. return 0;
  243. }
  244. static int qeth_l2_send_setdelvlan(struct qeth_card *card, __u16 i,
  245. enum qeth_ipa_cmds ipacmd)
  246. {
  247. struct qeth_ipa_cmd *cmd;
  248. struct qeth_cmd_buffer *iob;
  249. QETH_CARD_TEXT_(card, 4, "L2sdv%x", ipacmd);
  250. iob = qeth_get_ipacmd_buffer(card, ipacmd, QETH_PROT_IPV4);
  251. cmd = (struct qeth_ipa_cmd *)(iob->data+IPA_PDU_HEADER_SIZE);
  252. cmd->data.setdelvlan.vlan_id = i;
  253. return qeth_send_ipa_cmd(card, iob,
  254. qeth_l2_send_setdelvlan_cb, NULL);
  255. }
  256. static void qeth_l2_process_vlans(struct qeth_card *card)
  257. {
  258. struct qeth_vlan_vid *id;
  259. QETH_CARD_TEXT(card, 3, "L2prcvln");
  260. spin_lock_bh(&card->vlanlock);
  261. list_for_each_entry(id, &card->vid_list, list) {
  262. qeth_l2_send_setdelvlan(card, id->vid, IPA_CMD_SETVLAN);
  263. }
  264. spin_unlock_bh(&card->vlanlock);
  265. }
  266. static int qeth_l2_vlan_rx_add_vid(struct net_device *dev, unsigned short vid)
  267. {
  268. struct qeth_card *card = dev->ml_priv;
  269. struct qeth_vlan_vid *id;
  270. QETH_CARD_TEXT_(card, 4, "aid:%d", vid);
  271. if (!vid)
  272. return 0;
  273. if (card->info.type == QETH_CARD_TYPE_OSM) {
  274. QETH_CARD_TEXT(card, 3, "aidOSM");
  275. return 0;
  276. }
  277. if (qeth_wait_for_threads(card, QETH_RECOVER_THREAD)) {
  278. QETH_CARD_TEXT(card, 3, "aidREC");
  279. return 0;
  280. }
  281. id = kmalloc(sizeof(struct qeth_vlan_vid), GFP_ATOMIC);
  282. if (id) {
  283. id->vid = vid;
  284. qeth_l2_send_setdelvlan(card, vid, IPA_CMD_SETVLAN);
  285. spin_lock_bh(&card->vlanlock);
  286. list_add_tail(&id->list, &card->vid_list);
  287. spin_unlock_bh(&card->vlanlock);
  288. } else {
  289. return -ENOMEM;
  290. }
  291. return 0;
  292. }
  293. static int qeth_l2_vlan_rx_kill_vid(struct net_device *dev, unsigned short vid)
  294. {
  295. struct qeth_vlan_vid *id, *tmpid = NULL;
  296. struct qeth_card *card = dev->ml_priv;
  297. QETH_CARD_TEXT_(card, 4, "kid:%d", vid);
  298. if (card->info.type == QETH_CARD_TYPE_OSM) {
  299. QETH_CARD_TEXT(card, 3, "kidOSM");
  300. return 0;
  301. }
  302. if (qeth_wait_for_threads(card, QETH_RECOVER_THREAD)) {
  303. QETH_CARD_TEXT(card, 3, "kidREC");
  304. return 0;
  305. }
  306. spin_lock_bh(&card->vlanlock);
  307. list_for_each_entry(id, &card->vid_list, list) {
  308. if (id->vid == vid) {
  309. list_del(&id->list);
  310. tmpid = id;
  311. break;
  312. }
  313. }
  314. spin_unlock_bh(&card->vlanlock);
  315. if (tmpid) {
  316. qeth_l2_send_setdelvlan(card, vid, IPA_CMD_DELVLAN);
  317. kfree(tmpid);
  318. }
  319. qeth_l2_set_multicast_list(card->dev);
  320. return 0;
  321. }
  322. static int qeth_l2_stop_card(struct qeth_card *card, int recovery_mode)
  323. {
  324. int rc = 0;
  325. QETH_DBF_TEXT(SETUP , 2, "stopcard");
  326. QETH_DBF_HEX(SETUP, 2, &card, sizeof(void *));
  327. qeth_set_allowed_threads(card, 0, 1);
  328. if (card->read.state == CH_STATE_UP &&
  329. card->write.state == CH_STATE_UP &&
  330. (card->state == CARD_STATE_UP)) {
  331. if (recovery_mode &&
  332. card->info.type != QETH_CARD_TYPE_OSN) {
  333. qeth_l2_stop(card->dev);
  334. } else {
  335. rtnl_lock();
  336. dev_close(card->dev);
  337. rtnl_unlock();
  338. }
  339. card->info.mac_bits &= ~QETH_LAYER2_MAC_REGISTERED;
  340. card->state = CARD_STATE_SOFTSETUP;
  341. }
  342. if (card->state == CARD_STATE_SOFTSETUP) {
  343. qeth_l2_del_all_mc(card, 0);
  344. qeth_clear_ipacmd_list(card);
  345. card->state = CARD_STATE_HARDSETUP;
  346. }
  347. if (card->state == CARD_STATE_HARDSETUP) {
  348. qeth_qdio_clear_card(card, 0);
  349. qeth_clear_qdio_buffers(card);
  350. qeth_clear_working_pool_list(card);
  351. card->state = CARD_STATE_DOWN;
  352. }
  353. if (card->state == CARD_STATE_DOWN) {
  354. qeth_clear_cmd_buffers(&card->read);
  355. qeth_clear_cmd_buffers(&card->write);
  356. }
  357. return rc;
  358. }
  359. static int qeth_l2_process_inbound_buffer(struct qeth_card *card,
  360. int budget, int *done)
  361. {
  362. int work_done = 0;
  363. struct sk_buff *skb;
  364. struct qeth_hdr *hdr;
  365. unsigned int len;
  366. *done = 0;
  367. BUG_ON(!budget);
  368. while (budget) {
  369. skb = qeth_core_get_next_skb(card,
  370. &card->qdio.in_q->bufs[card->rx.b_index],
  371. &card->rx.b_element, &card->rx.e_offset, &hdr);
  372. if (!skb) {
  373. *done = 1;
  374. break;
  375. }
  376. skb->dev = card->dev;
  377. switch (hdr->hdr.l2.id) {
  378. case QETH_HEADER_TYPE_LAYER2:
  379. skb->pkt_type = PACKET_HOST;
  380. skb->protocol = eth_type_trans(skb, skb->dev);
  381. skb->ip_summed = CHECKSUM_NONE;
  382. if (skb->protocol == htons(ETH_P_802_2))
  383. *((__u32 *)skb->cb) = ++card->seqno.pkt_seqno;
  384. len = skb->len;
  385. netif_receive_skb(skb);
  386. break;
  387. case QETH_HEADER_TYPE_OSN:
  388. if (card->info.type == QETH_CARD_TYPE_OSN) {
  389. skb_push(skb, sizeof(struct qeth_hdr));
  390. skb_copy_to_linear_data(skb, hdr,
  391. sizeof(struct qeth_hdr));
  392. len = skb->len;
  393. card->osn_info.data_cb(skb);
  394. break;
  395. }
  396. /* else unknown */
  397. default:
  398. dev_kfree_skb_any(skb);
  399. QETH_CARD_TEXT(card, 3, "inbunkno");
  400. QETH_DBF_HEX(CTRL, 3, hdr, QETH_DBF_CTRL_LEN);
  401. continue;
  402. }
  403. work_done++;
  404. budget--;
  405. card->stats.rx_packets++;
  406. card->stats.rx_bytes += len;
  407. }
  408. return work_done;
  409. }
  410. static int qeth_l2_poll(struct napi_struct *napi, int budget)
  411. {
  412. struct qeth_card *card = container_of(napi, struct qeth_card, napi);
  413. int work_done = 0;
  414. struct qeth_qdio_buffer *buffer;
  415. int done;
  416. int new_budget = budget;
  417. if (card->options.performance_stats) {
  418. card->perf_stats.inbound_cnt++;
  419. card->perf_stats.inbound_start_time = qeth_get_micros();
  420. }
  421. while (1) {
  422. if (!card->rx.b_count) {
  423. card->rx.qdio_err = 0;
  424. card->rx.b_count = qdio_get_next_buffers(
  425. card->data.ccwdev, 0, &card->rx.b_index,
  426. &card->rx.qdio_err);
  427. if (card->rx.b_count <= 0) {
  428. card->rx.b_count = 0;
  429. break;
  430. }
  431. card->rx.b_element =
  432. &card->qdio.in_q->bufs[card->rx.b_index]
  433. .buffer->element[0];
  434. card->rx.e_offset = 0;
  435. }
  436. while (card->rx.b_count) {
  437. buffer = &card->qdio.in_q->bufs[card->rx.b_index];
  438. if (!(card->rx.qdio_err &&
  439. qeth_check_qdio_errors(card, buffer->buffer,
  440. card->rx.qdio_err, "qinerr")))
  441. work_done += qeth_l2_process_inbound_buffer(
  442. card, new_budget, &done);
  443. else
  444. done = 1;
  445. if (done) {
  446. if (card->options.performance_stats)
  447. card->perf_stats.bufs_rec++;
  448. qeth_put_buffer_pool_entry(card,
  449. buffer->pool_entry);
  450. qeth_queue_input_buffer(card, card->rx.b_index);
  451. card->rx.b_count--;
  452. if (card->rx.b_count) {
  453. card->rx.b_index =
  454. (card->rx.b_index + 1) %
  455. QDIO_MAX_BUFFERS_PER_Q;
  456. card->rx.b_element =
  457. &card->qdio.in_q
  458. ->bufs[card->rx.b_index]
  459. .buffer->element[0];
  460. card->rx.e_offset = 0;
  461. }
  462. }
  463. if (work_done >= budget)
  464. goto out;
  465. else
  466. new_budget = budget - work_done;
  467. }
  468. }
  469. napi_complete(napi);
  470. if (qdio_start_irq(card->data.ccwdev, 0))
  471. napi_schedule(&card->napi);
  472. out:
  473. if (card->options.performance_stats)
  474. card->perf_stats.inbound_time += qeth_get_micros() -
  475. card->perf_stats.inbound_start_time;
  476. return work_done;
  477. }
  478. static int qeth_l2_send_setdelmac(struct qeth_card *card, __u8 *mac,
  479. enum qeth_ipa_cmds ipacmd,
  480. int (*reply_cb) (struct qeth_card *,
  481. struct qeth_reply*,
  482. unsigned long))
  483. {
  484. struct qeth_ipa_cmd *cmd;
  485. struct qeth_cmd_buffer *iob;
  486. QETH_CARD_TEXT(card, 2, "L2sdmac");
  487. iob = qeth_get_ipacmd_buffer(card, ipacmd, QETH_PROT_IPV4);
  488. cmd = (struct qeth_ipa_cmd *)(iob->data+IPA_PDU_HEADER_SIZE);
  489. cmd->data.setdelmac.mac_length = OSA_ADDR_LEN;
  490. memcpy(&cmd->data.setdelmac.mac, mac, OSA_ADDR_LEN);
  491. return qeth_send_ipa_cmd(card, iob, reply_cb, NULL);
  492. }
  493. static int qeth_l2_send_setmac_cb(struct qeth_card *card,
  494. struct qeth_reply *reply,
  495. unsigned long data)
  496. {
  497. struct qeth_ipa_cmd *cmd;
  498. QETH_CARD_TEXT(card, 2, "L2Smaccb");
  499. cmd = (struct qeth_ipa_cmd *) data;
  500. if (cmd->hdr.return_code) {
  501. QETH_CARD_TEXT_(card, 2, "L2er%x", cmd->hdr.return_code);
  502. card->info.mac_bits &= ~QETH_LAYER2_MAC_REGISTERED;
  503. switch (cmd->hdr.return_code) {
  504. case IPA_RC_L2_DUP_MAC:
  505. case IPA_RC_L2_DUP_LAYER3_MAC:
  506. dev_warn(&card->gdev->dev,
  507. "MAC address %pM already exists\n",
  508. cmd->data.setdelmac.mac);
  509. break;
  510. case IPA_RC_L2_MAC_NOT_AUTH_BY_HYP:
  511. case IPA_RC_L2_MAC_NOT_AUTH_BY_ADP:
  512. dev_warn(&card->gdev->dev,
  513. "MAC address %pM is not authorized\n",
  514. cmd->data.setdelmac.mac);
  515. break;
  516. default:
  517. break;
  518. }
  519. } else {
  520. card->info.mac_bits |= QETH_LAYER2_MAC_REGISTERED;
  521. memcpy(card->dev->dev_addr, cmd->data.setdelmac.mac,
  522. OSA_ADDR_LEN);
  523. dev_info(&card->gdev->dev,
  524. "MAC address %pM successfully registered on device %s\n",
  525. card->dev->dev_addr, card->dev->name);
  526. }
  527. return 0;
  528. }
  529. static int qeth_l2_send_setmac(struct qeth_card *card, __u8 *mac)
  530. {
  531. QETH_CARD_TEXT(card, 2, "L2Setmac");
  532. return qeth_l2_send_setdelmac(card, mac, IPA_CMD_SETVMAC,
  533. qeth_l2_send_setmac_cb);
  534. }
  535. static int qeth_l2_send_delmac_cb(struct qeth_card *card,
  536. struct qeth_reply *reply,
  537. unsigned long data)
  538. {
  539. struct qeth_ipa_cmd *cmd;
  540. QETH_CARD_TEXT(card, 2, "L2Dmaccb");
  541. cmd = (struct qeth_ipa_cmd *) data;
  542. if (cmd->hdr.return_code) {
  543. QETH_CARD_TEXT_(card, 2, "err%d", cmd->hdr.return_code);
  544. return 0;
  545. }
  546. card->info.mac_bits &= ~QETH_LAYER2_MAC_REGISTERED;
  547. return 0;
  548. }
  549. static int qeth_l2_send_delmac(struct qeth_card *card, __u8 *mac)
  550. {
  551. QETH_CARD_TEXT(card, 2, "L2Delmac");
  552. if (!(card->info.mac_bits & QETH_LAYER2_MAC_REGISTERED))
  553. return 0;
  554. return qeth_l2_send_setdelmac(card, mac, IPA_CMD_DELVMAC,
  555. qeth_l2_send_delmac_cb);
  556. }
  557. static int qeth_l2_request_initial_mac(struct qeth_card *card)
  558. {
  559. int rc = 0;
  560. char vendor_pre[] = {0x02, 0x00, 0x00};
  561. QETH_DBF_TEXT(SETUP, 2, "doL2init");
  562. QETH_DBF_TEXT_(SETUP, 2, "doL2%s", CARD_BUS_ID(card));
  563. rc = qeth_query_setadapterparms(card);
  564. if (rc) {
  565. QETH_DBF_MESSAGE(2, "could not query adapter parameters on "
  566. "device %s: x%x\n", CARD_BUS_ID(card), rc);
  567. }
  568. if (card->info.type == QETH_CARD_TYPE_IQD ||
  569. card->info.type == QETH_CARD_TYPE_OSM ||
  570. card->info.type == QETH_CARD_TYPE_OSX ||
  571. card->info.guestlan) {
  572. rc = qeth_setadpparms_change_macaddr(card);
  573. if (rc) {
  574. QETH_DBF_MESSAGE(2, "couldn't get MAC address on "
  575. "device %s: x%x\n", CARD_BUS_ID(card), rc);
  576. QETH_DBF_TEXT_(SETUP, 2, "1err%d", rc);
  577. return rc;
  578. }
  579. QETH_DBF_HEX(SETUP, 2, card->dev->dev_addr, OSA_ADDR_LEN);
  580. } else {
  581. eth_random_addr(card->dev->dev_addr);
  582. memcpy(card->dev->dev_addr, vendor_pre, 3);
  583. }
  584. return 0;
  585. }
  586. static int qeth_l2_set_mac_address(struct net_device *dev, void *p)
  587. {
  588. struct sockaddr *addr = p;
  589. struct qeth_card *card = dev->ml_priv;
  590. int rc = 0;
  591. QETH_CARD_TEXT(card, 3, "setmac");
  592. if (qeth_l2_verify_dev(dev) != QETH_REAL_CARD) {
  593. QETH_CARD_TEXT(card, 3, "setmcINV");
  594. return -EOPNOTSUPP;
  595. }
  596. if (card->info.type == QETH_CARD_TYPE_OSN ||
  597. card->info.type == QETH_CARD_TYPE_OSM ||
  598. card->info.type == QETH_CARD_TYPE_OSX) {
  599. QETH_CARD_TEXT(card, 3, "setmcTYP");
  600. return -EOPNOTSUPP;
  601. }
  602. QETH_CARD_HEX(card, 3, addr->sa_data, OSA_ADDR_LEN);
  603. if (qeth_wait_for_threads(card, QETH_RECOVER_THREAD)) {
  604. QETH_CARD_TEXT(card, 3, "setmcREC");
  605. return -ERESTARTSYS;
  606. }
  607. rc = qeth_l2_send_delmac(card, &card->dev->dev_addr[0]);
  608. if (!rc)
  609. rc = qeth_l2_send_setmac(card, addr->sa_data);
  610. return rc ? -EINVAL : 0;
  611. }
  612. static void qeth_l2_set_multicast_list(struct net_device *dev)
  613. {
  614. struct qeth_card *card = dev->ml_priv;
  615. struct netdev_hw_addr *ha;
  616. if (card->info.type == QETH_CARD_TYPE_OSN)
  617. return ;
  618. QETH_CARD_TEXT(card, 3, "setmulti");
  619. if (qeth_threads_running(card, QETH_RECOVER_THREAD) &&
  620. (card->state != CARD_STATE_UP))
  621. return;
  622. qeth_l2_del_all_mc(card, 1);
  623. spin_lock_bh(&card->mclock);
  624. netdev_for_each_mc_addr(ha, dev)
  625. qeth_l2_add_mc(card, ha->addr, 0);
  626. netdev_for_each_uc_addr(ha, dev)
  627. qeth_l2_add_mc(card, ha->addr, 1);
  628. spin_unlock_bh(&card->mclock);
  629. if (!qeth_adp_supported(card, IPA_SETADP_SET_PROMISC_MODE))
  630. return;
  631. qeth_setadp_promisc_mode(card);
  632. }
  633. static int qeth_l2_hard_start_xmit(struct sk_buff *skb, struct net_device *dev)
  634. {
  635. int rc;
  636. struct qeth_hdr *hdr = NULL;
  637. int elements = 0;
  638. struct qeth_card *card = dev->ml_priv;
  639. struct sk_buff *new_skb = skb;
  640. int ipv = qeth_get_ip_version(skb);
  641. int cast_type = qeth_l2_get_cast_type(card, skb);
  642. struct qeth_qdio_out_q *queue = card->qdio.out_qs
  643. [qeth_get_priority_queue(card, skb, ipv, cast_type)];
  644. int tx_bytes = skb->len;
  645. int data_offset = -1;
  646. int elements_needed = 0;
  647. int hd_len = 0;
  648. if ((card->state != CARD_STATE_UP) || !card->lan_online) {
  649. card->stats.tx_carrier_errors++;
  650. goto tx_drop;
  651. }
  652. if ((card->info.type == QETH_CARD_TYPE_OSN) &&
  653. (skb->protocol == htons(ETH_P_IPV6)))
  654. goto tx_drop;
  655. if (card->options.performance_stats) {
  656. card->perf_stats.outbound_cnt++;
  657. card->perf_stats.outbound_start_time = qeth_get_micros();
  658. }
  659. netif_stop_queue(dev);
  660. if (card->info.type == QETH_CARD_TYPE_OSN)
  661. hdr = (struct qeth_hdr *)skb->data;
  662. else {
  663. if (card->info.type == QETH_CARD_TYPE_IQD) {
  664. new_skb = skb;
  665. data_offset = ETH_HLEN;
  666. hd_len = ETH_HLEN;
  667. hdr = kmem_cache_alloc(qeth_core_header_cache,
  668. GFP_ATOMIC);
  669. if (!hdr)
  670. goto tx_drop;
  671. elements_needed++;
  672. skb_reset_mac_header(new_skb);
  673. qeth_l2_fill_header(card, hdr, new_skb, ipv, cast_type);
  674. hdr->hdr.l2.pkt_length = new_skb->len;
  675. memcpy(((char *)hdr) + sizeof(struct qeth_hdr),
  676. skb_mac_header(new_skb), ETH_HLEN);
  677. } else {
  678. /* create a clone with writeable headroom */
  679. new_skb = skb_realloc_headroom(skb,
  680. sizeof(struct qeth_hdr));
  681. if (!new_skb)
  682. goto tx_drop;
  683. hdr = (struct qeth_hdr *)skb_push(new_skb,
  684. sizeof(struct qeth_hdr));
  685. skb_set_mac_header(new_skb, sizeof(struct qeth_hdr));
  686. qeth_l2_fill_header(card, hdr, new_skb, ipv, cast_type);
  687. }
  688. }
  689. elements = qeth_get_elements_no(card, (void *)hdr, new_skb,
  690. elements_needed);
  691. if (!elements) {
  692. if (data_offset >= 0)
  693. kmem_cache_free(qeth_core_header_cache, hdr);
  694. goto tx_drop;
  695. }
  696. if (card->info.type != QETH_CARD_TYPE_IQD) {
  697. if (qeth_hdr_chk_and_bounce(new_skb,
  698. sizeof(struct qeth_hdr_layer2)))
  699. goto tx_drop;
  700. rc = qeth_do_send_packet(card, queue, new_skb, hdr,
  701. elements);
  702. } else
  703. rc = qeth_do_send_packet_fast(card, queue, new_skb, hdr,
  704. elements, data_offset, hd_len);
  705. if (!rc) {
  706. card->stats.tx_packets++;
  707. card->stats.tx_bytes += tx_bytes;
  708. if (new_skb != skb)
  709. dev_kfree_skb_any(skb);
  710. rc = NETDEV_TX_OK;
  711. } else {
  712. if (data_offset >= 0)
  713. kmem_cache_free(qeth_core_header_cache, hdr);
  714. if (rc == -EBUSY) {
  715. if (new_skb != skb)
  716. dev_kfree_skb_any(new_skb);
  717. return NETDEV_TX_BUSY;
  718. } else
  719. goto tx_drop;
  720. }
  721. netif_wake_queue(dev);
  722. if (card->options.performance_stats)
  723. card->perf_stats.outbound_time += qeth_get_micros() -
  724. card->perf_stats.outbound_start_time;
  725. return rc;
  726. tx_drop:
  727. card->stats.tx_dropped++;
  728. card->stats.tx_errors++;
  729. if ((new_skb != skb) && new_skb)
  730. dev_kfree_skb_any(new_skb);
  731. dev_kfree_skb_any(skb);
  732. netif_wake_queue(dev);
  733. return NETDEV_TX_OK;
  734. }
  735. static int __qeth_l2_open(struct net_device *dev)
  736. {
  737. struct qeth_card *card = dev->ml_priv;
  738. int rc = 0;
  739. QETH_CARD_TEXT(card, 4, "qethopen");
  740. if (card->state == CARD_STATE_UP)
  741. return rc;
  742. if (card->state != CARD_STATE_SOFTSETUP)
  743. return -ENODEV;
  744. if ((card->info.type != QETH_CARD_TYPE_OSN) &&
  745. (!(card->info.mac_bits & QETH_LAYER2_MAC_REGISTERED))) {
  746. QETH_CARD_TEXT(card, 4, "nomacadr");
  747. return -EPERM;
  748. }
  749. card->data.state = CH_STATE_UP;
  750. card->state = CARD_STATE_UP;
  751. netif_start_queue(dev);
  752. if (qdio_stop_irq(card->data.ccwdev, 0) >= 0) {
  753. napi_enable(&card->napi);
  754. napi_schedule(&card->napi);
  755. } else
  756. rc = -EIO;
  757. return rc;
  758. }
  759. static int qeth_l2_open(struct net_device *dev)
  760. {
  761. struct qeth_card *card = dev->ml_priv;
  762. QETH_CARD_TEXT(card, 5, "qethope_");
  763. if (qeth_wait_for_threads(card, QETH_RECOVER_THREAD)) {
  764. QETH_CARD_TEXT(card, 3, "openREC");
  765. return -ERESTARTSYS;
  766. }
  767. return __qeth_l2_open(dev);
  768. }
  769. static int qeth_l2_stop(struct net_device *dev)
  770. {
  771. struct qeth_card *card = dev->ml_priv;
  772. QETH_CARD_TEXT(card, 4, "qethstop");
  773. netif_tx_disable(dev);
  774. if (card->state == CARD_STATE_UP) {
  775. card->state = CARD_STATE_SOFTSETUP;
  776. napi_disable(&card->napi);
  777. }
  778. return 0;
  779. }
  780. static int qeth_l2_probe_device(struct ccwgroup_device *gdev)
  781. {
  782. struct qeth_card *card = dev_get_drvdata(&gdev->dev);
  783. INIT_LIST_HEAD(&card->vid_list);
  784. INIT_LIST_HEAD(&card->mc_list);
  785. card->options.layer2 = 1;
  786. card->info.hwtrap = 0;
  787. return 0;
  788. }
  789. static void qeth_l2_remove_device(struct ccwgroup_device *cgdev)
  790. {
  791. struct qeth_card *card = dev_get_drvdata(&cgdev->dev);
  792. qeth_set_allowed_threads(card, 0, 1);
  793. wait_event(card->wait_q, qeth_threads_running(card, 0xffffffff) == 0);
  794. if (cgdev->state == CCWGROUP_ONLINE)
  795. qeth_l2_set_offline(cgdev);
  796. if (card->dev) {
  797. unregister_netdev(card->dev);
  798. card->dev = NULL;
  799. }
  800. return;
  801. }
  802. static const struct ethtool_ops qeth_l2_ethtool_ops = {
  803. .get_link = ethtool_op_get_link,
  804. .get_strings = qeth_core_get_strings,
  805. .get_ethtool_stats = qeth_core_get_ethtool_stats,
  806. .get_sset_count = qeth_core_get_sset_count,
  807. .get_drvinfo = qeth_core_get_drvinfo,
  808. .get_settings = qeth_core_ethtool_get_settings,
  809. };
  810. static const struct ethtool_ops qeth_l2_osn_ops = {
  811. .get_strings = qeth_core_get_strings,
  812. .get_ethtool_stats = qeth_core_get_ethtool_stats,
  813. .get_sset_count = qeth_core_get_sset_count,
  814. .get_drvinfo = qeth_core_get_drvinfo,
  815. };
  816. static const struct net_device_ops qeth_l2_netdev_ops = {
  817. .ndo_open = qeth_l2_open,
  818. .ndo_stop = qeth_l2_stop,
  819. .ndo_get_stats = qeth_get_stats,
  820. .ndo_start_xmit = qeth_l2_hard_start_xmit,
  821. .ndo_validate_addr = eth_validate_addr,
  822. .ndo_set_rx_mode = qeth_l2_set_multicast_list,
  823. .ndo_do_ioctl = qeth_l2_do_ioctl,
  824. .ndo_set_mac_address = qeth_l2_set_mac_address,
  825. .ndo_change_mtu = qeth_change_mtu,
  826. .ndo_vlan_rx_add_vid = qeth_l2_vlan_rx_add_vid,
  827. .ndo_vlan_rx_kill_vid = qeth_l2_vlan_rx_kill_vid,
  828. .ndo_tx_timeout = qeth_tx_timeout,
  829. };
  830. static int qeth_l2_setup_netdev(struct qeth_card *card)
  831. {
  832. switch (card->info.type) {
  833. case QETH_CARD_TYPE_IQD:
  834. card->dev = alloc_netdev(0, "hsi%d", ether_setup);
  835. break;
  836. case QETH_CARD_TYPE_OSN:
  837. card->dev = alloc_netdev(0, "osn%d", ether_setup);
  838. card->dev->flags |= IFF_NOARP;
  839. break;
  840. default:
  841. card->dev = alloc_etherdev(0);
  842. }
  843. if (!card->dev)
  844. return -ENODEV;
  845. card->dev->ml_priv = card;
  846. card->dev->watchdog_timeo = QETH_TX_TIMEOUT;
  847. card->dev->mtu = card->info.initial_mtu;
  848. card->dev->netdev_ops = &qeth_l2_netdev_ops;
  849. if (card->info.type != QETH_CARD_TYPE_OSN)
  850. SET_ETHTOOL_OPS(card->dev, &qeth_l2_ethtool_ops);
  851. else
  852. SET_ETHTOOL_OPS(card->dev, &qeth_l2_osn_ops);
  853. card->dev->features |= NETIF_F_HW_VLAN_FILTER;
  854. card->info.broadcast_capable = 1;
  855. qeth_l2_request_initial_mac(card);
  856. SET_NETDEV_DEV(card->dev, &card->gdev->dev);
  857. netif_napi_add(card->dev, &card->napi, qeth_l2_poll, QETH_NAPI_WEIGHT);
  858. return register_netdev(card->dev);
  859. }
  860. static int __qeth_l2_set_online(struct ccwgroup_device *gdev, int recovery_mode)
  861. {
  862. struct qeth_card *card = dev_get_drvdata(&gdev->dev);
  863. int rc = 0;
  864. enum qeth_card_states recover_flag;
  865. BUG_ON(!card);
  866. mutex_lock(&card->discipline_mutex);
  867. mutex_lock(&card->conf_mutex);
  868. QETH_DBF_TEXT(SETUP, 2, "setonlin");
  869. QETH_DBF_HEX(SETUP, 2, &card, sizeof(void *));
  870. recover_flag = card->state;
  871. rc = qeth_core_hardsetup_card(card);
  872. if (rc) {
  873. QETH_DBF_TEXT_(SETUP, 2, "2err%d", rc);
  874. rc = -ENODEV;
  875. goto out_remove;
  876. }
  877. if (!card->dev && qeth_l2_setup_netdev(card)) {
  878. rc = -ENODEV;
  879. goto out_remove;
  880. }
  881. if (card->info.type != QETH_CARD_TYPE_OSN)
  882. qeth_l2_send_setmac(card, &card->dev->dev_addr[0]);
  883. if (qeth_is_diagass_supported(card, QETH_DIAGS_CMD_TRAP)) {
  884. if (card->info.hwtrap &&
  885. qeth_hw_trap(card, QETH_DIAGS_TRAP_ARM))
  886. card->info.hwtrap = 0;
  887. } else
  888. card->info.hwtrap = 0;
  889. card->state = CARD_STATE_HARDSETUP;
  890. memset(&card->rx, 0, sizeof(struct qeth_rx));
  891. qeth_print_status_message(card);
  892. /* softsetup */
  893. QETH_DBF_TEXT(SETUP, 2, "softsetp");
  894. rc = qeth_send_startlan(card);
  895. if (rc) {
  896. QETH_DBF_TEXT_(SETUP, 2, "1err%d", rc);
  897. if (rc == 0xe080) {
  898. dev_warn(&card->gdev->dev,
  899. "The LAN is offline\n");
  900. card->lan_online = 0;
  901. goto contin;
  902. }
  903. rc = -ENODEV;
  904. goto out_remove;
  905. } else
  906. card->lan_online = 1;
  907. contin:
  908. if ((card->info.type == QETH_CARD_TYPE_OSD) ||
  909. (card->info.type == QETH_CARD_TYPE_OSX))
  910. /* configure isolation level */
  911. qeth_set_access_ctrl_online(card);
  912. if (card->info.type != QETH_CARD_TYPE_OSN &&
  913. card->info.type != QETH_CARD_TYPE_OSM)
  914. qeth_l2_process_vlans(card);
  915. netif_tx_disable(card->dev);
  916. rc = qeth_init_qdio_queues(card);
  917. if (rc) {
  918. QETH_DBF_TEXT_(SETUP, 2, "6err%d", rc);
  919. rc = -ENODEV;
  920. goto out_remove;
  921. }
  922. card->state = CARD_STATE_SOFTSETUP;
  923. if (card->lan_online)
  924. netif_carrier_on(card->dev);
  925. else
  926. netif_carrier_off(card->dev);
  927. qeth_set_allowed_threads(card, 0xffffffff, 0);
  928. if (recover_flag == CARD_STATE_RECOVER) {
  929. if (recovery_mode &&
  930. card->info.type != QETH_CARD_TYPE_OSN) {
  931. __qeth_l2_open(card->dev);
  932. } else {
  933. rtnl_lock();
  934. dev_open(card->dev);
  935. rtnl_unlock();
  936. }
  937. /* this also sets saved unicast addresses */
  938. qeth_l2_set_multicast_list(card->dev);
  939. }
  940. /* let user_space know that device is online */
  941. kobject_uevent(&gdev->dev.kobj, KOBJ_CHANGE);
  942. mutex_unlock(&card->conf_mutex);
  943. mutex_unlock(&card->discipline_mutex);
  944. return 0;
  945. out_remove:
  946. qeth_l2_stop_card(card, 0);
  947. ccw_device_set_offline(CARD_DDEV(card));
  948. ccw_device_set_offline(CARD_WDEV(card));
  949. ccw_device_set_offline(CARD_RDEV(card));
  950. if (recover_flag == CARD_STATE_RECOVER)
  951. card->state = CARD_STATE_RECOVER;
  952. else
  953. card->state = CARD_STATE_DOWN;
  954. mutex_unlock(&card->conf_mutex);
  955. mutex_unlock(&card->discipline_mutex);
  956. return rc;
  957. }
  958. static int qeth_l2_set_online(struct ccwgroup_device *gdev)
  959. {
  960. return __qeth_l2_set_online(gdev, 0);
  961. }
  962. static int __qeth_l2_set_offline(struct ccwgroup_device *cgdev,
  963. int recovery_mode)
  964. {
  965. struct qeth_card *card = dev_get_drvdata(&cgdev->dev);
  966. int rc = 0, rc2 = 0, rc3 = 0;
  967. enum qeth_card_states recover_flag;
  968. mutex_lock(&card->discipline_mutex);
  969. mutex_lock(&card->conf_mutex);
  970. QETH_DBF_TEXT(SETUP, 3, "setoffl");
  971. QETH_DBF_HEX(SETUP, 3, &card, sizeof(void *));
  972. if (card->dev && netif_carrier_ok(card->dev))
  973. netif_carrier_off(card->dev);
  974. recover_flag = card->state;
  975. if ((!recovery_mode && card->info.hwtrap) || card->info.hwtrap == 2) {
  976. qeth_hw_trap(card, QETH_DIAGS_TRAP_DISARM);
  977. card->info.hwtrap = 1;
  978. }
  979. qeth_l2_stop_card(card, recovery_mode);
  980. rc = ccw_device_set_offline(CARD_DDEV(card));
  981. rc2 = ccw_device_set_offline(CARD_WDEV(card));
  982. rc3 = ccw_device_set_offline(CARD_RDEV(card));
  983. if (!rc)
  984. rc = (rc2) ? rc2 : rc3;
  985. if (rc)
  986. QETH_DBF_TEXT_(SETUP, 2, "1err%d", rc);
  987. if (recover_flag == CARD_STATE_UP)
  988. card->state = CARD_STATE_RECOVER;
  989. /* let user_space know that device is offline */
  990. kobject_uevent(&cgdev->dev.kobj, KOBJ_CHANGE);
  991. mutex_unlock(&card->conf_mutex);
  992. mutex_unlock(&card->discipline_mutex);
  993. return 0;
  994. }
  995. static int qeth_l2_set_offline(struct ccwgroup_device *cgdev)
  996. {
  997. return __qeth_l2_set_offline(cgdev, 0);
  998. }
  999. static int qeth_l2_recover(void *ptr)
  1000. {
  1001. struct qeth_card *card;
  1002. int rc = 0;
  1003. card = (struct qeth_card *) ptr;
  1004. QETH_CARD_TEXT(card, 2, "recover1");
  1005. if (!qeth_do_run_thread(card, QETH_RECOVER_THREAD))
  1006. return 0;
  1007. QETH_CARD_TEXT(card, 2, "recover2");
  1008. dev_warn(&card->gdev->dev,
  1009. "A recovery process has been started for the device\n");
  1010. __qeth_l2_set_offline(card->gdev, 1);
  1011. rc = __qeth_l2_set_online(card->gdev, 1);
  1012. if (!rc)
  1013. dev_info(&card->gdev->dev,
  1014. "Device successfully recovered!\n");
  1015. else {
  1016. rtnl_lock();
  1017. dev_close(card->dev);
  1018. rtnl_unlock();
  1019. dev_warn(&card->gdev->dev, "The qeth device driver "
  1020. "failed to recover an error on the device\n");
  1021. }
  1022. qeth_clear_thread_start_bit(card, QETH_RECOVER_THREAD);
  1023. qeth_clear_thread_running_bit(card, QETH_RECOVER_THREAD);
  1024. return 0;
  1025. }
  1026. static int __init qeth_l2_init(void)
  1027. {
  1028. pr_info("register layer 2 discipline\n");
  1029. return 0;
  1030. }
  1031. static void __exit qeth_l2_exit(void)
  1032. {
  1033. pr_info("unregister layer 2 discipline\n");
  1034. }
  1035. static void qeth_l2_shutdown(struct ccwgroup_device *gdev)
  1036. {
  1037. struct qeth_card *card = dev_get_drvdata(&gdev->dev);
  1038. qeth_set_allowed_threads(card, 0, 1);
  1039. if ((gdev->state == CCWGROUP_ONLINE) && card->info.hwtrap)
  1040. qeth_hw_trap(card, QETH_DIAGS_TRAP_DISARM);
  1041. qeth_qdio_clear_card(card, 0);
  1042. qeth_clear_qdio_buffers(card);
  1043. }
  1044. static int qeth_l2_pm_suspend(struct ccwgroup_device *gdev)
  1045. {
  1046. struct qeth_card *card = dev_get_drvdata(&gdev->dev);
  1047. if (card->dev)
  1048. netif_device_detach(card->dev);
  1049. qeth_set_allowed_threads(card, 0, 1);
  1050. wait_event(card->wait_q, qeth_threads_running(card, 0xffffffff) == 0);
  1051. if (gdev->state == CCWGROUP_OFFLINE)
  1052. return 0;
  1053. if (card->state == CARD_STATE_UP) {
  1054. if (card->info.hwtrap)
  1055. qeth_hw_trap(card, QETH_DIAGS_TRAP_DISARM);
  1056. __qeth_l2_set_offline(card->gdev, 1);
  1057. } else
  1058. __qeth_l2_set_offline(card->gdev, 0);
  1059. return 0;
  1060. }
  1061. static int qeth_l2_pm_resume(struct ccwgroup_device *gdev)
  1062. {
  1063. struct qeth_card *card = dev_get_drvdata(&gdev->dev);
  1064. int rc = 0;
  1065. if (gdev->state == CCWGROUP_OFFLINE)
  1066. goto out;
  1067. if (card->state == CARD_STATE_RECOVER) {
  1068. rc = __qeth_l2_set_online(card->gdev, 1);
  1069. if (rc) {
  1070. rtnl_lock();
  1071. dev_close(card->dev);
  1072. rtnl_unlock();
  1073. }
  1074. } else
  1075. rc = __qeth_l2_set_online(card->gdev, 0);
  1076. out:
  1077. qeth_set_allowed_threads(card, 0xffffffff, 0);
  1078. if (card->dev)
  1079. netif_device_attach(card->dev);
  1080. if (rc)
  1081. dev_warn(&card->gdev->dev, "The qeth device driver "
  1082. "failed to recover an error on the device\n");
  1083. return rc;
  1084. }
  1085. struct qeth_discipline qeth_l2_discipline = {
  1086. .start_poll = qeth_qdio_start_poll,
  1087. .input_handler = (qdio_handler_t *) qeth_qdio_input_handler,
  1088. .output_handler = (qdio_handler_t *) qeth_qdio_output_handler,
  1089. .recover = qeth_l2_recover,
  1090. .setup = qeth_l2_probe_device,
  1091. .remove = qeth_l2_remove_device,
  1092. .set_online = qeth_l2_set_online,
  1093. .set_offline = qeth_l2_set_offline,
  1094. .shutdown = qeth_l2_shutdown,
  1095. .freeze = qeth_l2_pm_suspend,
  1096. .thaw = qeth_l2_pm_resume,
  1097. .restore = qeth_l2_pm_resume,
  1098. };
  1099. EXPORT_SYMBOL_GPL(qeth_l2_discipline);
  1100. static int qeth_osn_send_control_data(struct qeth_card *card, int len,
  1101. struct qeth_cmd_buffer *iob)
  1102. {
  1103. unsigned long flags;
  1104. int rc = 0;
  1105. QETH_CARD_TEXT(card, 5, "osndctrd");
  1106. wait_event(card->wait_q,
  1107. atomic_cmpxchg(&card->write.irq_pending, 0, 1) == 0);
  1108. qeth_prepare_control_data(card, len, iob);
  1109. QETH_CARD_TEXT(card, 6, "osnoirqp");
  1110. spin_lock_irqsave(get_ccwdev_lock(card->write.ccwdev), flags);
  1111. rc = ccw_device_start(card->write.ccwdev, &card->write.ccw,
  1112. (addr_t) iob, 0, 0);
  1113. spin_unlock_irqrestore(get_ccwdev_lock(card->write.ccwdev), flags);
  1114. if (rc) {
  1115. QETH_DBF_MESSAGE(2, "qeth_osn_send_control_data: "
  1116. "ccw_device_start rc = %i\n", rc);
  1117. QETH_CARD_TEXT_(card, 2, " err%d", rc);
  1118. qeth_release_buffer(iob->channel, iob);
  1119. atomic_set(&card->write.irq_pending, 0);
  1120. wake_up(&card->wait_q);
  1121. }
  1122. return rc;
  1123. }
  1124. static int qeth_osn_send_ipa_cmd(struct qeth_card *card,
  1125. struct qeth_cmd_buffer *iob, int data_len)
  1126. {
  1127. u16 s1, s2;
  1128. QETH_CARD_TEXT(card, 4, "osndipa");
  1129. qeth_prepare_ipa_cmd(card, iob, QETH_PROT_OSN2);
  1130. s1 = (u16)(IPA_PDU_HEADER_SIZE + data_len);
  1131. s2 = (u16)data_len;
  1132. memcpy(QETH_IPA_PDU_LEN_TOTAL(iob->data), &s1, 2);
  1133. memcpy(QETH_IPA_PDU_LEN_PDU1(iob->data), &s2, 2);
  1134. memcpy(QETH_IPA_PDU_LEN_PDU2(iob->data), &s2, 2);
  1135. memcpy(QETH_IPA_PDU_LEN_PDU3(iob->data), &s2, 2);
  1136. return qeth_osn_send_control_data(card, s1, iob);
  1137. }
  1138. int qeth_osn_assist(struct net_device *dev, void *data, int data_len)
  1139. {
  1140. struct qeth_cmd_buffer *iob;
  1141. struct qeth_card *card;
  1142. int rc;
  1143. if (!dev)
  1144. return -ENODEV;
  1145. card = dev->ml_priv;
  1146. if (!card)
  1147. return -ENODEV;
  1148. QETH_CARD_TEXT(card, 2, "osnsdmc");
  1149. if ((card->state != CARD_STATE_UP) &&
  1150. (card->state != CARD_STATE_SOFTSETUP))
  1151. return -ENODEV;
  1152. iob = qeth_wait_for_buffer(&card->write);
  1153. memcpy(iob->data+IPA_PDU_HEADER_SIZE, data, data_len);
  1154. rc = qeth_osn_send_ipa_cmd(card, iob, data_len);
  1155. return rc;
  1156. }
  1157. EXPORT_SYMBOL(qeth_osn_assist);
  1158. int qeth_osn_register(unsigned char *read_dev_no, struct net_device **dev,
  1159. int (*assist_cb)(struct net_device *, void *),
  1160. int (*data_cb)(struct sk_buff *))
  1161. {
  1162. struct qeth_card *card;
  1163. *dev = qeth_l2_netdev_by_devno(read_dev_no);
  1164. if (*dev == NULL)
  1165. return -ENODEV;
  1166. card = (*dev)->ml_priv;
  1167. if (!card)
  1168. return -ENODEV;
  1169. QETH_CARD_TEXT(card, 2, "osnreg");
  1170. if ((assist_cb == NULL) || (data_cb == NULL))
  1171. return -EINVAL;
  1172. card->osn_info.assist_cb = assist_cb;
  1173. card->osn_info.data_cb = data_cb;
  1174. return 0;
  1175. }
  1176. EXPORT_SYMBOL(qeth_osn_register);
  1177. void qeth_osn_deregister(struct net_device *dev)
  1178. {
  1179. struct qeth_card *card;
  1180. if (!dev)
  1181. return;
  1182. card = dev->ml_priv;
  1183. if (!card)
  1184. return;
  1185. QETH_CARD_TEXT(card, 2, "osndereg");
  1186. card->osn_info.assist_cb = NULL;
  1187. card->osn_info.data_cb = NULL;
  1188. return;
  1189. }
  1190. EXPORT_SYMBOL(qeth_osn_deregister);
  1191. module_init(qeth_l2_init);
  1192. module_exit(qeth_l2_exit);
  1193. MODULE_AUTHOR("Frank Blaschka <frank.blaschka@de.ibm.com>");
  1194. MODULE_DESCRIPTION("qeth layer 2 discipline");
  1195. MODULE_LICENSE("GPL");