Home
last modified time | relevance | path

Searched refs:connectionName (Results 1 – 25 of 37) sorted by relevance

12

/ohos5.0/base/useriam/user_auth_framework/services/remote_connect/src/
H A Dremote_connect_listener_manager.cpp31 (connectionName == other.connectionName || connectionName == GLOBAL_CONNECTION_NAME); in operator ==()
49 ListenerInfo info = { connectionName, endPointName, listener }; in RegisterListener()
73 ListenerInfo info = { connectionName, endPointName }; in UnregisterListener()
94 ListenerInfo info = { connectionName, endPointName }; in FindListener()
107 IAM_LOGI("OnConnectionDown connectionName:%{public}s", connectionName.c_str()); in OnConnectionDown()
113 if (it->connectionName == connectionName) { in OnConnectionDown()
119 [&](ListenerInfo item) { return item.connectionName == connectionName; }), in OnConnectionDown()
124 void RemoteConnectListenerManager::OnConnectionUp(const std::string &connectionName) in OnConnectionUp() argument
127 IAM_LOGI("OnConnectionUp connectionName:%{public}s", connectionName.c_str()); in OnConnectionUp()
129 if (it->connectionName == connectionName) { in OnConnectionUp()
[all …]
H A Dsoft_bus_manager.cpp357 std::string clientName = USER_AUTH_SOCKET_NAME + connectionName; in ClientSocketInit()
434 int32_t socketId = ClientSocketInit(connectionName, networkId); in DoOpenConnectionInner()
452 AddConnection(connectionName, clientSocket); in DoOpenConnectionInner()
483 ThreadHandlerManager::GetInstance().PostTask(connectionName, [=]() { in OpenConnection()
484 DoOpenConnection(connectionName, tokenId, networkId); in OpenConnection()
508 DeleteConnection(connectionName); in DoCloseConnection()
517 ThreadHandlerManager::GetInstance().PostTask(connectionName, [=]() { in CloseConnection()
518 DoCloseConnection(connectionName); in CloseConnection()
715 auto iter = clientSocketMap_.find(connectionName); in DeleteConnection()
720 clientSocketMap_.erase(connectionName); in DeleteConnection()
[all …]
H A Dsoft_bus_server_socket.cpp34 int32_t socketId = GetSocketIdByClientConnectionName(connectionName); in SendMessage()
40 return SendRequest(socketId, connectionName, srcEndPoint, destEndPoint, attributes, callback); in SendMessage()
58 std::string connectionName = GetClientConnectionName(socketId); in OnShutdown() local
59 if (!connectionName.empty()) { in OnShutdown()
60 RemoteConnectListenerManager::GetInstance().OnConnectionDown(connectionName); in OnShutdown()
82 std::string connectionName = softBusMessage->GetConnectionName(); in OnBytes() local
83 if (ack == false && !connectionName.empty()) { in OnBytes()
84 AddClientConnection(socketId, connectionName); in OnBytes()
158 std::string connectionName = iter->second; in DeleteClientConnection() local
177 int32_t ServerSocket::GetSocketIdByClientConnectionName(const std::string &connectionName) in GetSocketIdByClientConnectionName() argument
[all …]
H A Dremote_connect_manager.cpp36 ResultCode RemoteConnectionManager::OpenConnection(const std::string &connectionName, in OpenConnection() argument
40 return SoftBusManager::GetInstance().OpenConnection(connectionName, tokenId, remoteNetworkId); in OpenConnection()
43 ResultCode RemoteConnectionManager::CloseConnection(const std::string &connectionName) in CloseConnection() argument
46 return SoftBusManager::GetInstance().CloseConnection(connectionName); in CloseConnection()
49 ResultCode RemoteConnectionManager::RegisterConnectionListener(const std::string &connectionName, in RegisterConnectionListener() argument
53 …return RemoteConnectListenerManager::GetInstance().RegisterListener(connectionName, endPointName, … in RegisterConnectionListener()
63 ResultCode RemoteConnectionManager::UnregisterConnectionListener(const std::string &connectionName, in UnregisterConnectionListener() argument
67 …return RemoteConnectListenerManager::GetInstance().UnregisterListener(connectionName, endPointName… in UnregisterConnectionListener()
76 ResultCode RemoteConnectionManager::SendMessage(const std::string &connectionName, in SendMessage() argument
81 return SoftBusManager::GetInstance().SendMessage(connectionName, in SendMessage()
H A Dsoft_bus_client_socket.cpp44 ResultCode ClientSocket::SendMessage(const std::string &connectionName, const std::string &srcEndPo… in SendMessage() argument
55 return SendRequest(socketId, connectionName, srcEndPoint, destEndPoint, attributes, callback); in SendMessage()
66 std::string connectionName = GetConnectionName(); in OnShutdown() local
67 if (!connectionName.empty()) { in OnShutdown()
68 RemoteConnectListenerManager::GetInstance().OnConnectionDown(connectionName); in OnShutdown()
112 void ClientSocket::SetConnectionName(const std::string &connectionName) in SetConnectionName() argument
114 connectionName_ = connectionName; in SetConnectionName()
145 … IAM_LOGI("ConnectionName: %{public}s, receive keep alive message ack", connectionName.c_str()); in SendKeepAliveMessage()
158 [connectionName = connectionName_]() { in SendKeepAliveMessage()
159 RemoteConnectListenerManager::GetInstance().OnConnectionDown(connectionName); in SendKeepAliveMessage()
[all …]
H A Dsoft_bus_base_socket.cpp58 .connectionName = connectionName, in InsertMsgCallback()
77 std::string connectionName; in GetConnectionName() local
80 connectionName = iter->second.connectionName; in GetConnectionName()
82 return connectionName; in GetConnectionName()
162 std::string connectionName = GetConnectionName(messageSeq); in ReplyTimerTimeOut() local
163 if (connectionName.empty()) { in ReplyTimerTimeOut()
205 connectionName, srcEndPoint, destEndPoint, attributes); in SendRequest()
230 InsertMsgCallback(messageSeq, connectionName, callback, timerId); in SendRequest()
244 connectionName, srcEndPoint, destEndPoint, attributes); in SendResponse()
315 std::string connectionName = softBusMessage->GetConnectionName(); in ProcessMessage() local
[all …]
H A Dsocket_factory.cpp29 …ocket> SocketFactory::CreateClientSocket(const int32_t socketId, const std::string &connectionName, in CreateClientSocket() argument
38 clientSocket->SetConnectionName(connectionName); in CreateClientSocket()
39 clientSocket->SetNetworkId(connectionName); in CreateClientSocket()
H A Dremote_connect_listener.cpp23 void ConnectionListener::OnMessage(const std::string &connectionName, const std::string &secEndPoin… in OnMessage() argument
29 void ConnectionListener::OnConnectStatus(const std::string &connectionName, ConnectStatus connectSt… in OnConnectStatus() argument
/ohos5.0/base/useriam/user_auth_framework/test/fuzztest/services/softbus_fuzzer/
H A Dsoft_bus_fuzzer.cpp88 std::string connectionName = parcel.ReadString(); in FuzzSoftBusBaseSocketFisrst() local
115 clientSocket->SetConnectionName(connectionName); in FuzzSoftBusBaseSocketFisrst()
125 std::string connectionName = parcel.ReadString(); in FuzzSoftBusServerSocketFisrst() local
133 serverSocket->AddClientConnection(socketId, connectionName); in FuzzSoftBusServerSocketFisrst()
142 serverSocket->SendMessage(connectionName, connectionName, connectionName, attributes, callback); in FuzzSoftBusServerSocketFisrst()
160 std::string connectionName = parcel.ReadString(); in FuzzSoftBusManagerFisrst() local
169 softBusManager.FindClientSocket(connectionName); in FuzzSoftBusManagerFisrst()
181 softBusManager.CloseConnection(connectionName); in FuzzSoftBusManagerFisrst()
186 softBusManager.AddConnection(connectionName, clientSocket1); in FuzzSoftBusManagerFisrst()
187 softBusManager.DeleteConnection(connectionName); in FuzzSoftBusManagerFisrst()
[all …]
/ohos5.0/base/useriam/user_auth_framework/services/remote_connect/inc/
H A Dsoft_bus_manager.h43 …ResultCode OpenConnection(const std::string &connectionName, const uint32_t tokenId, const std::st…
44 ResultCode CloseConnection(const std::string &connectionName);
46 ResultCode SendMessage(const std::string &connectionName,
50 std::shared_ptr<BaseSocket> FindClientSocket(const std::string &connectionName);
59 void DoOpenConnection(const std::string &connectionName, const uint32_t tokenId,
61 ResultCode DoCloseConnection(const std::string &connectionName);
77 int32_t ClientSocketInit(const std::string &connectionName, const std::string &networkId);
80 void AddConnection(const std::string &connectionName, std::shared_ptr<BaseSocket> &socket);
81 void DeleteConnection(const std::string &connectionName);
86 ResultCode DoOpenConnectionInner(const std::string &connectionName, const uint32_t tokenId,
H A Dremote_connect_listener_manager.h35 ResultCode RegisterListener(const std::string &connectionName, const std::string &endPointName,
38 … ResultCode UnregisterListener(const std::string &connectionName, const std::string &endPointName);
41 std::shared_ptr<ConnectionListener> FindListener(const std::string &connectionName,
43 void OnConnectionDown(const std::string &connectionName);
44 void OnConnectionUp(const std::string &connectionName);
47 std::string connectionName; member
H A Dremote_connect_manager.h38 ResultCode OpenConnection(const std::string &connectionName,
40 ResultCode CloseConnection(const std::string &connectionName);
41 ResultCode RegisterConnectionListener(const std::string &connectionName,
45 ResultCode UnregisterConnectionListener(const std::string &connectionName,
48 ResultCode SendMessage(const std::string &connectionName,
H A Dsoft_bus_base_socket.h48 … virtual ResultCode SendMessage(const std::string &connectionName, const std::string &srcEndPoint,
50 ResultCode SendRequest(const int32_t socketId, const std::string &connectionName,
53 ResultCode SendResponse(const int32_t socketId, const std::string &connectionName,
71 std::string connectionName; member
78 void InsertMsgCallback(uint32_t messageSeq, const std::string &connectionName,
H A Dremote_connect_listener.h40 virtual void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
42 … virtual void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) = 0;
H A Dsoft_bus_client_socket.h32 ResultCode SendMessage(const std::string &connectionName, const std::string &srcEndPoint,
42 void SetConnectionName(const std::string &connectionName);
/ohos5.0/base/useriam/user_auth_framework/test/fuzztest/services/core/remoteexecutorstub_fuzzer/
H A Dremote_executor_stub_fuzzer.cpp57 std::string connectionName = parcel.ReadString(); in FuzzTest() local
62 g_RemoteExecutorStub->OnMessage(connectionName, srcEndPoint, request, reply); in FuzzTest()
79 std::string connectionName = parcel.ReadString(); in RemoteExecutorProxyFuzzTest() local
81 auto remoteExecutorProxy = MakeShared<RemoteExecutorProxy>(connectionName, regiregisterInfo); in RemoteExecutorProxyFuzzTest()
87 remoteExecutorProxy->OnMessage(connectionName, srcEndPoint, request, reply); in RemoteExecutorProxyFuzzTest()
88 remoteExecutorProxy->OnConnectStatus(connectionName, ConnectStatus::DISCONNECTED); in RemoteExecutorProxyFuzzTest()
105 std::string connectionName = parcel.ReadString(); in RemoteMsgUtilFuzzTest() local
106 RemoteMsgUtil::GetConnectionName(contextId, connectionName); in RemoteMsgUtilFuzzTest()
/ohos5.0/base/useriam/user_auth_framework/services/context/src/
H A Dremote_auth_service.cpp46 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
49 …int32_t ProcStartRemoteAuthRequest(std::string connectionName, const std::shared_ptr<Attributes> &…
72 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint, in OnMessage() argument
78 …IAM_LOGI("connectionName: %{public}s, srcEndPoint: %{public}s", connectionName.c_str(), srcEndPoin… in OnMessage()
80 RemoteAuthServiceImpl::GetInstance().OnMessage(connectionName, srcEndPoint, request, reply); in OnMessage()
83 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override in OnConnectStatus() argument
108 void RemoteAuthServiceImpl::OnMessage(const std::string &connectionName, const std::string &srcEndP… in OnMessage() argument
125 resultCode = ProcStartRemoteAuthRequest(connectionName, request, reply); in OnMessage()
176 int32_t RemoteAuthServiceImpl::ProcStartRemoteAuthRequest(std::string connectionName, in ProcStartRemoteAuthRequest() argument
208 remoteAuthContextParam.connectionName = connectionName; in ProcStartRemoteAuthRequest()
[all …]
H A Dremote_auth_context.cpp49 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint, in OnMessage() argument
55 …IAM_LOGI("connectionName: %{public}s, srcEndPoint: %{public}s", connectionName.c_str(), srcEndPoin… in OnMessage()
58 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override in OnConnectStatus() argument
60 …IAM_LOGI("connectionName: %{public}s, connectStatus %{public}d", connectionName.c_str(), connectSt… in OnConnectStatus()
64 …[connectionName, connectStatus, callbackWeakBase = callbackWeakBase_, callback = callback_, this](… in OnConnectStatus()
70 callback->OnConnectStatus(connectionName, connectStatus); in OnConnectStatus()
86 connectionName_(param.connectionName), in RemoteAuthContext()
277 void RemoteAuthContext::OnConnectStatus(const std::string &connectionName, ConnectStatus connectSta… in OnConnectStatus() argument
281 IF_FALSE_LOGE_AND_RETURN(connectionName_ == connectionName); in OnConnectStatus()
H A Dremote_auth_invoker_context.cpp50 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint, in OnMessage() argument
56 …IAM_LOGI("connectionName: %{public}s, srcEndPoint: %{public}s", connectionName.c_str(), srcEndPoin… in OnMessage()
62 callback_->OnMessage(connectionName, srcEndPoint, request, reply); in OnMessage()
65 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override in OnConnectStatus() argument
67 …IAM_LOGI("connectionName: %{public}s, connectStatus %{public}d", connectionName.c_str(), connectSt… in OnConnectStatus()
71 …[connectionName, connectStatus, callbackWeakBase = callbackWeakBase_, callback = callback_, this](… in OnConnectStatus()
77 callback->OnConnectStatus(connectionName, connectStatus); in OnConnectStatus()
93 connectionName_(param.connectionName), in RemoteAuthInvokerContext()
128 void RemoteAuthInvokerContext::OnMessage(const std::string &connectionName, const std::string &srcE… in OnMessage() argument
155 void RemoteAuthInvokerContext::OnConnectStatus(const std::string &connectionName, ConnectStatus con… in OnConnectStatus() argument
/ohos5.0/base/useriam/user_auth_framework/test/fuzztest/services/context/remoteauthcontext_fuzzer/
H A Dremote_auth_context_fuzzer.cpp106 param.connectionName = parcel.ReadString(); in RemoteAuthContextFuzzTest()
120 std::string connectionName = parcel.ReadString(); in RemoteAuthContextFuzzTest() local
121 remoteAuthContext->OnConnectStatus(connectionName, ConnectStatus::DISCONNECTED); in RemoteAuthContextFuzzTest()
122 remoteAuthContext->OnConnectStatus(connectionName, ConnectStatus::CONNECTED); in RemoteAuthContextFuzzTest()
144 param.connectionName = parcel.ReadString(); in RemoteAuthInvokerContextFuzzTest()
158 std::string connectionName = parcel.ReadString(); in RemoteAuthInvokerContextFuzzTest() local
159 remoteAuthInvokerContext->OnConnectStatus(connectionName, ConnectStatus::DISCONNECTED); in RemoteAuthInvokerContextFuzzTest()
160 remoteAuthInvokerContext->OnConnectStatus(connectionName, ConnectStatus::CONNECTED); in RemoteAuthInvokerContextFuzzTest()
168 remoteAuthInvokerContext->OnMessage(connectionName, srcEndPoint, request, reply); in RemoteAuthInvokerContextFuzzTest()
183 std::string connectionName = parcel.ReadString(); in RemoteIamCallbackFuzzTest() local
[all …]
/ohos5.0/base/useriam/user_auth_framework/services/core/src/
H A Dremote_executor_proxy.cpp94 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint, in OnMessage() argument
104 callback->OnMessage(connectionName, srcEndPoint, request, reply); in OnMessage()
107 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override in OnConnectStatus() argument
109 …IAM_LOGI("connectionName: %{public}s, connectStatus %{public}d", connectionName.c_str(), connectSt… in OnConnectStatus()
113 threadHandler_->PostTask([connectionName, connectStatus, callbackTemp = callback_, this]() { in OnConnectStatus()
117 callback->OnConnectStatus(connectionName, connectStatus); in OnConnectStatus()
129 RemoteExecutorProxy::RemoteExecutorProxy(std::string connectionName, ExecutorInfo registerInfo) in RemoteExecutorProxy() argument
130 : connectionName_(connectionName), in RemoteExecutorProxy()
174 void RemoteExecutorProxy::OnMessage(const std::string &connectionName, const std::string &srcEndPoi… in OnMessage() argument
180 IF_FALSE_LOGE_AND_RETURN(connectionName_ == connectionName); in OnMessage()
[all …]
/ohos5.0/base/useriam/user_auth_framework/services/context/inc/
H A Dremote_auth_context.h32 std::string connectionName; member
46 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
48 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus);
H A Dremote_auth_invoker_context.h33 std::string connectionName; member
50 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
52 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus);
H A Dremote_auth_service.h39 virtual void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
42 …virtual int32_t ProcStartRemoteAuthRequest(std::string connectionName, const std::shared_ptr<Attri…
/ohos5.0/base/useriam/user_auth_framework/services/core/inc/
H A Dremote_executor_proxy.h33 RemoteExecutorProxy(std::string connectionName, ExecutorInfo registerInfo);
39 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
41 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus);

12