| Index: net/quic/quic_chromium_connection_helper.cc
|
| diff --git a/net/quic/quic_chromium_connection_helper.cc b/net/quic/quic_chromium_connection_helper.cc
|
| index d88648f1d037c9ab5f456e794ca2cf07bd4af09c..7bd064ae13f4c3790c6158ffacbf7cf50a35135b 100644
|
| --- a/net/quic/quic_chromium_connection_helper.cc
|
| +++ b/net/quic/quic_chromium_connection_helper.cc
|
| @@ -15,90 +15,10 @@
|
|
|
| namespace net {
|
|
|
| -namespace {
|
| -
|
| -class QuicChromeAlarm : public QuicAlarm {
|
| - public:
|
| - QuicChromeAlarm(const QuicClock* clock,
|
| - base::TaskRunner* task_runner,
|
| - QuicArenaScopedPtr<QuicAlarm::Delegate> delegate)
|
| - : QuicAlarm(std::move(delegate)),
|
| - clock_(clock),
|
| - task_runner_(task_runner),
|
| - task_deadline_(QuicTime::Zero()),
|
| - weak_factory_(this) {}
|
| -
|
| - protected:
|
| - void SetImpl() override {
|
| - DCHECK(deadline().IsInitialized());
|
| - if (task_deadline_.IsInitialized()) {
|
| - if (task_deadline_ <= deadline()) {
|
| - // Since tasks can not be un-posted, OnAlarm will be invoked which
|
| - // will notice that deadline has not yet been reached, and will set
|
| - // the alarm for the new deadline.
|
| - return;
|
| - }
|
| - // The scheduled task is after new deadline. Invalidate the weak ptrs
|
| - // so that task does not execute when we're not expecting it.
|
| - weak_factory_.InvalidateWeakPtrs();
|
| - }
|
| -
|
| - int64_t delay_us = deadline().Subtract(clock_->Now()).ToMicroseconds();
|
| - if (delay_us < 0) {
|
| - delay_us = 0;
|
| - }
|
| - task_runner_->PostDelayedTask(
|
| - FROM_HERE,
|
| - base::Bind(&QuicChromeAlarm::OnAlarm, weak_factory_.GetWeakPtr()),
|
| - base::TimeDelta::FromMicroseconds(delay_us));
|
| - task_deadline_ = deadline();
|
| - }
|
| -
|
| - void CancelImpl() override {
|
| - DCHECK(!deadline().IsInitialized());
|
| - // Since tasks can not be un-posted, OnAlarm will be invoked which
|
| - // will notice that deadline is not Initialized and will do nothing.
|
| - }
|
| -
|
| - private:
|
| - void OnAlarm() {
|
| - DCHECK(task_deadline_.IsInitialized());
|
| - task_deadline_ = QuicTime::Zero();
|
| - // The alarm may have been cancelled.
|
| - if (!deadline().IsInitialized()) {
|
| - return;
|
| - }
|
| -
|
| - // The alarm may have been re-set to a later time.
|
| - if (clock_->Now() < deadline()) {
|
| - SetImpl();
|
| - return;
|
| - }
|
| -
|
| - Fire();
|
| - }
|
| -
|
| - const QuicClock* clock_;
|
| - base::TaskRunner* task_runner_;
|
| - // If a task has been posted to the message loop, this is the time it
|
| - // was scheduled to fire. Tracking this allows us to avoid posting a
|
| - // new tast if the new deadline is in the future, but permits us to
|
| - // post a new task when the new deadline now earlier than when
|
| - // previously posted.
|
| - QuicTime task_deadline_;
|
| - base::WeakPtrFactory<QuicChromeAlarm> weak_factory_;
|
| -};
|
| -
|
| -} // namespace
|
| -
|
| QuicChromiumConnectionHelper::QuicChromiumConnectionHelper(
|
| - base::TaskRunner* task_runner,
|
| const QuicClock* clock,
|
| QuicRandom* random_generator)
|
| - : task_runner_(task_runner),
|
| - clock_(clock),
|
| - random_generator_(random_generator),
|
| - weak_factory_(this) {}
|
| + : clock_(clock), random_generator_(random_generator), weak_factory_(this) {}
|
|
|
| QuicChromiumConnectionHelper::~QuicChromiumConnectionHelper() {}
|
|
|
| @@ -110,24 +30,6 @@ QuicRandom* QuicChromiumConnectionHelper::GetRandomGenerator() {
|
| return random_generator_;
|
| }
|
|
|
| -QuicArenaScopedPtr<QuicAlarm> QuicChromiumConnectionHelper::CreateAlarm(
|
| - QuicArenaScopedPtr<QuicAlarm::Delegate> delegate,
|
| - QuicConnectionArena* arena) {
|
| - if (arena != nullptr) {
|
| - return arena->New<QuicChromeAlarm>(clock_, task_runner_,
|
| - std::move(delegate));
|
| - } else {
|
| - return QuicArenaScopedPtr<QuicAlarm>(
|
| - new QuicChromeAlarm(clock_, task_runner_, std::move(delegate)));
|
| - }
|
| -}
|
| -
|
| -QuicAlarm* QuicChromiumConnectionHelper::CreateAlarm(
|
| - QuicAlarm::Delegate* delegate) {
|
| - return new QuicChromeAlarm(clock_, task_runner_,
|
| - QuicArenaScopedPtr<QuicAlarm::Delegate>(delegate));
|
| -}
|
| -
|
| QuicBufferAllocator* QuicChromiumConnectionHelper::GetBufferAllocator() {
|
| return &buffer_allocator_;
|
| }
|
|
|