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}