Home
last modified time | relevance | path

Searched refs:connectionName (Results 1 - 25 of 44) sorted by relevance

12

/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 ==()
41 ResultCode RemoteConnectListenerManager::RegisterListener(const std::string &connectionName, in RegisterListener() argument
46 IAM_LOGI("RegisterListener connectionName:%{public}s, endPointName:%{public}s", connectionName.c_str(), in RegisterListener()
49 ListenerInfo info = { connectionName, endPointName, listener }; in RegisterListener()
67 ResultCode RemoteConnectListenerManager::UnregisterListener(const std::string &connectionName, in UnregisterListener() argument
71 IAM_LOGI("UnregisterListener connectionName:%{public}s, endPointName:%{public}s", connectionName in UnregisterListener()
90 FindListener(const std::string &connectionName, const std::string &endPointName) FindListener() argument
104 OnConnectionDown(const std::string &connectionName) OnConnectionDown() argument
124 OnConnectionUp(const std::string &connectionName) OnConnectionUp() 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, listener); 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()
[all...]
H A Dsoft_bus_manager.cpp354 int32_t SoftBusManager::ClientSocketInit(const std::string &connectionName, const std::string &networkId) in ClientSocketInit() argument
357 std::string clientName = USER_AUTH_SOCKET_NAME + connectionName; in ClientSocketInit()
426 ResultCode SoftBusManager::DoOpenConnectionInner(const std::string &connectionName, const uint32_t tokenId, in DoOpenConnectionInner() argument
429 trace.connectionName = connectionName; in DoOpenConnectionInner()
436 int32_t socketId = ClientSocketInit(connectionName, networkId); in DoOpenConnectionInner()
443 auto clientSocket = SocketFactory::CreateClientSocket(socketId, connectionName, networkId); in DoOpenConnectionInner()
445 IAM_LOGE("CreateClientSocket failed, connectionName:%{public}s", connectionName.c_str()); in DoOpenConnectionInner()
455 AddConnection(connectionName, clientSocke in DoOpenConnectionInner()
461 DoOpenConnection(const std::string &connectionName, const uint32_t tokenId, const std::string &networkId) DoOpenConnection() argument
486 OpenConnection(const std::string &connectionName, const uint32_t tokenId, const std::string &networkId) OpenConnection() argument
499 DoCloseConnection(const std::string &connectionName) DoCloseConnection() argument
521 CloseConnection(const std::string &connectionName) CloseConnection() argument
533 SendMessage(const std::string &connectionName, const std::string &srcEndPoint, const std::string &destEndPoint, const std::shared_ptr<Attributes> &attributes, MsgCallback &callback) SendMessage() argument
716 AddConnection(const std::string &connectionName, std::shared_ptr<BaseSocket> &socket) AddConnection() argument
725 DeleteConnection(const std::string &connectionName) DeleteConnection() argument
737 FindClientSocket(const std::string &connectionName) FindClientSocket() argument
[all...]
H A Dsoft_bus_server_socket.cpp30 ResultCode ServerSocket::SendMessage(const std::string &connectionName, const std::string &srcEndPoint, in SendMessage() argument
34 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()
138 void ServerSocket::AddClientConnection(const int32_t socketId, const std::string &connectionName) in AddClientConnection() argument
158 std::string connectionName = iter->second; DeleteClientConnection() local
177 GetSocketIdByClientConnectionName(const std::string &connectionName) GetSocketIdByClientConnectionName() argument
[all...]
H A Dsoft_bus_client_socket.cpp44 ResultCode ClientSocket::SendMessage(const std::string &connectionName, const std::string &srcEndPoint, 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()
144 MsgCallback sendKeepAliveCallback = [connectionName = connectionName_](const std::shared_ptr<Attributes> &) { in SendKeepAliveMessage()
145 IAM_LOGI("ConnectionName: %{public}s, receive keep alive message ack", connectionName.c_str()); in SendKeepAliveMessage()
158 [connectionName in SendKeepAliveMessage()
[all...]
H A Dsoft_bus_base_socket.cpp57 void BaseSocket::InsertMsgCallback(uint32_t messageSeq, const std::string &connectionName, in InsertMsgCallback() argument
65 .connectionName = connectionName, in InsertMsgCallback()
84 std::string connectionName; in GetConnectionName() local
87 connectionName = iter->second.connectionName; in GetConnectionName()
89 return connectionName; in GetConnectionName()
169 std::string connectionName = GetConnectionName(messageSeq); in ReplyTimerTimeOut() local
170 if (connectionName.empty()) { in ReplyTimerTimeOut()
171 IAM_LOGE("GetMsgCallback connectionName fai in ReplyTimerTimeOut()
204 RefreshTraceInfo(const std::string &connectionName, int32_t msgType, bool ack, uint32_t messageSeq) RefreshTraceInfo() argument
212 SendRequest(const int32_t socketId, const std::string &connectionName, const std::string &srcEndPoint, const std::string &destEndPoint, const std::shared_ptr<Attributes> &attributes, MsgCallback &callback) SendRequest() argument
255 SendResponse(const int32_t socketId, const std::string &connectionName, const std::string &srcEndPoint, const std::string &destEndPoint, const std::shared_ptr<Attributes> &attributes, uint32_t messageSeq) SendResponse() argument
342 std::string connectionName = softBusMessage->GetConnectionName(); ProcessMessage() local
386 std::string connectionName = softBusMessage->GetConnectionName(); ProcDataReceive() local
[all...]
H A Dremote_connect_listener.cpp23 void ConnectionListener::OnMessage(const std::string &connectionName, const std::string &secEndPoint, in OnMessage() argument
29 void ConnectionListener::OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) in OnConnectStatus() argument
H A Dsocket_factory.cpp29 std::shared_ptr<BaseSocket> SocketFactory::CreateClientSocket(const int32_t socketId, const std::string &connectionName, in CreateClientSocket() argument
38 clientSocket->SetConnectionName(connectionName); in CreateClientSocket()
/base/useriam/user_auth_framework/services/remote_connect/inc/
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 Dsoft_bus_manager.h43 ResultCode OpenConnection(const std::string &connectionName, const uint32_t tokenId, const std::string &networkId);
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, cons
[all...]
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.h49 virtual ResultCode SendMessage(const std::string &connectionName, const std::string &srcEndPoint,
51 ResultCode SendRequest(const int32_t socketId, const std::string &connectionName,
54 ResultCode SendResponse(const int32_t socketId, const std::string &connectionName,
73 std::string connectionName; member
80 void InsertMsgCallback(uint32_t messageSeq, const std::string &connectionName,
92 void RefreshTraceInfo(const std::string &connectionName, int32_t msgType, bool ack, uint32_t messageSeq);
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);
/base/useriam/user_auth_framework/test/fuzztest/services/softbus_fuzzer/
H A Dsoft_bus_fuzzer.cpp88 std::string connectionName = parcel.ReadString(); in FuzzSoftBusBaseSocketFisrst() local
99 clientSocket->SendMessage(connectionName, srcEndPoint, destEndPoint, attributes, callback); in FuzzSoftBusBaseSocketFisrst()
101 clientSocket->SendResponse(socketId, connectionName, srcEndPoint, destEndPoint, attributes, messageSeq); in FuzzSoftBusBaseSocketFisrst()
106 clientSocket->InsertMsgCallback(messageSeq, connectionName, callback, timerId); in FuzzSoftBusBaseSocketFisrst()
115 clientSocket->SetConnectionName(connectionName); in FuzzSoftBusBaseSocketFisrst()
125 std::string connectionName = parcel.ReadString(); in FuzzSoftBusServerSocketFisrst() local
133 serverSocket->AddClientConnection(socketId, connectionName); in FuzzSoftBusServerSocketFisrst()
137 serverSocket->GetSocketIdByClientConnectionName(connectionName); in FuzzSoftBusServerSocketFisrst()
142 serverSocket->SendMessage(connectionName, connectionName, connectionNam in FuzzSoftBusServerSocketFisrst()
160 std::string connectionName = parcel.ReadString(); FuzzSoftBusManagerFisrst() local
[all...]
/base/useriam/user_auth_framework/test/fuzztest/services/core/remoteexecutorstub_fuzzer/
H A Dremote_executor_stub_fuzzer.cpp57 trace.connectionName = parcel.ReadString(); in FuzzTest()
61 std::string connectionName = parcel.ReadString(); in FuzzTest() local
66 g_RemoteExecutorStub->OnMessage(connectionName, srcEndPoint, request, reply); in FuzzTest()
83 std::string connectionName = parcel.ReadString(); in RemoteExecutorProxyFuzzTest() local
85 auto remoteExecutorProxy = MakeShared<RemoteExecutorProxy>(connectionName, regiregisterInfo); in RemoteExecutorProxyFuzzTest()
91 remoteExecutorProxy->OnMessage(connectionName, srcEndPoint, request, reply); in RemoteExecutorProxyFuzzTest()
92 remoteExecutorProxy->OnConnectStatus(connectionName, ConnectStatus::DISCONNECTED); in RemoteExecutorProxyFuzzTest()
109 std::string connectionName = parcel.ReadString(); in RemoteMsgUtilFuzzTest() local
110 RemoteMsgUtil::GetConnectionName(contextId, connectionName); in RemoteMsgUtilFuzzTest()
/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 in RemoteIamCallbackFuzzTest() local
[all...]
/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,
43 const std::string &connectionName, const std::shared_ptr<Attributes> &request,
/base/useriam/user_auth_framework/frameworks/native/common/dfx/inc/
H A Dhisysevent_adapter.h39 std::string connectionName; member
55 std::string connectionName; member
86 std::string connectionName; member
91 std::string connectionName; member
101 std::string connectionName; member
/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(const std::string &connectionName, const std::shared_ptr<Attributes> &request,
63 std::shared_ptr<ContextCallback> GetRemoteAuthContextCallback(std::string connectionName,
74 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
80 IAM_LOGI("connectionName: %{public}s, srcEndPoint: %{public}s", connectionName.c_str(), srcEndPoint.c_str());
82 RemoteAuthServiceImpl::GetInstance().OnMessage(connectionName, srcEndPoint, request, reply);
85 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override
110 void RemoteAuthServiceImpl::OnMessage(const std::string &connectionName, const std::string &srcEndPoint, in OnMessage() argument
127 resultCode = ProcStartRemoteAuthRequest(connectionName, reques in OnMessage()
181 GetRemoteAuthContextCallback(std::string connectionName, Authentication::AuthenticationPara para) GetRemoteAuthContextCallback() argument
199 ProcStartRemoteAuthRequest(const std::string &connectionName, const std::shared_ptr<Attributes> &request, std::shared_ptr<Attributes> &reply) ProcStartRemoteAuthRequest() argument
[all...]
H A Dremote_auth_context.cpp49 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
55 IAM_LOGI("connectionName: %{public}s, srcEndPoint: %{public}s", connectionName.c_str(), srcEndPoint.c_str());
58 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override
60 IAM_LOGI("connectionName: %{public}s, connectStatus %{public}d", connectionName.c_str(), connectStatus);
64 [connectionName, connectStatus, callbackWeakBase = callbackWeakBase_, callback = callback_, this]() {
70 callback->OnConnectStatus(connectionName, connectStatus);
86 connectionName_(param.connectionName), in RemoteAuthContext()
183 IAM_LOGI("%{public}s start remote auth success, connectionName in StartAuth()
286 OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) OnConnectStatus() argument
[all...]
/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);
/base/useriam/user_auth_framework/services/core/src/
H A Dremote_executor_proxy.cpp94 void OnMessage(const std::string &connectionName, const std::string &srcEndPoint,
100 IAM_LOGI("connectionName: %{public}s, srcEndPoint: %{public}s", connectionName.c_str(), srcEndPoint.c_str());
104 callback->OnMessage(connectionName, srcEndPoint, request, reply);
107 void OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) override
109 IAM_LOGI("connectionName: %{public}s, connectStatus %{public}d", connectionName.c_str(), connectStatus);
113 threadHandler_->PostTask([connectionName, connectStatus, callbackTemp = callback_, this]() {
117 callback->OnConnectStatus(connectionName, connectStatus);
129 RemoteExecutorProxy::RemoteExecutorProxy(std::string connectionName, ExecutorInf argument
174 OnMessage(const std::string &connectionName, const std::string &srcEndPoint, const std::shared_ptr<Attributes> &request, std::shared_ptr<Attributes> &reply) OnMessage() argument
208 OnConnectStatus(const std::string &connectionName, ConnectStatus connectStatus) OnConnectStatus() argument
[all...]

Completed in 9 milliseconds

12