Lines Matching refs:t
80 for (size_t t = 0; t < arraysize(fetcher->fd_task_maps_); ++t) { in LibcurlCloseSocketCallback() local
81 const auto fd_task_pair = fetcher->fd_task_maps_[t].find(item); in LibcurlCloseSocketCallback()
82 if (fd_task_pair != fetcher->fd_task_maps_[t].end()) { in LibcurlCloseSocketCallback()
86 << (t ? "writing" : "reading") << " the fd " << item; in LibcurlCloseSocketCallback()
88 fetcher->fd_task_maps_[t].erase(item); in LibcurlCloseSocketCallback()
618 for (size_t t = 0; t < arraysize(fd_task_maps_); ++t) { in SetupMessageLoopSources() local
619 if (!fd_task_maps_[t].empty()) in SetupMessageLoopSources()
620 fd_max = max(fd_max, fd_task_maps_[t].rbegin()->first); in SetupMessageLoopSources()
640 for (size_t t = 0; t < arraysize(fd_task_maps_); ++t) { in SetupMessageLoopSources() local
641 auto fd_task_it = fd_task_maps_[t].find(fd); in SetupMessageLoopSources()
642 bool tracked = fd_task_it != fd_task_maps_[t].end(); in SetupMessageLoopSources()
644 if (!must_track[t]) { in SetupMessageLoopSources()
648 fd_task_maps_[t].erase(fd_task_it); in SetupMessageLoopSources()
658 fd_task_maps_[t][fd] = MessageLoop::current()->WatchFileDescriptor( in SetupMessageLoopSources()
661 watch_modes[t], in SetupMessageLoopSources()
717 for (size_t t = 0; t < arraysize(fd_task_maps_); ++t) { in CleanUp() local
718 for (const auto& fd_taks_pair : fd_task_maps_[t]) { in CleanUp()
721 << " for " << (t ? "writing" : "reading") << " the fd " in CleanUp()
725 fd_task_maps_[t].clear(); in CleanUp()