| /external/webrtc/webrtc/p2p/base/ |
| D | stunrequest.cc | 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 …]
|
| D | stunport.cc | 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 …]
|
| D | stunrequest.h | 54 bool empty() { return requests_.empty(); } in empty()
66 RequestMap requests_; variable
|
| D | port.cc | 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()
|
| D | stunport.h | 214 StunRequestManager requests_; variable
|
| D | port.h | 618 StunRequestManager requests_; variable
|
| /external/tensorflow/tensorflow/contrib/cloud/kernels/ |
| D | bigquery_table_accessor_test.cc | 77 new FakeHttpRequestFactory(&requests_)), in CreateTableAccessor()
81 std::vector<HttpRequest*> requests_; member in tensorflow::BigQueryTableAccessorTest
100 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
187 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
192 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
217 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
222 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
248 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
253 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
278 requests_.emplace_back(new FakeHttpRequest( in TEST_F()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_response_cache.cc | 78 if (requests_.find(key) != requests_.end()) { in LookupOrCompute()
79 req = requests_[key]; in LookupOrCompute()
82 requests_[key] = req; in LookupOrCompute()
140 ordered_entries.reserve(requests_.size()); in MaybeCleanup()
141 for (const auto& p : requests_) { in MaybeCleanup()
177 << bytes_used << ". Cache size: " << requests_.size() << " -> " in MaybeCleanup()
180 std::swap(requests_, kept); in MaybeCleanup()
|
| D | grpc_response_cache.h | 84 std::unordered_map<string, std::shared_ptr<WorkerCacheEntry>> requests_
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | http_request_fake.h | 195 : requests_(requests) {} in FakeHttpRequestFactory()
198 EXPECT_EQ(current_index_, requests_->size()) in ~FakeHttpRequestFactory()
203 EXPECT_LT(current_index_, requests_->size()) in Create()
205 return (*requests_)[current_index_++]; in Create()
209 const std::vector<HttpRequest*>* requests_;
|
| /external/perfetto/src/ipc/ |
| D | host_impl_unittest.cc | 99 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in BindService()
100 requests_.emplace(request_id, 0); in BindService()
112 uint64_t request_id = requests_.empty() ? 1 : requests_.rbegin()->first + 1; in InvokeMethod()
113 requests_.emplace(request_id, 0); in InvokeMethod()
139 ASSERT_EQ(1u, requests_.count(frame->request_id())); in OnDataAvailable()
140 EXPECT_EQ(0, requests_[frame->request_id()]++); in OnDataAvailable()
162 std::map<uint64_t /* request_id */, int /* num_replies_received */> requests_; member in perfetto::ipc::__anon99777f4d0111::FakeClient
|
| /external/webrtc/webrtc/p2p/stunprober/ |
| D | stunprober.cc | 79 const std::vector<Request*>& requests() { return requests_; } in requests()
98 std::vector<Request*> requests_; member in stunprober::StunProber::Requester
125 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()
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| D | rtcp_utility.h | 38 uint32_t requests() const { return requests_; } in requests()
45 uint32_t requests_; variable
|
| D | rtcp_utility.cc | 28 requests_(0), in NackStats()
34 if (requests_ == 0 || in ReportRequest()
39 ++requests_; in ReportRequest()
|