Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 /* | 1 /* |
| 2 * libjingle | 2 * libjingle |
| 3 * Copyright 2004 Google Inc. | 3 * Copyright 2004 Google Inc. |
| 4 * | 4 * |
| 5 * Redistribution and use in source and binary forms, with or without | 5 * Redistribution and use in source and binary forms, with or without |
| 6 * modification, are permitted provided that the following conditions are met: | 6 * modification, are permitted provided that the following conditions are met: |
| 7 * | 7 * |
| 8 * 1. Redistributions of source code must retain the above copyright notice, | 8 * 1. Redistributions of source code must retain the above copyright notice, |
| 9 * this list of conditions and the following disclaimer. | 9 * this list of conditions and the following disclaimer. |
| 10 * 2. Redistributions in binary form must reproduce the above copyright notice, | 10 * 2. Redistributions in binary form must reproduce the above copyright notice, |
| (...skipping 119 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 130 if (std::find(receive_streams_.begin(), receive_streams_.end(), sp) != | 130 if (std::find(receive_streams_.begin(), receive_streams_.end(), sp) != |
| 131 receive_streams_.end()) { | 131 receive_streams_.end()) { |
| 132 return false; | 132 return false; |
| 133 } | 133 } |
| 134 receive_streams_.push_back(sp); | 134 receive_streams_.push_back(sp); |
| 135 return true; | 135 return true; |
| 136 } | 136 } |
| 137 virtual bool RemoveRecvStream(uint32 ssrc) { | 137 virtual bool RemoveRecvStream(uint32 ssrc) { |
| 138 return RemoveStreamBySsrc(&receive_streams_, ssrc); | 138 return RemoveStreamBySsrc(&receive_streams_, ssrc); |
| 139 } | 139 } |
| 140 virtual bool MuteStream(uint32 ssrc, bool on) { | |
| 141 if (!HasSendStream(ssrc) && ssrc != 0) | |
| 142 return false; | |
| 143 if (on) | |
| 144 muted_streams_.insert(ssrc); | |
| 145 else | |
| 146 muted_streams_.erase(ssrc); | |
| 147 return true; | |
| 148 } | |
| 149 bool IsStreamMuted(uint32 ssrc) const { | 140 bool IsStreamMuted(uint32 ssrc) const { |
| 150 bool ret = muted_streams_.find(ssrc) != muted_streams_.end(); | 141 bool ret = muted_streams_.find(ssrc) != muted_streams_.end(); |
| 151 // If |ssrc = 0| check if the first send stream is muted. | 142 // If |ssrc = 0| check if the first send stream is muted. |
| 152 if (!ret && ssrc == 0 && !send_streams_.empty()) { | 143 if (!ret && ssrc == 0 && !send_streams_.empty()) { |
| 153 return muted_streams_.find(send_streams_[0].first_ssrc()) != | 144 return muted_streams_.find(send_streams_[0].first_ssrc()) != |
| 154 muted_streams_.end(); | 145 muted_streams_.end(); |
| 155 } | 146 } |
| 156 return ret; | 147 return ret; |
| 157 } | 148 } |
| 158 const std::vector<StreamParams>& send_streams() const { | 149 const std::vector<StreamParams>& send_streams() const { |
| (...skipping 22 matching lines...) Expand all Loading... | |
| 181 if (send_streams_.empty()) | 172 if (send_streams_.empty()) |
| 182 return ""; | 173 return ""; |
| 183 return send_streams_[0].cname; | 174 return send_streams_[0].cname; |
| 184 } | 175 } |
| 185 | 176 |
| 186 bool ready_to_send() const { | 177 bool ready_to_send() const { |
| 187 return ready_to_send_; | 178 return ready_to_send_; |
| 188 } | 179 } |
| 189 | 180 |
| 190 protected: | 181 protected: |
| 182 bool MuteStream(uint32 ssrc, bool on) { | |
| 183 if (!HasSendStream(ssrc) && ssrc != 0) | |
| 184 return false; | |
| 185 if (on) | |
| 186 muted_streams_.insert(ssrc); | |
| 187 else | |
| 188 muted_streams_.erase(ssrc); | |
| 189 return true; | |
| 190 } | |
| 191 bool set_sending(bool send) { | 191 bool set_sending(bool send) { |
| 192 sending_ = send; | 192 sending_ = send; |
| 193 return true; | 193 return true; |
| 194 } | 194 } |
| 195 void set_playout(bool playout) { playout_ = playout; } | 195 void set_playout(bool playout) { playout_ = playout; } |
| 196 virtual void OnPacketReceived(rtc::Buffer* packet, | 196 virtual void OnPacketReceived(rtc::Buffer* packet, |
| 197 const rtc::PacketTime& packet_time) { | 197 const rtc::PacketTime& packet_time) { |
| 198 rtp_packets_.push_back(std::string(packet->data<char>(), packet->size())); | 198 rtp_packets_.push_back(std::string(packet->data<char>(), packet->size())); |
| 199 } | 199 } |
| 200 virtual void OnRtcpReceived(rtc::Buffer* packet, | 200 virtual void OnRtcpReceived(rtc::Buffer* packet, |
| (...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 276 virtual bool SetPlayout(bool playout) { | 276 virtual bool SetPlayout(bool playout) { |
| 277 set_playout(playout); | 277 set_playout(playout); |
| 278 return true; | 278 return true; |
| 279 } | 279 } |
| 280 virtual bool SetSend(SendFlags flag) { | 280 virtual bool SetSend(SendFlags flag) { |
| 281 if (fail_set_send_) { | 281 if (fail_set_send_) { |
| 282 return false; | 282 return false; |
| 283 } | 283 } |
| 284 return set_sending(flag != SEND_NOTHING); | 284 return set_sending(flag != SEND_NOTHING); |
| 285 } | 285 } |
| 286 virtual bool SetAudioSend(uint32 ssrc, bool mute, | |
| 287 const AudioOptions* options, | |
| 288 AudioRenderer* renderer) { | |
| 289 std::map<uint32, VoiceChannelAudioSink*>::iterator it = | |
| 290 local_renderers_.find(ssrc); | |
| 291 if (renderer) { | |
| 292 if (it != local_renderers_.end()) { | |
| 293 ASSERT(it->second->renderer() == renderer); | |
| 294 } else { | |
| 295 local_renderers_.insert(std::make_pair( | |
| 296 ssrc, new VoiceChannelAudioSink(renderer))); | |
| 297 } | |
| 298 } else { | |
| 299 if (it != local_renderers_.end()) { | |
| 300 delete it->second; | |
| 301 local_renderers_.erase(it); | |
| 302 } else { | |
| 303 return false; | |
| 304 } | |
| 305 } | |
| 306 bool result = RtpHelper<VoiceMediaChannel>::MuteStream(ssrc, mute); | |
| 307 if (result && !mute && options) { | |
| 308 return SetOptions(*options); | |
| 309 } else { | |
| 310 return result; | |
| 311 } | |
| 312 } | |
|
pthatcher1
2015/09/09 07:16:12
I think it will make the intention of this CL more
the sun
2015/09/09 09:50:50
Done.
| |
| 286 virtual bool SetMaxSendBandwidth(int bps) { return true; } | 313 virtual bool SetMaxSendBandwidth(int bps) { return true; } |
| 287 virtual bool AddRecvStream(const StreamParams& sp) { | 314 virtual bool AddRecvStream(const StreamParams& sp) { |
| 288 if (!RtpHelper<VoiceMediaChannel>::AddRecvStream(sp)) | 315 if (!RtpHelper<VoiceMediaChannel>::AddRecvStream(sp)) |
| 289 return false; | 316 return false; |
| 290 output_scalings_[sp.first_ssrc()] = OutputScaling(); | 317 output_scalings_[sp.first_ssrc()] = OutputScaling(); |
| 291 return true; | 318 return true; |
| 292 } | 319 } |
| 293 virtual bool RemoveRecvStream(uint32 ssrc) { | 320 virtual bool RemoveRecvStream(uint32 ssrc) { |
| 294 if (!RtpHelper<VoiceMediaChannel>::RemoveRecvStream(ssrc)) | 321 if (!RtpHelper<VoiceMediaChannel>::RemoveRecvStream(ssrc)) |
| 295 return false; | 322 return false; |
| (...skipping 13 matching lines...) Expand all Loading... | |
| 309 } else { | 336 } else { |
| 310 if (it != remote_renderers_.end()) { | 337 if (it != remote_renderers_.end()) { |
| 311 it->second->RemoveChannel(0); | 338 it->second->RemoveChannel(0); |
| 312 remote_renderers_.erase(it); | 339 remote_renderers_.erase(it); |
| 313 } else { | 340 } else { |
| 314 return false; | 341 return false; |
| 315 } | 342 } |
| 316 } | 343 } |
| 317 return true; | 344 return true; |
| 318 } | 345 } |
| 319 virtual bool SetLocalRenderer(uint32 ssrc, AudioRenderer* renderer) { | |
| 320 std::map<uint32, VoiceChannelAudioSink*>::iterator it = | |
| 321 local_renderers_.find(ssrc); | |
| 322 if (renderer) { | |
| 323 if (it != local_renderers_.end()) { | |
| 324 ASSERT(it->second->renderer() == renderer); | |
| 325 } else { | |
| 326 local_renderers_.insert(std::make_pair( | |
| 327 ssrc, new VoiceChannelAudioSink(renderer))); | |
| 328 } | |
| 329 } else { | |
| 330 if (it != local_renderers_.end()) { | |
| 331 delete it->second; | |
| 332 local_renderers_.erase(it); | |
| 333 } else { | |
| 334 return false; | |
| 335 } | |
| 336 } | |
| 337 return true; | |
| 338 } | |
| 339 | 346 |
| 340 virtual bool GetActiveStreams(AudioInfo::StreamList* streams) { return true; } | 347 virtual bool GetActiveStreams(AudioInfo::StreamList* streams) { return true; } |
| 341 virtual int GetOutputLevel() { return 0; } | 348 virtual int GetOutputLevel() { return 0; } |
| 342 void set_time_since_last_typing(int ms) { time_since_last_typing_ = ms; } | 349 void set_time_since_last_typing(int ms) { time_since_last_typing_ = ms; } |
| 343 virtual int GetTimeSinceLastTyping() { return time_since_last_typing_; } | 350 virtual int GetTimeSinceLastTyping() { return time_since_last_typing_; } |
| 344 virtual void SetTypingDetectionParameters( | 351 virtual void SetTypingDetectionParameters( |
| 345 int time_window, int cost_per_typing, int reporting_threshold, | 352 int time_window, int cost_per_typing, int reporting_threshold, |
| 346 int penalty_decay, int type_event_delay) {} | 353 int penalty_decay, int type_event_delay) {} |
| 347 | 354 |
| 348 virtual bool SetRingbackTone(const char* buf, int len) { return true; } | 355 virtual bool SetRingbackTone(const char* buf, int len) { return true; } |
| (...skipping 204 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 553 if (ssrc != 0 && renderers_.find(ssrc) == renderers_.end()) { | 560 if (ssrc != 0 && renderers_.find(ssrc) == renderers_.end()) { |
| 554 return false; | 561 return false; |
| 555 } | 562 } |
| 556 if (ssrc != 0) { | 563 if (ssrc != 0) { |
| 557 renderers_[ssrc] = r; | 564 renderers_[ssrc] = r; |
| 558 } | 565 } |
| 559 return true; | 566 return true; |
| 560 } | 567 } |
| 561 | 568 |
| 562 virtual bool SetSend(bool send) { return set_sending(send); } | 569 virtual bool SetSend(bool send) { return set_sending(send); } |
| 570 virtual bool SetVideoSend(uint32 ssrc, bool mute, | |
| 571 const VideoOptions* options) { | |
| 572 bool result = RtpHelper<VideoMediaChannel>::MuteStream(ssrc, mute); | |
| 573 if (result && !mute && options) { | |
| 574 return SetOptions(*options); | |
| 575 } else { | |
| 576 return result; | |
| 577 } | |
| 578 } | |
| 563 virtual bool SetCapturer(uint32 ssrc, VideoCapturer* capturer) { | 579 virtual bool SetCapturer(uint32 ssrc, VideoCapturer* capturer) { |
| 564 capturers_[ssrc] = capturer; | 580 capturers_[ssrc] = capturer; |
| 565 return true; | 581 return true; |
| 566 } | 582 } |
| 567 bool HasCapturer(uint32 ssrc) const { | 583 bool HasCapturer(uint32 ssrc) const { |
| 568 return capturers_.find(ssrc) != capturers_.end(); | 584 return capturers_.find(ssrc) != capturers_.end(); |
| 569 } | 585 } |
| 570 virtual bool SetMaxSendBandwidth(int bps) { | 586 virtual bool SetMaxSendBandwidth(int bps) { |
| 571 max_bps_ = bps; | 587 max_bps_ = bps; |
| 572 return true; | 588 return true; |
| (...skipping 479 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 1052 | 1068 |
| 1053 private: | 1069 private: |
| 1054 std::vector<FakeDataMediaChannel*> channels_; | 1070 std::vector<FakeDataMediaChannel*> channels_; |
| 1055 std::vector<DataCodec> data_codecs_; | 1071 std::vector<DataCodec> data_codecs_; |
| 1056 DataChannelType last_channel_type_; | 1072 DataChannelType last_channel_type_; |
| 1057 }; | 1073 }; |
| 1058 | 1074 |
| 1059 } // namespace cricket | 1075 } // namespace cricket |
| 1060 | 1076 |
| 1061 #endif // TALK_MEDIA_BASE_FAKEMEDIAENGINE_H_ | 1077 #endif // TALK_MEDIA_BASE_FAKEMEDIAENGINE_H_ |
| OLD | NEW |