← Back to branch summary

~pmdj/ubuntu/trusty/qemu/2.9+applesmc+fadtv3

« back to all changes in this revision

Viewing changes to chardev/char-win.c

  • Committer: Phil Dennis-Jordan
  • Date: 2017-07-21 08:03:43 UTC
  • mfrom: (1.1.1)
  • Revision ID: phil@philjordan.eu-20170721080343-2yr2vdj7713czahv
New upstream release 2.9.0.

Show diffs side-by-side

added added

removed removed

Lines of Context:
chardev/char-win.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 "qemu/osdep.h"
 
25
#include "qemu-common.h"
 
26
#include "qapi/error.h"
 
27
#include "char-win.h"
 
28
 
 
29
static void win_chr_readfile(Chardev *chr)
 
30
{
 
31
    WinChardev *s = WIN_CHARDEV(chr);
 
32
 
 
33
    int ret, err;
 
34
    uint8_t buf[CHR_READ_BUF_LEN];
 
35
    DWORD size;
 
36
 
 
37
    ZeroMemory(&s->orecv, sizeof(s->orecv));
 
38
    s->orecv.hEvent = s->hrecv;
 
39
    ret = ReadFile(s->hcom, buf, s->len, &size, &s->orecv);
 
40
    if (!ret) {
 
41
        err = GetLastError();
 
42
        if (err == ERROR_IO_PENDING) {
 
43
            ret = GetOverlappedResult(s->hcom, &s->orecv, &size, TRUE);
 
44
        }
 
45
    }
 
46
 
 
47
    if (size > 0) {
 
48
        qemu_chr_be_write(chr, buf, size);
 
49
    }
 
50
}
 
51
 
 
52
static void win_chr_read(Chardev *chr)
 
53
{
 
54
    WinChardev *s = WIN_CHARDEV(chr);
 
55
 
 
56
    if (s->len > s->max_size) {
 
57
        s->len = s->max_size;
 
58
    }
 
59
    if (s->len == 0) {
 
60
        return;
 
61
    }
 
62
 
 
63
    win_chr_readfile(chr);
 
64
}
 
65
 
 
66
static int win_chr_read_poll(Chardev *chr)
 
67
{
 
68
    WinChardev *s = WIN_CHARDEV(chr);
 
69
 
 
70
    s->max_size = qemu_chr_be_can_write(chr);
 
71
    return s->max_size;
 
72
}
 
73
 
 
74
static int win_chr_poll(void *opaque)
 
75
{
 
76
    Chardev *chr = CHARDEV(opaque);
 
77
    WinChardev *s = WIN_CHARDEV(opaque);
 
78
    COMSTAT status;
 
79
    DWORD comerr;
 
80
 
 
81
    ClearCommError(s->hcom, &comerr, &status);
 
82
    if (status.cbInQue > 0) {
 
83
        s->len = status.cbInQue;
 
84
        win_chr_read_poll(chr);
 
85
        win_chr_read(chr);
 
86
        return 1;
 
87
    }
 
88
    return 0;
 
89
}
 
90
 
 
91
int win_chr_init(Chardev *chr, const char *filename, Error **errp)
 
92
{
 
93
    WinChardev *s = WIN_CHARDEV(chr);
 
94
    COMMCONFIG comcfg;
 
95
    COMMTIMEOUTS cto = { 0, 0, 0, 0, 0};
 
96
    COMSTAT comstat;
 
97
    DWORD size;
 
98
    DWORD err;
 
99
 
 
100
    s->hsend = CreateEvent(NULL, TRUE, FALSE, NULL);
 
101
    if (!s->hsend) {
 
102
        error_setg(errp, "Failed CreateEvent");
 
103
        goto fail;
 
104
    }
 
105
    s->hrecv = CreateEvent(NULL, TRUE, FALSE, NULL);
 
106
    if (!s->hrecv) {
 
107
        error_setg(errp, "Failed CreateEvent");
 
108
        goto fail;
 
109
    }
 
110
 
 
111
    s->hcom = CreateFile(filename, GENERIC_READ | GENERIC_WRITE, 0, NULL,
 
112
                      OPEN_EXISTING, FILE_FLAG_OVERLAPPED, 0);
 
113
    if (s->hcom == INVALID_HANDLE_VALUE) {
 
114
        error_setg(errp, "Failed CreateFile (%lu)", GetLastError());
 
115
        s->hcom = NULL;
 
116
        goto fail;
 
117
    }
 
118
 
 
119
    if (!SetupComm(s->hcom, NRECVBUF, NSENDBUF)) {
 
120
        error_setg(errp, "Failed SetupComm");
 
121
        goto fail;
 
122
    }
 
123
 
 
124
    ZeroMemory(&comcfg, sizeof(COMMCONFIG));
 
125
    size = sizeof(COMMCONFIG);
 
126
    GetDefaultCommConfig(filename, &comcfg, &size);
 
127
    comcfg.dcb.DCBlength = sizeof(DCB);
 
128
    CommConfigDialog(filename, NULL, &comcfg);
 
129
 
 
130
    if (!SetCommState(s->hcom, &comcfg.dcb)) {
 
131
        error_setg(errp, "Failed SetCommState");
 
132
        goto fail;
 
133
    }
 
134
 
 
135
    if (!SetCommMask(s->hcom, EV_ERR)) {
 
136
        error_setg(errp, "Failed SetCommMask");
 
137
        goto fail;
 
138
    }
 
139
 
 
140
    cto.ReadIntervalTimeout = MAXDWORD;
 
141
    if (!SetCommTimeouts(s->hcom, &cto)) {
 
142
        error_setg(errp, "Failed SetCommTimeouts");
 
143
        goto fail;
 
144
    }
 
145
 
 
146
    if (!ClearCommError(s->hcom, &err, &comstat)) {
 
147
        error_setg(errp, "Failed ClearCommError");
 
148
        goto fail;
 
149
    }
 
150
    qemu_add_polling_cb(win_chr_poll, chr);
 
151
    return 0;
 
152
 
 
153
 fail:
 
154
    return -1;
 
155
}
 
