}
}
-static void __emit_signal_for_pkg_event(GVariant* gv) {
+static void __emit_signal_for_pkg_event(const char* signal, GVariant* gv) {
uid_t target_uid;
char* req_id;
char* pkg_type = NULL;
g_variant_iter_free(iter);
try {
- signal_sender->AsyncResult("", target_uid, req_id, std::move(pkgs), key, val);
+ signal_sender->AsyncResult(signal, target_uid, req_id,
+ std::move(pkgs), key, val);
} catch (...) {
LOGE("Exception occured");
}
} else {
gv = g_variant_new_from_data(G_VARIANT_TYPE("(usa(sss)ss)"),
data, data_len, TRUE, NULL, NULL);
- __emit_signal_for_pkg_event(gv);
+ __emit_signal_for_pkg_event(type_name, gv);
}
g_variant_unref(gv);
return -1;
}
auto& req = GetRequest();
+ const char* signal_name =
+ __get_signal_name(req, key.c_str(), pkg_type.c_str());
std::vector<rpc_port::PkgSignal::PkgInfo> pkgs;
pkgs.emplace_back(std::move(pkgid), std::move(appid), std::move(pkg_type));
try {
- signal_->AsyncResult("", req->GetUid(), req->GetSessionId(), std::move(pkgs),
- key, val);
+ signal_->AsyncResult(signal_name, req->GetUid(), req->GetSessionId(),
+ std::move(pkgs), key, val);
return 0;
} catch (...) {
_E("Exception occured");
return -1;
}
auto& req = GetRequest();
+ const char* signal_name =
+ __get_signal_name(req, key.c_str(), "");
try {
- signal_->AsyncResult("", req->GetUid(), req->GetSessionId(), pkgs_, key, val);
+ signal_->AsyncResult(signal_name, req->GetUid(),
+ req->GetSessionId(), pkgs_, key, val);
return 0;
} catch (...) {
_E("Exception occured");