tabspace: using 4spaces as a tab
authorJinhyung Choi <jinhyung2.choi@samsung.com>
Tue, 6 Jan 2015 08:27:13 +0000 (17:27 +0900)
committerJinhyung Choi <jinhyung2.choi@samsung.com>
Tue, 6 Jan 2015 08:27:13 +0000 (17:27 +0900)
Change-Id: Ic48460b5c2c2a62c87936c1c52202d9eb2fee3a1
Signed-off-by: Jinhyung Choi <jinhyung2.choi@samsung.com>
include/emuld.h
include/mobile.h
include/synbuf.h
include/wearable.h
src/common.cpp
src/emuld.cpp
src/mobile.cpp
src/mobile_dev.cpp
src/wearable.cpp
src/wearable_dev.cpp

index 8065ddd..8546d3f 100644 (file)
@@ -9,7 +9,7 @@
  * Sungmin Ha <sungmin82.ha@samsung.com>
  * Daiyoung Kim <daiyoung777.kim@samsung.com>
  * YeongKyoon Lee <yeongkyoon.lee@samsung.com>
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
@@ -21,7 +21,7 @@
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
- * 
+ *
  * Contributors:
  * - S-Core Co., Ltd
  *
@@ -40,7 +40,7 @@
 
 #include "evdi.h"
 
-#define FDTYPE_MAX                     6
+#define FDTYPE_MAX          6
 
 enum
 {
@@ -57,9 +57,9 @@ enum
 #define HEADER_SIZE         4
 
 // Thread TID profile uses >= 5
-#define TID_SDCARD                     1
-#define TID_LOCATION           2
-#define TID_HDS                                3
+#define TID_SDCARD          1
+#define TID_LOCATION        2
+#define TID_HDS             3
 
 extern pthread_t tid[MAX_CLIENT + 1];
 extern int g_fd[fdtype_max];
index b6aaace..47bf1a0 100644 (file)
@@ -30,7 +30,7 @@
 #ifndef __MOBILE_H__
 #define __MOBILE_H__
 
-#define TID_SENSOR                     5
+#define TID_SENSOR          5
 
 void msgproc_sensor(ijcommand* ijcmd);
 
index 7fd64ac..1b77a1d 100644 (file)
@@ -50,10 +50,10 @@ public:
         m_readptr = m_buf;
     }
 