156
 
 
157
int win_chr_pipe_poll(void *opaque)
 
158
{
 
159
    Chardev *chr = CHARDEV(opaque);
 
160
    WinChardev *s = WIN_CHARDEV(opaque);
 
161
    DWORD size;
 
162
 
 
163
    PeekNamedPipe(s->hcom, NULL, 0, NULL, &size, NULL);
 
164
    if (size > 0) {
 
165
        s->len = size;
 
166
        win_chr_read_poll(chr);
 
167
        win_chr_read(chr);
 
168
        return 1;
 
169
    }
 
170
    return 0;
 
171
}
 
172
 
 
173
/* Called with chr_write_lock held.  */
 
174
static int win_chr_write(Chardev *chr, const uint8_t *buf, int len1)
 
175
{
 
176
    WinChardev *s = WIN_CHARDEV(chr);
 
177
    DWORD len, ret, size, err;
 
178
 
 
179
    len = len1;
 
180
    ZeroMemory(&s->osend, sizeof(s->osend));
 
181
    s->osend.hEvent = s->hsend;
 
182
    while (len > 0) {
 
183
        if (s->hsend) {
 
184
            ret = WriteFile(s->hcom, buf, len, &size, &s->osend);
 
185
        } else {
 
186
            ret = WriteFile(s->hcom, buf, len, &size, NULL);
 
187
        }
 
188
        if (!ret) {
 
189
            err = GetLastError();
 
190
            if (err == ERROR_IO_PENDING) {
 
191
                ret = GetOverlappedResult(s->hcom, &s->osend, &size, TRUE);
 
192
                if (ret) {
 
193
                    buf += size;
 
194
                    len -= size;
 
195
                } else {
 
196
                    break;
 
197
                }
 
198
            } else {
 
199
                break;
 
200
            }
 
201
        } else {
 
202
            buf += size;
 
203
            len -= size;
 
204
        }
 
205
    }
 
206
    return len1 - len;
 
207
}
 
208
 
 
209
static void char_win_finalize(Object *obj)
 
210
{
 
211
    Chardev *chr = CHARDEV(obj);
 
212
    WinChardev *s = WIN_CHARDEV(chr);
 
213
 
 
214
    if (s->skip_free) {
 
215
        return;
 
216
    }
 
217
 
 
218
    if (s->hsend) {
 
219
        CloseHandle(s->hsend);
 
220
    }
 
221
    if (s->hrecv) {
 
222
        CloseHandle(s->hrecv);
 
223
    }
 
224
    if (s->hcom) {
 
225
        CloseHandle(s->hcom);
 
226
    }
 
227
    if (s->fpipe) {
 
228
        qemu_del_polling_cb(win_chr_pipe_poll, chr);
 
229
    } else {
 
230
        qemu_del_polling_cb(win_chr_poll, chr);
 
231
    }
 
232
 
 
233
    qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
 
234
}
 
235
 
 
236
void qemu_chr_open_win_file(Chardev *chr, HANDLE fd_out)
 
237
{
 
238
    WinChardev *s = WIN_CHARDEV(chr);
 
239
 
 
240
    s->skip_free = true;
 
241
    s->hcom = fd_out;
 
242
}
 
243
 
 
244
static void char_win_class_init(ObjectClass *oc, void *data)
 
245
{
 
246
    ChardevClass *cc = CHARDEV_CLASS(oc);
 
247
 
 
248
    cc->chr_write = win_chr_write;
 
249
}
 
250
 
 
251
static const TypeInfo char_win_type_info = {
 
252
    .name = TYPE_CHARDEV_WIN,
 
253
    .parent = TYPE_CHARDEV,
 
254
    .instance_size = sizeof(WinChardev),
 
255
    .instance_finalize = char_win_finalize,
 
256
    .class_init = char_win_class_init,
 
257
    .abstract = true,
 
258
};
 
259
 
 
260
static void register_types(void)
 
261
{
 
262
    type_register_static(&char_win_type_info);
 
263
}
 
264
 
 
265
type_init(register_types);