1
2
3
4
5
6
7
8
9#define DRV_NAME "cxgbit"
10#define DRV_VERSION "1.0.0-ko"
11#define pr_fmt(fmt) DRV_NAME ": " fmt
12
13#include "cxgbit.h"
14
15#ifdef CONFIG_CHELSIO_T4_DCB
16#include <net/dcbevent.h>
17#include "cxgb4_dcb.h"
18#endif
19
20LIST_HEAD(cdev_list_head);
21
22DEFINE_MUTEX(cdev_list_lock);
23
24void _cxgbit_free_cdev(struct kref *kref)
25{
26 struct cxgbit_device *cdev;
27
28 cdev = container_of(kref, struct cxgbit_device, kref);
29
30 cxgbi_ppm_release(cdev2ppm(cdev));
31 kfree(cdev);
32}
33
34static void cxgbit_set_mdsl(struct cxgbit_device *cdev)
35{
36 struct cxgb4_lld_info *lldi = &cdev->lldi;
37 u32 mdsl;
38
39#define ULP2_MAX_PKT_LEN 16224
40#define ISCSI_PDU_NONPAYLOAD_LEN 312
41 mdsl = min_t(u32, lldi->iscsi_iolen - ISCSI_PDU_NONPAYLOAD_LEN,
42 ULP2_MAX_PKT_LEN - ISCSI_PDU_NONPAYLOAD_LEN);
43 mdsl = min_t(u32, mdsl, 8192);
44 mdsl = min_t(u32, mdsl, (MAX_SKB_FRAGS - 1) * PAGE_SIZE);
45
46 cdev->mdsl = mdsl;
47}
48
49static void *cxgbit_uld_add(const struct cxgb4_lld_info *lldi)
50{
51 struct cxgbit_device *cdev;
52
53 if (is_t4(lldi->adapter_type))
54 return ERR_PTR(-ENODEV);
55
56 cdev = kzalloc(sizeof(*cdev), GFP_KERNEL);
57 if (!cdev)
58 return ERR_PTR(-ENOMEM);
59
60 kref_init(&cdev->kref);
61
62 cdev->lldi = *lldi;
63
64 cxgbit_set_mdsl(cdev);
65
66 if (cxgbit_ddp_init(cdev) < 0) {
67 kfree(cdev);
68 return ERR_PTR(-EINVAL);
69 }
70
71 if (!test_bit(CDEV_DDP_ENABLE, &cdev->flags))
72 pr_info("cdev %s ddp init failed\n",
73 pci_name(lldi->pdev));
74
75 if (lldi->fw_vers >= 0x10d2b00)
76 set_bit(CDEV_ISO_ENABLE, &cdev->flags);
77
78 spin_lock_init(&cdev->cskq.lock);
79 INIT_LIST_HEAD(&cdev->cskq.list);
80
81 mutex_lock(&cdev_list_lock);
82 list_add_tail(&cdev->list, &cdev_list_head);
83 mutex_unlock(&cdev_list_lock);
84
85 pr_info("cdev %s added for iSCSI target transport\n",
86 pci_name(lldi->pdev));
87
88 return cdev;
89}
90
91static void cxgbit_close_conn(struct cxgbit_device *cdev)
92{
93 struct cxgbit_sock *csk;
94 struct sk_buff *skb;
95 bool wakeup_thread = false;
96
97 spin_lock_bh(&cdev->cskq.lock);
98 list_for_each_entry(csk, &cdev->cskq.list, list) {
99 skb = alloc_skb(0, GFP_ATOMIC);
100 if (!skb)
101 continue;
102
103 spin_lock_bh(&csk->rxq.lock);
104 __skb_queue_tail(&csk->rxq, skb);
105 if (skb_queue_len(&csk->rxq) == 1)
106 wakeup_thread = true;
107 spin_unlock_bh(&csk->rxq.lock);
108
109 if (wakeup_thread) {
110 wake_up(&csk->waitq);
111 wakeup_thread = false;
112 }
113 }
114 spin_unlock_bh(&cdev->cskq.lock);
115}
116
117static void cxgbit_detach_cdev(struct cxgbit_device *cdev)
118{
119 bool free_cdev = false;
120
121 spin_lock_bh(&cdev->cskq.lock);
122 if (list_empty(&cdev->cskq.list))
123 free_cdev = true;
124 spin_unlock_bh(&cdev->cskq.lock);
125
126 if (free_cdev) {
127 mutex_lock(&cdev_list_lock);
128 list_del(&cdev->list);
129 mutex_unlock(&cdev_list_lock);
130
131 cxgbit_put_cdev(cdev);
132 } else {
133 cxgbit_close_conn(cdev);
134 }
135}
136
137static int cxgbit_uld_state_change(void *handle, enum cxgb4_state state)
138{
139 struct cxgbit_device *cdev = handle;
140
141 switch (state) {
142 case CXGB4_STATE_UP:
143 set_bit(CDEV_STATE_UP, &cdev->flags);
144 pr_info("cdev %s state UP.\n", pci_name(cdev->lldi.pdev));
145 break;
146 case CXGB4_STATE_START_RECOVERY:
147 clear_bit(CDEV_STATE_UP, &cdev->flags);
148 cxgbit_close_conn(cdev);
149 pr_info("cdev %s state RECOVERY.\n", pci_name(cdev->lldi.pdev));
150 break;
151 case CXGB4_STATE_DOWN:
152 pr_info("cdev %s state DOWN.\n", pci_name(cdev->lldi.pdev));
153 break;
154 case CXGB4_STATE_DETACH:
155 clear_bit(CDEV_STATE_UP, &cdev->flags);
156 pr_info("cdev %s state DETACH.\n", pci_name(cdev->lldi.pdev));
157 cxgbit_detach_cdev(cdev);
158 break;
159 default:
160 pr_info("cdev %s unknown state %d.\n",
161 pci_name(cdev->lldi.pdev), state);
162 break;
163 }
164 return 0;
165}
166
167static void
168cxgbit_proc_ddp_status(unsigned int tid, struct cpl_rx_data_ddp *cpl,
169 struct cxgbit_lro_pdu_cb *pdu_cb)
170{
171 unsigned int status = ntohl(cpl->ddpvld);
172
173 pdu_cb->flags |= PDUCBF_RX_STATUS;
174 pdu_cb->ddigest = ntohl(cpl->ulp_crc);
175 pdu_cb->pdulen = ntohs(cpl->len);
176
177 if (status & (1 << CPL_RX_ISCSI_DDP_STATUS_HCRC_SHIFT)) {
178 pr_info("tid 0x%x, status 0x%x, hcrc bad.\n", tid, status);
179 pdu_cb->flags |= PDUCBF_RX_HCRC_ERR;
180 }
181
182 if (status & (1 << CPL_RX_ISCSI_DDP_STATUS_DCRC_SHIFT)) {
183 pr_info("tid 0x%x, status 0x%x, dcrc bad.\n", tid, status);
184 pdu_cb->flags |= PDUCBF_RX_DCRC_ERR;
185 }
186
187 if (status & (1 << CPL_RX_ISCSI_DDP_STATUS_PAD_SHIFT))
188 pr_info("tid 0x%x, status 0x%x, pad bad.\n", tid, status);
189
190 if ((status & (1 << CPL_RX_ISCSI_DDP_STATUS_DDP_SHIFT)) &&
191 (!(pdu_cb->flags & PDUCBF_RX_DATA))) {
192 pdu_cb->flags |= PDUCBF_RX_DATA_DDPD;
193 }
194}
195
196static void
197cxgbit_lro_add_packet_rsp(struct sk_buff *skb, u8 op, const __be64 *rsp)
198{
199 struct cxgbit_lro_cb *lro_cb = cxgbit_skb_lro_cb(skb);
200 struct cxgbit_lro_pdu_cb *pdu_cb = cxgbit_skb_lro_pdu_cb(skb,
201 lro_cb->pdu_idx);
202 struct cpl_rx_iscsi_ddp *cpl = (struct cpl_rx_iscsi_ddp *)(rsp + 1);
203
204 cxgbit_proc_ddp_status(lro_cb->csk->tid, cpl, pdu_cb);
205
206 if (pdu_cb->flags & PDUCBF_RX_HDR)
207 pdu_cb->complete = true;
208
209 lro_cb->complete = true;
210 lro_cb->pdu_totallen += pdu_cb->pdulen;
211 lro_cb->pdu_idx++;
212}
213
214static void
215cxgbit_copy_frags(struct sk_buff *skb, const struct pkt_gl *gl,
216 unsigned int offset)
217{
218 u8 skb_frag_idx = skb_shinfo(skb)->nr_frags;
219 u8 i;
220
221
222 __skb_fill_page_desc(skb, skb_frag_idx, gl->frags[0].page,
223 gl->frags[0].offset + offset,
224 gl->frags[0].size - offset);
225 for (i = 1; i < gl->nfrags; i++)
226 __skb_fill_page_desc(skb, skb_frag_idx + i,
227 gl->frags[i].page,
228 gl->frags[i].offset,
229 gl->frags[i].size);
230
231 skb_shinfo(skb)->nr_frags += gl->nfrags;
232
233
234 get_page(gl->frags[gl->nfrags - 1].page);
235}
236
237static void
238cxgbit_lro_add_packet_gl(struct sk_buff *skb, u8 op, const struct pkt_gl *gl)
239{
240 struct cxgbit_lro_cb *lro_cb = cxgbit_skb_lro_cb(skb);
241 struct cxgbit_lro_pdu_cb *pdu_cb = cxgbit_skb_lro_pdu_cb(skb,
242 lro_cb->pdu_idx);
243 u32 len, offset;
244
245 if (op == CPL_ISCSI_HDR) {
246 struct cpl_iscsi_hdr *cpl = (struct cpl_iscsi_hdr *)gl->va;
247
248 offset = sizeof(struct cpl_iscsi_hdr);
249 pdu_cb->flags |= PDUCBF_RX_HDR;
250 pdu_cb->seq = ntohl(cpl->seq);
251 len = ntohs(cpl->len);
252 pdu_cb->hdr = gl->va + offset;
253 pdu_cb->hlen = len;
254 pdu_cb->hfrag_idx = skb_shinfo(skb)->nr_frags;
255
256 if (unlikely(gl->nfrags > 1))
257 cxgbit_skcb_flags(skb) = 0;
258
259 lro_cb->complete = false;
260 } else {
261 struct cpl_iscsi_data *cpl = (struct cpl_iscsi_data *)gl->va;
262
263 offset = sizeof(struct cpl_iscsi_data);
264 pdu_cb->flags |= PDUCBF_RX_DATA;
265 len = ntohs(cpl->len);
266 pdu_cb->dlen = len;
267 pdu_cb->doffset = lro_cb->offset;
268 pdu_cb->nr_dfrags = gl->nfrags;
269 pdu_cb->dfrag_idx = skb_shinfo(skb)->nr_frags;
270 }
271
272 cxgbit_copy_frags(skb, gl, offset);
273
274 pdu_cb->frags += gl->nfrags;
275 lro_cb->offset += len;
276 skb->len += len;
277 skb->data_len += len;
278 skb->truesize += len;
279}
280
281static struct sk_buff *
282cxgbit_lro_init_skb(struct cxgbit_sock *csk, u8 op, const struct pkt_gl *gl,
283 const __be64 *rsp, struct napi_struct *napi)
284{
285 struct sk_buff *skb;
286 struct cxgbit_lro_cb *lro_cb;
287
288 skb = napi_alloc_skb(napi, LRO_SKB_MAX_HEADROOM);
289
290 if (unlikely(!skb))
291 return NULL;
292
293 memset(skb->data, 0, LRO_SKB_MAX_HEADROOM);
294
295 cxgbit_skcb_flags(skb) |= SKCBF_RX_LRO;
296
297 lro_cb = cxgbit_skb_lro_cb(skb);
298
299 cxgbit_get_csk(csk);
300
301 lro_cb->csk = csk;
302
303 return skb;
304}
305
306static void cxgbit_queue_lro_skb(struct cxgbit_sock *csk, struct sk_buff *skb)
307{
308 bool wakeup_thread = false;
309
310 spin_lock(&csk->rxq.lock);
311 __skb_queue_tail(&csk->rxq, skb);
312 if (skb_queue_len(&csk->rxq) == 1)
313 wakeup_thread = true;
314 spin_unlock(&csk->rxq.lock);
315
316 if (wakeup_thread)
317 wake_up(&csk->waitq);
318}
319
320static void cxgbit_lro_flush(struct t4_lro_mgr *lro_mgr, struct sk_buff *skb)
321{
322 struct cxgbit_lro_cb *lro_cb = cxgbit_skb_lro_cb(skb);
323 struct cxgbit_sock *csk = lro_cb->csk;
324
325 csk->lro_skb = NULL;
326
327 __skb_unlink(skb, &lro_mgr->lroq);
328 cxgbit_queue_lro_skb(csk, skb);
329
330 cxgbit_put_csk(csk);
331
332 lro_mgr->lro_pkts++;
333 lro_mgr->lro_session_cnt--;
334}
335
336static void cxgbit_uld_lro_flush(struct t4_lro_mgr *lro_mgr)
337{
338 struct sk_buff *skb;
339
340 while ((skb = skb_peek(&lro_mgr->lroq)))
341 cxgbit_lro_flush(lro_mgr, skb);
342}
343
344static int
345cxgbit_lro_receive(struct cxgbit_sock *csk, u8 op, const __be64 *rsp,
346 const struct pkt_gl *gl, struct t4_lro_mgr *lro_mgr,
347 struct napi_struct *napi)
348{
349 struct sk_buff *skb;
350 struct cxgbit_lro_cb *lro_cb;
351
352 if (!csk) {
353 pr_err("%s: csk NULL, op 0x%x.\n", __func__, op);
354 goto out;
355 }
356
357 if (csk->lro_skb)
358 goto add_packet;
359
360start_lro:
361 if (lro_mgr->lro_session_cnt >= MAX_LRO_SESSIONS) {
362 cxgbit_uld_lro_flush(lro_mgr);
363 goto start_lro;
364 }
365
366 skb = cxgbit_lro_init_skb(csk, op, gl, rsp, napi);
367 if (unlikely(!skb))
368 goto out;
369
370 csk->lro_skb = skb;
371
372 __skb_queue_tail(&lro_mgr->lroq, skb);
373 lro_mgr->lro_session_cnt++;
374
375add_packet:
376 skb = csk->lro_skb;
377 lro_cb = cxgbit_skb_lro_cb(skb);
378
379 if ((gl && (((skb_shinfo(skb)->nr_frags + gl->nfrags) >
380 MAX_SKB_FRAGS) || (lro_cb->pdu_totallen >= LRO_FLUSH_LEN_MAX))) ||
381 (lro_cb->pdu_idx >= MAX_SKB_FRAGS)) {
382 cxgbit_lro_flush(lro_mgr, skb);
383 goto start_lro;
384 }
385
386 if (gl)
387 cxgbit_lro_add_packet_gl(skb, op, gl);
388 else
389 cxgbit_lro_add_packet_rsp(skb, op, rsp);
390
391 lro_mgr->lro_merged++;
392
393 return 0;
394
395out:
396 return -1;
397}
398
399static int
400cxgbit_uld_lro_rx_handler(void *hndl, const __be64 *rsp,
401 const struct pkt_gl *gl, struct t4_lro_mgr *lro_mgr,
402 struct napi_struct *napi)
403{
404 struct cxgbit_device *cdev = hndl;
405 struct cxgb4_lld_info *lldi = &cdev->lldi;
406 struct cpl_tx_data *rpl = NULL;
407 struct cxgbit_sock *csk = NULL;
408 unsigned int tid = 0;
409 struct sk_buff *skb;
410 unsigned int op = *(u8 *)rsp;
411 bool lro_flush = true;
412
413 switch (op) {
414 case CPL_ISCSI_HDR:
415 case CPL_ISCSI_DATA:
416 case CPL_RX_ISCSI_DDP:
417 case CPL_FW4_ACK:
418 lro_flush = false;
419 case CPL_ABORT_RPL_RSS:
420 case CPL_PASS_ESTABLISH:
421 case CPL_PEER_CLOSE:
422 case CPL_CLOSE_CON_RPL:
423 case CPL_ABORT_REQ_RSS:
424 case CPL_SET_TCB_RPL:
425 case CPL_RX_DATA:
426 rpl = gl ? (struct cpl_tx_data *)gl->va :
427 (struct cpl_tx_data *)(rsp + 1);
428 tid = GET_TID(rpl);
429 csk = lookup_tid(lldi->tids, tid);
430 break;
431 default:
432 break;
433 }
434
435 if (csk && csk->lro_skb && lro_flush)
436 cxgbit_lro_flush(lro_mgr, csk->lro_skb);
437
438 if (!gl) {
439 unsigned int len;
440
441 if (op == CPL_RX_ISCSI_DDP) {
442 if (!cxgbit_lro_receive(csk, op, rsp, NULL, lro_mgr,
443 napi))
444 return 0;
445 }
446
447 len = 64 - sizeof(struct rsp_ctrl) - 8;
448 skb = napi_alloc_skb(napi, len);
449 if (!skb)
450 goto nomem;
451 __skb_put(skb, len);
452 skb_copy_to_linear_data(skb, &rsp[1], len);
453 } else {
454 if (unlikely(op != *(u8 *)gl->va)) {
455 pr_info("? FL 0x%p,RSS%#llx,FL %#llx,len %u.\n",
456 gl->va, be64_to_cpu(*rsp),
457 be64_to_cpu(*(u64 *)gl->va),
458 gl->tot_len);
459 return 0;
460 }
461
462 if (op == CPL_ISCSI_HDR || op == CPL_ISCSI_DATA) {
463 if (!cxgbit_lro_receive(csk, op, rsp, gl, lro_mgr,
464 napi))
465 return 0;
466 }
467
468#define RX_PULL_LEN 128
469 skb = cxgb4_pktgl_to_skb(gl, RX_PULL_LEN, RX_PULL_LEN);
470 if (unlikely(!skb))
471 goto nomem;
472 }
473
474 rpl = (struct cpl_tx_data *)skb->data;
475 op = rpl->ot.opcode;
476 cxgbit_skcb_rx_opcode(skb) = op;
477
478 pr_debug("cdev %p, opcode 0x%x(0x%x,0x%x), skb %p.\n",
479 cdev, op, rpl->ot.opcode_tid,
480 ntohl(rpl->ot.opcode_tid), skb);
481
482 if (op < NUM_CPL_CMDS && cxgbit_cplhandlers[op]) {
483 cxgbit_cplhandlers[op](cdev, skb);
484 } else {
485 pr_err("No handler for opcode 0x%x.\n", op);
486 __kfree_skb(skb);
487 }
488 return 0;
489nomem:
490 pr_err("%s OOM bailing out.\n", __func__);
491 return 1;
492}
493
494#ifdef CONFIG_CHELSIO_T4_DCB
495struct cxgbit_dcb_work {
496 struct dcb_app_type dcb_app;
497 struct work_struct work;
498};
499
500static void
501cxgbit_update_dcb_priority(struct cxgbit_device *cdev, u8 port_id,
502 u8 dcb_priority, u16 port_num)
503{
504 struct cxgbit_sock *csk;
505 struct sk_buff *skb;
506 u16 local_port;
507 bool wakeup_thread = false;
508
509 spin_lock_bh(&cdev->cskq.lock);
510 list_for_each_entry(csk, &cdev->cskq.list, list) {
511 if (csk->port_id != port_id)
512 continue;
513
514 if (csk->com.local_addr.ss_family == AF_INET6) {
515 struct sockaddr_in6 *sock_in6;
516
517 sock_in6 = (struct sockaddr_in6 *)&csk->com.local_addr;
518 local_port = ntohs(sock_in6->sin6_port);
519 } else {
520 struct sockaddr_in *sock_in;
521
522 sock_in = (struct sockaddr_in *)&csk->com.local_addr;
523 local_port = ntohs(sock_in->sin_port);
524 }
525
526 if (local_port != port_num)
527 continue;
528
529 if (csk->dcb_priority == dcb_priority)
530 continue;
531
532 skb = alloc_skb(0, GFP_ATOMIC);
533 if (!skb)
534 continue;
535
536 spin_lock(&csk->rxq.lock);
537 __skb_queue_tail(&csk->rxq, skb);
538 if (skb_queue_len(&csk->rxq) == 1)
539 wakeup_thread = true;
540 spin_unlock(&csk->rxq.lock);
541
542 if (wakeup_thread) {
543 wake_up(&csk->waitq);
544 wakeup_thread = false;
545 }
546 }
547 spin_unlock_bh(&cdev->cskq.lock);
548}
549
550static void cxgbit_dcb_workfn(struct work_struct *work)
551{
552 struct cxgbit_dcb_work *dcb_work;
553 struct net_device *ndev;
554 struct cxgbit_device *cdev = NULL;
555 struct dcb_app_type *iscsi_app;
556 u8 priority, port_id = 0xff;
557
558 dcb_work = container_of(work, struct cxgbit_dcb_work, work);
559 iscsi_app = &dcb_work->dcb_app;
560
561 if (iscsi_app->dcbx & DCB_CAP_DCBX_VER_IEEE) {
562 if (iscsi_app->app.selector != IEEE_8021QAZ_APP_SEL_ANY)
563 goto out;
564
565 priority = iscsi_app->app.priority;
566
567 } else if (iscsi_app->dcbx & DCB_CAP_DCBX_VER_CEE) {
568 if (iscsi_app->app.selector != DCB_APP_IDTYPE_PORTNUM)
569 goto out;
570
571 if (!iscsi_app->app.priority)
572 goto out;
573
574 priority = ffs(iscsi_app->app.priority) - 1;
575 } else {
576 goto out;
577 }
578
579 pr_debug("priority for ifid %d is %u\n",
580 iscsi_app->ifindex, priority);
581
582 ndev = dev_get_by_index(&init_net, iscsi_app->ifindex);
583
584 if (!ndev)
585 goto out;
586
587 mutex_lock(&cdev_list_lock);
588 cdev = cxgbit_find_device(ndev, &port_id);
589
590 dev_put(ndev);
591
592 if (!cdev) {
593 mutex_unlock(&cdev_list_lock);
594 goto out;
595 }
596
597 cxgbit_update_dcb_priority(cdev, port_id, priority,
598 iscsi_app->app.protocol);
599 mutex_unlock(&cdev_list_lock);
600out:
601 kfree(dcb_work);
602}
603
604static int
605cxgbit_dcbevent_notify(struct notifier_block *nb, unsigned long action,
606 void *data)
607{
608 struct cxgbit_dcb_work *dcb_work;
609 struct dcb_app_type *dcb_app = data;
610
611 dcb_work = kzalloc(sizeof(*dcb_work), GFP_ATOMIC);
612 if (!dcb_work)
613 return NOTIFY_DONE;
614
615 dcb_work->dcb_app = *dcb_app;
616 INIT_WORK(&dcb_work->work, cxgbit_dcb_workfn);
617 schedule_work(&dcb_work->work);
618 return NOTIFY_OK;
619}
620#endif
621
622static enum target_prot_op cxgbit_get_sup_prot_ops(struct iscsi_conn *conn)
623{
624 return TARGET_PROT_NORMAL;
625}
626
627static struct iscsit_transport cxgbit_transport = {
628 .name = DRV_NAME,
629 .transport_type = ISCSI_CXGBIT,
630 .rdma_shutdown = false,
631 .priv_size = sizeof(struct cxgbit_cmd),
632 .owner = THIS_MODULE,
633 .iscsit_setup_np = cxgbit_setup_np,
634 .iscsit_accept_np = cxgbit_accept_np,
635 .iscsit_free_np = cxgbit_free_np,
636 .iscsit_free_conn = cxgbit_free_conn,
637 .iscsit_get_login_rx = cxgbit_get_login_rx,
638 .iscsit_put_login_tx = cxgbit_put_login_tx,
639 .iscsit_immediate_queue = iscsit_immediate_queue,
640 .iscsit_response_queue = iscsit_response_queue,
641 .iscsit_get_dataout = iscsit_build_r2ts_for_cmd,
642 .iscsit_queue_data_in = iscsit_queue_rsp,
643 .iscsit_queue_status = iscsit_queue_rsp,
644 .iscsit_xmit_pdu = cxgbit_xmit_pdu,
645 .iscsit_get_r2t_ttt = cxgbit_get_r2t_ttt,
646 .iscsit_get_rx_pdu = cxgbit_get_rx_pdu,
647 .iscsit_validate_params = cxgbit_validate_params,
648 .iscsit_release_cmd = cxgbit_release_cmd,
649 .iscsit_aborted_task = iscsit_aborted_task,
650 .iscsit_get_sup_prot_ops = cxgbit_get_sup_prot_ops,
651};
652
653static struct cxgb4_uld_info cxgbit_uld_info = {
654 .name = DRV_NAME,
655 .nrxq = MAX_ULD_QSETS,
656 .rxq_size = 1024,
657 .lro = true,
658 .add = cxgbit_uld_add,
659 .state_change = cxgbit_uld_state_change,
660 .lro_rx_handler = cxgbit_uld_lro_rx_handler,
661 .lro_flush = cxgbit_uld_lro_flush,
662};
663
664#ifdef CONFIG_CHELSIO_T4_DCB
665static struct notifier_block cxgbit_dcbevent_nb = {
666 .notifier_call = cxgbit_dcbevent_notify,
667};
668#endif
669
670static int __init cxgbit_init(void)
671{
672 cxgb4_register_uld(CXGB4_ULD_ISCSIT, &cxgbit_uld_info);
673 iscsit_register_transport(&cxgbit_transport);
674
675#ifdef CONFIG_CHELSIO_T4_DCB
676 pr_info("%s dcb enabled.\n", DRV_NAME);
677 register_dcbevent_notifier(&cxgbit_dcbevent_nb);
678#endif
679 BUILD_BUG_ON(FIELD_SIZEOF(struct sk_buff, cb) <
680 sizeof(union cxgbit_skb_cb));
681 return 0;
682}
683
684static void __exit cxgbit_exit(void)
685{
686 struct cxgbit_device *cdev, *tmp;
687
688#ifdef CONFIG_CHELSIO_T4_DCB
689 unregister_dcbevent_notifier(&cxgbit_dcbevent_nb);
690#endif
691 mutex_lock(&cdev_list_lock);
692 list_for_each_entry_safe(cdev, tmp, &cdev_list_head, list) {
693 list_del(&cdev->list);
694 cxgbit_put_cdev(cdev);
695 }
696 mutex_unlock(&cdev_list_lock);
697 iscsit_unregister_transport(&cxgbit_transport);
698 cxgb4_unregister_uld(CXGB4_ULD_ISCSIT);
699}
700
701module_init(cxgbit_init);
702module_exit(cxgbit_exit);
703
704MODULE_DESCRIPTION("Chelsio iSCSI target offload driver");
705MODULE_AUTHOR("Chelsio Communications");
706MODULE_VERSION(DRV_VERSION);
707MODULE_LICENSE("GPL");
708