-       ~synbuf()
-       {
+    ~synbuf()
+    {
         freebuf();
-       }
+    }
 
     void reset_buf()
     {
index 86164cd..401864d 100644 (file)
@@ -30,7 +30,7 @@
 #ifndef __WEARABLE_H__
 #define __WEARABLE_H__
 
-#define TID_PEDOMETER          5
+#define TID_PEDOMETER       5
 void msgproc_sensor(ijcommand* ijcmd);
 
 #endif
index 23c56ec..b424c00 100644 (file)
@@ -43,9 +43,9 @@
 
 #define MAX_PKGS_BUF        1024
 
-#define PATH_PACKAGE_INSTALL   "/opt/usr/apps/tmp/sdk_tools/"
-#define RPM_CMD_QUERY          "-q"
-#define RPM_CMD_INSTALL                "-U"
+#define PATH_PACKAGE_INSTALL    "/opt/usr/apps/tmp/sdk_tools/"
+#define RPM_CMD_QUERY       "-q"
+#define RPM_CMD_INSTALL     "-U"
 static pthread_mutex_t mutex_pkg = PTHREAD_MUTEX_INITIALIZER;
 
 static struct timeval tv_start_poweroff;
@@ -148,227 +148,227 @@ void msgproc_suspend(ijcommand* ijcmd)
 
 void send_to_ecs(const char* cat, int group, int action, char* data)
 {
-       int datalen = 0;
+    int datalen = 0;
     int tmplen = HEADER_SIZE;
-       if (data != NULL) {
-               datalen = strlen(data);
-               tmplen += datalen;
-       }
+    if (data != NULL) {
+        datalen = strlen(data);
+        tmplen += datalen;
+    }
 
     char* tmp = (char*) malloc(tmplen);
     if (!tmp)
         return;
 
-       if (data != NULL) {
-               memcpy(tmp, &datalen, 2);
-       }
-       memcpy(tmp + 2, &group, 1);
-       memcpy(tmp + 3, &action, 1);
-       if (data != NULL) {
-               memcpy(tmp + 4, data, datalen);
-       }
+    if (data != NULL) {
+        memcpy(tmp, &datalen, 2);
+    }
+    memcpy(tmp + 2, &group, 1);
+    memcpy(tmp + 3, &action, 1);
+    if (data != NULL) {
+        memcpy(tmp + 4, data, datalen);
+    }
 
     ijmsg_send_to_evdi(g_fd[fdtype_device], cat, (const char*) tmp, tmplen);
 
-       if (tmp)
-               free(tmp);
+    if (tmp)
+        free(tmp);
 }
 
 void send_emuld_connection(void)
 {
-       send_to_ecs(IJTYPE_GUEST, 0, 1, NULL);
+    send_to_ecs(IJTYPE_GUEST, 0, 1, NULL);
 }
 
 void send_default_suspend_req(void)
 {
-       send_to_ecs(IJTYPE_SUSPEND, 5, 15, NULL);
+    send_to_ecs(IJTYPE_SUSPEND, 5, 15, NULL);
 }
 
 static bool do_validate(char* pkgs)
 {
-       char buf[MAX_PKGS_BUF];
-
-       FILE* fp = popen(pkgs, "r");
-       if (fp == NULL) {
-               LOGERR("Failed to popen %s", pkgs);
-               return false;
-       }
-
-       memset(buf, 0, sizeof(buf));
-       while(fgets(buf, sizeof(buf), fp)) {
-               LOGINFO("[rpm]%s", buf);
-               if (!strncmp(buf, IJTYPE_PACKAGE, 7)) {
-                       pclose(fp);
-                       return false;
-               }
-           memset(buf, 0, sizeof(buf));
-       }
-
-       pclose(fp);
-       return true;
+    char buf[MAX_PKGS_BUF];
+
+    FILE* fp = popen(pkgs, "r");
+    if (fp == NULL) {
+        LOGERR("Failed to popen %s", pkgs);
+        return false;
+    }
+
+    memset(buf, 0, sizeof(buf));
+    while(fgets(buf, sizeof(buf), fp)) {
+        LOGINFO("[rpm]%s", buf);
+        if (!strncmp(buf, IJTYPE_PACKAGE, 7)) {
+            pclose(fp);
+            return false;
+        }
+        memset(buf, 0, sizeof(buf));
+    }
+
+    pclose(fp);
+    return true;
 }
 
 static bool do_install(char* pkgs)
 {
-       char buf[MAX_PKGS_BUF];
-       bool ret = true;
+    char buf[MAX_PKGS_BUF];
+    bool ret = true;
 
-       FILE* fp = popen(pkgs, "r");
-       if (fp == NULL) {
-               LOGERR("Failed to popen %s", pkgs);
-               return false;
-       }
+    FILE* fp = popen(pkgs, "r");
+    if (fp == NULL) {
+        LOGERR("Failed to popen %s", pkgs);
+        return false;
+    }
 
-       memset(buf, 0, sizeof(buf));
-       while(fgets(buf, sizeof(buf), fp)) {
-               LOGINFO("[rpm] %s", buf);
+    memset(buf, 0, sizeof(buf));
+    while(fgets(buf, sizeof(buf), fp)) {
+        LOGINFO("[rpm] %s", buf);
 
-               if (!strncmp(buf, "error", 5)) {
-                       ret = false;
-               }
-           memset(buf, 0, sizeof(buf));
-       }
+        if (!strncmp(buf, "error", 5)) {
+            ret = false;
+        }
+        memset(buf, 0, sizeof(buf));
+    }
 
-       pclose(fp);
+    pclose(fp);
 
-       return ret;
+    return ret;
 }
 
 static void remove_package(char* data)
 {
-       char token[] = ", ";
-       char pkg_list[MAX_PKGS_BUF];
-       char *addon = NULL;
-       char *copy = strdup(data);
-       if (copy == NULL) {
-               LOGERR("Failed to copy data.");
-               return;
-       }
+    char token[] = ", ";
+    char pkg_list[MAX_PKGS_BUF];
+    char *addon = NULL;
+    char *copy = strdup(data);
+    if (copy == NULL) {
+        LOGERR("Failed to copy data.");
+        return;
+    }
 
-       memset(pkg_list, 0, sizeof(pkg_list));
+    memset(pkg_list, 0, sizeof(pkg_list));
 
-       strcpy(pkg_list, "rm -rf ");
+    strcpy(pkg_list, "rm -rf ");
 
-       strcat(pkg_list, PATH_PACKAGE_INSTALL);
-       addon = strtok(copy, token);
-       strcat(pkg_list, addon);
+    strcat(pkg_list, PATH_PACKAGE_INSTALL);
+    addon = strtok(copy, token);
+    strcat(pkg_list, addon);
 
-       LOGINFO("remove packages: %s", pkg_list);
+    LOGINFO("remove packages: %s", pkg_list);
 
-       systemcall(pkg_list);
+    systemcall(pkg_list);
 
-       free(copy);
+    free(copy);
 }
 
 static bool do_package(int action, char* data)
 {
-       char token[] = ", ";
-       char *pkg = NULL;
-       char *addon = NULL;
-       char pkg_list[MAX_PKGS_BUF];
-
-       memset(pkg_list, 0, sizeof(pkg_list));
-
-       strcpy(pkg_list, "rpm");
-
-       if (action == 1) {
-               strcat(pkg_list, " ");
-               strcat(pkg_list, RPM_CMD_QUERY);
-       } else if (action == 2) {
-               strcat(pkg_list, " ");
-               strcat(pkg_list, RPM_CMD_INSTALL);
-       } else {
-               LOGERR("Unknown action.");
-               return false;
-       }
-       addon = strtok(data, token); // for addon path
-
-       pkg = strtok(NULL, token);
-       while (pkg != NULL) {
-               if (action == 1) {
-                       pkg[strlen(pkg) - 4] = 0; //remove .rpm
-               }
-               strcat(pkg_list, " ");
-               if (action == 2) {
-                       strcat(pkg_list, PATH_PACKAGE_INSTALL);
-                       strcat(pkg_list, addon);
-                       strcat(pkg_list, "/");
-               }
-               strcat(pkg_list, pkg);
-
-               pkg = strtok(NULL, token);
-       }
-
-       strcat(pkg_list, " ");
-       strcat(pkg_list, "2>&1");
-
-       LOGINFO("[cmd]%s", pkg_list);
-       if (action == 1 && do_validate(pkg_list)) {
-               return true;
-       } else if (action == 2 && do_install(pkg_list)) {
-               return true;
-       }
-
-       return false;
+    char token[] = ", ";
+    char *pkg = NULL;
+    char *addon = NULL;
+    char pkg_list[MAX_PKGS_BUF];
+
+    memset(pkg_list, 0, sizeof(pkg_list));
+
+    strcpy(pkg_list, "rpm");
+
+    if (action == 1) {
+        strcat(pkg_list, " ");
+        strcat(pkg_list, RPM_CMD_QUERY);
+    } else if (action == 2) {
+        strcat(pkg_list, " ");
+        strcat(pkg_list, RPM_CMD_INSTALL);
+    } else {
+        LOGERR("Unknown action.");
+        return false;
+    }
+    addon = strtok(data, token); // for addon path
+
+    pkg = strtok(NULL, token);
+    while (pkg != NULL) {
+        if (action == 1) {
+            pkg[strlen(pkg) - 4] = 0; //remove .rpm
+        }
+        strcat(pkg_list, " ");
+        if (action == 2) {
+            strcat(pkg_list, PATH_PACKAGE_INSTALL);
+            strcat(pkg_list, addon);
+            strcat(pkg_list, "/");
+        }
+        strcat(pkg_list, pkg);
+
+        pkg = strtok(NULL, token);
+    }
+
+    strcat(pkg_list, " ");
+    strcat(pkg_list, "2>&1");
+
+    LOGINFO("[cmd]%s", pkg_list);
+    if (action == 1 && do_validate(pkg_list)) {
+        return true;
+    } else if (action == 2 && do_install(pkg_list)) {
+        return true;
+    }
+
+    return false;
 }
 
 static void* package_thread(void* args)
 {
-       LOGINFO("install package_thread starts.");
-       int action = 0;
-       ijcommand* ijcmd = (ijcommand*)args;
-       char* data = strdup(ijcmd->data);
-       if (data == NULL) {
-               LOGERR("install data is failed to copied.");
-               return NULL;
-       }
-
-       if (ijcmd->msg.action == 1) { // validate packages
-               if (do_package(1, data)) {
-                       action = 1; // already installed
-               } else {
-                       action = 2; // need to install
-               }
-       } else if (ijcmd->msg.action == 2) { // install packages
-               if (do_package(2, data)) {
-                       action = 3; // install success
-               } else {
-                       action = 4; // failed to install
-               }
-               remove_package(ijcmd->data);
-       } else {
-               LOGERR("invalid command (action:%d)", ijcmd->msg.action);
-       }
-
-       LOGINFO("send %d, with %s", action, ijcmd->data);
-       send_to_ecs(IJTYPE_PACKAGE, 0, action, ijcmd->data);
-
-       free(data);
-
-       return NULL;
+    LOGINFO("install package_thread starts.");
+    int action = 0;
+    ijcommand* ijcmd = (ijcommand*)args;
+    char* data = strdup(ijcmd->data);
+    if (data == NULL) {
+        LOGERR("install data is failed to copied.");
+        return NULL;
+    }
+
+    if (ijcmd->msg.action == 1) { // validate packages
+        if (do_package(1, data)) {
+            action = 1; // already installed
+        } else {
+            action = 2; // need to install
+        }
+    } else if (ijcmd->msg.action == 2) { // install packages
+        if (do_package(2, data)) {
+            action = 3; // install success
+        } else {
+            action = 4; // failed to install
+        }
+        remove_package(ijcmd->data);
+    } else {
+        LOGERR("invalid command (action:%d)", ijcmd->msg.action);
+    }
+
+    LOGINFO("send %d, with %s", action, ijcmd->data);
+    send_to_ecs(IJTYPE_PACKAGE, 0, action, ijcmd->data);
+
+    free(data);
+
+    return NULL;
 }
 
 void msgproc_package(ijcommand* ijcmd)
 {
-       _auto_mutex _(&mutex_pkg);
-       int ret = 0;
-       void* retval = NULL;
-       pthread_t pkg_thread_id;
-
-       if (!ijcmd->data) {
-               LOGERR("package data is empty.");
-               return;
-       }
-
-       LOGINFO("received %d, with %s", ijcmd->msg.action, ijcmd->data);
-
-       if (pthread_create(&pkg_thread_id, NULL, package_thread, (void*)ijcmd) != 0)
-       {
-               LOGERR("validate package pthread creation is failed!");
-       }
-       ret = pthread_join(pkg_thread_id, &retval);
-       if (ret < 0) {
-               LOGERR("validate package pthread join is failed.");
-       }
+    _auto_mutex _(&mutex_pkg);
+    int ret = 0;
+    void* retval = NULL;
+    pthread_t pkg_thread_id;
+
+    if (!ijcmd->data) {
+        LOGERR("package data is empty.");
+        return;
+    }
+
+    LOGINFO("received %d, with %s", ijcmd->msg.action, ijcmd->data);
+
+    if (pthread_create(&pkg_thread_id, NULL, package_thread, (void*)ijcmd) != 0)
+    {
+        LOGERR("validate package pthread creation is failed!");
+    }
+    ret = pthread_join(pkg_thread_id, &retval);
+    if (ret < 0) {
+        LOGERR("validate package pthread join is failed.");
+    }
 }
 
index b2669c1..ba059af 100644 (file)
@@ -141,10 +141,10 @@ static int read_header(int fd, LXT_MESSAGE* packet)
     char* readbuf = NULL;
     int readed = recv_data(fd, &readbuf, HEADER_SIZE);
     if (readed <= 0){
-               if (readbuf)
-                       free(readbuf);
+        if (readbuf)
+            free(readbuf);
         return 0;
-       }
+    }
     memcpy((void*) packet, (void*) readbuf, HEADER_SIZE);
 
     if (readbuf)
