res, &err);
if (reply == nullptr) {
LOGE("No reply. err(%s)", err ? err->message : "Unknown");
- watcher->OnPortDisconnected(broker->watch_appid_, broker->watch_port_name_);
+ if (watcher) {
+ watcher->OnPortDisconnected(broker->watch_appid_,
+ broker->watch_port_name_);
+ }
g_error_free(err);
return;
}
GVariant* reply_body = g_dbus_message_get_body(reply);
if (reply_body == nullptr) {
LOGE("g_dbus_message_get_body() is failed");
- watcher->OnPortDisconnected(broker->watch_appid_, broker->watch_port_name_);
+ if (watcher) {
+ watcher->OnPortDisconnected(broker->watch_appid_,
+ broker->watch_port_name_);
+ }
g_object_unref(reply);
return;
}
g_object_unref(reply);
if (ret != 0) {
LOGE("Access Denied[sender_appid : %s]", broker->watch_appid_.c_str());
- watcher->OnPortRejected(broker->watch_appid_);
+ if (watcher)
+ watcher->OnPortRejected(broker->watch_appid_);
return;
}
- watcher->OnPortConnected(broker->watch_appid_, broker->watch_port_name_);
+ if (watcher)
+ watcher->OnPortConnected(broker->watch_appid_, broker->watch_port_name_);
LOGD("[Reply : %d]", ret);
}