proxmox-mirrors/qemu
1
0
Fork 0
mirror of https://git.proxmox.com/git/qemu synced 2025-08-13 22:22:37 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Clean up serial code for Win 32, by Kazu.

Browse Source 
git-svn-id: svn://svn.savannah.nongnu.org/qemu/trunk@2409 c046a42c-6fe2-441c-8c8c-71466251a162
This commit is contained in:
ths 2007-02-10 21:50:42 +00:00
parent b63891a08e
commit 087f4ae078
1 changed files with 33 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
vl.c
View File

@ -1874,7 +1874,6 @@ static CharDriverState *qemu_chr_open_pty(void)
#ifdef _WIN32 #ifdef _WIN32
typedef struct { typedef struct {
CharDriverState *chr;
int max_size; int max_size;
HANDLE hcom, hrecv, hsend; HANDLE hcom, hrecv, hsend;
OVERLAPPED orecv, osend; OVERLAPPED orecv, osend;
@ -1890,8 +1889,10 @@ typedef struct {
static int win_chr_poll(void *opaque); static int win_chr_poll(void *opaque);
static int win_chr_pipe_poll(void *opaque); static int win_chr_pipe_poll(void *opaque);
static void win_chr_close2(WinCharState *s) static void win_chr_close(CharDriverState *chr)
{ {
WinCharState *s = chr->opaque;
if (s->hsend) { if (s->hsend) {
CloseHandle(s->hsend); CloseHandle(s->hsend);
s->hsend = NULL; s->hsend = NULL;
@ -1905,19 +1906,14 @@ static void win_chr_close2(WinCharState *s)
s->hcom = NULL; s->hcom = NULL;
} }
if (s->fpipe) if (s->fpipe)
qemu_del_polling_cb(win_chr_pipe_poll, s); qemu_del_polling_cb(win_chr_pipe_poll, chr);
else else
qemu_del_polling_cb(win_chr_poll, s); qemu_del_polling_cb(win_chr_poll, chr);
} }
static void win_chr_close(CharDriverState *chr) static int win_chr_init(CharDriverState *chr, const char *filename)
{ {
WinCharState *s = chr->opaque; WinCharState *s = chr->opaque;
win_chr_close2(s);
}
static int win_chr_init(WinCharState *s, CharDriverState *chr, const char *filename)
{
COMMCONFIG comcfg; COMMCONFIG comcfg;
COMMTIMEOUTS cto = { 0, 0, 0, 0, 0}; COMMTIMEOUTS cto = { 0, 0, 0, 0, 0};
COMSTAT comstat; COMSTAT comstat;
@ -1974,12 +1970,11 @@ static int win_chr_init(WinCharState *s, CharDriverState *chr, const char *filen
fprintf(stderr, "Failed ClearCommError\n"); fprintf(stderr, "Failed ClearCommError\n");
goto fail; goto fail;
} }
s->chr = chr; qemu_add_polling_cb(win_chr_poll, chr);
qemu_add_polling_cb(win_chr_poll, s);
return 0; return 0;
fail: fail:
win_chr_close2(s); win_chr_close(chr);
return -1; return -1;
} }
@ -2017,14 +2012,17 @@ static int win_chr_write(CharDriverState *chr, const uint8_t *buf, int len1)
return len1 - len; return len1 - len;
} }
static int win_chr_read_poll(WinCharState *s) static int win_chr_read_poll(CharDriverState *chr)
{ {
s->max_size = qemu_chr_can_read(s->chr); WinCharState *s = chr->opaque;
s->max_size = qemu_chr_can_read(chr);
return s->max_size; return s->max_size;
} }
static void win_chr_readfile(WinCharState *s) static void win_chr_readfile(CharDriverState *chr)
{ {
WinCharState *s = chr->opaque;
int ret, err; int ret, err;
uint8_t buf[1024]; uint8_t buf[1024];
DWORD size; DWORD size;
@ -2040,31 +2038,34 @@ static void win_chr_readfile(WinCharState *s)
} }
if (size > 0) { if (size > 0) {
qemu_chr_read(s->chr, buf, size); qemu_chr_read(chr, buf, size);
} }
} }
static void win_chr_read(WinCharState *s) static void win_chr_read(CharDriverState *chr)
{ {
WinCharState *s = chr->opaque;
if (s->len > s->max_size) if (s->len > s->max_size)
s->len = s->max_size; s->len = s->max_size;
if (s->len == 0) if (s->len == 0)
return; return;
win_chr_readfile(s); win_chr_readfile(chr);
} }
static int win_chr_poll(void *opaque) static int win_chr_poll(void *opaque)
{ {
WinCharState *s = opaque; CharDriverState *chr = opaque;
WinCharState *s = chr->opaque;
COMSTAT status; COMSTAT status;
DWORD comerr; DWORD comerr;
ClearCommError(s->hcom, &comerr, &status); ClearCommError(s->hcom, &comerr, &status);
if (status.cbInQue > 0) { if (status.cbInQue > 0) {
s->len = status.cbInQue; s->len = status.cbInQue;
win_chr_read_poll(s); win_chr_read_poll(chr);
win_chr_read(s); win_chr_read(chr);
return 1; return 1;
} }
return 0; return 0;
@ -2087,7 +2088,7 @@ static CharDriverState *qemu_chr_open_win(const char *filename)
chr->chr_write = win_chr_write; chr->chr_write = win_chr_write;
chr->chr_close = win_chr_close; chr->chr_close = win_chr_close;
if (win_chr_init(s, chr, filename) < 0) { if (win_chr_init(chr, filename) < 0) {
free(s); free(s);
free(chr); free(chr);
return NULL; return NULL;
@ -2098,21 +2099,23 @@ static CharDriverState *qemu_chr_open_win(const char *filename)
static int win_chr_pipe_poll(void *opaque) static int win_chr_pipe_poll(void *opaque)
{ {
WinCharState *s = opaque; CharDriverState *chr = opaque;
WinCharState *s = chr->opaque;
DWORD size; DWORD size;
PeekNamedPipe(s->hcom, NULL, 0, NULL, &size, NULL); PeekNamedPipe(s->hcom, NULL, 0, NULL, &size, NULL);
if (size > 0) { if (size > 0) {
s->len = size; s->len = size;
win_chr_read_poll(s); win_chr_read_poll(chr);
win_chr_read(s); win_chr_read(chr);
return 1; return 1;
} }
return 0; return 0;
} }
static int win_chr_pipe_init(WinCharState *s, const char *filename) static int win_chr_pipe_init(CharDriverState *chr, const char *filename)
{ {
WinCharState *s = chr->opaque;
OVERLAPPED ov; OVERLAPPED ov;
int ret; int ret;
DWORD size; DWORD size;
@ -2164,11 +2167,11 @@ static int win_chr_pipe_init(WinCharState *s, const char *filename)
CloseHandle(ov.hEvent); CloseHandle(ov.hEvent);
ov.hEvent = NULL; ov.hEvent = NULL;
} }
qemu_add_polling_cb(win_chr_pipe_poll, s); qemu_add_polling_cb(win_chr_pipe_poll, chr);
return 0; return 0;
fail: fail:
win_chr_close2(s); win_chr_close(chr);
return -1; return -1;
} }
@ -2190,7 +2193,7 @@ static CharDriverState *qemu_chr_open_win_pipe(const char *filename)
chr->chr_write = win_chr_write; chr->chr_write = win_chr_write;
chr->chr_close = win_chr_close; chr->chr_close = win_chr_close;
if (win_chr_pipe_init(s, filename) < 0) { if (win_chr_pipe_init(chr, filename) < 0) {
free(s); free(s);
free(chr); free(chr);
return NULL; return NULL;