delete cb_data;
}
-MainLoopHandler::MainLoopCbData::MainLoopCbData() : result(OK), fd(-1)
+MainLoopHandler::MainLoopCbData::MainLoopCbData() : data(nullptr), result(OK), fd(-1), ctx(nullptr)
{
}
#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();
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_; };
const AittOption &option)
: public_api(parent),
id_(id),
+ mqtt_broker_port_(0),
mq(new MQProxy(id, option)),
discovery(id, option),
reply_id(0),
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());
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;
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());