2 * Copyright (c) 2021 - 2022 Samsung Electronics Co., Ltd All Rights Reserved
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
8 * http://www.apache.org/licenses/LICENSE-2.0
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.
17 #include <cpu-boosting.h>
19 #include <glib-unix.h>
26 #include "cache_flag.hh"
27 #include "create_cache_request.hh"
28 #include "cynara_checker.hh"
29 #include "pkg_request.hh"
31 #include "utils/logging.hh"
33 #include "pkgmgrinfo_debug.h"
34 #include "pkgmgrinfo_private.h"
39 #define LOG_TAG "PKGMGR_INFO"
41 namespace pkgmgr_server {
44 static const std::string SOCK_PATH = "/run/pkgmgr-info-server";
45 constexpr const char PRIVILEGE_PACKAGE_MANAGER_ADMIN[] =
46 "http://tizen.org/privilege/packagemanager.admin";
47 constexpr const char DEST_PROCESS_NAME[] = "pkgmgr-info";
51 Runner::Runner(unsigned int thread_num) {
52 /* thread_num_ <= hardware_concurrency */
53 thread_num_ = std::min(thread_num, std::thread::hardware_concurrency());
54 CynaraChecker::GetInst().Init();
55 server_ = std::make_unique<pkgmgr_common::socket::ServerSocket>(SOCK_PATH);
56 thread_pool_ = std::make_unique<WorkerThread>(thread_num_);
58 auto condition = static_cast<GIOCondition>(G_IO_IN);
59 sid_ = g_unix_fd_add(server_->GetFd(), condition, OnReceiveRequest, this);
60 default_uid_ = tzplatform_getuid(TZ_SYS_DEFAULT_USER);
61 pkgmgr_common::SystemLocale::GetInst().RegisterEvent(this);
62 thread_pool_->SetLocale(pkgmgr_common::SystemLocale::GetInst().Get());
64 if (CacheFlag::SetPreparing())
65 QueueRequest(std::make_shared<CreateCacheRequest>(default_uid_, this));
71 g_source_remove(sid_);
72 CynaraChecker::GetInst().Fini();
73 pkgmgr_common::SystemLocale::GetInst().UnRegisterEvent();
76 int Runner::OnReceiveRequest(int fd, GIOCondition cond, void* user_data) {
77 auto runner = static_cast<Runner*>(user_data);
78 int client_fd = runner->server_->Accept();
80 LOG(ERROR) << "Failed to Accept. errno:" << errno;
81 return G_SOURCE_CONTINUE;
84 auto req = std::make_shared<PkgRequest>(client_fd);
86 if (CacheFlag::SetPreparing()) {
88 std::make_shared<CreateCacheRequest>(runner->default_uid_, runner));
90 runner->QueueRequest(std::move(req));
92 return G_SOURCE_CONTINUE;
95 void Runner::OnChanged(const std::string& locale) {
96 thread_pool_->SetLocale(locale);
99 bool Runner::QueueRequest(std::shared_ptr<PkgRequest> req) {
100 thread_pool_->PushQueue(std::move(req));
104 void Runner::OnCreateCacheDone(bool success) {
105 static bool ready = false;
106 if (success && !ready) {
108 LOG(WARNING) << "pkginfo-server is ready";
110 [](gpointer data) -> gboolean {
111 int fd = creat("/run/.pkginfo_server_ready",
112 S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
116 return G_SOURCE_REMOVE;
122 void Runner::SetCPUInheritance() {
124 resource_pid_t resource_st = { 0, };
125 resource_st.pid = getpid();
127 ret = resource_register_cpu_inheritance_destination(
128 DEST_PROCESS_NAME, resource_st);
130 LOG(ERROR) << "Fail to register cpu inheritance destination ret : " << ret;
133 } // namespace pkgmgr_server