← Back to branch summary

~ubuntu-branches/ubuntu/wily/qemu-kvm-spice/wily

« back to all changes in this revision

Viewing changes to net/vde.c

  • Committer: Bazaar Package Importer
  • Author(s): Serge Hallyn
  • Date: 2011-10-19 10:44:56 UTC
  • Revision ID: james.westby@ubuntu.com-20111019104456-xgvskumk3sxi97f4
Tags: upstream-0.15.0+noroms
Import upstream version 0.15.0+noroms

Show diffs side-by-side

added added

removed removed

Lines of Context:
net/vde.c
 
1
/*
 
2
 * QEMU System Emulator
 
3
 *
 
4
 * Copyright (c) 2003-2008 Fabrice Bellard
 
5
 *
 
6
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 
7
 * of this software and associated documentation files (the "Software"), to deal
 
8
 * in the Software without restriction, including without limitation the rights
 
9
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 
10
 * copies of the Software, and to permit persons to whom the Software is
 
11
 * furnished to do so, subject to the following conditions:
 
12
 *
 
13
 * The above copyright notice and this permission notice shall be included in
 
14
 * all copies or substantial portions of the Software.
 
15
 *
 
16
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 
17
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 
18
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
 
19
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 
20
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 
21
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 
22
 * THE SOFTWARE.
 
23
 */
 
24
#include "net/vde.h"
 
25
 
 
26
#include "config-host.h"
 
27
 
 
28
#include <libvdeplug.h>
 
29
 
 
30
#include "net.h"
 
31
#include "qemu-char.h"
 
32
#include "qemu-common.h"
 
33
#include "qemu-option.h"
 
34
 
 
35
typedef struct VDEState {
 
36
    VLANClientState nc;
 
37
    VDECONN *vde;
 
38
} VDEState;
 
39
 
 
40
static void vde_to_qemu(void *opaque)
 
41
{
 
42
    VDEState *s = opaque;
 
43
    uint8_t buf[4096];
 
44
    int size;
 
45
 
 
46
    size = vde_recv(s->vde, (char *)buf, sizeof(buf), 0);
 
47
    if (size > 0) {
 
48
        qemu_send_packet(&s->nc, buf, size);
 
49
    }
 
50
}
 
51
 
 
52
static ssize_t vde_receive(VLANClientState *nc, const uint8_t *buf, size_t size)
 
53
{
 
54
    VDEState *s = DO_UPCAST(VDEState, nc, nc);
 
55
    ssize_t ret;
 
56
 
 
57
    do {
 
58
      ret = vde_send(s->vde, (const char *)buf, size, 0);
 
59
    } while (ret < 0 && errno == EINTR);
 
60
 
 
61
    return ret;
 
62
}
 
63
 
 
64
static void vde_cleanup(VLANClientState *nc)
 
65
{
 
66
    VDEState *s = DO_UPCAST(VDEState, nc, nc);
 
67
    qemu_set_fd_handler(vde_datafd(s->vde), NULL, NULL, NULL);
 
68
    vde_close(s->vde);
 
69
}
 
70
 
 
71
static NetClientInfo net_vde_info = {
 
72
    .type = NET_CLIENT_TYPE_VDE,
 
73
    .size = sizeof(VDEState),
 
74
    .receive = vde_receive,
 
75
    .cleanup = vde_cleanup,
 
76
};
 
77
 
 
78
static int net_vde_init(VLANState *vlan, const char *model,
 
79
                        const char *name, const char *sock,
 
80
                        int port, const char *group, int mode)
 
81
{
 
82
    VLANClientState *nc;
 
83
    VDEState *s;
 
84
    VDECONN *vde;
 
85
    char *init_group = (char *)group;
 
86
    char *init_sock = (char *)sock;
 
87
 
 
88
    struct vde_open_args args = {
 
89
        .port = port,
 
90
        .group = init_group,
 
91
        .mode = mode,
 
92
    };
 
93
 
 
94
    vde = vde_open(init_sock, (char *)"QEMU", &args);
 
95
    if (!vde){
 
96
        return -1;
 
97
    }
 
98
 
 
99
    nc = qemu_new_net_client(&net_vde_info, vlan, NULL, model, name);
 
100
 
 
101
    snprintf(nc->info_str, sizeof(nc->info_str), "sock=%s,fd=%d",
 
102
             sock, vde_datafd(vde));
 
103
 
 
104
    s = DO_UPCAST(VDEState, nc, nc);
 
105
 
 
106
    s->vde = vde;
 
107
 
 
108
    qemu_set_fd_handler(vde_datafd(s->vde), vde_to_qemu, NULL, s);
 
109
 
 
110
    return 0;
 
111
}
 
112
 
 
113
int net_init_vde(QemuOpts *opts, Monitor *mon, const char *name, VLANState *vlan)
 
114
{
 
115
    const char *sock;
 
116
    const char *group;
 
117
    int port, mode;
 
118
 
 
119
    sock  = qemu_opt_get(opts, "sock");
 
120
    group = qemu_opt_get(opts, "group");
 
121
 
 
122
    port = qemu_opt_get_number(opts, "port", 0);
 
123
    mode = qemu_opt_get_number(opts, "mode", 0700);
 
124
 
 
125
    if (net_vde_init(vlan, "vde", name, sock, port, group, mode) == -1) {
 
126
        return -1;
 
127
    }
 
128
 
 
129
    return 0;
 
130
}