remoting/host/audio_scheduler.cc - Issue 866863004: Replace AudioScheduler with AudioPump.

Side by Side Diff: remoting/host/audio_scheduler.cc

Issue 866863004: Replace AudioScheduler with AudioPump. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@mouse_cursor_pipe

Patch Set: Created 5 years, 10 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch

OLD	NEW
	(Empty)
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.

2 // Use of this source code is governed by a BSD-style license that can be

3 // found in the LICENSE file.

4

5 #include "remoting/host/audio_scheduler.h"

6

7 #include "base/bind.h"

8 #include "base/location.h"

9 #include "base/logging.h"

10 #include "base/single_thread_task_runner.h"

11 #include "remoting/codec/audio_encoder.h"

12 #include "remoting/host/audio_capturer.h"

13 #include "remoting/proto/audio.pb.h"

14 #include "remoting/protocol/audio_stub.h"

15

16 namespace remoting {

17

18 AudioScheduler::AudioScheduler(

19 scoped_refptr<base::SingleThreadTaskRunner> audio_task_runner,

20 scoped_refptr<base::SingleThreadTaskRunner> network_task_runner,

21 scoped_ptr<AudioCapturer> audio_capturer,

22 scoped_ptr<AudioEncoder> audio_encoder,

23 protocol::AudioStub* audio_stub)

24 : audio_task_runner_(audio_task_runner),

25 network_task_runner_(network_task_runner),

26 audio_capturer_(audio_capturer.Pass()),

27 audio_encoder_(audio_encoder.Pass()),

28 audio_stub_(audio_stub),

29 enabled_(true) {

30 DCHECK(network_task_runner_->BelongsToCurrentThread());

31 DCHECK(audio_capturer_);

32 DCHECK(audio_encoder_);

33 DCHECK(audio_stub_);

34 }

35

36 void AudioScheduler::Start() {

37 DCHECK(network_task_runner_->BelongsToCurrentThread());

38

39 audio_task_runner_->PostTask(

40 FROM_HERE, base::Bind(&AudioScheduler::StartOnAudioThread, this));

41 }

42

43 void AudioScheduler::Stop() {

44 DCHECK(network_task_runner_->BelongsToCurrentThread());

45 DCHECK(audio_stub_);

46

47 // Clear \|audio_stub_\| to prevent audio packets being delivered to the client.

48 audio_stub_ = nullptr;

49

50 audio_task_runner_->PostTask(

51 FROM_HERE,

52 base::Bind(&AudioScheduler::StopOnAudioThread, this));

53 }

54

55 AudioScheduler::~AudioScheduler() {

56 }

57

58 void AudioScheduler::StartOnAudioThread() {

59 DCHECK(audio_task_runner_->BelongsToCurrentThread());

60

61 // TODO(kxing): Do something with the return value.

62 audio_capturer_->Start(

63 base::Bind(&AudioScheduler::EncodeAudioPacket, this));

64 }

65

66 void AudioScheduler::StopOnAudioThread() {

67 DCHECK(audio_task_runner_->BelongsToCurrentThread());

68 audio_capturer_->Stop();

69 }

70

71 void AudioScheduler::Pause(bool pause) {

72 if (!audio_task_runner_->BelongsToCurrentThread()) {

73 audio_task_runner_->PostTask(

74 FROM_HERE, base::Bind(&AudioScheduler::Pause, this, pause));

75 return;

76 }

77

78 enabled_ = !pause;

79 }

80

81 void AudioScheduler::EncodeAudioPacket(scoped_ptr<AudioPacket> packet) {

82 DCHECK(audio_task_runner_->BelongsToCurrentThread());

83 DCHECK(packet.get());

84

85 if (!enabled_)

86 return;

87

88 scoped_ptr<AudioPacket> encoded_packet =

89 audio_encoder_->Encode(packet.Pass());

90

91 // The audio encoder returns a null audio packet if there's no audio to send.

92 if (encoded_packet.get()) {

93 network_task_runner_->PostTask(

94 FROM_HERE, base::Bind(&AudioScheduler::SendAudioPacket,

95 this, base::Passed(&encoded_packet)));

96 }

97 }

98

99 void AudioScheduler::SendAudioPacket(scoped_ptr<AudioPacket> packet) {

100 DCHECK(network_task_runner_->BelongsToCurrentThread());

101 DCHECK(packet.get());

102

103 if (!audio_stub_)

104 return;

105

106 audio_stub_->ProcessAudioPacket(packet.Pass(), base::Closure());

107 }

108

109 } // namespace remoting

OLD	NEW

« no previous file with comments | « remoting/host/audio_scheduler.h ('k') | remoting/host/client_session.h » ('j') | no next file with comments »