aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--drivers/block/virtio_blk.c2
-rw-r--r--drivers/char/hw_random/virtio-rng.c2
-rw-r--r--drivers/char/virtio_console.c4
-rw-r--r--drivers/net/virtio_net.c14
-rw-r--r--drivers/virtio/virtio_balloon.c2
-rw-r--r--drivers/virtio/virtio_ring.c6
-rw-r--r--include/linux/virtio.h2
-rw-r--r--net/9p/trans_virtio.c2
8 files changed, 19 insertions, 15 deletions
diff --git a/drivers/block/virtio_blk.c b/drivers/block/virtio_blk.c
index aa1a3d5a3e2b..d739ee4201f9 100644
--- a/drivers/block/virtio_blk.c
+++ b/drivers/block/virtio_blk.c
@@ -139,7 +139,7 @@ static bool do_req(struct request_queue *q, struct virtio_blk *vblk,
139 } 139 }
140 } 140 }
141 141
142 if (vblk->vq->vq_ops->add_buf(vblk->vq, vblk->sg, out, in, vbr)) { 142 if (vblk->vq->vq_ops->add_buf(vblk->vq, vblk->sg, out, in, vbr) < 0) {
143 mempool_free(vbr, vblk->pool); 143 mempool_free(vbr, vblk->pool);
144 return false; 144 return false;
145 } 145 }
diff --git a/drivers/char/hw_random/virtio-rng.c b/drivers/char/hw_random/virtio-rng.c
index 32216b623248..b6c24dcc987d 100644
--- a/drivers/char/hw_random/virtio-rng.c
+++ b/drivers/char/hw_random/virtio-rng.c
@@ -51,7 +51,7 @@ static void register_buffer(void)
51 51
52 sg_init_one(&sg, random_data+data_left, RANDOM_DATA_SIZE-data_left); 52 sg_init_one(&sg, random_data+data_left, RANDOM_DATA_SIZE-data_left);
53 /* There should always be room for one buffer. */ 53 /* There should always be room for one buffer. */
54 if (vq->vq_ops->add_buf(vq, &sg, 0, 1, random_data) != 0) 54 if (vq->vq_ops->add_buf(vq, &sg, 0, 1, random_data) < 0)
55 BUG(); 55 BUG();
56 vq->vq_ops->kick(vq); 56 vq->vq_ops->kick(vq);
57} 57}
diff --git a/drivers/char/virtio_console.c b/drivers/char/virtio_console.c
index c74dacfa6795..a035ae39a359 100644
--- a/drivers/char/virtio_console.c
+++ b/drivers/char/virtio_console.c
@@ -65,7 +65,7 @@ static int put_chars(u32 vtermno, const char *buf, int count)
65 65
66 /* add_buf wants a token to identify this buffer: we hand it any 66 /* add_buf wants a token to identify this buffer: we hand it any
67 * non-NULL pointer, since there's only ever one buffer. */ 67 * non-NULL pointer, since there's only ever one buffer. */
68 if (out_vq->vq_ops->add_buf(out_vq, sg, 1, 0, (void *)1) == 0) { 68 if (out_vq->vq_ops->add_buf(out_vq, sg, 1, 0, (void *)1) >= 0) {
69 /* Tell Host to go! */ 69 /* Tell Host to go! */
70 out_vq->vq_ops->kick(out_vq); 70 out_vq->vq_ops->kick(out_vq);
71 /* Chill out until it's done with the buffer. */ 71 /* Chill out until it's done with the buffer. */
@@ -85,7 +85,7 @@ static void add_inbuf(void)
85 sg_init_one(sg, inbuf, PAGE_SIZE); 85 sg_init_one(sg, inbuf, PAGE_SIZE);
86 86
87 /* We should always be able to add one buffer to an empty queue. */ 87 /* We should always be able to add one buffer to an empty queue. */
88 if (in_vq->vq_ops->add_buf(in_vq, sg, 0, 1, inbuf) != 0) 88 if (in_vq->vq_ops->add_buf(in_vq, sg, 0, 1, inbuf) < 0)
89 BUG(); 89 BUG();
90 in_vq->vq_ops->kick(in_vq); 90 in_vq->vq_ops->kick(in_vq);
91} 91}
diff --git a/drivers/net/virtio_net.c b/drivers/net/virtio_net.c
index 32266fb89c20..fbf04a553f5a 100644
--- a/drivers/net/virtio_net.c
+++ b/drivers/net/virtio_net.c
@@ -320,7 +320,7 @@ static bool try_fill_recv_maxbufs(struct virtnet_info *vi, gfp_t gfp)
320 skb_queue_head(&vi->recv, skb); 320 skb_queue_head(&vi->recv, skb);
321 321
322 err = vi->rvq->vq_ops->add_buf(vi->rvq, sg, 0, num, skb); 322 err = vi->rvq->vq_ops->add_buf(vi->rvq, sg, 0, num, skb);
323 if (err) { 323 if (err < 0) {
324 skb_unlink(skb, &vi->recv); 324 skb_unlink(skb, &vi->recv);
325 trim_pages(vi, skb); 325 trim_pages(vi, skb);
326 kfree_skb(skb); 326 kfree_skb(skb);
@@ -373,7 +373,7 @@ static bool try_fill_recv(struct virtnet_info *vi, gfp_t gfp)
373 skb_queue_head(&vi->recv, skb); 373 skb_queue_head(&vi->recv, skb);
374 374
375 err = vi->rvq->vq_ops->add_buf(vi->rvq, sg, 0, 1, skb); 375 err = vi->rvq->vq_ops->add_buf(vi->rvq, sg, 0, 1, skb);
376 if (err) { 376 if (err < 0) {
377 skb_unlink(skb, &vi->recv); 377 skb_unlink(skb, &vi->recv);
378 kfree_skb(skb); 378 kfree_skb(skb);
379 break; 379 break;
@@ -527,7 +527,7 @@ static int xmit_skb(struct virtnet_info *vi, struct sk_buff *skb)
527 num = skb_to_sgvec(skb, sg+1, 0, skb->len) + 1; 527 num = skb_to_sgvec(skb, sg+1, 0, skb->len) + 1;
528 528
529 err = vi->svq->vq_ops->add_buf(vi->svq, sg, num, 0, skb); 529 err = vi->svq->vq_ops->add_buf(vi->svq, sg, num, 0, skb);
530 if (!err && !vi->free_in_tasklet) 530 if (err >= 0 && !vi->free_in_tasklet)
531 mod_timer(&vi->xmit_free_timer, jiffies + (HZ/10)); 531 mod_timer(&vi->xmit_free_timer, jiffies + (HZ/10));
532 532
533 return err; 533 return err;
@@ -538,7 +538,7 @@ static void xmit_tasklet(unsigned long data)
538 struct virtnet_info *vi = (void *)data; 538 struct virtnet_info *vi = (void *)data;
539 539
540 netif_tx_lock_bh(vi->dev); 540 netif_tx_lock_bh(vi->dev);
541 if (vi->last_xmit_skb && xmit_skb(vi, vi->last_xmit_skb) == 0) { 541 if (vi->last_xmit_skb && xmit_skb(vi, vi->last_xmit_skb) >= 0) {
542 vi->svq->vq_ops->kick(vi->svq); 542 vi->svq->vq_ops->kick(vi->svq);
543 vi->last_xmit_skb = NULL; 543 vi->last_xmit_skb = NULL;
544 } 544 }
@@ -557,7 +557,7 @@ again:
557 557
558 /* If we has a buffer left over from last time, send it now. */ 558 /* If we has a buffer left over from last time, send it now. */
559 if (unlikely(vi->last_xmit_skb) && 559 if (unlikely(vi->last_xmit_skb) &&
560 xmit_skb(vi, vi->last_xmit_skb) != 0) 560 xmit_skb(vi, vi->last_xmit_skb) < 0)
561 goto stop_queue; 561 goto stop_queue;
562 562
563 vi->last_xmit_skb = NULL; 563 vi->last_xmit_skb = NULL;
@@ -565,7 +565,7 @@ again:
565 /* Put new one in send queue and do transmit */ 565 /* Put new one in send queue and do transmit */
566 if (likely(skb)) { 566 if (likely(skb)) {
567 __skb_queue_head(&vi->send, skb); 567 __skb_queue_head(&vi->send, skb);
568 if (xmit_skb(vi, skb) != 0) { 568 if (xmit_skb(vi, skb) < 0) {
569 vi->last_xmit_skb = skb; 569 vi->last_xmit_skb = skb;
570 skb = NULL; 570 skb = NULL;
571 goto stop_queue; 571 goto stop_queue;
@@ -668,7 +668,7 @@ static bool virtnet_send_command(struct virtnet_info *vi, u8 class, u8 cmd,
668 sg_set_buf(&sg[i + 1], sg_virt(s), s->length); 668 sg_set_buf(&sg[i + 1], sg_virt(s), s->length);
669 sg_set_buf(&sg[out + in - 1], &status, sizeof(status)); 669 sg_set_buf(&sg[out + in - 1], &status, sizeof(status));
670 670
671 BUG_ON(vi->cvq->vq_ops->add_buf(vi->cvq, sg, out, in, vi)); 671 BUG_ON(vi->cvq->vq_ops->add_buf(vi->cvq, sg, out, in, vi) < 0);
672 672
673 vi->cvq->vq_ops->kick(vi->cvq); 673 vi->cvq->vq_ops->kick(vi->cvq);
674 674
diff --git a/drivers/virtio/virtio_balloon.c b/drivers/virtio/virtio_balloon.c
index 26b278264796..39789232646d 100644
--- a/drivers/virtio/virtio_balloon.c
+++ b/drivers/virtio/virtio_balloon.c
@@ -84,7 +84,7 @@ static void tell_host(struct virtio_balloon *vb, struct virtqueue *vq)
84 init_completion(&vb->acked); 84 init_completion(&vb->acked);
85 85
86 /* We should always be able to add one buffer to an empty queue. */ 86 /* We should always be able to add one buffer to an empty queue. */
87 if (vq->vq_ops->add_buf(vq, &sg, 1, 0, vb) != 0) 87 if (vq->vq_ops->add_buf(vq, &sg, 1, 0, vb) < 0)
88 BUG(); 88 BUG();
89 vq->vq_ops->kick(vq); 89 vq->vq_ops->kick(vq);
90 90
diff --git a/drivers/virtio/virtio_ring.c b/drivers/virtio/virtio_ring.c
index a882f2606515..f53600580726 100644
--- a/drivers/virtio/virtio_ring.c
+++ b/drivers/virtio/virtio_ring.c
@@ -208,7 +208,11 @@ add_head:
208 208
209 pr_debug("Added buffer head %i to %p\n", head, vq); 209 pr_debug("Added buffer head %i to %p\n", head, vq);
210 END_USE(vq); 210 END_USE(vq);
211 return 0; 211
212 /* If we're indirect, we can fit many (assuming not OOM). */
213 if (vq->indirect)
214 return vq->num_free ? vq->vring.num : 0;
215 return vq->num_free;
212} 216}
213 217
214static void vring_kick(struct virtqueue *_vq) 218static void vring_kick(struct virtqueue *_vq)
diff --git a/include/linux/virtio.h b/include/linux/virtio.h
index 4fca4f5440ba..057a2e010758 100644
--- a/include/linux/virtio.h
+++ b/include/linux/virtio.h
@@ -34,7 +34,7 @@ struct virtqueue {
34 * out_num: the number of sg readable by other side 34 * out_num: the number of sg readable by other side
35 * in_num: the number of sg which are writable (after readable ones) 35 * in_num: the number of sg which are writable (after readable ones)
36 * data: the token identifying the buffer. 36 * data: the token identifying the buffer.
37 * Returns 0 or an error. 37 * Returns remaining capacity of queue (sg segments) or a negative error.
38 * @kick: update after add_buf 38 * @kick: update after add_buf
39 * vq: the struct virtqueue 39 * vq: the struct virtqueue
40 * After one or more add_buf calls, invoke this to kick the other side. 40 * After one or more add_buf calls, invoke this to kick the other side.
diff --git a/net/9p/trans_virtio.c b/net/9p/trans_virtio.c
index 9bf0b737aa51..53c139d31a21 100644
--- a/net/9p/trans_virtio.c
+++ b/net/9p/trans_virtio.c
@@ -200,7 +200,7 @@ p9_virtio_request(struct p9_client *client, struct p9_req_t *req)
200 200
201 req->status = REQ_STATUS_SENT; 201 req->status = REQ_STATUS_SENT;
202 202
203 if (chan->vq->vq_ops->add_buf(chan->vq, chan->sg, out, in, req->tc)) { 203 if (chan->vq->vq_ops->add_buf(chan->vq, chan->sg, out, in, req->tc) < 0) {
204 P9_DPRINTK(P9_DEBUG_TRANS, 204 P9_DPRINTK(P9_DEBUG_TRANS,
205 "9p debug: virtio rpc add_buf returned failure"); 205 "9p debug: virtio rpc add_buf returned failure");
206 return -EIO; 206 return -EIO;