return writer_pid_list_.erase(pid) == 1;
}
-void DBHandleProvider::RegisterPendingPackageInfo(
- package_x* info, pid_t pid) {
+void DBHandleProvider::RegisterPendingPackageInfo(package_x* info) {
if (!info || !info->package)
return;
- pending_pkg_[pid].emplace(info->package);
+ pending_pkg_.emplace(info->package);
}
bool DBHandleProvider::UpdatePendingPackageInfo(sqlite3* db,
pid_t pid, uid_t uid, const std::string& locale) {
- auto it = pending_pkg_.find(pid);
- if (it == pending_pkg_.end()) {
- LOG(WARNING) << "There is no package that is pending by the pid : " << pid;
- return true;
- }
-
GHashTable* list = g_hash_table_new(g_str_hash, g_str_equal);
if (list == nullptr) {
LOG(ERROR) << "Out of memory";
};
tmp_filter.cache_flag = true;
tmp_filter.list = g_slist_append(tmp_filter.list, (gpointer)&node);
- for (const auto& pkg : it->second) {
+ for (const auto& pkg : pending_pkg_) {
pkg_map_.erase(pkg);
for (auto& appid : pkg_app_map_[pkg]) {
app_map_.erase(appid);
g_hash_table_destroy(list);
g_slist_free(tmp_filter.list);
- pending_pkg_.erase(pid);
+ pending_pkg_.clear();
return true;
}