| Index: webrtc/media/base/fakenetworkinterface.h
|
| diff --git a/webrtc/media/base/fakenetworkinterface.h b/webrtc/media/base/fakenetworkinterface.h
|
| index d9caac0197910281dd93ba31e3fe98151dc19844..65dac2529b4ae778af9b3205180a4223eafb8fec 100644
|
| --- a/webrtc/media/base/fakenetworkinterface.h
|
| +++ b/webrtc/media/base/fakenetworkinterface.h
|
| @@ -14,8 +14,8 @@
|
| #include <map>
|
| #include <vector>
|
|
|
| -#include "webrtc/base/buffer.h"
|
| #include "webrtc/base/byteorder.h"
|
| +#include "webrtc/base/copyonwritebuffer.h"
|
| #include "webrtc/base/criticalsection.h"
|
| #include "webrtc/base/dscp.h"
|
| #include "webrtc/base/messagehandler.h"
|
| @@ -84,12 +84,12 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
| }
|
|
|
| // Note: callers are responsible for deleting the returned buffer.
|
| - const rtc::Buffer* GetRtpPacket(int index) {
|
| + const rtc::CopyOnWriteBuffer* GetRtpPacket(int index) {
|
| rtc::CritScope cs(&crit_);
|
| if (index >= NumRtpPackets()) {
|
| return NULL;
|
| }
|
| - return new rtc::Buffer(rtp_packets_[index]);
|
| + return new rtc::CopyOnWriteBuffer(rtp_packets_[index]);
|
| }
|
|
|
| int NumRtcpPackets() {
|
| @@ -98,12 +98,12 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
| }
|
|
|
| // Note: callers are responsible for deleting the returned buffer.
|
| - const rtc::Buffer* GetRtcpPacket(int index) {
|
| + const rtc::CopyOnWriteBuffer* GetRtcpPacket(int index) {
|
| rtc::CritScope cs(&crit_);
|
| if (index >= NumRtcpPackets()) {
|
| return NULL;
|
| }
|
| - return new rtc::Buffer(rtcp_packets_[index]);
|
| + return new rtc::CopyOnWriteBuffer(rtcp_packets_[index]);
|
| }
|
|
|
| int sendbuf_size() const { return sendbuf_size_; }
|
| @@ -111,7 +111,7 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
| rtc::DiffServCodePoint dscp() const { return dscp_; }
|
|
|
| protected:
|
| - virtual bool SendPacket(rtc::Buffer* packet,
|
| + virtual bool SendPacket(rtc::CopyOnWriteBuffer* packet,
|
| const rtc::PacketOptions& options) {
|
| rtc::CritScope cs(&crit_);
|
|
|
| @@ -123,13 +123,12 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
|
|
| rtp_packets_.push_back(*packet);
|
| if (conf_) {
|
| - rtc::Buffer buffer_copy(*packet);
|
| for (size_t i = 0; i < conf_sent_ssrcs_.size(); ++i) {
|
| - if (!SetRtpSsrc(buffer_copy.data(), buffer_copy.size(),
|
| + if (!SetRtpSsrc(packet->data(), packet->size(),
|
| conf_sent_ssrcs_[i])) {
|
| return false;
|
| }
|
| - PostMessage(ST_RTP, buffer_copy);
|
| + PostMessage(ST_RTP, *packet);
|
| }
|
| } else {
|
| PostMessage(ST_RTP, *packet);
|
| @@ -137,7 +136,7 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
| return true;
|
| }
|
|
|
| - virtual bool SendRtcp(rtc::Buffer* packet,
|
| + virtual bool SendRtcp(rtc::CopyOnWriteBuffer* packet,
|
| const rtc::PacketOptions& options) {
|
| rtc::CritScope cs(&crit_);
|
| rtcp_packets_.push_back(*packet);
|
| @@ -160,13 +159,13 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
| return 0;
|
| }
|
|
|
| - void PostMessage(int id, const rtc::Buffer& packet) {
|
| + void PostMessage(int id, const rtc::CopyOnWriteBuffer& packet) {
|
| thread_->Post(this, id, rtc::WrapMessageData(packet));
|
| }
|
|
|
| virtual void OnMessage(rtc::Message* msg) {
|
| - rtc::TypedMessageData<rtc::Buffer>* msg_data =
|
| - static_cast<rtc::TypedMessageData<rtc::Buffer>*>(
|
| + rtc::TypedMessageData<rtc::CopyOnWriteBuffer>* msg_data =
|
| + static_cast<rtc::TypedMessageData<rtc::CopyOnWriteBuffer>*>(
|
| msg->pdata);
|
| if (dest_) {
|
| if (msg->message_id == ST_RTP) {
|
| @@ -216,8 +215,8 @@ class FakeNetworkInterface : public MediaChannel::NetworkInterface,
|
| // Map to track packet-number that needs to be dropped per ssrc.
|
| std::map<uint32_t, std::set<uint32_t> > drop_map_;
|
| rtc::CriticalSection crit_;
|
| - std::vector<rtc::Buffer> rtp_packets_;
|
| - std::vector<rtc::Buffer> rtcp_packets_;
|
| + std::vector<rtc::CopyOnWriteBuffer> rtp_packets_;
|
| + std::vector<rtc::CopyOnWriteBuffer> rtcp_packets_;
|
| int sendbuf_size_;
|
| int recvbuf_size_;
|
| rtc::DiffServCodePoint dscp_;
|
|
|