Applied code review results 88/100588/1
authorkmook <kmook.choi@samsung.com>
Mon, 28 Nov 2016 12:38:16 +0000 (21:38 +0900)
committerkmook <kmook.choi@samsung.com>
Mon, 28 Nov 2016 12:38:16 +0000 (21:38 +0900)
Change-Id: I882871e8fcd5104a6d886cf83d99a65aae867a12
Signed-off-by: kmook <kmook.choi@samsung.com>
12 files changed:
msf_tizen_client/include/Error.h
msf_tizen_client/include/MSFDSearchProvider.h
msf_tizen_client/include/Message.h
msf_tizen_client/include/Search.h
msf_tizen_client/include/SearchProvider.h
msf_tizen_client/include/Service.h
msf_tizen_client/include/mDNSSearchProvider.h
msf_tizen_client/src/Application.cpp
msf_tizen_client/src/ApplicationInfo.cpp
msf_tizen_client/src/Channel.cpp
msf_tizen_client/src/Client.cpp
msf_tizen_client/src/Message.cpp

index daaabcb..c96fa1f 100644 (file)
@@ -18,8 +18,8 @@
 #define __MSF_ERROR_H__
 
 #include <stdio.h>
-#include<iostream>
-#include<string>
+#include <iostream>
+#include <string>
 
 using namespace std;
 
index 3e029be..c35a8f1 100644 (file)
@@ -20,7 +20,7 @@
 #include <map>
 #include <json-glib/json-glib.h>
 #include <json-glib/json-parser.h>
-#include"SearchProvider.h"
+#include "SearchProvider.h"
 
 using namespace std;
 
index 62d9496..6471ce0 100755 (executable)
@@ -23,7 +23,6 @@
 #include <string>
 #include <vector>
 
-
 using namespace std;
 
 class Message
index 5479796..747a5ba 100644 (file)
 #define __MSF_SEARCH_H__
 
 #include <list>
-#include"SearchProvider.h"
+#include "SearchProvider.h"
 #include <list>
 #include <pthread.h>
 #include <string>
-#include"mDNSSearchProvider.h"
+#include "mDNSSearchProvider.h"
 
 #define NUM_OF_THREADS 3
 #define MDNS_THREAD_NUMBER 0
index d627ae0..9e7e15c 100644 (file)
@@ -17,9 +17,9 @@
 #ifndef __MSF_SEARCH_PROVIDER_H__
 #define __MSF_SEARCH_PROVIDER_H__
 
-#include<iostream>
-#include<list>
-#include<string>
+#include <iostream>
+#include <list>
+#include <string>
 #include <map>
 
 //#include "Service.h"
index 84c05fa..e0231c1 100755 (executable)
@@ -22,7 +22,6 @@
 #include <json-glib/json-glib.h>
 #include <json-glib/json-parser.h>
 
-
 using namespace std;
 
 class Application;
index e03c547..e6d767c 100644 (file)
@@ -19,7 +19,7 @@
 
 using namespace std;
 
-#include"SearchProvider.h"
+#include "SearchProvider.h"
 #include <nsd/dns-sd.h>
 #include "Service.h"
 #include "Result.h"
index e304ad4..2e7d8f0 100755 (executable)
@@ -41,7 +41,6 @@ public:
                if (in_result_cb != NULL) {
                        if (((*in_result_cb) != NULL)) {
                                (*in_result_cb)->onStart(result);
-                       } else {
                        }
                }
 
@@ -54,7 +53,6 @@ public:
                if (in_result_cb != NULL) {
                        if (((*in_result_cb) != NULL)) {
                                (*in_result_cb)->onStart(false);
-                       } else {
                        }
                }
                delete this;
@@ -72,7 +70,6 @@ public:
                if (in_result_cb != NULL) {
                        if (((*in_result_cb) != NULL)) {
                                (*in_result_cb)->onStop(result);
-                       } else {
                        }
                }
 
@@ -85,7 +82,6 @@ public:
                if (in_result_cb != NULL) {
                        if (((*in_result_cb) != NULL)) {
                                (*in_result_cb)->onStop(false);
-                       } else {
                        }
                }
                delete this;
