From 98aeee4a33cf8b3b5dbe2ba12734030baf7d2ef9 Mon Sep 17 00:00:00 2001 From: Jinhyung Choi Date: Wed, 2 Jul 2014 10:17:23 +0900 Subject: [PATCH] sdb noti server: migrated into sdb - bug fixed (uninitialized variable) Change-Id: I74bde4a954c94a86cec0265d2e525c09d9025d49 Signed-off-by: Jinhyung Choi --- tizen/src/emulator.c | 1 - tizen/src/hw/maru_pm.c | 2 +- tizen/src/util/Makefile.objs | 3 - tizen/src/util/sdb.c | 449 +++++++++++++++++++++++++++++++++++++-- tizen/src/util/sdb.h | 51 ++++- tizen/src/util/sdb_noti_server.c | 430 ------------------------------------- tizen/src/util/sdb_noti_server.h | 40 ---- 7 files changed, 471 insertions(+), 505 deletions(-) delete mode 100644 tizen/src/util/sdb_noti_server.c delete mode 100644 tizen/src/util/sdb_noti_server.h diff --git a/tizen/src/emulator.c b/tizen/src/emulator.c index a659db8..3c269f5 100644 --- a/tizen/src/emulator.c +++ b/tizen/src/emulator.c @@ -38,7 +38,6 @@ #include "emulator.h" #include "emul_state.h" #include "emulator_options.h" -#include "util/sdb_noti_server.h" #include "util/check_gl.h" #include "maru_err_table.h" #include "util/osutil.h" diff --git a/tizen/src/hw/maru_pm.c b/tizen/src/hw/maru_pm.c index 2b963e5..c983364 100644 --- a/tizen/src/hw/maru_pm.c +++ b/tizen/src/hw/maru_pm.c @@ -31,7 +31,7 @@ #include "sysemu/sysemu.h" #include "debug_ch.h" -#include "util/sdb_noti_server.h" +#include "util/sdb.h" /* define debug channel */ MULTI_DEBUG_CHANNEL(tizen, maru_pm); diff --git a/tizen/src/util/Makefile.objs b/tizen/src/util/Makefile.objs index 2234ec0..1102f2e 100644 --- a/tizen/src/util/Makefile.objs +++ b/tizen/src/util/Makefile.objs @@ -8,9 +8,6 @@ obj-$(CONFIG_DARWIN) += osutil-darwin.o #sdb obj-y += sdb.o -# sdb noti server -obj-y += sdb_noti_server.o - # check gl obj-y += check_gl_core.o obj-$(CONFIG_LINUX) += check_gl_glx.o diff --git a/tizen/src/util/sdb.c b/tizen/src/util/sdb.c index 8cc3c5e..fea3dda 100644 --- a/tizen/src/util/sdb.c +++ b/tizen/src/util/sdb.c @@ -1,14 +1,32 @@ -/* Copyright (C) 2006-2010 The Android Open Source Project -** -** This software is licensed under the terms of the GNU General Public -** License version 2, as published by the Free Software Foundation, and -** may be copied, distributed, and modified under those terms. -** -** This program is distributed in the hope that it will be useful, -** but WITHOUT ANY WARRANTY; without even the implied warranty of -** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -** GNU General Public License for more details. -*/ +/* + * Emulator SDB Notification Server + * + * Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved + * + * Contact: + * Jinhyung choi + * MunKyu Im + * Sangho Park + * YeongKyoon Lee + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + * + * Contributors: + * - S-Core Co., Ltd + * + */ #include "net/slirp.h" @@ -20,12 +38,14 @@ #include "debug_ch.h" #include "emul_state.h" -MULTI_DEBUG_CHANNEL(qemu, sdb); +#include "hw/virtio/maru_virtio_hwkey.h" +#include "skin/maruskin_server.h" +#include "hw/maru_pm.h" +#include "ecs/ecs.h" -extern char tizen_target_path[]; +MULTI_DEBUG_CHANNEL(qemu, sdb); #ifdef _WIN32 - #include "qemu/main-loop.h" static void socket_close_handler( void* _fd ) @@ -105,7 +125,7 @@ int check_port_bind_listen(uint32_t port) s = qemu_socket(AF_INET, SOCK_STREAM, 0); if (s < 0) { - ERR("failed to create a socket\n", port); + INFO("failed to create a socket\n"); return -1; } @@ -113,7 +133,7 @@ int check_port_bind_listen(uint32_t port) ret = setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(int)); if (ret < 0) { - ERR("setsockopt failure\n"); + INFO("setsockopt failure\n"); close(s); return -1; } @@ -123,7 +143,7 @@ int check_port_bind_listen(uint32_t port) (listen(s, 1) < 0)) { /* failure */ ret = -1; - ERR("port(%d) listen failure\n", port); + INFO("port(%d) listen failure\n", port); } else { /* success */ ret = 1; @@ -159,7 +179,7 @@ void set_base_port(void) } if (!success) { - ERR( "it seems too many emulator instances are running on this machine. Aborting\n" ); + INFO( "it seems too many emulator instances are running on this machine. Aborting\n" ); exit(1); } @@ -191,7 +211,7 @@ void sdb_setup(void) INFO("redirect [%s] success\n", buf); if (!success) { - ERR( "it seems too many emulator instances are running on this machine. Aborting\n" ); + INFO( "it seems too many emulator instances are running on this machine. Aborting\n" ); exit(1); } @@ -217,5 +237,396 @@ int sdb_loopback_client(int port, int type) } return s; +} + +/* + * SDB Notification server + */ + +#define RECV_BUF_SIZE 32 +typedef struct SDB_Noti_Server { + int server_fd; + GIOChannel *server_chan; + guint server_tag; +} SDB_Noti_Server; + +typedef struct SDB_Client { + int port; + struct sockaddr_in addr; + char serial[RECV_BUF_SIZE]; + + QTAILQ_ENTRY(SDB_Client) next; +} SDB_Client; + +static QTAILQ_HEAD(SDB_ClientHead, SDB_Client) +clients = QTAILQ_HEAD_INITIALIZER(clients); + +static SDB_Noti_Server *current_server; +static QemuMutex mutex_clients; + +static void remove_sdb_client(SDB_Client* client) +{ + if (client == NULL) { + return; + } + + qemu_mutex_lock(&mutex_clients); + + QTAILQ_REMOVE(&clients, client, next); + + qemu_mutex_unlock(&mutex_clients); + + g_free(client); +} + +static void send_to_sdb_client(SDB_Client* client, int state) +{ + struct sockaddr_in sock_addr; + int s, slen = sizeof(sock_addr); + int serial_len = 0; + char buf [32]; + + if ((s = socket(AF_INET, SOCK_STREAM, 0)) == -1){ + INFO("socket creation error! %d\n", errno); + return; + } + + memset(&sock_addr, 0, sizeof(sock_addr)); + + sock_addr.sin_family = AF_INET; + sock_addr.sin_port = htons(client->port); + sock_addr.sin_addr = (client->addr).sin_addr; + + if (connect(s, (struct sockaddr*)&sock_addr, slen) == -1) { + INFO("connect error! remove this client.\n"); + remove_sdb_client(client); + close(s); + return; + } + + memset(buf, 0, sizeof(buf)); + + serial_len = strlen(client->serial); + + // send message "[4 digit message length]host:sync:emulator-26101:[0|1]" + sprintf(buf, "%04xhost:sync:%s:%01d", (serial_len + 12), client->serial, state); + + INFO("send %s to client %s\n", buf, inet_ntoa(client->addr.sin_addr)); + + if (send(s, buf, sizeof(buf), 0) == -1) + { + INFO("send error! remove this client.\n"); + remove_sdb_client(client); + } + + close(s); +} + +void notify_all_sdb_clients(int state) +{ + qemu_mutex_lock(&mutex_clients); + SDB_Client *client, *next; + + QTAILQ_FOREACH_SAFE(client, &clients, next, next) + { + send_to_sdb_client(client, state); + } + qemu_mutex_unlock(&mutex_clients); + +} + +static void add_sdb_client(struct sockaddr_in* addr, int port, const char* serial) +{ + SDB_Client *cli = NULL; + SDB_Client *client = NULL, *next; + + if (addr == NULL) { + INFO("SDB_Client client's address is EMPTY.\n"); + return; + } else if (serial == NULL || strlen(serial) <= 0) { + INFO("SDB_Client client's serial is EMPTY.\n"); + return; + } else if (strlen(serial) > RECV_BUF_SIZE) { + INFO("SDB_Client client's serial is too long. %s\n", serial); + return; + } + + qemu_mutex_lock(&mutex_clients); + QTAILQ_FOREACH_SAFE(cli, &clients, next, next) + { + if (!strcmp(serial, cli->serial) && !strcmp(inet_ntoa(addr->sin_addr), inet_ntoa((cli->addr).sin_addr))) { + INFO("Client cannot be duplicated.\n"); + qemu_mutex_unlock(&mutex_clients); + return; + } + } + qemu_mutex_unlock(&mutex_clients); + + client = g_malloc0(sizeof(SDB_Client)); + if (NULL == client) { + INFO("SDB_Client allocation failed.\n"); + return; + } + + memcpy(&client->addr, addr, sizeof(struct sockaddr_in)); + client->port = port; + strcpy(client->serial, serial); + + qemu_mutex_lock(&mutex_clients); + + QTAILQ_INSERT_TAIL(&clients, client, next); + + qemu_mutex_unlock(&mutex_clients); + + INFO("Added new sdb client. ip: %s, port: %d, serial: %s\n", inet_ntoa((client->addr).sin_addr), client->port, client->serial); + + send_to_sdb_client(client, runstate_check(RUN_STATE_SUSPENDED)); +} + +static int parse_val(char* buff, unsigned char data, char* parsbuf) +{ + int count = 0; + + while (1) { + if (count > 12) { + return -1; + } + + if (buff[count] == data) { + count++; + strncpy(parsbuf, buff, count); + return count; + } + + count++; + } + + return 0; +} + +#define SDB_SERVER_PORT 26097 +static void register_sdb_server(char* readbuf, struct sockaddr_in* client_addr) +{ + int port = 0; + char token[] = "\n"; + char* ret = NULL; + char* serial = NULL; + + ret = strtok(readbuf, token); + if (ret == NULL) { + INFO("command is not found."); + return; + } + + serial = strtok(NULL, token); + if (serial == NULL) { + INFO("serial is not found."); + return; + } + + port = SDB_SERVER_PORT; + + add_sdb_client(client_addr, port, serial); +} + +#define PRESS 1 +#define RELEASE 2 +#define POWER_KEY 116 +static void wakeup_guest(void) +{ + // FIXME: Temporarily working model. + // It must be fixed as the way it works. + maru_hwkey_event(PRESS, POWER_KEY); + maru_hwkey_event(RELEASE, POWER_KEY); +} + +static void suspend_lock_state(int state) +{ + ecs_suspend_lock_state(state); +} + +static void command_handler(char* readbuf, struct sockaddr_in* client_addr) +{ + char command[RECV_BUF_SIZE]; + memset(command, '\0', sizeof(command)); + + parse_val(readbuf, 0x0a, command); + + TRACE("----------------------------------------\n"); + TRACE("command:%s\n", command); + if (strcmp(command, "2\n" ) == 0) { + notify_sdb_daemon_start(); + } else if (strcmp(command, "5\n") == 0) { + register_sdb_server(readbuf, client_addr); + } else if (strcmp(command, "6\n") == 0) { + wakeup_guest(); + } else if (strcmp(command, "7\n") == 0) { + suspend_lock_state(SUSPEND_LOCK); + } else if (strcmp(command, "8\n") == 0) { + suspend_lock_state(SUSPEND_UNLOCK); + } else { + INFO("!!! unknown command : %s\n", command); + } + TRACE("========================================\n"); +} + +static void close_clients(void) +{ + qemu_mutex_lock(&mutex_clients); + SDB_Client * client, *next; + + QTAILQ_FOREACH_SAFE(client, &clients, next, next) + { + QTAILQ_REMOVE(&clients, client, next); + + if (NULL != client) + { + g_free(client); + } + } + + qemu_mutex_unlock(&mutex_clients); +} + +static void close_server(void) +{ + if (current_server == NULL) { + return; + } + + close_clients(); + if (current_server->server_fd > 0) { + if (current_server->server_tag) { + g_source_remove(current_server->server_tag); + current_server->server_tag = 0; + } + if (current_server->server_chan) { + g_io_channel_unref(current_server->server_chan); + } + closesocket(current_server->server_fd); + } + + g_free(current_server); + + qemu_mutex_destroy(&mutex_clients); +} + +static gboolean sdb_noti_read(GIOChannel *channel, GIOCondition cond, void *opaque) +{ + int recv_cnt = 0; + struct sockaddr_in client_addr; + socklen_t client_len = sizeof(client_addr); + char readbuf[RECV_BUF_SIZE + 1]; + SDB_Noti_Server *server = opaque; + + memset(&readbuf, 0, sizeof(readbuf)); + + + recv_cnt = recvfrom(server->server_fd, readbuf, RECV_BUF_SIZE, 0, + (struct sockaddr*) &client_addr, &client_len); + + if (recv_cnt > 0) { + command_handler((char*)readbuf, &client_addr); + } else if (recv_cnt == 0) { + INFO("noti server recvfrom returned 0.\n"); + } else { +#ifdef _WIN32 + errno = WSAGetLastError(); +#endif + TRACE("recvfrom error case (it can be from non-blocking socket): %d", errno); + } + + return TRUE; } + +static int create_UDP_server(SDB_Noti_Server *server, int port) +{ + struct sockaddr_in server_addr; + int opt = 1; + + if ((server->server_fd = socket(PF_INET, SOCK_DGRAM, 0)) < 0) { + INFO("create listen socket error:%d\n", errno); + return -1; + } + + memset(&server_addr, '\0', sizeof(server_addr)); + server_addr.sin_family = PF_INET; + server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); + server_addr.sin_port = htons(port); + + qemu_set_nonblock(server->server_fd); + + if (qemu_setsockopt(server->server_fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) == -1) { + INFO("setsockopt SO_REUSEADDR is failed.: %d\n", errno); + return -1; + } + + if (bind(server->server_fd, (struct sockaddr *) &server_addr, sizeof(server_addr)) < 0) { + INFO("sdb noti server bind error: %d", errno); + return -1; + } + + return 0; +} + +static GIOChannel *io_channel_from_socket(int fd) +{ + GIOChannel *chan; + + if (fd == -1) { + return NULL; + } + +#ifdef _WIN32 + chan = g_io_channel_win32_new_socket(fd); +#else + chan = g_io_channel_unix_new(fd); +#endif + + g_io_channel_set_encoding(chan, NULL, NULL); + g_io_channel_set_buffered(chan, FALSE); + + return chan; +} + +static void sdb_noti_server_notify_exit(Notifier *notifier, void *data) +{ + INFO("shutdown sdb notification server.\n"); + close_server(); +} + +static Notifier sdb_noti_server_exit = { .notify = sdb_noti_server_notify_exit }; + +void start_sdb_noti_server(int server_port) +{ + SDB_Noti_Server *server; + int ret; + + INFO("start sdb noti server thread.\n"); + + server = g_malloc0(sizeof(SDB_Noti_Server)); + if (server == NULL) { + INFO("SDB Notification server allocation is failed.\n"); + return; + } + + ret = create_UDP_server(server, server_port); + if (ret < 0) { + INFO("failed to create UDP server\n"); + close_server(); + return; + } + + server->server_chan = io_channel_from_socket(server->server_fd); + server->server_tag = g_io_add_watch(server->server_chan, G_IO_IN, sdb_noti_read, server); + + current_server = server; + + qemu_mutex_init(&mutex_clients); + + INFO("success to bind port[127.0.0.1:%d/udp] for sdb noti server in host \n", server_port); + + emulator_add_exit_notifier(&sdb_noti_server_exit); +} + diff --git a/tizen/src/util/sdb.h b/tizen/src/util/sdb.h index 2e1acfc..c1b6637 100644 --- a/tizen/src/util/sdb.h +++ b/tizen/src/util/sdb.h @@ -1,14 +1,35 @@ -/* Copyright (C) 2006-2010 The Android Open Source Project -** -** This software is licensed under the terms of the GNU General Public -** License version 2, as published by the Free Software Foundation, and -** may be copied, distributed, and modified under those terms. -** -** This program is distributed in the hope that it will be useful, -** but WITHOUT ANY WARRANTY; without even the implied warranty of -** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -** GNU General Public License for more details. -*/ +/* + * Emulator SDB Notification Server + * + * Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved + * + * Contact: + * Jinhyung choi + * MunKyu Im + * Sangho Park + * YeongKyoon Lee + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + * + * Contributors: + * - S-Core Co., Ltd + * + */ + +#ifndef SDB_SERVER_H_ +#define SDB_SERVER_H_ #include "maru_common.h" @@ -41,3 +62,11 @@ void socket_close(int fd); int check_port_bind_listen(uint32_t port); int sdb_loopback_client(int port, int type); +void start_sdb_noti_server(int server_port); + +#define STATE_RUNNING 0 +#define STATE_SUSPEND 1 +void notify_all_sdb_clients(int state); + +#endif + diff --git a/tizen/src/util/sdb_noti_server.c b/tizen/src/util/sdb_noti_server.c deleted file mode 100644 index 3d22b4b..0000000 --- a/tizen/src/util/sdb_noti_server.c +++ /dev/null @@ -1,430 +0,0 @@ -/* - * Emulator SDB Notification Server - * - * Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved - * - * Contact: - * Jinhyung choi - * MunKyu Im - * Sangho Park - * YeongKyoon Lee - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. - * - * Contributors: - * - S-Core Co., Ltd - * - */ - -#include "qemu/sockets.h" - -#include "hw/maru_pm.h" -#include "hw/virtio/maru_virtio_hwkey.h" -#include "skin/maruskin_server.h" -#include "ecs/ecs.h" - -#include "emulator.h" -#include "debug_ch.h" -#include "sdb_noti_server.h" - -MULTI_DEBUG_CHANNEL(qemu, sdb_noti); - -#define RECV_BUF_SIZE 32 - -typedef struct SDB_Noti_Server { - int server_fd; - GIOChannel *server_chan; - guint server_tag; -} SDB_Noti_Server; - -typedef struct SDB_Client { - int port; - struct sockaddr_in addr; - char serial[RECV_BUF_SIZE]; - - QTAILQ_ENTRY(SDB_Client) next; -} SDB_Client; - -static QTAILQ_HEAD(SDB_ClientHead, SDB_Client) -clients = QTAILQ_HEAD_INITIALIZER(clients); - -static SDB_Noti_Server *current_server; -static QemuMutex mutex_clients; - -static void remove_sdb_client(SDB_Client* client) -{ - if (client == NULL) { - return; - } - - qemu_mutex_lock(&mutex_clients); - - QTAILQ_REMOVE(&clients, client, next); - - qemu_mutex_unlock(&mutex_clients); - - g_free(client); -} - -static void send_to_sdb_client(SDB_Client* client, int state) -{ - struct sockaddr_in sock_addr; - int s, slen = sizeof(sock_addr); - int serial_len = 0; - char buf [32]; - - if ((s = socket(AF_INET, SOCK_STREAM, 0)) == -1){ - INFO("socket creation error! %d\n", errno); - return; - } - - memset(&sock_addr, 0, sizeof(sock_addr)); - - sock_addr.sin_family = AF_INET; - sock_addr.sin_port = htons(client->port); - sock_addr.sin_addr = (client->addr).sin_addr; - - if (connect(s, (struct sockaddr*)&sock_addr, slen) == -1) { - INFO("connect error! remove this client.\n"); - remove_sdb_client(client); - close(s); - return; - } - - memset(buf, 0, sizeof(buf)); - - serial_len = strlen(client->serial); - - // send message "[4 digit message length]host:sync:emulator-26101:[0|1]" - sprintf(buf, "%04xhost:sync:%s:%01d", (serial_len + 12), client->serial, state); - - INFO("send %s to client %s\n", buf, inet_ntoa(client->addr.sin_addr)); - - if (send(s, buf, sizeof(buf), 0) == -1) - { - INFO("send error! remove this client.\n"); - remove_sdb_client(client); - } - - close(s); -} - -void notify_all_sdb_clients(int state) -{ - qemu_mutex_lock(&mutex_clients); - SDB_Client *client, *next; - - QTAILQ_FOREACH_SAFE(client, &clients, next, next) - { - send_to_sdb_client(client, state); - } - qemu_mutex_unlock(&mutex_clients); - -} - -static void add_sdb_client(struct sockaddr_in* addr, int port, const char* serial) -{ - SDB_Client *cli = NULL; - SDB_Client *client = NULL, *next; - - if (addr == NULL) { - INFO("SDB_Client client's address is EMPTY.\n"); - return; - } else if (serial == NULL || strlen(serial) <= 0) { - INFO("SDB_Client client's serial is EMPTY.\n"); - return; - } else if (strlen(serial) > RECV_BUF_SIZE) { - INFO("SDB_Client client's serial is too long. %s\n", serial); - return; - } - - qemu_mutex_lock(&mutex_clients); - QTAILQ_FOREACH_SAFE(cli, &clients, next, next) - { - if (!strcmp(serial, cli->serial) && !strcmp(inet_ntoa(addr->sin_addr), inet_ntoa((cli->addr).sin_addr))) { - INFO("Client cannot be duplicated.\n"); - qemu_mutex_unlock(&mutex_clients); - return; - } - } - qemu_mutex_unlock(&mutex_clients); - - client = g_malloc0(sizeof(SDB_Client)); - if (NULL == client) { - INFO("SDB_Client allocation failed.\n"); - return; - } - - memcpy(&client->addr, addr, sizeof(struct sockaddr_in)); - client->port = port; - strcpy(client->serial, serial); - - qemu_mutex_lock(&mutex_clients); - - QTAILQ_INSERT_TAIL(&clients, client, next); - - qemu_mutex_unlock(&mutex_clients); - - INFO("Added new sdb client. ip: %s, port: %d, serial: %s\n", inet_ntoa((client->addr).sin_addr), client->port, client->serial); - - send_to_sdb_client(client, runstate_check(RUN_STATE_SUSPENDED)); -} - -static int parse_val(char* buff, unsigned char data, char* parsbuf) -{ - int count = 0; - - while (1) { - if (count > 12) { - return -1; - } - - if (buff[count] == data) { - count++; - strncpy(parsbuf, buff, count); - return count; - } - - count++; - } - - return 0; -} - -#define SDB_SERVER_PORT 26097 -static void register_sdb_server(char* readbuf, struct sockaddr_in* client_addr) -{ - int port = 0; - char token[] = "\n"; - char* ret = NULL; - char* serial = NULL; - - ret = strtok(readbuf, token); - if (ret == NULL) { - INFO("command is not found."); - return; - } - - serial = strtok(NULL, token); - if (serial == NULL) { - INFO("serial is not found."); - return; - } - - port = SDB_SERVER_PORT; - - add_sdb_client(client_addr, port, serial); -} - -#define PRESS 1 -#define RELEASE 2 -#define POWER_KEY 116 -static void wakeup_guest(void) -{ - // FIXME: Temporarily working model. - // It must be fixed as the way it works. - maru_hwkey_event(PRESS, POWER_KEY); - maru_hwkey_event(RELEASE, POWER_KEY); -} - -static void suspend_lock_state(int state) -{ - ecs_suspend_lock_state(state); -} - -static void command_handler(char* readbuf, struct sockaddr_in* client_addr) -{ - char command[RECV_BUF_SIZE]; - memset(command, '\0', sizeof(command)); - - parse_val(readbuf, 0x0a, command); - - TRACE("----------------------------------------\n"); - TRACE("command:%s\n", command); - if (strcmp(command, "2\n" ) == 0) { - notify_sdb_daemon_start(); - } else if (strcmp(command, "5\n") == 0) { - register_sdb_server(readbuf, client_addr); - } else if (strcmp(command, "6\n") == 0) { - wakeup_guest(); - } else if (strcmp(command, "7\n") == 0) { - suspend_lock_state(SUSPEND_LOCK); - } else if (strcmp(command, "8\n") == 0) { - suspend_lock_state(SUSPEND_UNLOCK); - } else { - INFO("!!! unknown command : %s\n", command); - } - TRACE("========================================\n"); -} - -static void close_clients(void) -{ - qemu_mutex_lock(&mutex_clients); - SDB_Client * client, *next; - - QTAILQ_FOREACH_SAFE(client, &clients, next, next) - { - QTAILQ_REMOVE(&clients, client, next); - - if (NULL != client) - { - g_free(client); - } - } - - qemu_mutex_unlock(&mutex_clients); -} - -static void close_server(void) -{ - if (current_server == NULL) { - return; - } - - close_clients(); - - if (current_server->server_fd > 0) { - if (current_server->server_tag) { - g_source_remove(current_server->server_tag); - current_server->server_tag = 0; - } - if (current_server->server_chan) { - g_io_channel_unref(current_server->server_chan); - } - closesocket(current_server->server_fd); - } - - g_free(current_server); - - qemu_mutex_destroy(&mutex_clients); -} - -static gboolean sdb_noti_read(GIOChannel *channel, GIOCondition cond, void *opaque) -{ - int recv_cnt = 0; - struct sockaddr_in client_addr; - socklen_t client_len; - char readbuf[RECV_BUF_SIZE + 1]; - SDB_Noti_Server *server = opaque; - - memset(&readbuf, 0, sizeof(readbuf)); - - recv_cnt = recvfrom(server->server_fd, readbuf, RECV_BUF_SIZE, 0, - (struct sockaddr*) &client_addr, &client_len); - - if (recv_cnt > 0) { - command_handler((char*)readbuf, &client_addr); - } else if (recv_cnt == 0) { - INFO("noti server recvfrom returned 0.\n"); - } else { -#ifdef _WIN32 - errno = WSAGetLastError(); -#endif - TRACE("recvfrom error case (it can be from non-blocking socket): %d", errno); - } - - return TRUE; -} - -static int create_UDP_server(SDB_Noti_Server *server, int port) -{ - struct sockaddr_in server_addr; - int opt = 1; - - if ((server->server_fd = socket(PF_INET, SOCK_DGRAM, 0)) < 0) { - INFO("create listen socket error:%d\n", errno); - return -1; - } - - memset(&server_addr, '\0', sizeof(server_addr)); - server_addr.sin_family = PF_INET; - server_addr.sin_addr.s_addr = inet_addr("127.0.0.1"); - server_addr.sin_port = htons(port); - - qemu_set_nonblock(server->server_fd); - - if (qemu_setsockopt(server->server_fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)) == -1) { - INFO("setsockopt SO_REUSEADDR is failed.: %d\n", errno); - return -1; - } - - if (bind(server->server_fd, (struct sockaddr *) &server_addr, sizeof(server_addr)) < 0) { - INFO("sdb noti server bind error: %d", errno); - return -1; - } - - return 0; -} - -static GIOChannel *io_channel_from_socket(int fd) -{ - GIOChannel *chan; - - if (fd == -1) { - return NULL; - } - -#ifdef _WIN32 - chan = g_io_channel_win32_new_socket(fd); -#else - chan = g_io_channel_unix_new(fd); -#endif - - g_io_channel_set_encoding(chan, NULL, NULL); - g_io_channel_set_buffered(chan, FALSE); - - return chan; -} - -static void sdb_noti_server_notify_exit(Notifier *notifier, void *data) -{ - INFO("shutdown sdb notification server.\n"); - close_server(); -} - -static Notifier sdb_noti_server_exit = { .notify = sdb_noti_server_notify_exit }; - -void start_sdb_noti_server(int server_port) -{ - SDB_Noti_Server *server; - int ret; - - INFO("start sdb noti server thread.\n"); - - server = g_malloc0(sizeof(SDB_Noti_Server)); - if (server == NULL) { - INFO("SDB Notification server allocation is failed.\n"); - return; - } - - ret = create_UDP_server(server, server_port); - if (ret < 0) { - INFO("failed to create UDP server\n"); - close_server(); - return; - } - - server->server_chan = io_channel_from_socket(server->server_fd); - server->server_tag = g_io_add_watch(server->server_chan, G_IO_IN, sdb_noti_read, server); - - current_server = server; - - qemu_mutex_init(&mutex_clients); - - INFO("success to bind port[127.0.0.1:%d/udp] for sdb noti server in host \n", server_port); - - emulator_add_exit_notifier(&sdb_noti_server_exit); -} - diff --git a/tizen/src/util/sdb_noti_server.h b/tizen/src/util/sdb_noti_server.h deleted file mode 100644 index 9aaf7b3..0000000 --- a/tizen/src/util/sdb_noti_server.h +++ /dev/null @@ -1,40 +0,0 @@ -/* - * Emulator SDB Notification Server - * - * Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved - * - * Contact: - * Jinhyung choi - * MunKyu Im - * Sangho Park - * YeongKyoon Lee - * - * This program is free software; you can redistribute it and/or - * modify it under the terms of the GNU General Public License - * as published by the Free Software Foundation; either version 2 - * of the License, or (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. - * - * Contributors: - * - S-Core Co., Ltd - * - */ - -#ifndef SDB_NOTI_SERVER_H_ -#define SDB_NOTI_SERVER_H_ - -void start_sdb_noti_server(int server_port); - -#define STATE_RUNNING 0 -#define STATE_SUSPEND 1 -void notify_all_sdb_clients(int state); - -#endif -- 2.7.4