Searched refs:TMessenger (Results 1 - 4 of 4) sorted by relevance
/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
H A D | tmessenger.h | 74 // class 'TMessenger' is used to notify test result 75 class TMessenger { class 77 static TMessenger &GetInstance() in GetInstance() 79 static TMessenger instance; in GetInstance() 93 TMessenger() = default; 94 TMessenger(const TMessenger &other) = delete; 95 TMessenger(const TMessenger &&other) = delete; 96 TMessenger [all...] |
H A D | tmessenger.cpp | 126 int32_t TMessenger::Open( in Open() 133 void TMessenger::Close() in Close() 152 int32_t TMessenger::StartListen(const std::string &pkgName, const std::string &myName) in StartListen() 175 .OnBind = TMessenger::OnBind, in StartListen() 176 .OnMessage = TMessenger::OnMessage, in StartListen() 177 .OnShutdown = TMessenger::OnShutdown, in StartListen() 192 int32_t TMessenger::StartConnect(const std::string &pkgName, const std::string &myName, const std::string &peerName) in StartConnect() 240 void TMessenger::OnBind(int32_t socket, PeerSocketInfo info) in OnBind() 242 TMessenger::GetInstance().SetConnectSocket(socket, info); in OnBind() 245 void TMessenger [all...] |
H A D | stream_encrypt_server_mt.cpp | 47 ret = TMessenger::GetInstance().Open(PKG_NAME, TEST_NOTIFY_SRV_NAME, "", true); in SetUpTestCase() 55 TMessenger::GetInstance().Close(); in TearDownTestCase() 142 TMessenger::GetInstance().RegisterOnQuery([] { in HWTEST_F() 201 TMessenger::GetInstance().RegisterOnQuery([] { in HWTEST_F() 261 TMessenger::GetInstance().RegisterOnQuery([] { in HWTEST_F() 321 TMessenger::GetInstance().RegisterOnQuery([] { in HWTEST_F()
|
H A D | stream_encrypt_client_mt.cpp | 43 ret = TMessenger::GetInstance().Open(PKG_NAME, TEST_NOTIFY_NAME, TEST_NOTIFY_SRV_NAME, false); in SetUpTestCase() 51 TMessenger::GetInstance().Close(); in TearDownTestCase() 147 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F() 200 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F() 341 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F()
|
Completed in 3 milliseconds