And also make them uniform and prefix the message with 'xen-blkback'.
Signed-off-by: Konrad Rzeszutek Wilk <konrad.wilk@oracle.com>
struct xenbus_device *dev = xen_blkbk_xenbus(blkif->be);
unsigned long long new_size = vbd_sz(vbd);
struct xenbus_device *dev = xen_blkbk_xenbus(blkif->be);
unsigned long long new_size = vbd_sz(vbd);
- printk(KERN_INFO "VBD Resize: Domid: %d, Device: (%d, %d)\n",
+ pr_info("xen-blkback: VBD Resize: Domid: %d, Device: (%d, %d)\n",
blkif->domid, MAJOR(vbd->pdevice), MINOR(vbd->pdevice));
blkif->domid, MAJOR(vbd->pdevice), MINOR(vbd->pdevice));
- printk(KERN_INFO "VBD Resize: new size %llu\n", new_size);
+ pr_info("xen-blkback: VBD Resize: new size %llu\n", new_size);
vbd->size = new_size;
again:
err = xenbus_transaction_start(&xbt);
if (err) {
vbd->size = new_size;
again:
err = xenbus_transaction_start(&xbt);
if (err) {
- printk(KERN_WARNING "Error starting transaction");
+ pr_warn("xen-blkback: Error starting transaction");
return;
}
err = xenbus_printf(xbt, dev->nodename, "sectors", "%llu",
(unsigned long long)vbd_sz(vbd));
if (err) {
return;
}
err = xenbus_printf(xbt, dev->nodename, "sectors", "%llu",
(unsigned long long)vbd_sz(vbd));
if (err) {
- printk(KERN_WARNING "Error writing new size");
+ pr_warn("xen-blkback: Error writing new size");
*/
err = xenbus_printf(xbt, dev->nodename, "state", "%d", dev->state);
if (err) {
*/
err = xenbus_printf(xbt, dev->nodename, "state", "%d", dev->state);
if (err) {
- printk(KERN_WARNING "Error writing the state");
+ pr_warn("xen-blkback: Error writing the state");
if (err == -EAGAIN)
goto again;
if (err)
if (err == -EAGAIN)
goto again;
if (err)
- printk(KERN_WARNING "Error ending transaction");
+ pr_warn("xen-blkback: Error ending transaction");
abort:
xenbus_transaction_end(xbt, 1);
}
abort:
xenbus_transaction_end(xbt, 1);
}
static void print_stats(struct blkif_st *blkif)
{
static void print_stats(struct blkif_st *blkif)
{
- printk(KERN_DEBUG "%s: oo %3d | rd %4d | wr %4d | f %4d\n",
- current->comm, blkif->st_oo_req,
- blkif->st_rd_req, blkif->st_wr_req, blkif->st_f_req);
+ pr_debug("xen-blkback (%s): oo %3d | rd %4d | wr %4d | f %4d\n",
+ current->comm, blkif->st_oo_req,
+ blkif->st_rd_req, blkif->st_wr_req, blkif->st_f_req);
blkif->st_print = jiffies + msecs_to_jiffies(10 * 1000);
blkif->st_rd_req = 0;
blkif->st_wr_req = 0;
blkif->st_print = jiffies + msecs_to_jiffies(10 * 1000);
blkif->st_rd_req = 0;
blkif->st_wr_req = 0;
xen_blkif_get(blkif);
if (debug_lvl)
xen_blkif_get(blkif);
if (debug_lvl)
- printk(KERN_DEBUG "%s: started\n", current->comm);
+ pr_debug("xen-blkback: %s: started\n", current->comm);
while (!kthread_should_stop()) {
if (try_to_freeze())
while (!kthread_should_stop()) {
if (try_to_freeze())
if (log_stats)
print_stats(blkif);
if (debug_lvl)
if (log_stats)
print_stats(blkif);
if (debug_lvl)
- printk(KERN_DEBUG "%s: exiting\n", current->comm);
+ pr_debug("xen-blkback: %s: exiting\n", current->comm);
blkif->xenblkd = NULL;
xen_blkif_put(blkif);
blkif->xenblkd = NULL;
xen_blkif_put(blkif);
ret = m2p_remove_override(
virt_to_page(unmap[i].host_addr), false);
if (ret) {
ret = m2p_remove_override(
virt_to_page(unmap[i].host_addr), false);
if (ret) {
- printk(KERN_ALERT "Failed to remove M2P override for %lx\n",
- (unsigned long)unmap[i].host_addr);
+ pr_alert("xen-blkback: Failed to remove M2P override for %lx\n",
+ (unsigned long)unmap[i].host_addr);
*/
for (i = 0; i < nseg; i++) {
if (unlikely(map[i].status != 0)) {
*/
for (i = 0; i < nseg; i++) {
if (unlikely(map[i].status != 0)) {
- DPRINTK("invalid buffer -- could not remap it\n");
+ pr_debug("xen-blkback: invalid buffer -- could not remap it\n");
map[i].handle = BLKBACK_INVALID_HANDLE;
ret |= 1;
}
map[i].handle = BLKBACK_INVALID_HANDLE;
ret |= 1;
}
ret = m2p_add_override(PFN_DOWN(map[i].dev_bus_addr),
blkbk->pending_page(pending_req, i), false);
if (ret) {
ret = m2p_add_override(PFN_DOWN(map[i].dev_bus_addr),
blkbk->pending_page(pending_req, i), false);
if (ret) {
- printk(KERN_ALERT "Failed to install M2P override for"\
- " %lx (ret: %d)\n", (unsigned long)
- map[i].dev_bus_addr, ret);
+ pr_alert("xen-blkback: Failed to install M2P override for %lx (ret: %d)\n",
+ (unsigned long)map[i].dev_bus_addr, ret);
/* We could switch over to GNTTABOP_copy */
continue;
}
/* We could switch over to GNTTABOP_copy */
continue;
}
/* An error fails the entire request. */
if ((pending_req->operation == BLKIF_OP_FLUSH_DISKCACHE) &&
(error == -EOPNOTSUPP)) {
/* An error fails the entire request. */
if ((pending_req->operation == BLKIF_OP_FLUSH_DISKCACHE) &&
(error == -EOPNOTSUPP)) {
- DPRINTK("blkback: flush diskcache op failed, not supported\n");
+ pr_debug("xen-blkback: flush diskcache op failed, not supported\n");
xen_blkbk_flush_diskcache(XBT_NIL, pending_req->blkif->be, 0);
pending_req->status = BLKIF_RSP_EOPNOTSUPP;
} else if (error) {
xen_blkbk_flush_diskcache(XBT_NIL, pending_req->blkif->be, 0);
pending_req->status = BLKIF_RSP_EOPNOTSUPP;
} else if (error) {
- DPRINTK("Buffer not up-to-date at end of operation, "
- "error=%d\n", error);
+ pr_debug("xen-blkback: Buffer not up-to-date at end of operation,"
+ " error=%d\n", error);
pending_req->status = BLKIF_RSP_ERROR;
}
pending_req->status = BLKIF_RSP_ERROR;
}
nseg = req->nr_segments;
if (unlikely(nseg == 0 && operation != WRITE_FLUSH) ||
unlikely(nseg > BLKIF_MAX_SEGMENTS_PER_REQUEST)) {
nseg = req->nr_segments;
if (unlikely(nseg == 0 && operation != WRITE_FLUSH) ||
unlikely(nseg > BLKIF_MAX_SEGMENTS_PER_REQUEST)) {
- DPRINTK("Bad number of segments in request (%d)\n", nseg);
+ pr_debug("xen-blkback: Bad number of segments in request (%d)\n",
+ nseg);
/* Haven't submitted any bio's yet. */
goto fail_response;
}
/* Haven't submitted any bio's yet. */
goto fail_response;
}
}
if (vbd_translate(&preq, blkif, operation) != 0) {
}
if (vbd_translate(&preq, blkif, operation) != 0) {
- DPRINTK("access denied: %s of [%llu,%llu] on dev=%04x\n",
- operation == READ ? "read" : "write",
- preq.sector_number,
- preq.sector_number + preq.nr_sects, preq.dev);
+ pr_debug("xen-blkback: access denied: %s of [%llu,%llu] on dev=%04x\n",
+ operation == READ ? "read" : "write",
+ preq.sector_number,
+ preq.sector_number + preq.nr_sects, preq.dev);
for (i = 0; i < nseg; i++) {
if (((int)preq.sector_number|(int)seg[i].nsec) &
((bdev_logical_block_size(preq.bdev) >> 9) - 1)) {
for (i = 0; i < nseg; i++) {
if (((int)preq.sector_number|(int)seg[i].nsec) &
((bdev_logical_block_size(preq.bdev) >> 9) - 1)) {
- DPRINTK("Misaligned I/O request from domain %d",
- blkif->domid);
+ pr_debug("xen-blkback: Misaligned I/O request from domain %d",
+ blkif->domid);
blkbk = kzalloc(sizeof(struct xen_blkbk), GFP_KERNEL);
if (!blkbk) {
blkbk = kzalloc(sizeof(struct xen_blkbk), GFP_KERNEL);
if (!blkbk) {
- printk(KERN_ALERT "%s: out of memory!\n", __func__);
+ pr_alert("xen-blkback: %s: out of memory!\n", __func__);
- printk(KERN_ERR "%s: out of memory\n", __func__);
+ pr_alert("xen-blkback: %s: out of memory\n", __func__);
failed_init:
kfree(blkbk->pending_reqs);
kfree(blkbk->pending_grant_handles);
failed_init:
kfree(blkbk->pending_reqs);
kfree(blkbk->pending_grant_handles);
#undef DPRINTK
#define DPRINTK(fmt, args...) \
#undef DPRINTK
#define DPRINTK(fmt, args...) \
- pr_debug("blkback/xenbus (%s:%d) " fmt ".\n", \
+ pr_debug("xen-blkback: (%s:%d) " fmt ".\n", \
__func__, __LINE__, ##args)
struct backend_info {
__func__, __LINE__, ##args)
struct backend_info {
- DPRINTK(" Grant table operation failure !\n");
+ DPRINTK("Grant table operation failure !\n");
if ((be->major || be->minor) &&
((be->major != major) || (be->minor != minor))) {
if ((be->major || be->minor) &&
((be->major != major) || (be->minor != minor))) {
- printk(KERN_WARNING
- "blkback: changing physical device (from %x:%x to "
- "%x:%x) not supported.\n", be->major, be->minor,
- major, minor);
+ pr_warn("xen-blkback: changing physical device (from %x:%x to %x:%x) not supported.\n",
+ be->major, be->minor, major, minor);
switch (frontend_state) {
case XenbusStateInitialising:
if (dev->state == XenbusStateClosed) {
switch (frontend_state) {
case XenbusStateInitialising:
if (dev->state == XenbusStateClosed) {
- printk(KERN_INFO "%s: %s: prepare for reconnect\n",
- __func__, dev->nodename);
+ pr_info("xen-blkback: %s: prepare for reconnect\n",
+ dev->nodename);
xenbus_switch_state(dev, XenbusStateInitWait);
}
break;
xenbus_switch_state(dev, XenbusStateInitWait);
}
break;
xenbus_dev_fatal(dev, err, "unknown fe protocol %s", protocol);
return -1;
}
xenbus_dev_fatal(dev, err, "unknown fe protocol %s", protocol);
return -1;
}
- printk(KERN_INFO
- "blkback: ring-ref %ld, event-channel %d, protocol %d (%s)\n",
- ring_ref, evtchn, be->blkif->blk_protocol, protocol);
+ pr_info("xen-blkback: ring-ref %ld, event-channel %d, protocol %d (%s)\n",
+ ring_ref, evtchn, be->blkif->blk_protocol, protocol);
/* Map the shared frame, irq etc. */
err = xen_blkif_map(be->blkif, ring_ref, evtchn);
/* Map the shared frame, irq etc. */
err = xen_blkif_map(be->blkif, ring_ref, evtchn);