Searched refs:mSockFd (Results 1 – 4 of 4) sorted by relevance
| /system/chre/host/common/ |
| D | socket_client.cc | 37 std::atomic_init(&mSockFd, INVALID_SOCKET); in SocketClient()
68 if (mSockFd != INVALID_SOCKET && shutdown(mSockFd, SHUT_RDWR) != 0) { in disconnect()
80 return (mSockFd != INVALID_SOCKET); in isConnected()
86 if (mSockFd == INVALID_SOCKET) { in sendMessage()
89 ssize_t bytesSent = send(mSockFd, data, length, 0); in sendMessage()
144 while (!mGracefulShutdown && (mSockFd != INVALID_SOCKET || reconnect())) { in receiveThread()
146 ssize_t bytesReceived = recv(mSockFd, buffer, sizeof(buffer), 0); in receiveThread()
161 if (close(mSockFd) != 0) { in receiveThread()
164 mSockFd = INVALID_SOCKET; in receiveThread()
251 mSockFd = socket_local_client_connect(sockFd, mSocketName, in tryConnect()
[all …]
|
| D | socket_server.cc | 72 mSockFd = android_get_control_socket(socketName); in run()
73 if (mSockFd == INVALID_SOCKET && allowSocketCreation) { in run()
75 mSockFd = socket_local_server(socketName, ANDROID_SOCKET_NAMESPACE_RESERVED, in run()
79 if (mSockFd == INVALID_SOCKET) { in run()
82 int ret = listen(mSockFd, kMaxPendingConnectionRequests); in run()
100 close(mSockFd); in run()
143 int clientSocket = accept(mSockFd, NULL, NULL); in acceptClientConnection()
252 mPollFds[kListenIndex].fd = mSockFd; in serviceSocket()
|
| /system/chre/host/common/include/chre_host/ |
| D | socket_client.h | 129 std::atomic<int> mSockFd; variable
|
| D | socket_server.h | 92 int mSockFd = INVALID_SOCKET; variable
|