aboutsummaryrefslogtreecommitdiffstats
path: root/drivers/block/nbd.c
diff options
context:
space:
mode:
Diffstat (limited to 'drivers/block/nbd.c')
-rw-r--r--drivers/block/nbd.c22
1 files changed, 9 insertions, 13 deletions
diff --git a/drivers/block/nbd.c b/drivers/block/nbd.c
index be92c658f06e..228b2ff577aa 100644
--- a/drivers/block/nbd.c
+++ b/drivers/block/nbd.c
@@ -180,7 +180,7 @@ static inline int sock_send_bvec(struct socket *sock, struct bio_vec *bvec,
180 180
181static int nbd_send_req(struct nbd_device *lo, struct request *req) 181static int nbd_send_req(struct nbd_device *lo, struct request *req)
182{ 182{
183 int result, i, flags; 183 int result, flags;
184 struct nbd_request request; 184 struct nbd_request request;
185 unsigned long size = req->nr_sectors << 9; 185 unsigned long size = req->nr_sectors << 9;
186 struct socket *sock = lo->sock; 186 struct socket *sock = lo->sock;
@@ -205,16 +205,15 @@ static int nbd_send_req(struct nbd_device *lo, struct request *req)
205 } 205 }
206 206
207 if (nbd_cmd(req) == NBD_CMD_WRITE) { 207 if (nbd_cmd(req) == NBD_CMD_WRITE) {
208 struct bio *bio; 208 struct req_iterator iter;
209 struct bio_vec *bvec;
209 /* 210 /*
210 * we are really probing at internals to determine 211 * we are really probing at internals to determine
211 * whether to set MSG_MORE or not... 212 * whether to set MSG_MORE or not...
212 */ 213 */
213 rq_for_each_bio(bio, req) { 214 rq_for_each_segment(bvec, req, iter) {
214 struct bio_vec *bvec;
215 bio_for_each_segment(bvec, bio, i) {
216 flags = 0; 215 flags = 0;
217 if ((i < (bio->bi_vcnt - 1)) || bio->bi_next) 216 if (!rq_iter_last(req, iter))
218 flags = MSG_MORE; 217 flags = MSG_MORE;
219 dprintk(DBG_TX, "%s: request %p: sending %d bytes data\n", 218 dprintk(DBG_TX, "%s: request %p: sending %d bytes data\n",
220 lo->disk->disk_name, req, 219 lo->disk->disk_name, req,
@@ -226,7 +225,6 @@ static int nbd_send_req(struct nbd_device *lo, struct request *req)
226 result); 225 result);
227 goto error_out; 226 goto error_out;
228 } 227 }
229 }
230 } 228 }
231 } 229 }
232 return 0; 230 return 0;
@@ -321,11 +319,10 @@ static struct request *nbd_read_stat(struct nbd_device *lo)
321 dprintk(DBG_RX, "%s: request %p: got reply\n", 319 dprintk(DBG_RX, "%s: request %p: got reply\n",
322 lo->disk->disk_name, req); 320 lo->disk->disk_name, req);
323 if (nbd_cmd(req) == NBD_CMD_READ) { 321 if (nbd_cmd(req) == NBD_CMD_READ) {
324 int i; 322 struct req_iterator iter;
325 struct bio *bio; 323 struct bio_vec *bvec;
326 rq_for_each_bio(bio, req) { 324
327 struct bio_vec *bvec; 325 rq_for_each_segment(bvec, req, iter) {
328 bio_for_each_segment(bvec, bio, i) {
329 result = sock_recv_bvec(sock, bvec); 326 result = sock_recv_bvec(sock, bvec);
330 if (result <= 0) { 327 if (result <= 0) {
331 printk(KERN_ERR "%s: Receive data failed (result %d)\n", 328 printk(KERN_ERR "%s: Receive data failed (result %d)\n",
@@ -336,7 +333,6 @@ static struct request *nbd_read_stat(struct nbd_device *lo)
336 } 333 }
337 dprintk(DBG_RX, "%s: request %p: got %d bytes data\n", 334 dprintk(DBG_RX, "%s: request %p: got %d bytes data\n",
338 lo->disk->disk_name, req, bvec->bv_len); 335 lo->disk->disk_name, req, bvec->bv_len);
339 }
340 } 336 }
341 } 337 }
342 return req; 338 return req;