@@ -99,6 +95,8 @@ Application::Application()
        webapp = false;
        install_listener = NULL;
        install_result = false;
+       result = NULL;
+       startArgs = NULL;
 }
 
 Application::Application(Service *se, string Uri, string Id)
@@ -120,7 +118,9 @@ Application::Application(Service *se, string Uri, string Id)
        waitForOnReady = false;
        install_listener = NULL;
        install_result = false;
-       setSecureSupport(se->IsSecureConnectionSupport());
+       if (se != NULL) {
+               setSecureSupport(se->IsSecureConnectionSupport());
+       }
 }
 
 Application::Application(Service *se, string Uri, string Id, map<string, string> startargs)
index 9d7c6dc..bb7bc93 100755 (executable)
@@ -23,6 +23,7 @@ string ApplicationInfo::PROPERTY_VERSION = "version";
 
 ApplicationInfo::ApplicationInfo()
 {
+       running = false;
 }
 
 ApplicationInfo::ApplicationInfo(string iD, bool state, string Name, string Version)
index eb02d2c..24de9ea 100755 (executable)
@@ -64,6 +64,11 @@ ChannelConnectionHandler::ChannelConnectionHandler() {
        pingTimeout = 5000000;
        lastPingReceived = 0;
        running = false;
+       longestRT = 0;
+       numPings = 0;
+       startTime = 0;
+       pingSent = 0;
+       average = 0;
 }
 
 Channel::Channel() {
@@ -773,6 +778,7 @@ void Channel::write_socket(Channel* ch_p)
                lws_callback_on_writable(ch_p->wsi_mirror);
        }
 
+       MSF_DBG("write_buf_count:%d", ch_p->write_buf_count);
        if (ch_p->write_buf_count) {
                if (ch_p->write_buf_last_sent_index == 999) {
                        ch_p->write_buf_last_sent_index = 1;
@@ -805,7 +811,7 @@ void Channel::write_socket(Channel* ch_p)
                                ch_p->onPublishListener->onPublished(false, ch_p->publish_user_data[ch_p->write_buf_last_sent_index]);
                        }
                } else {
-                       MSF_DBG("Writing succeed\n");
+                       MSF_DBG("Writing succeed : %d", n);
                        if (ch_p->onPublishListener) {
                                ch_p->onPublishListener->onPublished(true, ch_p->publish_user_data[ch_p->write_buf_last_sent_index]);
                        }
@@ -886,9 +892,10 @@ int Channel::callback_lws_mirror(struct lws *wsi,
                        this_ptr->cl_payload[len - 2 - header_size] = 0;
                        this_ptr->cl_payload_size = len - 2 - header_size;
 
+/*
                        MSF_DBG("payload = %s",
                                                &(this_ptr->cl_payload[0]));
-
+*/
                        this_ptr->connectionHandler->resetLastPingReceived();
 
                        if (this_ptr->eventType == CONNECT_EVENT) {
@@ -1110,7 +1117,7 @@ unsigned char *Channel::prepareMessageMap(string method, string event,
        int l = 0;
        int header_size = 0;
 
-       int prepare_buf_size = LWS_SEND_BUFFER_PRE_PADDING + 4096 + LWS_SEND_BUFFER_POST_PADDING;
+       int prepare_buf_size = LWS_SEND_BUFFER_PRE_PADDING + payload_size + LWS_SEND_BUFFER_POST_PADDING + 128;
        unsigned char *prepare_buf = new unsigned char[prepare_buf_size];
 
        if (payload) {
index ed7d277..5545ce2 100644 (file)
@@ -27,6 +27,7 @@ Client::Client()
        id   = string();
        host = false ;
        connectTime = 0;
+       m_channel = NULL;
 }
 
 void Client::create(Client &client)
index 92235a7..cdee8aa 100755 (executable)
@@ -64,6 +64,9 @@ Message::Message(Channel *ch, string event, string data, string from, unsigned c
 
 Message::Message()
 {
+       m_channel = NULL;
+       m_payload = NULL;
+       m_payload_size = 0;
 }
 
 Message::Message(const Message& m)