Searched refs:AppPipeHandler (Results 1 – 8 of 8) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | app_pipe_handler.cpp | 34 AppPipeHandler::~AppPipeHandler() in ~AppPipeHandler()
39 AppPipeHandler::AppPipeHandler(const PipeInfo &pipeInfo) in AppPipeHandler() function in OHOS::AppDistributedKv::AppPipeHandler
46 std::pair<Status, int32_t> AppPipeHandler::SendData(const PipeInfo &pipeInfo, const DeviceId &devic… in SendData()
52 Status AppPipeHandler::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &… in StartWatchDataChange()
57 Status AppPipeHandler::StopWatchDataChange(__attribute__((unused))const AppDataChangeListener *obse… in StopWatchDataChange()
63 bool AppPipeHandler::IsSameStartedOnPeer(const struct PipeInfo &pipeInfo, in IsSameStartedOnPeer()
69 void AppPipeHandler::SetMessageTransFlag(const PipeInfo &pipeInfo, bool flag) in SetMessageTransFlag()
74 int AppPipeHandler::CreateSessionServer(const std::string &sessionName) const in CreateSessionServer()
79 int AppPipeHandler::RemoveSessionServer(const std::string &sessionName) const in RemoveSessionServer()
|
| H A D | app_pipe_mgr.cpp | 70 std::shared_ptr<AppPipeHandler> appPipeHandler; in SendData()
97 auto handler = std::make_shared<AppPipeHandler>(pipeInfo); in Start()
104 …dataBusMap_.insert(std::pair<std::string, std::shared_ptr<AppPipeHandler>>(pipeInfo.pipeId, handle… in Start()
117 std::shared_ptr<AppPipeHandler> appPipeHandler = it->second; in Stop()
135 std::shared_ptr<AppPipeHandler> appPipeHandler; in IsSameStartedOnPeer()
153 std::shared_ptr<AppPipeHandler> appPipeHandler; in SetMessageTransFlag()
|
| H A D | app_pipe_handler.h | 35 class AppPipeHandler {
37 ~AppPipeHandler();
38 explicit AppPipeHandler(const PipeInfo &pipeInfo);
|
| H A D | app_pipe_mgr.h | 51 std::map<std::string, std::shared_ptr<AppPipeHandler>> dataBusMap_ {};
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | app_pipe_handler.cpp | 26 AppPipeHandler::~AppPipeHandler() in ~AppPipeHandler()
31 AppPipeHandler::AppPipeHandler(const PipeInfo &pipeInfo) : pipeInfo_(pipeInfo) in AppPipeHandler() function in OHOS::ObjectStore::AppPipeHandler
37 Status AppPipeHandler::SendData(const PipeInfo &pipeInfo, const DeviceId &deviceId, const DataInfo … in SendData()
43 Status AppPipeHandler::StartWatchDataChange(const AppDataChangeListener *observer, const PipeInfo &… in StartWatchDataChange()
48 Status AppPipeHandler::StopWatchDataChange( in StopWatchDataChange()
54 bool AppPipeHandler::IsSameStartedOnPeer( in IsSameStartedOnPeer()
60 int AppPipeHandler::CreateSessionServer(const std::string &sessionName) const in CreateSessionServer()
65 int AppPipeHandler::RemoveSessionServer(const std::string &sessionName) const in RemoveSessionServer()
|
| H A D | app_pipe_mgr.cpp | 66 std::shared_ptr<AppPipeHandler> appPipeHandler; in SendData()
93 auto handler = std::make_shared<AppPipeHandler>(pipeInfo); in Start()
100 …dataBusMap_.insert(std::pair<std::string, std::shared_ptr<AppPipeHandler>>(pipeInfo.pipeId, handle… in Start()
107 std::shared_ptr<AppPipeHandler> appPipeHandler; in Stop()
135 std::shared_ptr<AppPipeHandler> appPipeHandler; in IsSameStartedOnPeer()
|
| /ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/communicator/ |
| H A D | app_pipe_handler.h | 31 class AppPipeHandler {
33 ~AppPipeHandler();
34 explicit AppPipeHandler(const PipeInfo &pipeInfo);
|
| H A D | app_pipe_mgr.h | 55 std::map<std::string, std::shared_ptr<AppPipeHandler>> dataBusMap_{};
|