src/server/database/cache_db_handler.cc

   1 /*
   2  * Copyright (c) 2021 Samsung Electronics Co., Ltd All Rights Reserved
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 #include "cache_db_handler.hh"
  18
  19 #include <shared_mutex>
  20 #include <vector>
  21
  22 #include "cache_flag.hh"
  23 #include "db_handle_provider.hh"
  24 #include "utils/logging.hh"
  25
  26 namespace pkgmgr_server {
  27 namespace database {
  28
  29 CacheDBHandler::CacheDBHandler(uid_t uid, int pid)
  30     : AbstractDBHandler(uid, pid), uid_(uid) {}
  31
  32 CacheDBHandler::~CacheDBHandler() {}
  33
  34 int CacheDBHandler::Execute() {
  35   std::shared_lock<std::shared_mutex> s(lock_);
  36   SetOpType(pkgmgr_common::DBOperationType::OPERATION_TYPE_READ);
  37   SetDBType(pkgmgr_common::DBType::DB_TYPE_FILE_PKGDB);
  38
  39   std::vector<std::pair<sqlite3*, uid_t>> conn_list;
  40   if (!Connect()) {
  41     CacheFlag::SetStatus(CacheFlag::Status::UNPREPARED);
  42     return PMINFO_R_ERROR;
  43   }
  44
  45   conn_list = GetConnection();
  46   auto lock = CacheFlag::GetWriterLock();
  47   int ret = PMINFO_R_OK;
  48   for (auto& conn : conn_list) {
  49     ret = DBHandleProvider::GetInst(conn.second)
  50               .UpdateCache(conn.first, GetPID(), uid_, false, GetLocale());
  51     if (ret != PMINFO_R_OK) {
  52       LOG(ERROR) << "Failed to update pkginfo cache : " << ret;
  53       break;
  54     }
  55   }
  56
  57   CacheFlag::SetStatus(ret == PMINFO_R_OK ?
  58       CacheFlag::Status::PREPARED :
  59       CacheFlag::Status::UNPREPARED);
  60
  61   return ret;
  62 }
  63
  64 }  // namespace database
  65 }  // namespace pkgmgr_server