| /base/msdp/device_status/services/native/src/ |
| H A D | stream_server.cpp | 95 int32_t &serverFd, int32_t &toReturnClientFd, int32_t &tokenType)
in AddSocketPairInfo()
104 serverFd = sockFds[0];
in AddSocketPairInfo()
106 if (serverFd < 0 || toReturnClientFd < 0) {
in AddSocketPairInfo()
110 int32_t setSockOptResult = SetSockOpt(serverFd, toReturnClientFd, tokenType);
in AddSocketPairInfo()
115 sess = std::make_shared<StreamSession>(programName, moduleType, serverFd, uid, pid);
in AddSocketPairInfo()
119 return CloseFd(serverFd, toReturnClientFd);
in AddSocketPairInfo()
121 if (AddEpoll(EPOLL_EVENT_SOCKET, serverFd) != RET_OK) {
in AddSocketPairInfo()
123 return CloseFd(serverFd, toReturnClientFd);
in AddSocketPairInfo()
129 int32_t StreamServer::SetSockOpt(int32_t &serverFd, int32_t &toReturnClientFd, int32_t &tokenType)
in SetSockOpt() argument
135 if (setsockopt(serverFd, SOL_SOCKE in SetSockOpt()
94 AddSocketPairInfo(const std::string &programName, int32_t moduleType, int32_t uid, int32_t pid, int32_t &serverFd, int32_t &toReturnClientFd, int32_t &tokenType) AddSocketPairInfo() argument
165 CloseFd(int32_t &serverFd, int32_t &toReturnClientFd) CloseFd() argument
[all...] |
| H A D | devicestatus_service.cpp | 387 int32_t serverFd = -1; in AllocSocketFd() local
391 [this, programName, moduleType, uid, pid, &serverFd, &toReturnClientFd, &tokenType] { in AllocSocketFd()
392 return this->AddSocketPairInfo(programName, moduleType, uid, pid, serverFd, in AllocSocketFd()
|
| /base/sensors/sensor/services/src/ |
| H A D | stream_server.cpp | 82 int32_t &serverFd, int32_t &clientFd) in AddSocketPairInfo()
90 serverFd = sockFds[0]; in AddSocketPairInfo()
92 if (serverFd < 0 || clientFd < 0) { in AddSocketPairInfo()
98 if (setsockopt(serverFd, SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
99 SEN_HILOGE("Setsockopt serverFd send buffer size failed, errno:%{public}d", errno); in AddSocketPairInfo()
102 if (setsockopt(serverFd, SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
103 SEN_HILOGE("Setsockopt serverFd recv buffer size failed, errno:%{public}d", errno); in AddSocketPairInfo()
114 sess = std::make_shared<StreamSession>("", serverFd, uid, pid); in AddSocketPairInfo()
123 close(serverFd); in AddSocketPairInfo()
81 AddSocketPairInfo(int32_t uid, int32_t pid, int32_t tokenType, int32_t &serverFd, int32_t &clientFd) AddSocketPairInfo() argument
|
| H A D | sensor_service.cpp | 533 int32_t serverFd = -1; in CreateSocketChannel() local
536 serverFd, std::ref(clientFd)); in CreateSocketChannel()
|
| /base/msdp/device_status/services/native/include/ |
| H A D | stream_server.h | 56 int32_t &serverFd, int32_t &toReturnClientFd, int32_t &tokenType) override;
62 int32_t SetSockOpt(int32_t &serverFd, int32_t &toReturnClientFd, int32_t &tokenType);
63 int32_t CloseFd(int32_t &serverFd, int32_t &toReturnClientFd);
|
| H A D | i_stream_server.h | 28 int32_t pid, int32_t &serverFd, int32_t &toReturnClientFd,
|
| /base/sensors/sensor/services/include/ |
| H A D | stream_server.h | 35 int32_t AddSocketPairInfo(int32_t uid, int32_t pid, int32_t tokenType, int32_t &serverFd, int32_t &clientFd);
|
| /base/startup/init/services/loopevent/socket/ |
| H A D | le_socket.c | 167 static int AcceptPipeSocket_(int serverFd)
in AcceptPipeSocket_() argument
172 int fd = accept(serverFd, (struct sockaddr *)&clientAddr, &addrlen);
in AcceptPipeSocket_()
178 static int AcceptTcpSocket_(int serverFd)
in AcceptTcpSocket_() argument
183 int fd = accept(serverFd, (struct sockaddr *)&clientAddr, &addrlen);
in AcceptTcpSocket_()
|