48 static void _qede_rdma_dev_add(struct qede_dev *edev)  in _qede_rdma_dev_add()  argument
54 	edev->rdma_info.exp_recovery = false;  in _qede_rdma_dev_add()
55 	edev->rdma_info.qedr_dev = qedr_drv->add(edev->cdev, edev->pdev,  in _qede_rdma_dev_add()
56 						 edev->ndev);  in _qede_rdma_dev_add()
59 static int qede_rdma_create_wq(struct qede_dev *edev)  in qede_rdma_create_wq()  argument
61 	INIT_LIST_HEAD(&edev->rdma_info.rdma_event_list);  in qede_rdma_create_wq()
62 	edev->rdma_info.rdma_wq = create_singlethread_workqueue("rdma_wq");  in qede_rdma_create_wq()
63 	if (!edev->rdma_info.rdma_wq) {  in qede_rdma_create_wq()
64 		DP_NOTICE(edev, "qedr: Could not create workqueue\n");  in qede_rdma_create_wq()
71 static void qede_rdma_cleanup_event(struct qede_dev *edev)  in qede_rdma_cleanup_event()  argument
73 	struct list_head *head = &edev->rdma_info.rdma_event_list;  in qede_rdma_cleanup_event()
76 	flush_workqueue(edev->rdma_info.rdma_wq);  in qede_rdma_cleanup_event()
86 static void qede_rdma_destroy_wq(struct qede_dev *edev)  in qede_rdma_destroy_wq()  argument
88 	qede_rdma_cleanup_event(edev);  in qede_rdma_destroy_wq()
89 	destroy_workqueue(edev->rdma_info.rdma_wq);  in qede_rdma_destroy_wq()
92 int qede_rdma_dev_add(struct qede_dev *edev, bool recovery)  in qede_rdma_dev_add()  argument
96 	if (!qede_rdma_supported(edev))  in qede_rdma_dev_add()
103 	rc = qede_rdma_create_wq(edev);  in qede_rdma_dev_add()
107 	INIT_LIST_HEAD(&edev->rdma_info.entry);  in qede_rdma_dev_add()
109 	list_add_tail(&edev->rdma_info.entry, &qedr_dev_list);  in qede_rdma_dev_add()
110 	_qede_rdma_dev_add(edev);  in qede_rdma_dev_add()
116 static void _qede_rdma_dev_remove(struct qede_dev *edev)  in _qede_rdma_dev_remove()  argument
118 	if (qedr_drv && qedr_drv->remove && edev->rdma_info.qedr_dev)  in _qede_rdma_dev_remove()
119 		qedr_drv->remove(edev->rdma_info.qedr_dev);  in _qede_rdma_dev_remove()
122 void qede_rdma_dev_remove(struct qede_dev *edev, bool recovery)  in qede_rdma_dev_remove()  argument
124 	if (!qede_rdma_supported(edev))  in qede_rdma_dev_remove()
129 		qede_rdma_destroy_wq(edev);  in qede_rdma_dev_remove()
131 		if (!edev->rdma_info.exp_recovery)  in qede_rdma_dev_remove()
132 			_qede_rdma_dev_remove(edev);  in qede_rdma_dev_remove()
133 		edev->rdma_info.qedr_dev = NULL;  in qede_rdma_dev_remove()
134 		list_del(&edev->rdma_info.entry);  in qede_rdma_dev_remove()
137 		if (!edev->rdma_info.exp_recovery) {  in qede_rdma_dev_remove()
139 			_qede_rdma_dev_remove(edev);  in qede_rdma_dev_remove()
142 		edev->rdma_info.exp_recovery = true;  in qede_rdma_dev_remove()
146 static void _qede_rdma_dev_open(struct qede_dev *edev)  in _qede_rdma_dev_open()  argument
148 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)  in _qede_rdma_dev_open()
149 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_UP);  in _qede_rdma_dev_open()
152 static void qede_rdma_dev_open(struct qede_dev *edev)  in qede_rdma_dev_open()  argument
154 	if (!qede_rdma_supported(edev))  in qede_rdma_dev_open()
158 	_qede_rdma_dev_open(edev);  in qede_rdma_dev_open()
162 static void _qede_rdma_dev_close(struct qede_dev *edev)  in _qede_rdma_dev_close()  argument
164 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)  in _qede_rdma_dev_close()
165 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_DOWN);  in _qede_rdma_dev_close()
168 static void qede_rdma_dev_close(struct qede_dev *edev)  in qede_rdma_dev_close()  argument
170 	if (!qede_rdma_supported(edev))  in qede_rdma_dev_close()
174 	_qede_rdma_dev_close(edev);  in qede_rdma_dev_close()
178 static void qede_rdma_dev_shutdown(struct qede_dev *edev)  in qede_rdma_dev_shutdown()  argument
180 	if (!qede_rdma_supported(edev))  in qede_rdma_dev_shutdown()
184 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)  in qede_rdma_dev_shutdown()
185 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_CLOSE);  in qede_rdma_dev_shutdown()
191 	struct qede_dev *edev;  in qede_rdma_register_driver()  local
201 	list_for_each_entry(edev, &qedr_dev_list, rdma_info.entry) {  in qede_rdma_register_driver()
205 		_qede_rdma_dev_add(edev);  in qede_rdma_register_driver()
206 		ndev = edev->ndev;  in qede_rdma_register_driver()
208 			_qede_rdma_dev_open(edev);  in qede_rdma_register_driver()
221 	struct qede_dev *edev;  in qede_rdma_unregister_driver()  local
224 	list_for_each_entry(edev, &qedr_dev_list, rdma_info.entry) {  in qede_rdma_unregister_driver()
226 		if (edev->rdma_info.qedr_dev && !edev->rdma_info.exp_recovery)  in qede_rdma_unregister_driver()
227 			_qede_rdma_dev_remove(edev);  in qede_rdma_unregister_driver()
234 static void qede_rdma_changeaddr(struct qede_dev *edev)  in qede_rdma_changeaddr()  argument
236 	if (!qede_rdma_supported(edev))  in qede_rdma_changeaddr()
239 	if (qedr_drv && edev->rdma_info.qedr_dev && qedr_drv->notify)  in qede_rdma_changeaddr()
240 		qedr_drv->notify(edev->rdma_info.qedr_dev, QEDE_CHANGE_ADDR);  in qede_rdma_changeaddr()
244 qede_rdma_get_free_event_node(struct qede_dev *edev)  in qede_rdma_get_free_event_node()  argument
250 	list_for_each(list_node, &edev->rdma_info.rdma_event_list) {  in qede_rdma_get_free_event_node()
262 			DP_NOTICE(edev,  in qede_rdma_get_free_event_node()
267 			      &edev->rdma_info.rdma_event_list);  in qede_rdma_get_free_event_node()
277 	struct qede_dev *edev;  in qede_rdma_handle_event()  local
281 	edev = event_node->ptr;  in qede_rdma_handle_event()
285 		qede_rdma_dev_open(edev);  in qede_rdma_handle_event()
288 		qede_rdma_dev_close(edev);  in qede_rdma_handle_event()
291 		qede_rdma_dev_shutdown(edev);  in qede_rdma_handle_event()
294 		qede_rdma_changeaddr(edev);  in qede_rdma_handle_event()
297 		DP_NOTICE(edev, "Invalid rdma event %d", event);  in qede_rdma_handle_event()
301 static void qede_rdma_add_event(struct qede_dev *edev,  in qede_rdma_add_event()  argument
307 	if (edev->rdma_info.exp_recovery)  in qede_rdma_add_event()
310 	if (!edev->rdma_info.qedr_dev)  in qede_rdma_add_event()
313 	event_node = qede_rdma_get_free_event_node(edev);  in qede_rdma_add_event()
318 	event_node->ptr = edev;  in qede_rdma_add_event()
321 	queue_work(edev->rdma_info.rdma_wq, &event_node->work);  in qede_rdma_add_event()
324 void qede_rdma_dev_event_open(struct qede_dev *edev)  in qede_rdma_dev_event_open()  argument
326 	qede_rdma_add_event(edev, QEDE_UP);  in qede_rdma_dev_event_open()
329 void qede_rdma_dev_event_close(struct qede_dev *edev)  in qede_rdma_dev_event_close()  argument
331 	qede_rdma_add_event(edev, QEDE_DOWN);  in qede_rdma_dev_event_close()
334 void qede_rdma_event_changeaddr(struct qede_dev *edev)  in qede_rdma_event_changeaddr()  argument
336 	qede_rdma_add_event(edev, QEDE_CHANGE_ADDR);  in qede_rdma_event_changeaddr()