Home
last modified time | relevance | path

Searched refs:serverFd (Results 1 – 8 of 8) sorted by relevance

/base/sensors/sensor/services/sensor/src/
Dstream_server.cpp80 int32_t &serverFd, int32_t &clientFd) in AddSocketPairInfo() argument
88 serverFd = sockFds[0]; in AddSocketPairInfo()
90 if (serverFd < 0 || clientFd < 0) { in AddSocketPairInfo()
96 if (setsockopt(serverFd, SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
100 if (setsockopt(serverFd, SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
112 sess = std::make_shared<StreamSession>("", serverFd, uid, pid); in AddSocketPairInfo()
121 close(serverFd); in AddSocketPairInfo()
Dsensor_service.cpp486 int32_t serverFd = -1; in CreateSocketChannel() local
489 serverFd, std::ref(clientFd)); in CreateSocketChannel()
/base/msdp/device_status/services/native/src/
Dstream_server.cpp95 int32_t& serverFd, int32_t& toReturnClientFd, int32_t& tokenType) in AddSocketPairInfo() argument
104 serverFd = sockFds[0]; in AddSocketPairInfo()
106 if (serverFd < 0 || toReturnClientFd < 0) { in AddSocketPairInfo()
113 if (setsockopt(serverFd, SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
117 if (setsockopt(serverFd, SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
140 sess = std::make_shared<StreamSession>(programName, moduleType, serverFd, uid, pid); in AddSocketPairInfo()
146 if (AddEpoll(EPOLL_EVENT_SOCKET, serverFd) != RET_OK) { in AddSocketPairInfo()
154 if (close(serverFd) < 0) { in AddSocketPairInfo()
155 …HILOGE("Close server fd failed, error:%{public}s, serverFd:%{public}d", strerror(errno), serverFd); in AddSocketPairInfo()
157 serverFd = -1; in AddSocketPairInfo()
Ddevicestatus_service.cpp302 int32_t serverFd = -1; in AllocSocketFd() local
306 programName, moduleType, uid, pid, serverFd, std::ref(toReturnClientFd), tokenType)); in AllocSocketFd()
/base/startup/init/services/loopevent/socket/
Dle_socket.c137 static int AcceptPipeSocket_(int serverFd) in AcceptPipeSocket_() argument
142 int fd = accept(serverFd, (struct sockaddr *)&clientAddr, &addrlen); in AcceptPipeSocket_()
148 static int AcceptTcpSocket_(int serverFd) in AcceptTcpSocket_() argument
153 int fd = accept(serverFd, (struct sockaddr *)&clientAddr, &addrlen); in AcceptTcpSocket_()
/base/msdp/device_status/services/native/include/
Di_stream_server.h28 int32_t pid, int32_t& serverFd, int32_t& toReturnClientFd,
Dstream_server.h55 int32_t& serverFd, int32_t& toReturnClientFd, int32_t& tokenType) override;
/base/sensors/sensor/services/sensor/include/
Dstream_server.h35 …int32_t AddSocketPairInfo(int32_t uid, int32_t pid, int32_t tokenType, int32_t &serverFd, int32_t …