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