@@ -197,7 +197,7 @@ void recv_from_evdi(evdi_fd fd)
 {
     LOGDEBUG("recv_from_evdi");
     int readed;
-       synbuf g_synbuf;
+    synbuf g_synbuf;
 
     struct msg_info _msg;
     int to_read = sizeof(struct msg_info);
@@ -243,7 +243,7 @@ void recv_from_evdi(evdi_fd fd)
         return;
 
     LOGDEBUG("HEADER : action = %d, group = %d, length = %d",
-                       ijcmd.msg.action, ijcmd.msg.group, ijcmd.msg.length);
+            ijcmd.msg.action, ijcmd.msg.group, ijcmd.msg.length);
 
     if (ijcmd.msg.length > 0)
     {
@@ -269,12 +269,12 @@ void recv_from_evdi(evdi_fd fd)
 void writelog(const char* fmt, ...)
 {
     FILE* logfile = fopen("/tmp/emuld.log", "a+");
-       va_list args;
-       va_start(args, fmt);
-       vfprintf(logfile, fmt, args);
-       vfprintf(logfile, "\n", NULL);
-       va_end(args);
-       fclose(logfile);
+    va_list args;
+    va_start(args, fmt);
+    vfprintf(logfile, fmt, args);
+    vfprintf(logfile, "\n", NULL);
+    va_end(args);
+    fclose(logfile);
 }
 
 int main( int argc , char *argv[])
@@ -294,9 +294,9 @@ int main( int argc , char *argv[])
 
     LOGINFO("[START] epoll & device init success");
 
-       init_profile();
+    init_profile();
 
-       send_emuld_connection();
+    send_emuld_connection();
 
     send_default_suspend_req();
 
@@ -305,11 +305,11 @@ int main( int argc , char *argv[])
         exit_flag = server_process();
     }
 
