1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "third_party/blink/renderer/platform/peerconnection/rtc_dtmf_sender_handler.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/task/single_thread_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/threading/thread_checker.h"
#include "third_party/blink/renderer/platform/scheduler/public/post_cross_thread_task.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_copier_base.h"
#include "third_party/blink/renderer/platform/wtf/cross_thread_functional.h"
#include "third_party/blink/renderer/platform/wtf/thread_safe_ref_counted.h"
namespace blink {
class RtcDtmfSenderHandler::Observer
: public WTF::ThreadSafeRefCounted<Observer>,
public webrtc::DtmfSenderObserverInterface {
public:
explicit Observer(scoped_refptr<base::SingleThreadTaskRunner> main_thread,
const base::WeakPtr<RtcDtmfSenderHandler>& handler)
: main_thread_(std::move(main_thread)), handler_(handler) {}
private:
friend class WTF::ThreadSafeRefCounted<Observer>;
~Observer() override {}
void OnToneChange(const std::string& tone) override {
PostCrossThreadTask(*main_thread_.get(), FROM_HERE,
CrossThreadBindOnce(&Observer::OnToneChangeOnMainThread,
scoped_refptr<Observer>(this),
String(tone.data())));
}
void OnToneChangeOnMainThread(const String& tone) {
DCHECK_CALLED_ON_VALID_THREAD(thread_checker_);
if (handler_)
handler_->OnToneChange(tone);
}
THREAD_CHECKER(thread_checker_);
const scoped_refptr<base::SingleThreadTaskRunner> main_thread_;
base::WeakPtr<RtcDtmfSenderHandler> handler_;
};
RtcDtmfSenderHandler::RtcDtmfSenderHandler(
scoped_refptr<base::SingleThreadTaskRunner> main_thread,
webrtc::DtmfSenderInterface* dtmf_sender)
: dtmf_sender_(dtmf_sender), webkit_client_(nullptr) {
DVLOG(1) << "::ctor";
observer_ = base::MakeRefCounted<Observer>(std::move(main_thread),
weak_factory_.GetWeakPtr());
dtmf_sender_->RegisterObserver(observer_.get());
}
RtcDtmfSenderHandler::~RtcDtmfSenderHandler() {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DVLOG(1) << "::dtor";
dtmf_sender_->UnregisterObserver();
// Release |observer| before |weak_factory_| is destroyed.
observer_ = nullptr;
}
void RtcDtmfSenderHandler::SetClient(RtcDtmfSenderHandler::Client* client) {
webkit_client_ = client;
}
String RtcDtmfSenderHandler::CurrentToneBuffer() {
return String::FromUTF8(dtmf_sender_->tones());
}
bool RtcDtmfSenderHandler::CanInsertDTMF() {
return dtmf_sender_->CanInsertDtmf();
}
bool RtcDtmfSenderHandler::InsertDTMF(const String& tones,
int duration,
int inter_tone_gap) {
std::string utf8_tones = tones.Utf8();
return dtmf_sender_->InsertDtmf(utf8_tones, duration, inter_tone_gap);
}
void RtcDtmfSenderHandler::OnToneChange(const String& tone) {
if (!webkit_client_) {
LOG(ERROR) << "RtcDtmfSenderHandler::Client not set.";
return;
}
webkit_client_->DidPlayTone(tone);
}
} // namespace blink
|
