提交 78574878 编写于 作者: T Tao Chen 提交者: David Vrabel

xen-scsiback: define a pr_fmt macro with xen-pvscsi

Add the {xen-pvscsi: } prefix in pr_fmt and remove DPRINTK, then
replace all DPRINTK with pr_debug.

Also fixed up some comments just as eliminate redundant whitespace
and format the code.

These will make the code easier to read.
Signed-off-by: NTao Chen <boby.chen@huawei.com>
Reviewed-by: NJuergen Gross <jgross@suse.com>
Signed-off-by: NDavid Vrabel <david.vrabel@citrix.com>
上级 ebfe79a7
...@@ -31,6 +31,8 @@ ...@@ -31,6 +31,8 @@
* IN THE SOFTWARE. * IN THE SOFTWARE.
*/ */
#define pr_fmt(fmt) "xen-pvscsi: " fmt
#include <stdarg.h> #include <stdarg.h>
#include <linux/module.h> #include <linux/module.h>
...@@ -69,9 +71,6 @@ ...@@ -69,9 +71,6 @@
#include <xen/interface/grant_table.h> #include <xen/interface/grant_table.h>
#include <xen/interface/io/vscsiif.h> #include <xen/interface/io/vscsiif.h>
#define DPRINTK(_f, _a...) \
pr_debug("(file=%s, line=%d) " _f, __FILE__ , __LINE__ , ## _a)
#define VSCSI_VERSION "v0.1" #define VSCSI_VERSION "v0.1"
#define VSCSI_NAMELEN 32 #define VSCSI_NAMELEN 32
...@@ -271,7 +270,7 @@ static void scsiback_print_status(char *sense_buffer, int errors, ...@@ -271,7 +270,7 @@ static void scsiback_print_status(char *sense_buffer, int errors,
{ {
struct scsiback_tpg *tpg = pending_req->v2p->tpg; struct scsiback_tpg *tpg = pending_req->v2p->tpg;
pr_err("xen-pvscsi[%s:%d] cmnd[0]=%02x -> st=%02x msg=%02x host=%02x drv=%02x\n", pr_err("[%s:%d] cmnd[0]=%02x -> st=%02x msg=%02x host=%02x drv=%02x\n",
tpg->tport->tport_name, pending_req->v2p->lun, tpg->tport->tport_name, pending_req->v2p->lun,
pending_req->cmnd[0], status_byte(errors), msg_byte(errors), pending_req->cmnd[0], status_byte(errors), msg_byte(errors),
host_byte(errors), driver_byte(errors)); host_byte(errors), driver_byte(errors));
...@@ -427,7 +426,7 @@ static int scsiback_gnttab_data_map_batch(struct gnttab_map_grant_ref *map, ...@@ -427,7 +426,7 @@ static int scsiback_gnttab_data_map_batch(struct gnttab_map_grant_ref *map,
BUG_ON(err); BUG_ON(err);
for (i = 0; i < cnt; i++) { for (i = 0; i < cnt; i++) {
if (unlikely(map[i].status != GNTST_okay)) { if (unlikely(map[i].status != GNTST_okay)) {
pr_err("xen-pvscsi: invalid buffer -- could not remap it\n"); pr_err("invalid buffer -- could not remap it\n");
map[i].handle = SCSIBACK_INVALID_HANDLE; map[i].handle = SCSIBACK_INVALID_HANDLE;
err = -ENOMEM; err = -ENOMEM;
} else { } else {
...@@ -449,7 +448,7 @@ static int scsiback_gnttab_data_map_list(struct vscsibk_pend *pending_req, ...@@ -449,7 +448,7 @@ static int scsiback_gnttab_data_map_list(struct vscsibk_pend *pending_req,
for (i = 0; i < cnt; i++) { for (i = 0; i < cnt; i++) {
if (get_free_page(pg + mapcount)) { if (get_free_page(pg + mapcount)) {
put_free_pages(pg, mapcount); put_free_pages(pg, mapcount);
pr_err("xen-pvscsi: no grant page\n"); pr_err("no grant page\n");
return -ENOMEM; return -ENOMEM;
} }
gnttab_set_map_op(&map[mapcount], vaddr_page(pg[mapcount]), gnttab_set_map_op(&map[mapcount], vaddr_page(pg[mapcount]),
...@@ -492,7 +491,7 @@ static int scsiback_gnttab_data_map(struct vscsiif_request *ring_req, ...@@ -492,7 +491,7 @@ static int scsiback_gnttab_data_map(struct vscsiif_request *ring_req,
return 0; return 0;
if (nr_segments > VSCSIIF_SG_TABLESIZE) { if (nr_segments > VSCSIIF_SG_TABLESIZE) {
DPRINTK("xen-pvscsi: invalid parameter nr_seg = %d\n", pr_debug("invalid parameter nr_seg = %d\n",
ring_req->nr_segments); ring_req->nr_segments);
return -EINVAL; return -EINVAL;
} }
...@@ -516,13 +515,12 @@ static int scsiback_gnttab_data_map(struct vscsiif_request *ring_req, ...@@ -516,13 +515,12 @@ static int scsiback_gnttab_data_map(struct vscsiif_request *ring_req,
nr_segments += n_segs; nr_segments += n_segs;
} }
if (nr_segments > SG_ALL) { if (nr_segments > SG_ALL) {
DPRINTK("xen-pvscsi: invalid nr_seg = %d\n", pr_debug("invalid nr_seg = %d\n", nr_segments);
nr_segments);
return -EINVAL; return -EINVAL;
} }
} }
/* free of (sgl) in fast_flush_area()*/ /* free of (sgl) in fast_flush_area() */
pending_req->sgl = kmalloc_array(nr_segments, pending_req->sgl = kmalloc_array(nr_segments,
sizeof(struct scatterlist), GFP_KERNEL); sizeof(struct scatterlist), GFP_KERNEL);
if (!pending_req->sgl) if (!pending_req->sgl)
...@@ -679,7 +677,8 @@ static int prepare_pending_reqs(struct vscsibk_info *info, ...@@ -679,7 +677,8 @@ static int prepare_pending_reqs(struct vscsibk_info *info,
v2p = scsiback_do_translation(info, &vir); v2p = scsiback_do_translation(info, &vir);
if (!v2p) { if (!v2p) {
pending_req->v2p = NULL; pending_req->v2p = NULL;
DPRINTK("xen-pvscsi: doesn't exist.\n"); pr_debug("the v2p of (chn:%d, tgt:%d, lun:%d) doesn't exist.\n",
vir.chn, vir.tgt, vir.lun);
return -ENODEV; return -ENODEV;
} }
pending_req->v2p = v2p; pending_req->v2p = v2p;
...@@ -690,14 +689,14 @@ static int prepare_pending_reqs(struct vscsibk_info *info, ...@@ -690,14 +689,14 @@ static int prepare_pending_reqs(struct vscsibk_info *info,
(pending_req->sc_data_direction != DMA_TO_DEVICE) && (pending_req->sc_data_direction != DMA_TO_DEVICE) &&
(pending_req->sc_data_direction != DMA_FROM_DEVICE) && (pending_req->sc_data_direction != DMA_FROM_DEVICE) &&
(pending_req->sc_data_direction != DMA_NONE)) { (pending_req->sc_data_direction != DMA_NONE)) {
DPRINTK("xen-pvscsi: invalid parameter data_dir = %d\n", pr_debug("invalid parameter data_dir = %d\n",
pending_req->sc_data_direction); pending_req->sc_data_direction);
return -EINVAL; return -EINVAL;
} }
pending_req->cmd_len = ring_req->cmd_len; pending_req->cmd_len = ring_req->cmd_len;
if (pending_req->cmd_len > VSCSIIF_MAX_COMMAND_SIZE) { if (pending_req->cmd_len > VSCSIIF_MAX_COMMAND_SIZE) {
DPRINTK("xen-pvscsi: invalid parameter cmd_len = %d\n", pr_debug("invalid parameter cmd_len = %d\n",
pending_req->cmd_len); pending_req->cmd_len);
return -EINVAL; return -EINVAL;
} }
...@@ -721,7 +720,7 @@ static int scsiback_do_cmd_fn(struct vscsibk_info *info) ...@@ -721,7 +720,7 @@ static int scsiback_do_cmd_fn(struct vscsibk_info *info)
if (RING_REQUEST_PROD_OVERFLOW(ring, rp)) { if (RING_REQUEST_PROD_OVERFLOW(ring, rp)) {
rc = ring->rsp_prod_pvt; rc = ring->rsp_prod_pvt;
pr_warn("xen-pvscsi: Dom%d provided bogus ring requests (%#x - %#x = %u). Halting ring processing\n", pr_warn("Dom%d provided bogus ring requests (%#x - %#x = %u). Halting ring processing\n",
info->domid, rp, rc, rp - rc); info->domid, rp, rc, rp - rc);
info->ring_error = 1; info->ring_error = 1;
return 0; return 0;
...@@ -772,7 +771,7 @@ static int scsiback_do_cmd_fn(struct vscsibk_info *info) ...@@ -772,7 +771,7 @@ static int scsiback_do_cmd_fn(struct vscsibk_info *info)
scsiback_device_action(pending_req, TMR_LUN_RESET, 0); scsiback_device_action(pending_req, TMR_LUN_RESET, 0);
break; break;
default: default:
pr_err_ratelimited("xen-pvscsi: invalid request\n"); pr_err_ratelimited("invalid request\n");
scsiback_do_resp_with_sense(NULL, DRIVER_ERROR << 24, scsiback_do_resp_with_sense(NULL, DRIVER_ERROR << 24,
0, pending_req); 0, pending_req);
kmem_cache_free(scsiback_cachep, pending_req); kmem_cache_free(scsiback_cachep, pending_req);
...@@ -874,14 +873,13 @@ static int scsiback_add_translation_entry(struct vscsibk_info *info, ...@@ -874,14 +873,13 @@ static int scsiback_add_translation_entry(struct vscsibk_info *info,
lunp = strrchr(phy, ':'); lunp = strrchr(phy, ':');
if (!lunp) { if (!lunp) {
pr_err("xen-pvscsi: illegal format of physical device %s\n", pr_err("illegal format of physical device %s\n", phy);
phy);
return -EINVAL; return -EINVAL;
} }
*lunp = 0; *lunp = 0;
lunp++; lunp++;
if (kstrtouint(lunp, 10, &lun) || lun >= TRANSPORT_MAX_LUNS_PER_TPG) { if (kstrtouint(lunp, 10, &lun) || lun >= TRANSPORT_MAX_LUNS_PER_TPG) {
pr_err("xen-pvscsi: lun number not valid: %s\n", lunp); pr_err("lun number not valid: %s\n", lunp);
return -EINVAL; return -EINVAL;
} }
...@@ -909,7 +907,7 @@ static int scsiback_add_translation_entry(struct vscsibk_info *info, ...@@ -909,7 +907,7 @@ static int scsiback_add_translation_entry(struct vscsibk_info *info,
mutex_unlock(&scsiback_mutex); mutex_unlock(&scsiback_mutex);
if (!tpg) { if (!tpg) {
pr_err("xen-pvscsi: %s:%d %s\n", phy, lun, error); pr_err("%s:%d %s\n", phy, lun, error);
return -ENODEV; return -ENODEV;
} }
...@@ -926,7 +924,7 @@ static int scsiback_add_translation_entry(struct vscsibk_info *info, ...@@ -926,7 +924,7 @@ static int scsiback_add_translation_entry(struct vscsibk_info *info,
if ((entry->v.chn == v->chn) && if ((entry->v.chn == v->chn) &&
(entry->v.tgt == v->tgt) && (entry->v.tgt == v->tgt) &&
(entry->v.lun == v->lun)) { (entry->v.lun == v->lun)) {
pr_warn("xen-pvscsi: Virtual ID is already used. Assignment was not performed.\n"); pr_warn("Virtual ID is already used. Assignment was not performed.\n");
err = -EEXIST; err = -EEXIST;
goto out; goto out;
} }
...@@ -997,7 +995,7 @@ static void scsiback_do_add_lun(struct vscsibk_info *info, const char *state, ...@@ -997,7 +995,7 @@ static void scsiback_do_add_lun(struct vscsibk_info *info, const char *state,
if (!scsiback_add_translation_entry(info, phy, vir)) { if (!scsiback_add_translation_entry(info, phy, vir)) {
if (xenbus_printf(XBT_NIL, info->dev->nodename, state, if (xenbus_printf(XBT_NIL, info->dev->nodename, state,
"%d", XenbusStateInitialised)) { "%d", XenbusStateInitialised)) {
pr_err("xen-pvscsi: xenbus_printf error %s\n", state); pr_err("xenbus_printf error %s\n", state);
scsiback_del_translation_entry(info, vir); scsiback_del_translation_entry(info, vir);
} }
} else { } else {
...@@ -1012,7 +1010,7 @@ static void scsiback_do_del_lun(struct vscsibk_info *info, const char *state, ...@@ -1012,7 +1010,7 @@ static void scsiback_do_del_lun(struct vscsibk_info *info, const char *state,
if (!scsiback_del_translation_entry(info, vir)) { if (!scsiback_del_translation_entry(info, vir)) {
if (xenbus_printf(XBT_NIL, info->dev->nodename, state, if (xenbus_printf(XBT_NIL, info->dev->nodename, state,
"%d", XenbusStateClosed)) "%d", XenbusStateClosed))
pr_err("xen-pvscsi: xenbus_printf error %s\n", state); pr_err("xenbus_printf error %s\n", state);
} }
} }
...@@ -1071,15 +1069,14 @@ static void scsiback_do_1lun_hotplug(struct vscsibk_info *info, int op, ...@@ -1071,15 +1069,14 @@ static void scsiback_do_1lun_hotplug(struct vscsibk_info *info, int op,
/* modify vscsi-devs/dev-x/state */ /* modify vscsi-devs/dev-x/state */
if (xenbus_printf(XBT_NIL, dev->nodename, state, if (xenbus_printf(XBT_NIL, dev->nodename, state,
"%d", XenbusStateConnected)) { "%d", XenbusStateConnected)) {
pr_err("xen-pvscsi: xenbus_printf error %s\n", pr_err("xenbus_printf error %s\n", str);
str);
scsiback_del_translation_entry(info, &vir); scsiback_del_translation_entry(info, &vir);
xenbus_printf(XBT_NIL, dev->nodename, state, xenbus_printf(XBT_NIL, dev->nodename, state,
"%d", XenbusStateClosed); "%d", XenbusStateClosed);
} }
} }
break; break;
/*When it is necessary, processing is added here.*/ /* When it is necessary, processing is added here. */
default: default:
break; break;
} }
...@@ -1196,7 +1193,7 @@ static int scsiback_probe(struct xenbus_device *dev, ...@@ -1196,7 +1193,7 @@ static int scsiback_probe(struct xenbus_device *dev,
struct vscsibk_info *info = kzalloc(sizeof(struct vscsibk_info), struct vscsibk_info *info = kzalloc(sizeof(struct vscsibk_info),
GFP_KERNEL); GFP_KERNEL);
DPRINTK("%p %d\n", dev, dev->otherend_id); pr_debug("%s %p %d\n", __func__, dev, dev->otherend_id);
if (!info) { if (!info) {
xenbus_dev_fatal(dev, -ENOMEM, "allocating backend structure"); xenbus_dev_fatal(dev, -ENOMEM, "allocating backend structure");
...@@ -1227,7 +1224,7 @@ static int scsiback_probe(struct xenbus_device *dev, ...@@ -1227,7 +1224,7 @@ static int scsiback_probe(struct xenbus_device *dev,
return 0; return 0;
fail: fail:
pr_warn("xen-pvscsi: %s failed\n", __func__); pr_warn("%s failed\n", __func__);
scsiback_remove(dev); scsiback_remove(dev);
return err; return err;
...@@ -1432,7 +1429,7 @@ scsiback_make_tport(struct target_fabric_configfs *tf, ...@@ -1432,7 +1429,7 @@ scsiback_make_tport(struct target_fabric_configfs *tf,
} }
snprintf(&tport->tport_name[0], VSCSI_NAMELEN, "%s", &name[off]); snprintf(&tport->tport_name[0], VSCSI_NAMELEN, "%s", &name[off]);
pr_debug("xen-pvscsi: Allocated emulated Target %s Address: %s\n", pr_debug("Allocated emulated Target %s Address: %s\n",
scsiback_dump_proto_id(tport), name); scsiback_dump_proto_id(tport), name);
return &tport->tport_wwn; return &tport->tport_wwn;
...@@ -1443,7 +1440,7 @@ static void scsiback_drop_tport(struct se_wwn *wwn) ...@@ -1443,7 +1440,7 @@ static void scsiback_drop_tport(struct se_wwn *wwn)
struct scsiback_tport *tport = container_of(wwn, struct scsiback_tport *tport = container_of(wwn,
struct scsiback_tport, tport_wwn); struct scsiback_tport, tport_wwn);
pr_debug("xen-pvscsi: Deallocating emulated Target %s Address: %s\n", pr_debug("Deallocating emulated Target %s Address: %s\n",
scsiback_dump_proto_id(tport), tport->tport_name); scsiback_dump_proto_id(tport), tport->tport_name);
kfree(tport); kfree(tport);
...@@ -1470,8 +1467,8 @@ static u32 scsiback_tpg_get_inst_index(struct se_portal_group *se_tpg) ...@@ -1470,8 +1467,8 @@ static u32 scsiback_tpg_get_inst_index(struct se_portal_group *se_tpg)
static int scsiback_check_stop_free(struct se_cmd *se_cmd) static int scsiback_check_stop_free(struct se_cmd *se_cmd)
{ {
/* /*
* Do not release struct se_cmd's containing a valid TMR * Do not release struct se_cmd's containing a valid TMR pointer.
* pointer. These will be released directly in scsiback_device_action() * These will be released directly in scsiback_device_action()
* with transport_generic_free_cmd(). * with transport_generic_free_cmd().
*/ */
if (se_cmd->se_cmd_flags & SCF_SCSI_TMR_CDB) if (se_cmd->se_cmd_flags & SCF_SCSI_TMR_CDB)
...@@ -1637,7 +1634,7 @@ static int scsiback_make_nexus(struct scsiback_tpg *tpg, ...@@ -1637,7 +1634,7 @@ static int scsiback_make_nexus(struct scsiback_tpg *tpg,
return -ENOMEM; return -ENOMEM;
} }
/* /*
* Initialize the struct se_session pointer * Initialize the struct se_session pointer
*/ */
tv_nexus->tvn_se_sess = transport_init_session(TARGET_PROT_NORMAL); tv_nexus->tvn_se_sess = transport_init_session(TARGET_PROT_NORMAL);
if (IS_ERR(tv_nexus->tvn_se_sess)) { if (IS_ERR(tv_nexus->tvn_se_sess)) {
...@@ -1708,7 +1705,7 @@ static int scsiback_drop_nexus(struct scsiback_tpg *tpg) ...@@ -1708,7 +1705,7 @@ static int scsiback_drop_nexus(struct scsiback_tpg *tpg)
return -EBUSY; return -EBUSY;
} }
pr_debug("xen-pvscsi: Removing I_T Nexus to emulated %s Initiator Port: %s\n", pr_debug("Removing I_T Nexus to emulated %s Initiator Port: %s\n",
scsiback_dump_proto_id(tpg->tport), scsiback_dump_proto_id(tpg->tport),
tv_nexus->tvn_se_sess->se_node_acl->initiatorname); tv_nexus->tvn_se_sess->se_node_acl->initiatorname);
...@@ -1754,7 +1751,7 @@ static ssize_t scsiback_tpg_store_nexus(struct se_portal_group *se_tpg, ...@@ -1754,7 +1751,7 @@ static ssize_t scsiback_tpg_store_nexus(struct se_portal_group *se_tpg,
unsigned char i_port[VSCSI_NAMELEN], *ptr, *port_ptr; unsigned char i_port[VSCSI_NAMELEN], *ptr, *port_ptr;
int ret; int ret;
/* /*
* Shutdown the active I_T nexus if 'NULL' is passed.. * Shutdown the active I_T nexus if 'NULL' is passed.
*/ */
if (!strncmp(page, "NULL", 4)) { if (!strncmp(page, "NULL", 4)) {
ret = scsiback_drop_nexus(tpg); ret = scsiback_drop_nexus(tpg);
...@@ -1925,7 +1922,7 @@ static void scsiback_drop_tpg(struct se_portal_group *se_tpg) ...@@ -1925,7 +1922,7 @@ static void scsiback_drop_tpg(struct se_portal_group *se_tpg)
*/ */
scsiback_drop_nexus(tpg); scsiback_drop_nexus(tpg);
/* /*
* Deregister the se_tpg from TCM.. * Deregister the se_tpg from TCM.
*/ */
core_tpg_deregister(se_tpg); core_tpg_deregister(se_tpg);
kfree(tpg); kfree(tpg);
...@@ -1995,7 +1992,7 @@ static int scsiback_register_configfs(void) ...@@ -1995,7 +1992,7 @@ static int scsiback_register_configfs(void)
struct target_fabric_configfs *fabric; struct target_fabric_configfs *fabric;
int ret; int ret;
pr_debug("xen-pvscsi: fabric module %s on %s/%s on "UTS_RELEASE"\n", pr_debug("fabric module %s on %s/%s on "UTS_RELEASE"\n",
VSCSI_VERSION, utsname()->sysname, utsname()->machine); VSCSI_VERSION, utsname()->sysname, utsname()->machine);
/* /*
* Register the top level struct config_item_type with TCM core * Register the top level struct config_item_type with TCM core
...@@ -2032,7 +2029,7 @@ static int scsiback_register_configfs(void) ...@@ -2032,7 +2029,7 @@ static int scsiback_register_configfs(void)
* Setup our local pointer to *fabric * Setup our local pointer to *fabric
*/ */
scsiback_fabric_configfs = fabric; scsiback_fabric_configfs = fabric;
pr_debug("xen-pvscsi: Set fabric -> scsiback_fabric_configfs\n"); pr_debug("Set fabric -> scsiback_fabric_configfs\n");
return 0; return 0;
}; };
...@@ -2043,7 +2040,7 @@ static void scsiback_deregister_configfs(void) ...@@ -2043,7 +2040,7 @@ static void scsiback_deregister_configfs(void)
target_fabric_configfs_deregister(scsiback_fabric_configfs); target_fabric_configfs_deregister(scsiback_fabric_configfs);
scsiback_fabric_configfs = NULL; scsiback_fabric_configfs = NULL;
pr_debug("xen-pvscsi: Cleared scsiback_fabric_configfs\n"); pr_debug("Cleared scsiback_fabric_configfs\n");
}; };
static const struct xenbus_device_id scsiback_ids[] = { static const struct xenbus_device_id scsiback_ids[] = {
...@@ -2094,7 +2091,7 @@ static int __init scsiback_init(void) ...@@ -2094,7 +2091,7 @@ static int __init scsiback_init(void)
xenbus_unregister_driver(&scsiback_driver); xenbus_unregister_driver(&scsiback_driver);
out_cache_destroy: out_cache_destroy:
kmem_cache_destroy(scsiback_cachep); kmem_cache_destroy(scsiback_cachep);
pr_err("xen-pvscsi: %s: error %d\n", __func__, ret); pr_err("%s: error %d\n", __func__, ret);
return ret; return ret;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册