-       exit_profile();
+    exit_profile();
 
     stop_listen();
 
-       LOGINFO("emuld exit");
+    LOGINFO("emuld exit");
 
     return 0;
 }
index f8c7041..d05b5a8 100644 (file)
@@ -98,7 +98,7 @@ bool server_process(void)
         }
         else
         {
-               LOGERR("unknown request event fd : (%d)", fd_tmp);
+            LOGERR("unknown request event fd : (%d)", fd_tmp);
         }
     }
 
index 9b04229..cfc700c 100644 (file)
@@ -120,11 +120,11 @@ static void dbus_send_power_supply(int capacity, int charger)
     memset(option, 0, 128);
 
     if (capacity == 100 && charger == 1) {
-               memcpy(state, FULL, 4);
+        memcpy(state, FULL, 4);
     } else if (charger == 1) {
-               memcpy(state, CHARGING, 8);
+        memcpy(state, CHARGING, 8);
     } else {
-               memcpy(state, DISCHARGING, 11);
+        memcpy(state, DISCHARGING, 11);
     }
 
     sprintf(option, "int32:5 string:\"%d\" string:\"%s\" string:\"Good\" string:\"%d\" string:\"1\"",
@@ -148,7 +148,7 @@ static void dbus_send_usb(int on)
 
 static void dbus_send_earjack(int on)
 {
-       const char* earjack_device = DEVICE_CHANGED;
+    const char* earjack_device = DEVICE_CHANGED;
     char option [128];
     memset(option, 0, 128);
 
@@ -337,9 +337,9 @@ int parse_earjack_data(int len, char *buffer)
     fclose(fd);
 
     // because time based polling
-       //FIXME: change to dbus
+    //FIXME: change to dbus
     //system_cmd("/usr/bin/sys_event device_earjack_chgdet");
-       dbus_send_earjack(x);
+    dbus_send_earjack(x);
     return 0;
 }
 
@@ -509,30 +509,30 @@ static void* getting_sensor(void* data)
         break;
     }
 
