提交 1876ed04 编写于 作者: M Marc-André Lureau 提交者: Paolo Bonzini

char: rename TCPChardev and NetChardev

Rename the types to follow the name of the chardev kind.
- socket: TCPChardev -> SocketChardev
- udp: NetChardev -> UdpChardev
Signed-off-by: NMarc-André Lureau <marcandre.lureau@redhat.com>
Reviewed-by: NEric Blake <eblake@redhat.com>
Signed-off-by: NPaolo Bonzini <pbonzini@redhat.com>
上级 0ec7b3e7
...@@ -2691,12 +2691,12 @@ typedef struct { ...@@ -2691,12 +2691,12 @@ typedef struct {
int bufcnt; int bufcnt;
int bufptr; int bufptr;
int max_size; int max_size;
} NetChardev; } UdpChardev;
/* Called with chr_write_lock held. */ /* Called with chr_write_lock held. */
static int udp_chr_write(Chardev *chr, const uint8_t *buf, int len) static int udp_chr_write(Chardev *chr, const uint8_t *buf, int len)
{ {
NetChardev *s = (NetChardev *)chr; UdpChardev *s = (UdpChardev *)chr;
return qio_channel_write( return qio_channel_write(
s->ioc, (const char *)buf, len, NULL); s->ioc, (const char *)buf, len, NULL);
...@@ -2705,7 +2705,7 @@ static int udp_chr_write(Chardev *chr, const uint8_t *buf, int len) ...@@ -2705,7 +2705,7 @@ static int udp_chr_write(Chardev *chr, const uint8_t *buf, int len)
static int udp_chr_read_poll(void *opaque) static int udp_chr_read_poll(void *opaque)
{ {
Chardev *chr = opaque; Chardev *chr = opaque;
NetChardev *s = opaque; UdpChardev *s = opaque;
s->max_size = qemu_chr_be_can_write(chr); s->max_size = qemu_chr_be_can_write(chr);
...@@ -2723,7 +2723,7 @@ static int udp_chr_read_poll(void *opaque) ...@@ -2723,7 +2723,7 @@ static int udp_chr_read_poll(void *opaque)
static gboolean udp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque) static gboolean udp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
{ {
Chardev *chr = opaque; Chardev *chr = opaque;
NetChardev *s = opaque; UdpChardev *s = opaque;
ssize_t ret; ssize_t ret;
if (s->max_size == 0) { if (s->max_size == 0) {
...@@ -2750,7 +2750,7 @@ static gboolean udp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque) ...@@ -2750,7 +2750,7 @@ static gboolean udp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
static void udp_chr_update_read_handler(Chardev *chr, static void udp_chr_update_read_handler(Chardev *chr,
GMainContext *context) GMainContext *context)
{ {
NetChardev *s = (NetChardev *)chr; UdpChardev *s = (UdpChardev *)chr;
remove_fd_in_watch(chr); remove_fd_in_watch(chr);
if (s->ioc) { if (s->ioc) {
...@@ -2763,7 +2763,7 @@ static void udp_chr_update_read_handler(Chardev *chr, ...@@ -2763,7 +2763,7 @@ static void udp_chr_update_read_handler(Chardev *chr,
static void udp_chr_free(Chardev *chr) static void udp_chr_free(Chardev *chr)
{ {
NetChardev *s = (NetChardev *)chr; UdpChardev *s = (UdpChardev *)chr;
remove_fd_in_watch(chr); remove_fd_in_watch(chr);
if (s->ioc) { if (s->ioc) {
...@@ -2799,13 +2799,13 @@ typedef struct { ...@@ -2799,13 +2799,13 @@ typedef struct {
guint reconnect_timer; guint reconnect_timer;
int64_t reconnect_time; int64_t reconnect_time;
bool connect_err_reported; bool connect_err_reported;
} TCPChardev; } SocketChardev;
static gboolean socket_reconnect_timeout(gpointer opaque); static gboolean socket_reconnect_timeout(gpointer opaque);
static void qemu_chr_socket_restart_timer(Chardev *chr) static void qemu_chr_socket_restart_timer(Chardev *chr)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
char *name; char *name;
assert(s->connected == 0); assert(s->connected == 0);
...@@ -2819,7 +2819,7 @@ static void qemu_chr_socket_restart_timer(Chardev *chr) ...@@ -2819,7 +2819,7 @@ static void qemu_chr_socket_restart_timer(Chardev *chr)
static void check_report_connect_error(Chardev *chr, static void check_report_connect_error(Chardev *chr,
Error *err) Error *err)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
if (!s->connect_err_reported) { if (!s->connect_err_reported) {
error_report("Unable to connect character device %s: %s", error_report("Unable to connect character device %s: %s",
...@@ -2836,7 +2836,7 @@ static gboolean tcp_chr_accept(QIOChannel *chan, ...@@ -2836,7 +2836,7 @@ static gboolean tcp_chr_accept(QIOChannel *chan,
/* Called with chr_write_lock held. */ /* Called with chr_write_lock held. */
static int tcp_chr_write(Chardev *chr, const uint8_t *buf, int len) static int tcp_chr_write(Chardev *chr, const uint8_t *buf, int len)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
if (s->connected) { if (s->connected) {
int ret = io_channel_send_full(s->ioc, buf, len, int ret = io_channel_send_full(s->ioc, buf, len,
...@@ -2860,7 +2860,7 @@ static int tcp_chr_write(Chardev *chr, const uint8_t *buf, int len) ...@@ -2860,7 +2860,7 @@ static int tcp_chr_write(Chardev *chr, const uint8_t *buf, int len)
static int tcp_chr_read_poll(void *opaque) static int tcp_chr_read_poll(void *opaque)
{ {
Chardev *chr = opaque; Chardev *chr = opaque;
TCPChardev *s = opaque; SocketChardev *s = opaque;
if (!s->connected) if (!s->connected)
return 0; return 0;
s->max_size = qemu_chr_be_can_write(chr); s->max_size = qemu_chr_be_can_write(chr);
...@@ -2870,7 +2870,7 @@ static int tcp_chr_read_poll(void *opaque) ...@@ -2870,7 +2870,7 @@ static int tcp_chr_read_poll(void *opaque)
#define IAC 255 #define IAC 255
#define IAC_BREAK 243 #define IAC_BREAK 243
static void tcp_chr_process_IAC_bytes(Chardev *chr, static void tcp_chr_process_IAC_bytes(Chardev *chr,
TCPChardev *s, SocketChardev *s,
uint8_t *buf, int *size) uint8_t *buf, int *size)
{ {
/* Handle any telnet client's basic IAC options to satisfy char by /* Handle any telnet client's basic IAC options to satisfy char by
...@@ -2919,7 +2919,7 @@ static void tcp_chr_process_IAC_bytes(Chardev *chr, ...@@ -2919,7 +2919,7 @@ static void tcp_chr_process_IAC_bytes(Chardev *chr,
static int tcp_get_msgfds(Chardev *chr, int *fds, int num) static int tcp_get_msgfds(Chardev *chr, int *fds, int num)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
int to_copy = (s->read_msgfds_num < num) ? s->read_msgfds_num : num; int to_copy = (s->read_msgfds_num < num) ? s->read_msgfds_num : num;
...@@ -2945,7 +2945,7 @@ static int tcp_get_msgfds(Chardev *chr, int *fds, int num) ...@@ -2945,7 +2945,7 @@ static int tcp_get_msgfds(Chardev *chr, int *fds, int num)
static int tcp_set_msgfds(Chardev *chr, int *fds, int num) static int tcp_set_msgfds(Chardev *chr, int *fds, int num)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
/* clear old pending fd array */ /* clear old pending fd array */
g_free(s->write_msgfds); g_free(s->write_msgfds);
...@@ -2970,7 +2970,7 @@ static int tcp_set_msgfds(Chardev *chr, int *fds, int num) ...@@ -2970,7 +2970,7 @@ static int tcp_set_msgfds(Chardev *chr, int *fds, int num)
static ssize_t tcp_chr_recv(Chardev *chr, char *buf, size_t len) static ssize_t tcp_chr_recv(Chardev *chr, char *buf, size_t len)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
struct iovec iov = { .iov_base = buf, .iov_len = len }; struct iovec iov = { .iov_base = buf, .iov_len = len };
int ret; int ret;
size_t i; size_t i;
...@@ -3027,13 +3027,13 @@ static ssize_t tcp_chr_recv(Chardev *chr, char *buf, size_t len) ...@@ -3027,13 +3027,13 @@ static ssize_t tcp_chr_recv(Chardev *chr, char *buf, size_t len)
static GSource *tcp_chr_add_watch(Chardev *chr, GIOCondition cond) static GSource *tcp_chr_add_watch(Chardev *chr, GIOCondition cond)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
return qio_channel_create_watch(s->ioc, cond); return qio_channel_create_watch(s->ioc, cond);
} }
static void tcp_chr_free_connection(Chardev *chr) static void tcp_chr_free_connection(Chardev *chr)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
int i; int i;
if (!s->connected) { if (!s->connected) {
...@@ -3062,7 +3062,7 @@ static void tcp_chr_free_connection(Chardev *chr) ...@@ -3062,7 +3062,7 @@ static void tcp_chr_free_connection(Chardev *chr)
static void tcp_chr_disconnect(Chardev *chr) static void tcp_chr_disconnect(Chardev *chr)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
if (!s->connected) { if (!s->connected) {
return; return;
...@@ -3085,7 +3085,7 @@ static void tcp_chr_disconnect(Chardev *chr) ...@@ -3085,7 +3085,7 @@ static void tcp_chr_disconnect(Chardev *chr)
static gboolean tcp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque) static gboolean tcp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
{ {
Chardev *chr = opaque; Chardev *chr = opaque;
TCPChardev *s = opaque; SocketChardev *s = opaque;
uint8_t buf[READ_BUF_LEN]; uint8_t buf[READ_BUF_LEN];
int len, size; int len, size;
...@@ -3111,7 +3111,7 @@ static gboolean tcp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque) ...@@ -3111,7 +3111,7 @@ static gboolean tcp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
static int tcp_chr_sync_read(Chardev *chr, const uint8_t *buf, int len) static int tcp_chr_sync_read(Chardev *chr, const uint8_t *buf, int len)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
int size; int size;
if (!s->connected) { if (!s->connected) {
...@@ -3130,7 +3130,7 @@ static int tcp_chr_sync_read(Chardev *chr, const uint8_t *buf, int len) ...@@ -3130,7 +3130,7 @@ static int tcp_chr_sync_read(Chardev *chr, const uint8_t *buf, int len)
static void tcp_chr_connect(void *opaque) static void tcp_chr_connect(void *opaque)
{ {
Chardev *chr = opaque; Chardev *chr = opaque;
TCPChardev *s = opaque; SocketChardev *s = opaque;
g_free(chr->filename); g_free(chr->filename);
chr->filename = sockaddr_to_str( chr->filename = sockaddr_to_str(
...@@ -3151,7 +3151,7 @@ static void tcp_chr_connect(void *opaque) ...@@ -3151,7 +3151,7 @@ static void tcp_chr_connect(void *opaque)
static void tcp_chr_update_read_handler(Chardev *chr, static void tcp_chr_update_read_handler(Chardev *chr,
GMainContext *context) GMainContext *context)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
if (!s->connected) { if (!s->connected) {
return; return;
...@@ -3202,7 +3202,7 @@ static gboolean tcp_chr_telnet_init_io(QIOChannel *ioc, ...@@ -3202,7 +3202,7 @@ static gboolean tcp_chr_telnet_init_io(QIOChannel *ioc,
static void tcp_chr_telnet_init(Chardev *chr) static void tcp_chr_telnet_init(Chardev *chr)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
TCPCharDriverTelnetInit *init = TCPCharDriverTelnetInit *init =
g_new0(TCPCharDriverTelnetInit, 1); g_new0(TCPCharDriverTelnetInit, 1);
size_t n = 0; size_t n = 0;
...@@ -3237,7 +3237,7 @@ static void tcp_chr_tls_handshake(QIOTask *task, ...@@ -3237,7 +3237,7 @@ static void tcp_chr_tls_handshake(QIOTask *task,
gpointer user_data) gpointer user_data)
{ {
Chardev *chr = user_data; Chardev *chr = user_data;
TCPChardev *s = user_data; SocketChardev *s = user_data;
if (qio_task_propagate_error(task, NULL)) { if (qio_task_propagate_error(task, NULL)) {
tcp_chr_disconnect(chr); tcp_chr_disconnect(chr);
...@@ -3253,7 +3253,7 @@ static void tcp_chr_tls_handshake(QIOTask *task, ...@@ -3253,7 +3253,7 @@ static void tcp_chr_tls_handshake(QIOTask *task,
static void tcp_chr_tls_init(Chardev *chr) static void tcp_chr_tls_init(Chardev *chr)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
QIOChannelTLS *tioc; QIOChannelTLS *tioc;
Error *err = NULL; Error *err = NULL;
gchar *name; gchar *name;
...@@ -3292,7 +3292,7 @@ static void tcp_chr_tls_init(Chardev *chr) ...@@ -3292,7 +3292,7 @@ static void tcp_chr_tls_init(Chardev *chr)
static void tcp_chr_set_client_ioc_name(Chardev *chr, static void tcp_chr_set_client_ioc_name(Chardev *chr,
QIOChannelSocket *sioc) QIOChannelSocket *sioc)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
char *name; char *name;
name = g_strdup_printf("chardev-tcp-%s-%s", name = g_strdup_printf("chardev-tcp-%s-%s",
s->is_listen ? "server" : "client", s->is_listen ? "server" : "client",
...@@ -3304,7 +3304,7 @@ static void tcp_chr_set_client_ioc_name(Chardev *chr, ...@@ -3304,7 +3304,7 @@ static void tcp_chr_set_client_ioc_name(Chardev *chr,
static int tcp_chr_new_client(Chardev *chr, QIOChannelSocket *sioc) static int tcp_chr_new_client(Chardev *chr, QIOChannelSocket *sioc)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
if (s->ioc != NULL) { if (s->ioc != NULL) {
return -1; return -1;
...@@ -3376,7 +3376,7 @@ static gboolean tcp_chr_accept(QIOChannel *channel, ...@@ -3376,7 +3376,7 @@ static gboolean tcp_chr_accept(QIOChannel *channel,
static int tcp_chr_wait_connected(Chardev *chr, Error **errp) static int tcp_chr_wait_connected(Chardev *chr, Error **errp)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
QIOChannelSocket *sioc; QIOChannelSocket *sioc;
/* It can't wait on s->connected, since it is set asynchronously /* It can't wait on s->connected, since it is set asynchronously
...@@ -3424,7 +3424,7 @@ int qemu_chr_fe_wait_connected(CharBackend *be, Error **errp) ...@@ -3424,7 +3424,7 @@ int qemu_chr_fe_wait_connected(CharBackend *be, Error **errp)
static void tcp_chr_free(Chardev *chr) static void tcp_chr_free(Chardev *chr)
{ {
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
tcp_chr_free_connection(chr); tcp_chr_free_connection(chr);
...@@ -3452,7 +3452,7 @@ static void qemu_chr_socket_connected(QIOTask *task, void *opaque) ...@@ -3452,7 +3452,7 @@ static void qemu_chr_socket_connected(QIOTask *task, void *opaque)
{ {
QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task)); QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task));
Chardev *chr = opaque; Chardev *chr = opaque;
TCPChardev *s = (TCPChardev *)chr; SocketChardev *s = (SocketChardev *)chr;
Error *err = NULL; Error *err = NULL;
if (qio_task_propagate_error(task, &err)) { if (qio_task_propagate_error(task, &err)) {
...@@ -4733,7 +4733,7 @@ static const CharDriver serial_driver = { ...@@ -4733,7 +4733,7 @@ static const CharDriver serial_driver = {
static gboolean socket_reconnect_timeout(gpointer opaque) static gboolean socket_reconnect_timeout(gpointer opaque)
{ {
Chardev *chr = opaque; Chardev *chr = opaque;
TCPChardev *s = opaque; SocketChardev *s = opaque;
QIOChannelSocket *sioc; QIOChannelSocket *sioc;
s->reconnect_timer = 0; s->reconnect_timer = 0;
...@@ -4759,7 +4759,7 @@ static Chardev *qmp_chardev_open_socket(const CharDriver *driver, ...@@ -4759,7 +4759,7 @@ static Chardev *qmp_chardev_open_socket(const CharDriver *driver,
Error **errp) Error **errp)
{ {
Chardev *chr; Chardev *chr;
TCPChardev *s; SocketChardev *s;
ChardevSocket *sock = backend->u.socket.data; ChardevSocket *sock = backend->u.socket.data;
SocketAddress *addr = sock->addr; SocketAddress *addr = sock->addr;
bool do_nodelay = sock->has_nodelay ? sock->nodelay : false; bool do_nodelay = sock->has_nodelay ? sock->nodelay : false;
...@@ -4774,7 +4774,7 @@ static Chardev *qmp_chardev_open_socket(const CharDriver *driver, ...@@ -4774,7 +4774,7 @@ static Chardev *qmp_chardev_open_socket(const CharDriver *driver,
if (!chr) { if (!chr) {
return NULL; return NULL;
} }
s = (TCPChardev *)chr; s = (SocketChardev *)chr;
s->is_unix = addr->type == SOCKET_ADDRESS_KIND_UNIX; s->is_unix = addr->type == SOCKET_ADDRESS_KIND_UNIX;
s->is_listen = is_listen; s->is_listen = is_listen;
...@@ -4881,7 +4881,7 @@ static Chardev *qmp_chardev_open_socket(const CharDriver *driver, ...@@ -4881,7 +4881,7 @@ static Chardev *qmp_chardev_open_socket(const CharDriver *driver,
} }
static const CharDriver socket_driver = { static const CharDriver socket_driver = {
.instance_size = sizeof(TCPChardev), .instance_size = sizeof(SocketChardev),
.kind = CHARDEV_BACKEND_KIND_SOCKET, .kind = CHARDEV_BACKEND_KIND_SOCKET,
.parse = qemu_chr_parse_socket, .parse = qemu_chr_parse_socket,
.create = qmp_chardev_open_socket, .create = qmp_chardev_open_socket,
...@@ -4909,7 +4909,7 @@ static Chardev *qmp_chardev_open_udp(const CharDriver *driver, ...@@ -4909,7 +4909,7 @@ static Chardev *qmp_chardev_open_udp(const CharDriver *driver,
QIOChannelSocket *sioc = qio_channel_socket_new(); QIOChannelSocket *sioc = qio_channel_socket_new();
char *name; char *name;
Chardev *chr; Chardev *chr;
NetChardev *s; UdpChardev *s;
if (qio_channel_socket_dgram_sync(sioc, if (qio_channel_socket_dgram_sync(sioc,
udp->local, udp->remote, udp->local, udp->remote,
...@@ -4927,7 +4927,7 @@ static Chardev *qmp_chardev_open_udp(const CharDriver *driver, ...@@ -4927,7 +4927,7 @@ static Chardev *qmp_chardev_open_udp(const CharDriver *driver,
qio_channel_set_name(QIO_CHANNEL(sioc), name); qio_channel_set_name(QIO_CHANNEL(sioc), name);
g_free(name); g_free(name);
s = (NetChardev *)chr; s = (UdpChardev *)chr;
s->ioc = QIO_CHANNEL(sioc); s->ioc = QIO_CHANNEL(sioc);
/* be isn't opened until we get a connection */ /* be isn't opened until we get a connection */
*be_opened = false; *be_opened = false;
...@@ -4936,7 +4936,7 @@ static Chardev *qmp_chardev_open_udp(const CharDriver *driver, ...@@ -4936,7 +4936,7 @@ static Chardev *qmp_chardev_open_udp(const CharDriver *driver,
} }
static const CharDriver udp_driver = { static const CharDriver udp_driver = {
.instance_size = sizeof(NetChardev), .instance_size = sizeof(UdpChardev),
.kind = CHARDEV_BACKEND_KIND_UDP, .kind = CHARDEV_BACKEND_KIND_UDP,
.parse = qemu_chr_parse_udp, .parse = qemu_chr_parse_udp,
.create = qmp_chardev_open_udp, .create = qmp_chardev_open_udp,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册