add initialization of members
authorYoungjae Shin <yj99.shin@samsung.com>
Thu, 15 Sep 2022 02:23:02 +0000 (11:23 +0900)
committerYoungjae Shin <yj99.shin@samsung.com>
Tue, 20 Sep 2022 07:45:38 +0000 (16:45 +0900)
common/MainLoopHandler.cc
modules/webrtc/MqttServer.cc
modules/webrtc/WebRtcRoom.h
src/AITTImpl.cc
src/aitt_c.cc

index 747a6bc..0c7a691 100644 (file)
@@ -180,7 +180,7 @@ void MainLoopHandler::DestroyNotify(gpointer data)
     delete cb_data;
 }
 
-MainLoopHandler::MainLoopCbData::MainLoopCbData() : result(OK), fd(-1)
+MainLoopHandler::MainLoopCbData::MainLoopCbData() : data(nullptr), result(OK), fd(-1), ctx(nullptr)
 {
 }
 
index 726161e..b8a9c45 100644 (file)
@@ -22,7 +22,8 @@
 #define MQTT_HANDLER_MGMT_QOS 2
 
 MqttServer::MqttServer(const Config &config)
-      : mq(new aitt::MQProxy(config.GetLocalId(), AittOption(true, false)))
+      : mq(new aitt::MQProxy(config.GetLocalId(), AittOption(true, false))),
+        connection_state_(ConnectionState::Disconnected)
 {
     broker_ip_ = config.GetBrokerIp();
     broker_port_ = config.GetBrokerPort();
index fabeb1e..2df2d62 100644 (file)
@@ -30,7 +30,7 @@ class WebRtcRoom {
         JOINED,
     };
     WebRtcRoom() = delete;
-    WebRtcRoom(const std::string &room_id) : id_(room_id){};
+    explicit WebRtcRoom(const std::string &room_id) : id_(room_id), state_(State::JOINNING){};
     ~WebRtcRoom();
     void setRoomState(State current) { state_ = current; }
     State getRoomState(void) const { return state_; };
index 775972a..e976dab 100644 (file)
@@ -35,6 +35,7 @@ AITT::Impl::Impl(AITT &parent, const std::string &id, const std::string &my_ip,
       const AittOption &option)
       : public_api(parent),
         id_(id),
+        mqtt_broker_port_(0),
         mq(new MQProxy(id, option)),
         discovery(id, option),
         reply_id(0),
@@ -299,8 +300,8 @@ int AITT::Impl::PublishWithReply(const std::string &topic, const void *data, con
 
     Subscribe(
           replyTopic,
-          [this, cb](
-                MSG *sub_msg, const void *sub_data, const size_t sub_datalen, void *sub_cbdata) {
+          [this, cb](MSG *sub_msg, const void *sub_data, const size_t sub_datalen,
+                void *sub_cbdata) {
               if (sub_msg->IsEndSequence()) {
                   try {
                       Unsubscribe(sub_msg->GetID());
index d2f68db..9e175f2 100644 (file)
@@ -24,7 +24,7 @@
 using namespace aitt;
 
 struct aitt_handle {
-    aitt_handle() : aitt(nullptr) {}
+    aitt_handle() : aitt(nullptr), connected(false), custom_broker(false) {}
     AITT *aitt;
     bool connected;
     bool custom_broker;
@@ -58,7 +58,6 @@ API aitt_h aitt_new(const char *id, aitt_option_h option)
 
         handle = new aitt_handle();
         handle->aitt = new AITT(valid_id, valid_ip, aitt_option);
-        handle->connected = false;
         handle->custom_broker = custom_broker;
     } catch (std::exception &e) {
         ERR("new() Fail(%s)", e.what());