106f6ba60Sopenharmony_ci/* 206f6ba60Sopenharmony_ci * Copyright (c) Huawei Technologies Co., Ltd. 2021. All rights reserved. 306f6ba60Sopenharmony_ci * Licensed under the Apache License, Version 2.0 (the "License"); 406f6ba60Sopenharmony_ci * you may not use this file except in compliance with the License. 506f6ba60Sopenharmony_ci * You may obtain a copy of the License at 606f6ba60Sopenharmony_ci * 706f6ba60Sopenharmony_ci * http://www.apache.org/licenses/LICENSE-2.0 806f6ba60Sopenharmony_ci * 906f6ba60Sopenharmony_ci * Unless required by applicable law or agreed to in writing, software 1006f6ba60Sopenharmony_ci * distributed under the License is distributed on an "AS IS" BASIS, 1106f6ba60Sopenharmony_ci * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1206f6ba60Sopenharmony_ci * See the License for the specific language governing permissions and 1306f6ba60Sopenharmony_ci * limitations under the License. 1406f6ba60Sopenharmony_ci */ 1506f6ba60Sopenharmony_ci 1606f6ba60Sopenharmony_ci#include "service_entry.h" 1706f6ba60Sopenharmony_ci#include "logging.h" 1806f6ba60Sopenharmony_ci#include "service_base.h" 1906f6ba60Sopenharmony_ci#include "unix_socket_server.h" 2006f6ba60Sopenharmony_ci 2106f6ba60Sopenharmony_ciServiceEntry::ServiceEntry() 2206f6ba60Sopenharmony_ci{ 2306f6ba60Sopenharmony_ci unixSocketServer_ = nullptr; 2406f6ba60Sopenharmony_ci} 2506f6ba60Sopenharmony_ciServiceEntry::~ServiceEntry() {} 2606f6ba60Sopenharmony_cibool ServiceEntry::StartServer(const std::string& addrname) 2706f6ba60Sopenharmony_ci{ 2806f6ba60Sopenharmony_ci CHECK_TRUE(unixSocketServer_ == nullptr, false, "Servier Already Started"); 2906f6ba60Sopenharmony_ci 3006f6ba60Sopenharmony_ci auto server = std::make_shared<UnixSocketServer>(); 3106f6ba60Sopenharmony_ci 3206f6ba60Sopenharmony_ci CHECK_TRUE(server->StartServer(addrname, *this), false, "StartServer FAIL"); 3306f6ba60Sopenharmony_ci 3406f6ba60Sopenharmony_ci unixSocketServer_ = server; 3506f6ba60Sopenharmony_ci return true; 3606f6ba60Sopenharmony_ci} 3706f6ba60Sopenharmony_ci 3806f6ba60Sopenharmony_cibool ServiceEntry::RegisterService(ServiceBase& psb) 3906f6ba60Sopenharmony_ci{ 4006f6ba60Sopenharmony_ci CHECK_TRUE(serviceMap_.find(psb.serviceName_) == serviceMap_.end(), false, "RegisterService FAIL"); 4106f6ba60Sopenharmony_ci serviceMap_[psb.serviceName_] = &psb; 4206f6ba60Sopenharmony_ci return true; 4306f6ba60Sopenharmony_ci} 4406f6ba60Sopenharmony_ciconst ServiceBase* ServiceEntry::FindServiceByName(const std::string& service_name) 4506f6ba60Sopenharmony_ci{ 4606f6ba60Sopenharmony_ci CHECK_TRUE(serviceMap_.find(service_name) != serviceMap_.end(), nullptr, "FindServiceByName FAIL %s", 4706f6ba60Sopenharmony_ci service_name.c_str()); 4806f6ba60Sopenharmony_ci 4906f6ba60Sopenharmony_ci return serviceMap_[service_name]; 5006f6ba60Sopenharmony_ci} 5106f6ba60Sopenharmony_ci 5206f6ba60Sopenharmony_cinamespace { 5306f6ba60Sopenharmony_ciconst int MS_PER_S = 1000; 5406f6ba60Sopenharmony_ciconst int US_PER_S = 1000000; 5506f6ba60Sopenharmony_ciconst int NS_PER_US = 1000; 5606f6ba60Sopenharmony_ciconst int NS_PER_S = 1000000000; 5706f6ba60Sopenharmony_ciconst int NS_PER_MS = 1000000; 5806f6ba60Sopenharmony_ci} // namespace 5906f6ba60Sopenharmony_ci 6006f6ba60Sopenharmony_ciuint64_t GetTimeMS() 6106f6ba60Sopenharmony_ci{ 6206f6ba60Sopenharmony_ci struct timespec ts; 6306f6ba60Sopenharmony_ci clock_gettime(CLOCK_BOOTTIME, &ts); 6406f6ba60Sopenharmony_ci return ts.tv_sec * MS_PER_S + ts.tv_nsec / NS_PER_MS; 6506f6ba60Sopenharmony_ci} 6606f6ba60Sopenharmony_ci 6706f6ba60Sopenharmony_ciuint64_t GetTimeUS() 6806f6ba60Sopenharmony_ci{ 6906f6ba60Sopenharmony_ci struct timespec ts; 7006f6ba60Sopenharmony_ci clock_gettime(CLOCK_BOOTTIME, &ts); 7106f6ba60Sopenharmony_ci return ts.tv_sec * US_PER_S + ts.tv_nsec / NS_PER_US; 7206f6ba60Sopenharmony_ci} 7306f6ba60Sopenharmony_ci 7406f6ba60Sopenharmony_ciuint64_t GetTimeNS() 7506f6ba60Sopenharmony_ci{ 7606f6ba60Sopenharmony_ci struct timespec ts; 7706f6ba60Sopenharmony_ci clock_gettime(CLOCK_BOOTTIME, &ts); 7806f6ba60Sopenharmony_ci return ts.tv_sec * NS_PER_S + ts.tv_nsec; 7906f6ba60Sopenharmony_ci}