Searched refs:sent_ (Results 1 – 3 of 3) sorted by relevance
| /external/openscreen/osp/public/ |
| D | request_response_handler.h | 79 for (auto& message : sent_) { in Reset()
82 sent_.clear(); in Reset()
104 sent_.emplace_back(RequestWithId{id, std::move(message)}); in WriteMessage()
130 sent_.erase(std::remove_if( in CancelMessage()
131 sent_.begin(), sent_.end(), in CancelMessage()
133 sent_.end()); in CancelMessage()
134 if (sent_.empty()) { in CancelMessage()
148 sent_.emplace_back(std::move(message)); in SetConnection()
176 sent_.begin(), sent_.end(), [&response](const RequestWithId& msg) { in OnStreamMessage()
180 if (it != sent_.end()) { in OnStreamMessage()
[all …]
|
| /external/webrtc/test/network/ |
| D | network_emulation.h | 236 sent_.emplace(next_packet_id_, packet); in SendPacket()
244 action_(std::move(sent_[packet_id]), packet.arrival_time); in OnPacketReceived()
245 sent_.erase(packet_id); in OnPacketReceived()
254 std::map<int, FakePacketType> sent_; variable
|
| /external/webrtc/rtc_base/ |
| D | ssl_stream_adapter_unittest.cc | 799 sent_(0) {} in SSLStreamAdapterTestDTLSBase()
808 sent_(0) {} in SSLStreamAdapterTestDTLSBase()
820 while (sent_ < count_) { in WriteData()
821 unsigned int rand_state = sent_; in WriteData()
822 packet[0] = sent_; in WriteData()
832 RTC_LOG(LS_VERBOSE) << "Sent: " << sent_; in WriteData()
833 sent_++; in WriteData()
887 EXPECT_TRUE_WAIT(sent_ == count_, 10000); in TestTransfer()
888 RTC_LOG(LS_INFO) << "sent_ == " << sent_; in TestTransfer()
894 EXPECT_EQ_WAIT(static_cast<size_t>(sent_), received_.size(), 1000); in TestTransfer()
[all …]
|