| Index: webrtc/p2p/stunprober/stunprober.cc
|
| diff --git a/webrtc/p2p/stunprober/stunprober.cc b/webrtc/p2p/stunprober/stunprober.cc
|
| index 90dc60e1514a8f25556f1bdb68d181859c17729e..df5cdb27e1fe5b53a83cf2ad5e9ac2ec3822bf0a 100644
|
| --- a/webrtc/p2p/stunprober/stunprober.cc
|
| +++ b/webrtc/p2p/stunprober/stunprober.cc
|
| @@ -22,6 +22,7 @@
|
| #include "webrtc/base/logging.h"
|
| #include "webrtc/base/timeutils.h"
|
| #include "webrtc/base/thread.h"
|
| +#include "webrtc/base/thread_scope.h"
|
| #include "webrtc/p2p/base/packetsocketfactory.h"
|
| #include "webrtc/p2p/base/stun.h"
|
| #include "webrtc/p2p/stunprober/stunprober.h"
|
| @@ -97,7 +98,7 @@ class StunProber::Requester : public sigslot::has_slots<> {
|
| rtc::SocketAddress addr_;
|
| std::unique_ptr<rtc::ByteBufferWriter> response_packet_;
|
|
|
| - std::vector<Request*> requests_;
|
| + std::vector<Request*> requests_ GUARDED_BY(thread_checker_);
|
| std::vector<rtc::SocketAddress> server_ips_;
|
| int16_t num_request_sent_ = 0;
|
| int16_t num_response_received_ = 0;
|
| @@ -132,7 +133,7 @@ StunProber::Requester::~Requester() {
|
| }
|
|
|
| void StunProber::Requester::SendStunRequest() {
|
| - RTC_DCHECK(thread_checker_.CalledOnValidThread());
|
| + RTC_DCHECK_RUN_ON(&thread_checker_);
|
| requests_.push_back(new Request());
|
| Request& request = *(requests_.back());
|
| cricket::StunMessage message;
|
| @@ -219,7 +220,7 @@ void StunProber::Requester::OnStunResponseReceived(
|
|
|
| StunProber::Requester::Request* StunProber::Requester::GetRequestByAddress(
|
| const rtc::IPAddress& ipaddr) {
|
| - RTC_DCHECK(thread_checker_.CalledOnValidThread());
|
| + RTC_DCHECK_RUN_ON(&thread_checker_);
|
| for (auto request : requests_) {
|
| if (request->server_addr == ipaddr) {
|
| return request;
|
|
|