Searched refs:requests_ (Results 1 – 11 of 11) 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
75 requests_.insert(std::make_pair(++last_request_id_, response_callback)); in SendRequestWithCustomTimeout()111 auto p = requests_.find(id); in HandleIqStanza()112 if (p != requests_.end()) { in HandleIqStanza()116 requests_.erase(p); in HandleIqStanza()136 if (requests_.erase(id) > 0) in OnTimeOut()
74 std::map<RequestId, ResponseCallback> requests_; variable
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()