package_ = package;
}
-void PkgSetDBHandler::SetPkgID(std::string pkgid) {
- pkgid = std::move(pkgid);
-}
-
void PkgSetDBHandler::SetWriteType(pkgmgr_common::PkgWriteType write_type) {
write_type_ = write_type;
}
if (!Connect())
return PMINFO_R_ERROR;
- if (!is_offline_)
- DBHandleProvider::GetInst(uid_).SetMemoryMode(GetPID());
-
const auto& db = GetConnection().front().first;
int ret = 0;
- if (write_type_ == pkgmgr_common::PkgWriteType::Insert)
+ if (write_type_ == pkgmgr_common::PkgWriteType::Insert) {
ret = pkgmgr_server::internal::InsertPkgInfo(db, package_, uid_);
- else if (write_type_ == pkgmgr_common::PkgWriteType::Update)
+ } else if (write_type_ == pkgmgr_common::PkgWriteType::Update) {
ret = pkgmgr_server::internal::UpdatePkgInfo(db, package_, uid_);
- else if (write_type_ == pkgmgr_common::PkgWriteType::Delete)
+ } else if (write_type_ == pkgmgr_common::PkgWriteType::Delete) {
ret = pkgmgr_server::internal::DeletePkgInfo(db, package_->package, uid_);
- else
+ } else {
LOG(ERROR) << "Unknown db write type";
+ return PMINFO_R_ERROR;
+ }
if (is_offline_ || ret != PMINFO_R_OK)
return ret;
auto lock = CacheFlag::GetWriterLock();
- if (CacheFlag::GetStatus() == CacheFlag::Status::PREPARED)
- DBHandleProvider::GetInst(uid_).RegisterPendingPackageInfo(package_);
+ if (CacheFlag::GetStatus() == CacheFlag::Status::PREPARED) {
+ DBHandleProvider::GetInst(uid_).RegisterPendingPackageInfo(db,
+ package_, GetPID(), uid_, GetLocale(), write_type_);
+ }
return ret;
}