Lines Matching refs:clientSocket
71 int clientSocket = pair.first; in run() local
72 if (close(clientSocket) != 0) { in run()
88 int clientSocket = pair.first; in sendToAllClients() local
90 if (sendToClientSocket(data, length, clientSocket, clientId)) { in sendToAllClients()
112 int clientSocket = pair.first; in sendToClientById() local
113 sent = sendToClientSocket(data, length, clientSocket, thisClientId); in sendToClientById()
122 int clientSocket = accept(mSockFd, NULL, NULL); in acceptClientConnection() local
123 if (clientSocket < 0) { in acceptClientConnection()
127 close(clientSocket); in acceptClientConnection()
144 mPollFds[i].fd = clientSocket; in acceptClientConnection()
153 close(clientSocket); in acceptClientConnection()
157 mClients[clientSocket] = clientData; in acceptClientConnection()
167 void SocketServer::handleClientData(int clientSocket) { in handleClientData() argument
168 const ClientData &clientData = mClients[clientSocket]; in handleClientData()
172 recv(clientSocket, mRecvBuffer.data(), mRecvBuffer.size(), MSG_DONTWAIT); in handleClientData()
177 disconnectClient(clientSocket); in handleClientData()
181 disconnectClient(clientSocket); in handleClientData()
188 void SocketServer::disconnectClient(int clientSocket) { in disconnectClient() argument
191 mClients.erase(clientSocket); in disconnectClient()
193 close(clientSocket); in disconnectClient()
197 if (mPollFds[i].fd == clientSocket) { in disconnectClient()
211 int clientSocket, uint16_t clientId) { in sendToClientSocket() argument
213 ssize_t bytesSent = send(clientSocket, data, length, 0); in sendToClientSocket()