Lines Matching refs:StreamServer
27 #define LOG_TAG "StreamServer"
33 StreamServer::~StreamServer()
39 void StreamServer::UdsStop()
54 int32_t StreamServer::GetClientFd(int32_t pid) const
63 int32_t StreamServer::GetClientPid(int32_t fd) const
72 bool StreamServer::SendMsg(int32_t fd, NetPacket &pkt)
87 void StreamServer::Multicast(const std::vector<int32_t> &fdList, NetPacket &pkt)
94 int32_t StreamServer::AddSocketPairInfo(const std::string &programName, int32_t moduleType, int32_t uid, int32_t pid,
129 int32_t StreamServer::SetSockOpt(int32_t &serverFd, int32_t &toReturnClientFd, int32_t &tokenType)
165 int32_t StreamServer::CloseFd(int32_t &serverFd, int32_t &toReturnClientFd)
178 void StreamServer::SetRecvFun(MsgServerFunCallback fun)
183 void StreamServer::ReleaseSession(int32_t fd, epoll_event &ev)
204 void StreamServer::OnPacket(int32_t fd, NetPacket &pkt)
211 void StreamServer::OnEpollRecv(int32_t fd, epoll_event &ev)
245 void StreamServer::OnEpollEvent(epoll_event &ev)
261 void StreamServer::DumpSession(const std::string &title)
271 SessionPtr StreamServer::GetSession(int32_t fd) const
282 SessionPtr StreamServer::GetSessionByPid(int32_t pid) const
292 bool StreamServer::AddSession(SessionPtr ses)
318 void StreamServer::DelSession(int32_t fd)
338 void StreamServer::AddSessionDeletedCallback(int32_t pid, std::function<void(SessionPtr)> callback)
349 void StreamServer::NotifySessionDeleted(SessionPtr ses)