Searched refs:requests_ (Results 1 – 10 of 10) sorted by relevance
32 while (requests_.begin() != requests_.end()) { in ~StunRequestManager()33 StunRequest *request = requests_.begin()->second; in ~StunRequestManager()34 requests_.erase(requests_.begin()); in ~StunRequestManager()45 ASSERT(requests_.find(request->id()) == requests_.end()); in SendDelayed()48 requests_[request->id()] = request; in SendDelayed()57 for (const auto kv : requests_) { in Flush()68 RequestMap::iterator iter = requests_.find(request->id()); in Remove()69 if (iter != requests_.end()) { in Remove()71 requests_.erase(iter); in Remove()78 for (RequestMap::iterator i = requests_.begin(); i != requests_.end(); ++i) in Clear()[all …]
68 port_->requests_.SendDelayed( in OnResponse()89 port_->requests_.SendDelayed( in OnErrorResponse()177 requests_(thread), in UDPPort()183 requests_.set_origin(origin); in UDPPort()205 requests_(thread), in UDPPort()211 requests_.set_origin(origin); in UDPPort()228 requests_.SignalSendPacket.connect(this, &UDPPort::OnSendPacket); in Init()238 ASSERT(requests_.empty()); in PrepareAddress()330 requests_.CheckResponse(data, size); in OnReadPacket()353 ASSERT(requests_.empty()); in SendStunBindingRequests()[all …]
54 bool empty() { return requests_.empty(); } in empty()66 RequestMap requests_; variable
777 requests_(port->thread()), in Connection()794 requests_.SignalSendPacket.connect(this, &Connection::OnSendStunPacket); in Connection()937 requests_.CheckResponse(msg.get()); in OnReadPacket()997 requests_.Clear(); in Prune()1100 requests_.Send(req); in Ping()
214 StunRequestManager requests_; variable
618 StunRequestManager requests_; variable
213 Requests requests_; member in mojo::common::__anonbd2b9ff10111::WatcherThreadManager248 for (Requests::iterator i = requests_.begin(); i != requests_.end(); ++i) { in StopWatching()251 requests_.erase(i); in StopWatching()266 const bool was_empty = requests_.empty(); in AddRequest()267 requests_.push_back(data); in AddRequest()285 requests_.swap(requests); in ProcessRequestsOnBackendThread()
79 const std::vector<Request*>& requests() { return requests_; } in requests()98 std::vector<Request*> requests_; member in stunprober::StunProber::Requester125 for (auto req : requests_) { in ~Requester()134 requests_.push_back(new Request()); in SendStunRequest()135 Request& request = *(requests_.back()); in SendStunRequest()221 for (auto request : requests_) { in GetRequestByAddress()
38 uint32_t requests() const { return requests_; } in requests()45 uint32_t requests_; variable
28 requests_(0), in NackStats()34 if (requests_ == 0 || in ReportRequest()39 ++requests_; in ReportRequest()