qlogic/qede/qede_rdma.c

23 static void _qede_rdma_dev_add(struct qede_dev *edev)
29 	edev->rdma_info.exp_recovery = false;
30 	edev->rdma_info.qedr_dev = qedr_drv->add(edev->cdev, edev->pdev,
31 						 edev->ndev);
34 static int qede_rdma_create_wq(struct qede_dev *edev)
36 	INIT_LIST_HEAD(&edev->rdma_info.rdma_event_list);
37 	kref_init(&edev->rdma_info.refcnt);
38 	init_completion(&edev->rdma_info.event_comp);
40 	edev->rdma_info.rdma_wq = create_singlethread_workqueue("rdma_wq");
41 	if (!edev->rdma_info.rdma_wq) {
42 		DP_NOTICE(edev, "qedr: Could not create workqueue\n");
49 static void qede_rdma_cleanup_event(struct qede_dev *edev)
51 	struct list_head *head = &edev->rdma_info.rdma_event_list;
54 	flush_workqueue(edev->rdma_info.rdma_wq);
73 static void qede_rdma_destroy_wq(struct qede_dev *edev)
78 	kref_put(&edev->rdma_info.refcnt, qede_rdma_complete_event);
79 	wait_for_completion(&edev->rdma_info.event_comp);
81 	qede_rdma_cleanup_event(edev);
82 	destroy_workqueue(edev->rdma_info.rdma_wq);
83 	edev->rdma_info.rdma_wq = NULL;
86 int qede_rdma_dev_add(struct qede_dev *edev, bool recovery)
90 	if (!qede_rdma_supported(edev))
97 	rc = qede_rdma_create_wq(edev);
101 	INIT_LIST_HEAD(&edev->rdma_info.entry);
103 	list_add_tail(&edev->rdma_info.entry, &qedr_dev_list);
104 	_qede_rdma_dev_add(edev);
110 static void _qede_rdma_dev_remove(struct qede_dev *edev)
112 	if (qedr_drv && qedr_drv->remove && edev->rdma_info.qedr_dev)
113 		qedr_drv->remove(edev->rdma_info.qedr_dev);
116 void qede_rdma_dev_remove(struct qede_dev *edev, bool recovery)
118 	if (!qede_rdma_supported(edev))
123 		qede_rdma_destroy_wq(edev);
125 		if (!edev->rdma_info.exp_recovery)
126 			_qede_rdma_dev_remove(edev);
127 		edev->rdma_info.qedr_dev = NULL;
128 		list_del(&edev->rdma_info.entry);
131 		if (!edev->rdma_info.exp_recovery) {
133 			_qede_rdma_dev_remove(edev);
136 		edev->rdma_info.exp_recovery = true;
140 static void _qede_rdma_dev_open(struct qede_dev *edev)
142 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)
143 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_UP);
146 static void qede_rdma_dev_open(struct qede_dev *edev)
148 	if (!qede_rdma_supported(edev))
152 	_qede_rdma_dev_open(edev);
156 static void _qede_rdma_dev_close(struct qede_dev *edev)
158 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)
159 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_DOWN);
162 static void qede_rdma_dev_close(struct qede_dev *edev)
164 	if (!qede_rdma_supported(edev))
168 	_qede_rdma_dev_close(edev);
172 static void qede_rdma_dev_shutdown(struct qede_dev *edev)
174 	if (!qede_rdma_supported(edev))
178 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)
179 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_CLOSE);
185 	struct qede_dev *edev;
195 	list_for_each_entry(edev, &qedr_dev_list, rdma_info.entry) {
199 		_qede_rdma_dev_add(edev);
200 		ndev = edev->ndev;
202 			_qede_rdma_dev_open(edev);
215 	struct qede_dev *edev;
218 	list_for_each_entry(edev, &qedr_dev_list, rdma_info.entry) {
220 		if (edev->rdma_info.qedr_dev && !edev->rdma_info.exp_recovery)
221 			_qede_rdma_dev_remove(edev);
228 static void qede_rdma_changeaddr(struct qede_dev *edev)
230 	if (!qede_rdma_supported(edev))
233 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)
234 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_CHANGE_ADDR);
237 static void qede_rdma_change_mtu(struct qede_dev *edev)
239 	if (qede_rdma_supported(edev)) {
240 		if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)
241 			qedr_drv->notify(edev->rdma_info.qedr_dev,
247 qede_rdma_get_free_event_node(struct qede_dev *edev)
252 	list_for_each_entry(event_node, &edev->rdma_info.rdma_event_list,
263 			DP_NOTICE(edev,
268 			      &edev->rdma_info.rdma_event_list);
278 	struct qede_dev *edev;
282 	edev = event_node->ptr;
286 		qede_rdma_dev_open(edev);
289 		qede_rdma_dev_close(edev);
292 		qede_rdma_dev_shutdown(edev);
295 		qede_rdma_changeaddr(edev);
298 		qede_rdma_change_mtu(edev);
301 		DP_NOTICE(edev, "Invalid rdma event %d", event);
305 static void qede_rdma_add_event(struct qede_dev *edev,
311 	if (edev->rdma_info.exp_recovery)
314 	if (!edev->rdma_info.qedr_dev || !edev->rdma_info.rdma_wq)
320 	if (!kref_get_unless_zero(&edev->rdma_info.refcnt))
323 	event_node = qede_rdma_get_free_event_node(edev);
328 	event_node->ptr = edev;
331 	queue_work(edev->rdma_info.rdma_wq, &event_node->work);
334 	kref_put(&edev->rdma_info.refcnt, qede_rdma_complete_event);
337 void qede_rdma_dev_event_open(struct qede_dev *edev)
339 	qede_rdma_add_event(edev, QEDE_UP);
342 void qede_rdma_dev_event_close(struct qede_dev *edev)
344 	qede_rdma_add_event(edev, QEDE_DOWN);
347 void qede_rdma_event_changeaddr(struct qede_dev *edev)
349 	qede_rdma_add_event(edev, QEDE_CHANGE_ADDR);
352 void qede_rdma_event_change_mtu(struct qede_dev *edev)
354 	qede_rdma_add_event(edev, QEDE_CHANGE_MTU);