Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 0a85d23b authored by Stefano Stabellini's avatar Stefano Stabellini Committed by Boris Ostrovsky
Browse files

xen/pvcalls: disconnect and module_exit 



Implement backend_disconnect. Call pvcalls_back_release_active on active
sockets and pvcalls_back_release_passive on passive sockets.

Implement module_exit by calling backend_disconnect on frontend
connections.

[ boris: fixed long lines ]

Signed-off-by: default avatarStefano Stabellini <stefano@aporeto.com>
Reviewed-by: default avatarJuergen Gross <jgross@suse.com>
CC: boris.ostrovsky@oracle.com
CC: jgross@suse.com
Signed-off-by: default avatarBoris Ostrovsky <boris.ostrovsky@oracle.com>
parent a51729cb

drivers/xen/pvcalls-back.c

+53 −0
Original line number Diff line number Diff line
@@ -807,6 +807,43 @@ static int backend_connect(struct xenbus_device *dev) 


static int backend_disconnect(struct xenbus_device *dev)

{

	struct pvcalls_fedata *fedata;

	struct sock_mapping *map, *n;

	struct sockpass_mapping *mappass;

	struct radix_tree_iter iter;

	void **slot;





	fedata = dev_get_drvdata(&dev->dev);



	down(&fedata->socket_lock);

	list_for_each_entry_safe(map, n, &fedata->socket_mappings, list) {

		list_del(&map->list);

		pvcalls_back_release_active(dev, fedata, map);

	}



	radix_tree_for_each_slot(slot, &fedata->socketpass_mappings, &iter, 0) {

		mappass = radix_tree_deref_slot(slot);

		if (!mappass)

			continue;

		if (radix_tree_exception(mappass)) {

			if (radix_tree_deref_retry(mappass))

				slot = radix_tree_iter_retry(&iter);

		} else {

			radix_tree_delete(&fedata->socketpass_mappings,

					  mappass->id);

			pvcalls_back_release_passive(dev, fedata, mappass);

		}

	}

	up(&fedata->socket_lock);



	unbind_from_irqhandler(fedata->irq, dev);

	xenbus_unmap_ring_vfree(dev, fedata->sring);



	list_del(&fedata->list);

	kfree(fedata);

	dev_set_drvdata(&dev->dev, NULL);



	return 0;

}
@@ -1003,3 +1040,19 @@ static int __init pvcalls_back_init(void) 
	return 0;

}

module_init(pvcalls_back_init);



static void __exit pvcalls_back_fin(void)

{

	struct pvcalls_fedata *fedata, *nfedata;



	down(&pvcalls_back_global.frontends_lock);

	list_for_each_entry_safe(fedata, nfedata,

				 &pvcalls_back_global.frontends, list) {

		backend_disconnect(fedata->dev);

	}

	up(&pvcalls_back_global.frontends_lock);



	xenbus_unregister_driver(&pvcalls_back_driver);

}



module_exit(pvcalls_back_fin);