| /base/startup/appspawn/interfaces/innerkits/client/ |
| D | appspawn_socket.cpp | 81 int socketFd = socket(AF_UNIX, SOCK_STREAM, 0); // SOCK_SEQPACKET in CreateSocket() local
82 APPSPAWN_CHECK(socketFd >= 0, return -errno, "Failed to create socket: %{public}d", errno); in CreateSocket()
85 int ret = setsockopt(socketFd, IPPROTO_TCP, TCP_NODELAY, (char *)&flag, sizeof(int)); in CreateSocket()
86 APPSPAWN_LOGV("Created socket with fd %{public}d, setsockopt %{public}d", socketFd, ret); in CreateSocket()
87 return socketFd; in CreateSocket()
90 void AppSpawnSocket::CloseSocket(int &socketFd) in CloseSocket() argument
92 if (socketFd >= 0) { in CloseSocket()
93 APPSPAWN_LOGV("Closed socket with fd %{public}d", socketFd); in CloseSocket()
95 setsockopt(socketFd, IPPROTO_TCP, TCP_NODELAY, (char *)&flag, sizeof(int)); in CloseSocket()
96 close(socketFd); in CloseSocket()
[all …]
|
| /base/startup/appspawn/test/unittest/app_spawn_socket_test/ |
| D | app_spawn_socket_test.cpp | 62 auto socketFd = appSpawnSocket->CreateSocket(); variable
63 EXPECT_LE(0, socketFd);
64 appSpawnSocket->CloseSocket(socketFd);
65 EXPECT_EQ(-1, socketFd);
85 int32_t socketFd = -2; variable
86 appSpawnSocket->CloseSocket(socketFd);
88 EXPECT_EQ(-2, socketFd);
171 int32_t socketFd = -1; variable
176 EXPECT_EQ(-1, appSpawnSocket->ReadSocketMessage(socketFd, buff.get(), len));
195 auto socketFd = appSpawnSocket->CreateSocket(); variable
[all …]
|
| /base/hiviewdfx/hilog/frameworks/libhilog/base/ |
| D | hilog_base.c | 40 int socketFd = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCKET_TYPE, 0)); in SendMessage() local
41 if (socketFd < 0) { in SendMessage()
43 return socketFd; in SendMessage()
47 …TEMP_FAILURE_RETRY(connect(socketFd, (const struct sockaddr *)(&SOCKET_ADDR), sizeof(SOCKET_ADDR))… in SendMessage()
50 if (socketFd >= 0) { in SendMessage()
51 close(socketFd); in SendMessage()
73 int ret = TEMP_FAILURE_RETRY(writev(socketFd, vec, LOG_LEN)); in SendMessage()
74 if (socketFd >= 0) { in SendMessage()
75 close(socketFd); in SendMessage()
|
| /base/msdp/device_status/intention/ipc/socket/src/ |
| D | socket_params.cpp | 41 AllocSocketPairReply::AllocSocketPairReply(int32_t tokenType, int32_t socketFd) in AllocSocketPairReply() argument
42 : tokenType(tokenType), socketFd(socketFd) in AllocSocketPairReply()
49 parcel.WriteFileDescriptor(socketFd) in Marshalling()
57 ((socketFd = parcel.ReadFileDescriptor()) >= 0) in Unmarshalling()
|
| D | socket_connection.cpp | 31 SocketConnection::SocketConnection(int32_t socketFd, in SocketConnection() argument
34 : socketFd_(socketFd), recv_(recv), onDisconnected_(onDisconnected) in SocketConnection()
|
| D | socket_client.cpp | 92 FI_HILOGD("Connected to intention service (%{public}d)", reply.socketFd); in Socket()
93 return reply.socketFd; in Socket()
|
| /base/startup/appspawn/interfaces/innerkits/include/ |
| D | appspawn_socket.h | 65 virtual int ReadSocketMessage(int socketFd, void *buf, int len);
76 virtual int WriteSocketMessage(int socketFd, const void *buf, int len);
83 static void CloseSocket(int &socketFd);
|
| /base/tee/tee_client/frameworks/libteec_vendor/ |
| D | tee_client_socket.c | 34 static int ConnectTeecdSocket(int *socketFd) in ConnectTeecdSocket() argument
40 if (socketFd == NULL) { in ConnectTeecdSocket()
79 *socketFd = s; in ConnectTeecdSocket()
100 static int RecvFileDescriptor(int cmd, int socketFd) in RecvFileDescriptor() argument
135 res = recvmsg(socketFd, &hmsg, 0); in RecvFileDescriptor()
142 res = recvmsg(socketFd, &hmsg, 0); in RecvFileDescriptor()
|
| /base/msdp/device_status/intention/ipc/socket/include/ |
| D | socket_params.h | 43 AllocSocketPairReply(int32_t tokenType, int32_t socketFd);
48 int32_t socketFd { -1 };
|
| D | socket_connection.h | 34 SocketConnection(int32_t socketFd,
|
| /base/security/access_token/services/tokensyncmanager/src/remote/ |
| D | soft_bus_manager.cpp | 332 int32_t socketFd = InitSocketAndListener(networkId, listener); in BindService() local
337 ACCESSTOKEN_LOG_DEBUG(LABEL, "create client socket[%{public}d] success.", socketFd); in BindService()
342 auto iter = clientSocketMap_.find(socketFd); in BindService()
344 clientSocketMap_.insert(std::pair<int32_t, std::string>(socketFd, networkId)); in BindService()
362 int32_t res = ::Bind(socketFd, clientQos, QOS_LEN, &listener); in BindService()
371 ACCESSTOKEN_LOG_DEBUG(LABEL, "Bind service succeed, socketFd is %{public}d.", socketFd); in BindService()
372 return socketFd; in BindService()
375 int SoftBusManager::CloseSocket(int socketFd) in CloseSocket() argument
377 if (socketFd <= Constant::INVALID_SOCKET_FD) { in CloseSocket()
382 ::Shutdown(socketFd); in CloseSocket()
[all …]
|
| /base/startup/appspawn/test/unittest/client_socket_test/ |
| D | client_socket_test.cpp | 64 int32_t socketFd = clientSocket->GetSocketFd(); variable
66 EXPECT_EQ(socketFd, clientSocket->GetSocketFd());
303 int32_t socketFd = clientSocket->GetSocketFd(); variable
305 EXPECT_EQ(socketFd, clientSocket->GetSocketFd());
|
| /base/security/access_token/services/tokensyncmanager/include/remote/ |
| D | soft_bus_manager.h | 80 int CloseSocket(int socketFd);
|
| /base/hiviewdfx/faultloggerd/services/ |
| D | fault_logger_daemon.h | 36 void HandleAccept(int32_t epollFd, int32_t socketFd);
|
| D | fault_logger_daemon.cpp | 131 void FaultLoggerDaemon::HandleAccept(int32_t epollFd, int32_t socketFd) in HandleAccept() argument
136 …int connectionFd = accept(socketFd, reinterpret_cast<struct sockaddr *>(&clientAddr), &clientAddrS… in HandleAccept()
143 connectionMap_.insert(std::pair<int32_t, int32_t>(connectionFd, socketFd)); in HandleAccept()
|
| /base/msdp/device_status/services/communication/base/ |
| D | i_devicestatus.h | 59 int32_t &socketFd, int32_t &tokenType) = 0;
|
| /base/msdp/device_status/services/communication/client/include/ |
| D | devicestatus_srv_proxy.h | 41 int32_t &socketFd, int32_t &tokenType) override;
|
| /base/msdp/device_status/services/communication/client/src/ |
| D | devicestatus_srv_proxy.cpp | 496 int32_t &socketFd, int32_t &tokenType) in AllocSocketFd() argument
516 socketFd = reply.ReadFileDescriptor(); in AllocSocketFd()
517 if (socketFd < RET_OK) { in AllocSocketFd()
518 FI_HILOGE("Read file descriptor failed, fd:%{public}d", socketFd); in AllocSocketFd()
522 FI_HILOGD("socketFd:%{public}d, tokenType:%{public}d", socketFd, tokenType); in AllocSocketFd()
|