Skip to content

Commit

Permalink
9pfs: move handle_9p_output and make it static function
Browse files Browse the repository at this point in the history
It's only used in virtio device.

Signed-off-by: Wei Liu <wei.liu2@citrix.com>
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
  • Loading branch information
Wei Liu authored and kvaneesh committed Jan 8, 2016
1 parent 4b311c5 commit 0192cc5
Show file tree
Hide file tree
Showing 3 changed files with 34 additions and 34 deletions.
34 changes: 34 additions & 0 deletions hw/9pfs/virtio-9p-device.c
Expand Up @@ -19,6 +19,7 @@
#include "9p-xattr.h"
#include "coth.h"
#include "hw/virtio/virtio-access.h"
#include "qemu/iov.h"

void virtio_9p_push_and_notify(V9fsPDU *pdu)
{
Expand All @@ -31,6 +32,39 @@ void virtio_9p_push_and_notify(V9fsPDU *pdu)
virtio_notify(VIRTIO_DEVICE(s), s->vq);
}

static void handle_9p_output(VirtIODevice *vdev, VirtQueue *vq)
{
V9fsState *s = (V9fsState *)vdev;
V9fsPDU *pdu;
ssize_t len;

while ((pdu = pdu_alloc(s)) &&
(len = virtqueue_pop(vq, &pdu->elem)) != 0) {
struct {
uint32_t size_le;
uint8_t id;
uint16_t tag_le;
} QEMU_PACKED out;
int len;

BUG_ON(pdu->elem.out_num == 0 || pdu->elem.in_num == 0);
QEMU_BUILD_BUG_ON(sizeof out != 7);

len = iov_to_buf(pdu->elem.out_sg, pdu->elem.out_num, 0,
&out, sizeof out);
BUG_ON(len != sizeof out);

pdu->size = le32_to_cpu(out.size_le);

pdu->id = out.id;
pdu->tag = le16_to_cpu(out.tag_le);

qemu_co_queue_init(&pdu->complete);
pdu_submit(pdu);
}
pdu_free(pdu);
}

static uint64_t virtio_9p_get_features(VirtIODevice *vdev, uint64_t features,
Error **errp)
{
Expand Down
33 changes: 0 additions & 33 deletions hw/9pfs/virtio-9p.c
Expand Up @@ -3266,39 +3266,6 @@ void pdu_submit(V9fsPDU *pdu)
qemu_coroutine_enter(co, pdu);
}

void handle_9p_output(VirtIODevice *vdev, VirtQueue *vq)
{
V9fsState *s = (V9fsState *)vdev;
V9fsPDU *pdu;
ssize_t len;

while ((pdu = pdu_alloc(s)) &&
(len = virtqueue_pop(vq, &pdu->elem)) != 0) {
struct {
uint32_t size_le;
uint8_t id;
uint16_t tag_le;
} QEMU_PACKED out;
int len;

BUG_ON(pdu->elem.out_num == 0 || pdu->elem.in_num == 0);
QEMU_BUILD_BUG_ON(sizeof out != 7);

len = iov_to_buf(pdu->elem.out_sg, pdu->elem.out_num, 0,
&out, sizeof out);
BUG_ON(len != sizeof out);

pdu->size = le32_to_cpu(out.size_le);

pdu->id = out.id;
pdu->tag = le16_to_cpu(out.tag_le);

qemu_co_queue_init(&pdu->complete);
pdu_submit(pdu);
}
pdu_free(pdu);
}

static void __attribute__((__constructor__)) virtio_9p_set_fd_limit(void)
{
struct rlimit rlim;
Expand Down
1 change: 0 additions & 1 deletion hw/9pfs/virtio-9p.h
Expand Up @@ -5,7 +5,6 @@
#include "hw/virtio/virtio.h"
#include "9p.h"

extern void handle_9p_output(VirtIODevice *vdev, VirtQueue *vq);
extern void virtio_9p_push_and_notify(V9fsPDU *pdu);

ssize_t virtio_pdu_vmarshal(V9fsPDU *pdu, size_t offset,
Expand Down

0 comments on commit 0192cc5

Please sign in to comment.