-       if (msg == 0)
-       {
-               LOGDEBUG("send error message to injector");
-               memset(packet, 0, sizeof(LXT_MESSAGE));
-               packet->length = 0;
-               packet->group = STATUS;
-               packet->action = param->ActionID;
-       }
-       else
-       {
-               LOGDEBUG("send data to injector");
-       }
-
-       const int tmplen = HEADER_SIZE + packet->length;
-       char* tmp = (char*) malloc(tmplen);
-       if (tmp)
-       {
-               memcpy(tmp, packet, HEADER_SIZE);
-               if (packet->length > 0)
-                       memcpy(tmp + HEADER_SIZE, msg, packet->length);
-
-               ijmsg_send_to_evdi(g_fd[fdtype_device], param->type_cmd, (const char*) tmp, tmplen);
-
-               free(tmp);
+    if (msg == 0)
+    {
+        LOGDEBUG("send error message to injector");
+        memset(packet, 0, sizeof(LXT_MESSAGE));
+        packet->length = 0;
+        packet->group = STATUS;
+        packet->action = param->ActionID;
+    }
+    else
+    {
+        LOGDEBUG("send data to injector");
+    }
+
+    const int tmplen = HEADER_SIZE + packet->length;
+    char* tmp = (char*) malloc(tmplen);
+    if (tmp)
+    {
+        memcpy(tmp, packet, HEADER_SIZE);
+        if (packet->length > 0)
+            memcpy(tmp + HEADER_SIZE, msg, packet->length);
+
+        ijmsg_send_to_evdi(g_fd[fdtype_device], param->type_cmd, (const char*) tmp, tmplen);
+
+        free(tmp);
     }
 
     if(msg != 0)
index c3b1a0d..9836aac 100644 (file)
@@ -95,7 +95,7 @@ bool server_process(void)
         }
         else
         {
-               LOGERR("unknown request event fd : (%d)", fd_tmp);
+            LOGERR("unknown request event fd : (%d)", fd_tmp);
         }
     }
 
index fdc390c..454f6b1 100644 (file)
@@ -75,11 +75,11 @@ static void dbus_send_power_supply(int capacity, int charger)
     memset(option, 0, 128);
 
     if (capacity == 100 && charger == 1) {
-               memcpy(state, FULL, 4);
+        memcpy(state, FULL, 4);
     } else if (charger == 1) {
-               memcpy(state, CHARGING, 8);
+        memcpy(state, CHARGING, 8);
     } else {
-               memcpy(state, DISCHARGING, 11);
+        memcpy(state, DISCHARGING, 11);
     }
 
     sprintf(option, "int32:5 string:\"%d\" string:\"%s\" string:\"Good\" string:\"%d\" string:\"1\"",
@@ -102,7 +102,7 @@ static void dbus_send_usb(int on)
 
 static void dbus_send_earjack(int on)
 {
-       const char* earjack_device = DEVICE_CHANGED;
+    const char* earjack_device = DEVICE_CHANGED;
     char option [128];
     memset(option, 0, 128);
 
@@ -202,7 +202,7 @@ int parse_earjack_data(int len, char *buffer)
     fprintf(fd, "%d", x);
     fclose(fd);
 
-       dbus_send_earjack(x);
+    dbus_send_earjack(x);
     return 0;
 }