Home
last modified time | relevance | path

Searched refs:socketId (Results 1 - 25 of 38) sorted by relevance

12

/base/useriam/user_auth_framework/services/remote_connect/src/
H A Dsoft_bus_server_socket.cpp24 ServerSocket::ServerSocket(const int32_t socketId) in ServerSocket() argument
25 : BaseSocket(socketId) in ServerSocket()
27 IAM_LOGI("server socket id is %{public}d.", socketId); in ServerSocket()
34 int32_t socketId = GetSocketIdByClientConnectionName(connectionName); in SendMessage() local
35 if (socketId == INVALID_SOCKET_ID) { in SendMessage()
40 return SendRequest(socketId, connectionName, srcEndPoint, destEndPoint, attributes, callback); in SendMessage()
43 void ServerSocket::OnBind(int32_t socketId, PeerSocketInfo info) in OnBind() argument
45 IAM_LOGI("start, socket id is %{public}d", socketId); in OnBind()
46 if (socketId <= INVALID_SOCKET_ID) { in OnBind()
52 AddServerSocket(socketId, peerNetworkI in OnBind()
55 OnShutdown(int32_t socketId, ShutdownReason reason) OnShutdown() argument
66 OnBytes(int32_t socketId, const void *data, uint32_t dataLen) OnBytes() argument
94 OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) OnQos() argument
99 AddServerSocket(const int32_t socketId, const std::string &networkId) AddServerSocket() argument
113 DeleteServerSocket(const int32_t socketId) DeleteServerSocket() argument
125 GetNetworkIdBySocketId(int32_t socketId) GetNetworkIdBySocketId() argument
138 AddClientConnection(const int32_t socketId, const std::string &connectionName) AddClientConnection() argument
150 DeleteClientConnection(const int32_t socketId) DeleteClientConnection() argument
164 GetClientConnectionName(const int32_t socketId) GetClientConnectionName() argument
180 int32_t socketId = INVALID_SOCKET_ID; GetSocketIdByClientConnectionName() local
[all...]
H A Dsoft_bus_socket_listener.cpp28 bool SoftBusSocketListener::OnNegotiate(int32_t socketId, PeerSocketInfo info) in OnNegotiate() argument
30 if (socketId <= INVALID_SOCKET_ID) { in OnNegotiate()
43 void SoftBusSocketListener::OnBind(int32_t socketId, PeerSocketInfo info) in OnBind() argument
45 IAM_LOGI("socket id is %{public}d.", socketId); in OnBind()
46 if (socketId <= INVALID_SOCKET_ID) { in OnBind()
56 SoftBusManager::GetInstance().OnBind(socketId, info); in OnBind()
59 void SoftBusSocketListener::OnShutdown(int32_t socketId, ShutdownReason reason) in OnShutdown() argument
61 IAM_LOGI("socket id %{public}d shutdown because %{public}d.", socketId, reason); in OnShutdown()
62 if (socketId <= INVALID_SOCKET_ID) { in OnShutdown()
67 SoftBusManager::GetInstance().OnShutdown(socketId, reaso in OnShutdown()
70 OnClientBytes(int32_t socketId, const void *data, uint32_t dataLen) OnClientBytes() argument
86 OnServerBytes(int32_t socketId, const void *data, uint32_t dataLen) OnServerBytes() argument
[all...]
H A Dsoft_bus_client_socket.cpp31 ClientSocket::ClientSocket(const int32_t socketId) in ClientSocket() argument
32 : BaseSocket(socketId) in ClientSocket()
34 IAM_LOGI("client socket id is %{public}d.", socketId); in ClientSocket()
48 int32_t socketId = GetSocketId(); in SendMessage() local
49 if (socketId == INVALID_SOCKET_ID) { in SendMessage()
55 return SendRequest(socketId, connectionName, srcEndPoint, destEndPoint, attributes, callback); in SendMessage()
58 void ClientSocket::OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) in OnQos() argument
60 IAM_LOGI("start, socket id is %{public}d", socketId); in OnQos()
63 void ClientSocket::OnShutdown(int32_t socketId, ShutdownReason reason) in OnShutdown() argument
65 IAM_LOGI("start, socket id is %{public}d", socketId); in OnShutdown()
72 OnBytes(int32_t socketId, const void *data, uint32_t dataLen) OnBytes() argument
97 OnBind(int32_t socketId, PeerSocketInfo info) OnBind() argument
[all...]
H A Dsoft_bus_manager.cpp238 ResultCode SoftBusManager::ServiceSocketListen(const int32_t socketId) in ServiceSocketListen() argument
254 int32_t ret = Listen(socketId, serverQos, QOS_LEN, &listener); in ServiceSocketListen()
304 int32_t socketId = Socket(info); in DoServiceSocketInit() local
305 if (socketId <= INVALID_SOCKET_ID) { in DoServiceSocketInit()
310 int ret = ServiceSocketListen(socketId); in DoServiceSocketInit()
316 auto serverSocket = SocketFactory::CreateServerSocket(socketId); in DoServiceSocketInit()
322 AddSocket(socketId, serverSocket); in DoServiceSocketInit()
346 for (int32_t socketId : socketIds) { in ServiceSocketUnInit()
347 IAM_LOGI("service down shutdown socket %{public}d", socketId); in ServiceSocketUnInit()
348 OnShutdown(socketId, SHUTDOWN_REASON_SERVICE_DIE in ServiceSocketUnInit()
394 ClientSocketBind(const int32_t socketId) ClientSocketBind() argument
436 int32_t socketId = ClientSocketInit(connectionName, networkId); DoOpenConnectionInner() local
508 int32_t socketId = clientSocket->GetSocketId(); DoCloseConnection() local
567 OnBind(int32_t socketId, PeerSocketInfo info) OnBind() argument
584 OnShutdown(int32_t socketId, ShutdownReason reason) OnShutdown() argument
614 OnClientBytes(int32_t socketId, const void *data, uint32_t dataLen) OnClientBytes() argument
632 OnServerBytes(int32_t socketId, const void *data, uint32_t dataLen) OnServerBytes() argument
650 AddSocket(const int32_t socketId, std::shared_ptr<BaseSocket> &socket) AddSocket() argument
660 DeleteSocket(const int32_t socketId) DeleteSocket() argument
674 FindSocketBySocketId(const int32_t socketId) FindSocketBySocketId() argument
[all...]
H A Dsocket_factory.cpp29 std::shared_ptr<BaseSocket> SocketFactory::CreateClientSocket(const int32_t socketId, const std::string &connectionName, in CreateClientSocket() argument
33 auto clientSocket = Common::MakeShared<ClientSocket>(socketId); in CreateClientSocket()
43 std::shared_ptr<BaseSocket> SocketFactory::CreateServerSocket(const int32_t socketId) in CreateServerSocket() argument
46 return Common::MakeShared<ServerSocket>(socketId); in CreateServerSocket()
H A Dsoft_bus_base_socket.cpp33 BaseSocket::BaseSocket(const int32_t socketId) in BaseSocket() argument
34 : socketId_(socketId) in BaseSocket()
37 currTraceInfo_.socketId = socketId; in BaseSocket()
141 [weakSelf = weak_from_this(), messageSeq, socketId = socketId_] { in StartReplyTimer()
144 IAM_LOGE("socket %{public}d is released", socketId); in StartReplyTimer()
212 ResultCode BaseSocket::SendRequest(const int32_t socketId, const std::string &connectionName, in SendRequest() argument
218 IF_FALSE_LOGE_AND_RETURN_VAL(socketId != INVALID_SOCKET_ID, INVALID_PARAMETERS); in SendRequest()
238 int ret = SendBytes(socketId, data.data(), data.size()); in SendRequest()
255 ResultCode BaseSocket::SendResponse(const int32_t socketId, cons argument
360 ProcDataReceive(const int32_t socketId, std::shared_ptr<SoftBusMessage> &softBusMessage) ProcDataReceive() argument
[all...]
/base/startup/appspawn/test/unittest/app_spawn_standard_test/
H A Dnweb_spawn_service_test.cpp219 int socketId = -1; in HWTEST_F() local
222 socketId = testServer->CreateSocket(1); in HWTEST_F()
223 APPSPAWN_CHECK(socketId >= 0, break, "Failed to create socket %{public}s", NWEBSPAWN_SERVER_NAME); in HWTEST_F()
230 int len = write(socketId, buffer.data(), msgLen); in HWTEST_F()
234 len = read(socketId, buffer.data(), buffer.size()); in HWTEST_F()
241 if (socketId >= 0) { in HWTEST_F()
242 CloseClientSocket(socketId); in HWTEST_F()
247 static int RecvMsg(int socketId, uint8_t *buffer, uint32_t buffSize) in RecvMsg() argument
249 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketId, buffer, buffSize)); in RecvMsg()
260 int socketId in HWTEST_F() local
291 int socketId = -1; HWTEST_F() local
324 int socketId = -1; HWTEST_F() local
377 int socketId = -1; HWTEST_F() local
417 int socketId = -1; HWTEST_F() local
457 int socketId = -1; HWTEST_F() local
486 int socketId = -1; HWTEST_F() local
[all...]
H A Dapp_spawn_service_test.cpp263 int socketId = -1; in HWTEST_F() local
266 socketId = testServer->CreateSocket(); in HWTEST_F()
267 APPSPAWN_CHECK(socketId >= 0, break, "Failed to create socket %{public}s", APPSPAWN_SERVER_NAME); in HWTEST_F()
274 int len = write(socketId, buffer.data(), msgLen); in HWTEST_F()
278 len = read(socketId, buffer.data(), buffer.size()); in HWTEST_F()
285 if (socketId >= 0) { in HWTEST_F()
286 CloseClientSocket(socketId); in HWTEST_F()
291 static int RecvMsg(int socketId, uint8_t *buffer, uint32_t buffSize) in RecvMsg() argument
293 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketId, buffer, buffSize)); in RecvMsg()
304 int socketId in HWTEST_F() local
335 int socketId = -1; HWTEST_F() local
368 int socketId = -1; HWTEST_F() local
421 int socketId = -1; HWTEST_F() local
462 int socketId = -1; HWTEST_F() local
502 int socketId = -1; HWTEST_F() local
531 int socketId = -1; HWTEST_F() local
[all...]
/base/hiviewdfx/hisysevent/interfaces/native/innerkits/hisysevent_easy/
H A Deasy_socket_writer.c35 static int InitSendBuffer(int socketId) in InitSendBuffer() argument
38 if (setsockopt(socketId, SOL_SOCKET, SO_SNDBUF, (void*)(&sendBuffSize), sizeof(int)) < 0) { in InitSendBuffer()
67 int socketId = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in Write() local
68 if (socketId < 0) { in Write()
69 close(socketId); in Write()
72 int ret = InitSendBuffer(socketId); in Write()
74 close(socketId); in Write()
80 close(socketId); in Write()
87 sendRet = sendto(socketId, data, dataLen, 0, (struct sockaddr*)(&socketAddr), in Write()
92 close(socketId); in Write()
[all...]
/base/useriam/user_auth_framework/services/remote_connect/inc/
H A Dsoft_bus_server_socket.h27 ServerSocket(const int32_t socketId);
33 void OnBind(int32_t socketId, PeerSocketInfo info) override;
34 void OnShutdown(int32_t socketId, ShutdownReason reason) override;
35 void OnBytes(int32_t socketId, const void *data, uint32_t dataLen) override;
36 void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) override;
42 void AddServerSocket(const int32_t socketId, const std::string &networkId);
43 void DeleteServerSocket(const int32_t socketId);
45 void AddClientConnection(const int32_t socketId, const std::string &connectionName);
46 void DeleteClientConnection(const int32_t socketId);
48 std::string GetNetworkIdBySocketId(int32_t socketId);
[all...]
H A Dsoft_bus_socket_listener.h35 static void OnBind(int32_t socketId, PeerSocketInfo info);
36 static void OnShutdown(int32_t socketId, ShutdownReason reason);
37 static void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) {}; in OnQos() argument
38 static void OnClientBytes(int32_t socketId, const void *data, uint32_t dataLen);
39 static void OnServerBytes(int32_t socketId, const void *data, uint32_t dataLen);
40 static bool OnNegotiate(int32_t socketId, PeerSocketInfo info);
H A Dsoft_bus_manager.h52 std::shared_ptr<BaseSocket> FindSocketBySocketId(const int32_t socketId);
54 void OnBind(int32_t socketId, PeerSocketInfo info);
55 void OnShutdown(int32_t socketId, ShutdownReason reason);
56 void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) {}; in OnQos() argument
57 void OnClientBytes(int32_t socketId, const void *data, uint32_t dataLen);
58 void OnServerBytes(int32_t socketId, const void *data, uint32_t dataLen);
76 ResultCode ServiceSocketListen(const int32_t socketId);
78 ResultCode ClientSocketBind(const int32_t socketId);
82 void AddSocket(const int32_t socketId, std::shared_ptr<BaseSocket> &socket);
83 void DeleteSocket(const int32_t socketId);
[all...]
H A Dsoft_bus_client_socket.h29 ClientSocket(const int32_t socketId);
35 void OnBind(int32_t socketId, PeerSocketInfo info) override;
36 void OnShutdown(int32_t socketId, ShutdownReason reason) override;
37 void OnBytes(int32_t socketId, const void *data, uint32_t dataLen) override;
38 void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) override;
H A Dsoft_bus_base_socket.h46 BaseSocket(const int32_t socketId);
51 ResultCode SendRequest(const int32_t socketId, const std::string &connectionName,
54 ResultCode SendResponse(const int32_t socketId, const std::string &connectionName,
59 ResultCode ProcDataReceive(const int32_t socketId, std::shared_ptr<SoftBusMessage> &softBusMessage);
64 virtual void OnBind(int32_t socketId, PeerSocketInfo info) = 0;
65 virtual void OnShutdown(int32_t socketId, ShutdownReason reason) = 0;
66 virtual void OnBytes(int32_t socketId, const void *data, uint32_t dataLen) = 0;
67 virtual void OnQos(int32_t socketId, QoSEvent eventId, const QosTV *qos, uint32_t qosCount) = 0;
H A Dsocket_factory.h32 static std::shared_ptr<BaseSocket> CreateClientSocket(const int32_t socketId,
34 static std::shared_ptr<BaseSocket> CreateServerSocket(const int32_t socketId);
/base/useriam/user_auth_framework/test/fuzztest/services/softbus_fuzzer/
H A Dsoft_bus_fuzzer.cpp58 int32_t socketId = parcel.ReadInt32(); in FuzzSoftBusBaseSocketSecond() local
59 auto clientSocket = Common::MakeShared<ClientSocket>(socketId); in FuzzSoftBusBaseSocketSecond()
61 clientSocket->OnBind(socketId, info); in FuzzSoftBusBaseSocketSecond()
68 clientSocket->OnShutdown(socketId, reason); in FuzzSoftBusBaseSocketSecond()
69 clientSocket->OnBytes(socketId, message, messageLen); in FuzzSoftBusBaseSocketSecond()
77 clientSocket->ProcDataReceive(socketId, softBusMessage1); in FuzzSoftBusBaseSocketSecond()
79 clientSocket->ProcDataReceive(socketId, softBusMessage1); in FuzzSoftBusBaseSocketSecond()
82 clientSocket->ProcDataReceive(socketId, softBusMessage1); in FuzzSoftBusBaseSocketSecond()
89 int32_t socketId = parcel.ReadInt32(); in FuzzSoftBusBaseSocketFisrst() local
90 auto clientSocket = Common::MakeShared<ClientSocket>(socketId); in FuzzSoftBusBaseSocketFisrst()
123 int32_t socketId = parcel.ReadInt32(); FuzzSoftBusServerSocketFisrst() local
155 int32_t socketId = parcel.ReadInt32(); FuzzSoftBusManagerFisrst() local
[all...]
/base/hiviewdfx/hisysevent/interfaces/native/innerkits/hisysevent/
H A Dtransport.cpp66 void Transport::InitRecvBuffer(int socketId) in InitRecvBuffer() argument
70 if (getsockopt(socketId, SOL_SOCKET, SO_SNDBUF, static_cast<void *>(&oldN), &oldOutSize) < 0) { in InitRecvBuffer()
75 if (setsockopt(socketId, SOL_SOCKET, SO_SNDBUF, static_cast<void *>(&sendBuffSize), sizeof(int)) < 0) { in InitRecvBuffer()
81 if (getsockopt(socketId, SOL_SOCKET, SO_SNDBUF, static_cast<void *>(&newN), &newOutSize) < 0) { in InitRecvBuffer()
90 auto socketId = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in SendToHiSysEventDataSource() local
91 if (socketId < 0) { in SendToHiSysEventDataSource()
95 InitRecvBuffer(socketId); in SendToHiSysEventDataSource()
99 sendRet = sendto(socketId, rawData.GetData(), rawData.GetDataLength(), 0, in SendToHiSysEventDataSource()
109 close(socketId); in SendToHiSysEventDataSource()
112 close(socketId); in SendToHiSysEventDataSource()
[all...]
/base/startup/appspawn/interfaces/innerkits/client/
H A Dappspawn_client.c71 clientInstance->socketId = -1; in InitClientInstance()
82 APPSPAWN_STATIC void CloseClientSocket(int socketId) in CloseClientSocket() argument
84 APPSPAWN_LOGV("Closed socket with fd %{public}d", socketId); in CloseClientSocket()
85 if (socketId >= 0) { in CloseClientSocket()
87 setsockopt(socketId, IPPROTO_TCP, TCP_NODELAY, (char *)&flag, sizeof(int)); in CloseClientSocket()
88 close(socketId); in CloseClientSocket()
212 static int HandleMsgSend(AppSpawnReqMsgMgr *reqMgr, int socketId, AppSpawnReqMsgNode *reqNode) in HandleMsgSend() argument
220 int ret = WriteMessage(socketId, sendBlock->buffer, sendBlock->currentIndex, in HandleMsgSend()
242 if (reqMgr->socketId < 0) { in TryCreateSocket()
243 reqMgr->socketId in TryCreateSocket()
[all...]
H A Dappspawn_client.h67 int socketId; member
/base/startup/init/test/systest/
H A Dloopclient_systest.c60 int socketId; member
117 clientInstance->socketId = -1; in InitClientInstance()
153 if (reqMgr->socketId >= 0) { in ClientDestroy()
154 CloseClientSocket(reqMgr->socketId); in ClientDestroy()
155 reqMgr->socketId = -1; in ClientDestroy()
161 static void CloseClientSocket(int socketId) in CloseClientSocket() argument
163 printf("Closed socket with fd %d \n", socketId); in CloseClientSocket()
164 if (socketId >= 0) { in CloseClientSocket()
166 setsockopt(socketId, IPPROTO_TCP, TCP_NODELAY, (char *)&flag, sizeof(int)); in CloseClientSocket()
167 close(socketId); in CloseClientSocket()
291 HandleMsgSend(ReqMsgMgr *reqMgr, int socketId, ReqMsgNode *reqNode) HandleMsgSend() argument
[all...]
H A Dloopserver_systest.c129 int socketId = GetControlSocket(name); in CreatePipeServer() local
130 printf("get socket from env %s socketId %d \n", SOCKET_NAME, socketId); in CreatePipeServer()
134 info.socketId = socketId; in CreatePipeServer()
157 int socketId = GetControlSocket(name); in CreateTcpServer() local
158 printf("get socket from env %s socketId %d \n", SOCKET_NAME, socketId); in CreateTcpServer()
162 info.socketId = socketId; in CreateTcpServer()
[all...]
/base/hiviewdfx/hiview/plugins/sysevent_source/
H A Devent_server.cpp59 void InitSocketBuf(int socketId, int optName) in InitSocketBuf() argument
63 if (getsockopt(socketId, SOL_SOCKET, optName, static_cast<void *>(&bufferSizeOld), &sizeOfInt) < 0) { in InitSocketBuf()
68 if (setsockopt(socketId, SOL_SOCKET, optName, static_cast<void *>(&bufferSizeSet), sizeof(int)) < 0) { in InitSocketBuf()
74 if (getsockopt(socketId, SOL_SOCKET, optName, static_cast<void *>(&bufferSizeNew), &sizeOfInt) < 0) { in InitSocketBuf()
80 void InitRecvBuffer(int socketId) in InitRecvBuffer() argument
82 InitSocketBuf(socketId, SO_RCVBUF); in InitRecvBuffer()
147 void SocketDevice::InitSocket(int &socketId) in InitSocket() argument
152 socketId = -1; in InitSocket()
157 socketId = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCK_DGRAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0)); in InitSocket()
158 if (socketId < in InitSocket()
[all...]
/base/hiviewdfx/hisysevent/interfaces/native/innerkits/hisysevent/include/
H A Dtransport.h43 void InitRecvBuffer(int socketId);
/base/useriam/user_auth_framework/frameworks/native/common/dfx/inc/
H A Dhisysevent_adapter.h95 int32_t socketId = -1; member
100 int32_t socketId = -1; member
/base/security/device_security_level/baselib/msglib/src/standard/
H A Dmessenger_device_socket_manager.c378 static int32_t ProcessCreateServer(const char *session, const char *pkg, int32_t *socketId) in ProcessCreateServer() argument
380 if (session == NULL || pkg == NULL || socketId == NULL) { in ProcessCreateServer()
426 *socketId = socket; in ProcessCreateServer()
635 static int32_t PrepareBindSocket(const char *socketName, DeviceIdentify *devId, int32_t *socketId, bool isSame) in PrepareBindSocket() argument
637 if (socketName == NULL || devId == NULL || socketId == NULL) { in PrepareBindSocket()
681 *socketId = socket; in PrepareBindSocket()

Completed in 12 milliseconds

12