[IMPROVE] add write_to_buf check result

    for all write_to_buf calls add LOGE messages on fail

Change-Id: Iafeafa6411f149da7b79a1859f948928404e6f76
Signed-off-by: Vitaliy Cherepanov <v.cherepanov@samsung.com>

diff --git a/daemon/da_protocol.c b/daemon/da_protocol.c
index abb7701..e3952b6 100644 (file)
--- a/daemon/da_protocol.c
+++ b/daemon/da_protocol.c
@@ -562,7 +562,8 @@ static int send_reply(struct msg_t *msg)
 static void write_msg_error(const char *err_str)
 {
        struct msg_data_t *err_msg = gen_message_error(err_str);
-       write_to_buf(err_msg);
+       if (write_to_buf(err_msg) != 0)
+               LOGE("write to buf fail\n");
        free_msg_data(err_msg);
 }
 

diff --git a/daemon/daemon.c b/daemon/daemon.c
index af1490c..0e11fd4 100644 (file)
--- a/daemon/daemon.c
+++ b/daemon/daemon.c
@@ -325,7 +325,8 @@ static void terminate_error(char *errstr, int send_to_host)
        if (send_to_host != 0) {
                msg = gen_message_error(errstr);
                if (msg) {
-                       write_to_buf(msg);
+                       if (write_to_buf(msg) != 0)
+                               LOGE("write to buf fail\n");
                        free_msg_data(msg);
                } else {
                        LOGI("cannot generate error message\n");

diff --git a/daemon/input_events.c b/daemon/input_events.c
index e382bee..0335837 100644 (file)
--- a/daemon/input_events.c
+++ b/daemon/input_events.c
@@ -189,7 +189,8 @@ static int deviceEventHandler(input_dev *dev, int input_type)
                             input_type == INPUT_ID_KEY ? STR_KEY : STR_TOUCH);
                        log = gen_message_event(in_ev, count, input_type);
                        printBuf((char *)log, MSG_DATA_HDR_LEN + log->len);
-                       write_to_buf(log);
+                       if (write_to_buf(log) != 0)
+                               LOGE("write to buf fail\n");
                        free_msg_data(log);
                }
        } else {

diff --git a/daemon/threads.c b/daemon/threads.c
index 23bb195..a3175f9 100644 (file)
--- a/daemon/threads.c
+++ b/daemon/threads.c
@@ -90,7 +90,8 @@ static void* recvThread(void* data)
                        recvLen = recv(target->socket,
                                       (char *)msg + MSG_DATA_HDR_LEN,
                                       msg->len, MSG_WAITALL);
-                       write_to_buf(msg);
+                       if (write_to_buf(msg) != 0)
+                               LOGE("write to buf fail\n");
                        free(msg);
                        continue;
                }
@@ -156,7 +157,8 @@ static void* recvThread(void* data)
                        fill_data_msg_head(msg, NMSG_TERMINATE, 0,
                                           sizeof(uint32_t));
                        *(uint32_t *) msg->payload = (uint32_t) target->pid;
-                       write_to_buf(msg);
+                       if (write_to_buf(msg) != 0)
+                               LOGE("write to buf fail\n");
                        free(msg);
                        break;
                } else if (log.type == MSG_MSG) {
@@ -263,7 +265,8 @@ static void *samplingThread(void *data)
                                continue;
                        }
 
-                       write_to_buf(msg);
+                       if (write_to_buf(msg) != 0)
+                               LOGE("write to buf fail\n");
 
                        printBuf((char *)msg, MSG_DATA_HDR_LEN + msg->len);