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#ifndef UNIX_SOCKET_SERVER_H 1706f6ba60Sopenharmony_ci#define UNIX_SOCKET_SERVER_H 1806f6ba60Sopenharmony_ci 1906f6ba60Sopenharmony_ci#include <ostream> 2006f6ba60Sopenharmony_ci#include <thread> 2106f6ba60Sopenharmony_ci 2206f6ba60Sopenharmony_ci#include "socket_context.h" 2306f6ba60Sopenharmony_ci 2406f6ba60Sopenharmony_ci#include "client_connection.h" 2506f6ba60Sopenharmony_ci 2606f6ba60Sopenharmony_ciclass ServiceEntry; 2706f6ba60Sopenharmony_ci 2806f6ba60Sopenharmony_ciclass UnixSocketServer { 2906f6ba60Sopenharmony_cipublic: 3006f6ba60Sopenharmony_ci UnixSocketServer(); 3106f6ba60Sopenharmony_ci ~UnixSocketServer(); 3206f6ba60Sopenharmony_ci 3306f6ba60Sopenharmony_ci int socketHandle_; 3406f6ba60Sopenharmony_ci bool StartServer(const std::string& addrname, ServiceEntry& p); 3506f6ba60Sopenharmony_ci 3606f6ba60Sopenharmony_ci std::string sAddrName_; 3706f6ba60Sopenharmony_ci // private: 3806f6ba60Sopenharmony_ci ServiceEntry* serviceEntry_; 3906f6ba60Sopenharmony_ci 4006f6ba60Sopenharmony_ciprivate: 4106f6ba60Sopenharmony_ci void UnixSocketAccept(); 4206f6ba60Sopenharmony_ci std::map<int, std::shared_ptr<ClientConnection>> socketClients_; 4306f6ba60Sopenharmony_ci std::thread acceptThread_; 4406f6ba60Sopenharmony_ci}; 4506f6ba60Sopenharmony_ci 4606f6ba60Sopenharmony_ci#endif