47 struct xenbus_device *xen_blkbk_xenbus(struct backend_info *be)  in xen_blkbk_xenbus()  argument
49 	return be->dev;  in xen_blkbk_xenbus()
67 	struct xenbus_device *dev = blkif->be->dev;  in blkback_name()
95 	if (blkif->be->dev->state == XenbusStateConnected)  in xen_update_blkif_status()
99 	connect(blkif->be);  in xen_update_blkif_status()
100 	if (blkif->be->dev->state != XenbusStateConnected)  in xen_update_blkif_status()
105 		xenbus_dev_error(blkif->be->dev, err, "get blkback dev name");  in xen_update_blkif_status()
111 		xenbus_dev_error(blkif->be->dev, err, "block flush");  in xen_update_blkif_status()
120 		xenbus_dev_error(blkif->be->dev, err, "start xenblkd");  in xen_update_blkif_status()
169 	err = xenbus_map_ring_valloc(blkif->be->dev, gref, nr_grefs,  in xen_blkif_map()
207 		xenbus_unmap_ring_vfree(blkif->be->dev, blkif->blk_ring);  in xen_blkif_map()
240 		xenbus_unmap_ring_vfree(blkif->be->dev, blkif->blk_ring);  in xen_blkif_disconnect()
305 		struct backend_info *be = dev_get_drvdata(&dev->dev);	\
311 VBD_SHOW(oo_req,  "%llu\n", be->blkif->st_oo_req);
312 VBD_SHOW(rd_req,  "%llu\n", be->blkif->st_rd_req);
313 VBD_SHOW(wr_req,  "%llu\n", be->blkif->st_wr_req);
314 VBD_SHOW(f_req,  "%llu\n", be->blkif->st_f_req);
315 VBD_SHOW(ds_req,  "%llu\n", be->blkif->st_ds_req);
316 VBD_SHOW(rd_sect, "%llu\n", be->blkif->st_rd_sect);
317 VBD_SHOW(wr_sect, "%llu\n", be->blkif->st_wr_sect);
335 VBD_SHOW(physical_device, "%x:%x\n", be->major, be->minor);
336 VBD_SHOW(mode, "%s\n", be->mode);
428 	struct backend_info *be = dev_get_drvdata(&dev->dev);  in xen_blkbk_remove()  local
432 	if (be->major || be->minor)  in xen_blkbk_remove()
435 	if (be->backend_watch.node) {  in xen_blkbk_remove()
436 		unregister_xenbus_watch(&be->backend_watch);  in xen_blkbk_remove()
437 		kfree(be->backend_watch.node);  in xen_blkbk_remove()
438 		be->backend_watch.node = NULL;  in xen_blkbk_remove()
443 	if (be->blkif) {  in xen_blkbk_remove()
444 		xen_blkif_disconnect(be->blkif);  in xen_blkbk_remove()
445 		xen_blkif_put(be->blkif);  in xen_blkbk_remove()
448 	kfree(be->mode);  in xen_blkbk_remove()
449 	kfree(be);  in xen_blkbk_remove()
454 			      struct backend_info *be, int state)  in xen_blkbk_flush_diskcache()  argument
456 	struct xenbus_device *dev = be->dev;  in xen_blkbk_flush_diskcache()
467 static void xen_blkbk_discard(struct xenbus_transaction xbt, struct backend_info *be)  in xen_blkbk_discard()  argument
469 	struct xenbus_device *dev = be->dev;  in xen_blkbk_discard()
470 	struct xen_blkif *blkif = be->blkif;  in xen_blkbk_discard()
473 	struct block_device *bdev = be->blkif->vbd.bdev;  in xen_blkbk_discard()
512 		      struct backend_info *be, int state)  in xen_blkbk_barrier()  argument
514 	struct xenbus_device *dev = be->dev;  in xen_blkbk_barrier()
534 	struct backend_info *be = kzalloc(sizeof(struct backend_info),  in xen_blkbk_probe()  local
540 	if (!be) {  in xen_blkbk_probe()
545 	be->dev = dev;  in xen_blkbk_probe()
546 	dev_set_drvdata(&dev->dev, be);  in xen_blkbk_probe()
548 	be->blkif = xen_blkif_alloc(dev->otherend_id);  in xen_blkbk_probe()
549 	if (IS_ERR(be->blkif)) {  in xen_blkbk_probe()
550 		err = PTR_ERR(be->blkif);  in xen_blkbk_probe()
551 		be->blkif = NULL;  in xen_blkbk_probe()
557 	be->blkif->be = be;  in xen_blkbk_probe()
559 	err = xenbus_watch_pathfmt(dev, &be->backend_watch, backend_changed,  in xen_blkbk_probe()
593 	struct backend_info *be  in backend_changed()  local
595 	struct xenbus_device *dev = be->dev;  in backend_changed()
617 	if (be->major | be->minor) {  in backend_changed()
618 		if (be->major != major || be->minor != minor)  in backend_changed()
620 				be->major, be->minor, major, minor);  in backend_changed()
624 	be->mode = xenbus_read(XBT_NIL, dev->nodename, "mode", NULL);  in backend_changed()
625 	if (IS_ERR(be->mode)) {  in backend_changed()
626 		err = PTR_ERR(be->mode);  in backend_changed()
627 		be->mode = NULL;  in backend_changed()
643 	be->major = major;  in backend_changed()
644 	be->minor = minor;  in backend_changed()
646 	err = xen_vbd_create(be->blkif, handle, major, minor,  in backend_changed()
647 			     !strchr(be->mode, 'w'), cdrom);  in backend_changed()
654 			xen_vbd_free(&be->blkif->vbd);  in backend_changed()
660 		kfree(be->mode);  in backend_changed()
661 		be->mode = NULL;  in backend_changed()
662 		be->major = 0;  in backend_changed()
663 		be->minor = 0;  in backend_changed()
666 		xen_update_blkif_status(be->blkif);  in backend_changed()
677 	struct backend_info *be = dev_get_drvdata(&dev->dev);  in frontend_changed()  local
704 		err = xen_blkif_disconnect(be->blkif);  in frontend_changed()
710 		err = connect_ring(be);  in frontend_changed()
713 		xen_update_blkif_status(be->blkif);  in frontend_changed()
721 		xen_blkif_disconnect(be->blkif);  in frontend_changed()
746 static void connect(struct backend_info *be)  in connect()  argument
750 	struct xenbus_device *dev = be->dev;  in connect()
763 	xen_blkbk_flush_diskcache(xbt, be, be->blkif->vbd.flush_support);  in connect()
765 	xen_blkbk_discard(xbt, be);  in connect()
767 	xen_blkbk_barrier(xbt, be, be->blkif->vbd.flush_support);  in connect()
782 			    (unsigned long long)vbd_sz(&be->blkif->vbd));  in connect()
791 			    be->blkif->vbd.type |  in connect()
792 			    (be->blkif->vbd.readonly ? VDISK_READONLY : 0));  in connect()
800 			    bdev_logical_block_size(be->blkif->vbd.bdev));  in connect()
807 			    bdev_physical_block_size(be->blkif->vbd.bdev));  in connect()
829 static int connect_ring(struct backend_info *be)  in connect_ring()  argument
831 	struct xenbus_device *dev = be->dev;  in connect_ring()
893 	be->blkif->blk_protocol = BLKIF_PROTOCOL_DEFAULT;  in connect_ring()
899 		be->blkif->blk_protocol = BLKIF_PROTOCOL_NATIVE;  in connect_ring()
901 		be->blkif->blk_protocol = BLKIF_PROTOCOL_X86_32;  in connect_ring()
903 		be->blkif->blk_protocol = BLKIF_PROTOCOL_X86_64;  in connect_ring()
914 	be->blkif->vbd.feature_gnt_persistent = pers_grants;  in connect_ring()
915 	be->blkif->vbd.overflow_max_grants = 0;  in connect_ring()
916 	be->blkif->nr_ring_pages = nr_grefs;  in connect_ring()
919 		nr_grefs, evtchn, be->blkif->blk_protocol, protocol,  in connect_ring()
926 		list_add_tail(&req->free_list, &be->blkif->pending_free);  in connect_ring()
941 	err = xen_blkif_map(be->blkif, ring_ref, nr_grefs, evtchn);  in connect_ring()
950 	list_for_each_entry_safe(req, n, &be->blkif->pending_free, free_list) {  in connect_ring()