153 void RunLoop::postSocketRecv(int sock, AsyncFunction fn) {  in postSocketRecv()  argument
154     CHECK_GE(sock, 0);  in postSocketRecv()
158     mAddInfos.push_back({ sock, InfoType::RECV, fn });  in postSocketRecv()
162 void RunLoop::postSocketSend(int sock, AsyncFunction fn) {  in postSocketSend()  argument
163     CHECK_GE(sock, 0);  in postSocketSend()
167     mAddInfos.push_back({ sock, InfoType::SEND, fn });  in postSocketSend()
171 void RunLoop::cancelSocket(int sock) {  in cancelSocket()  argument
172     CHECK_GE(sock, 0);  in cancelSocket()
175     mAddInfos.push_back({ sock, InfoType::CANCEL, nullptr });  in cancelSocket()
229                 const int sock = addInfo.mSock;  in run()  local
232                 auto it = socketCallbacksByFd.find(sock);  in run()
238                             socketCallbacksByFd[sock] = { fn, nullptr, pollFds.size() };  in run()
239                             pollFds.push_back({ sock, POLLIN, 0 });  in run()
255                             socketCallbacksByFd[sock] = { nullptr, fn, pollFds.size() };  in run()
256                             pollFds.push_back({ sock, POLLOUT, 0 });  in run()
263                                     << sock;  in run()
272                                     << sock;  in run()
378                         const int sock = pollFd.fd;  in run()  local
380                         const auto &it = socketCallbacksByFd.find(sock);  in run()