| Index: webrtc/base/stream.cc
|
| diff --git a/webrtc/base/stream.cc b/webrtc/base/stream.cc
|
| index f58d3673e9168248d19b77fa4ca74b6a2c65707b..67ef104044e3158ebe7cf37bc88b29e296ab36c7 100644
|
| --- a/webrtc/base/stream.cc
|
| +++ b/webrtc/base/stream.cc
|
| @@ -78,7 +78,7 @@ StreamResult StreamInterface::ReadLine(std::string* line) {
|
| StreamResult result = SR_SUCCESS;
|
| while (true) {
|
| char ch;
|
| - result = Read(&ch, sizeof(ch), NULL, NULL);
|
| + result = Read(&ch, sizeof(ch), nullptr, nullptr);
|
| if (result != SR_SUCCESS) {
|
| break;
|
| }
|
| @@ -103,11 +103,11 @@ void StreamInterface::PostEvent(int events, int err) {
|
| }
|
|
|
| const void* StreamInterface::GetReadData(size_t* data_len) {
|
| - return NULL;
|
| + return nullptr;
|
| }
|
|
|
| void* StreamInterface::GetWriteBuffer(size_t* buf_len) {
|
| - return NULL;
|
| + return nullptr;
|
| }
|
|
|
| bool StreamInterface::SetPosition(size_t position) {
|
| @@ -156,7 +156,7 @@ void StreamInterface::OnMessage(Message* msg) {
|
| StreamAdapterInterface::StreamAdapterInterface(StreamInterface* stream,
|
| bool owned)
|
| : stream_(stream), owned_(owned) {
|
| - if (NULL != stream_)
|
| + if (nullptr != stream_)
|
| stream_->SignalEvent.connect(this, &StreamAdapterInterface::OnEvent);
|
| }
|
|
|
| @@ -208,21 +208,21 @@ bool StreamAdapterInterface::Flush() {
|
| }
|
|
|
| void StreamAdapterInterface::Attach(StreamInterface* stream, bool owned) {
|
| - if (NULL != stream_)
|
| + if (nullptr != stream_)
|
| stream_->SignalEvent.disconnect(this);
|
| if (owned_)
|
| delete stream_;
|
| stream_ = stream;
|
| owned_ = owned;
|
| - if (NULL != stream_)
|
| + if (nullptr != stream_)
|
| stream_->SignalEvent.connect(this, &StreamAdapterInterface::OnEvent);
|
| }
|
|
|
| StreamInterface* StreamAdapterInterface::Detach() {
|
| - if (NULL != stream_)
|
| + if (nullptr != stream_)
|
| stream_->SignalEvent.disconnect(this);
|
| StreamInterface* stream = stream_;
|
| - stream_ = NULL;
|
| + stream_ = nullptr;
|
| return stream;
|
| }
|
|
|
| @@ -273,7 +273,7 @@ StreamResult StreamTap::Read(void* buffer, size_t buffer_len,
|
| StreamResult res = StreamAdapterInterface::Read(buffer, buffer_len,
|
| read, error);
|
| if ((res == SR_SUCCESS) && (tap_result_ == SR_SUCCESS)) {
|
| - tap_result_ = tap_->WriteAll(buffer, *read, NULL, &tap_error_);
|
| + tap_result_ = tap_->WriteAll(buffer, *read, nullptr, &tap_error_);
|
| }
|
| return res;
|
| }
|
| @@ -287,7 +287,7 @@ StreamResult StreamTap::Write(const void* data, size_t data_len,
|
| StreamResult res = StreamAdapterInterface::Write(data, data_len,
|
| written, error);
|
| if ((res == SR_SUCCESS) && (tap_result_ == SR_SUCCESS)) {
|
| - tap_result_ = tap_->WriteAll(data, *written, NULL, &tap_error_);
|
| + tap_result_ = tap_->WriteAll(data, *written, nullptr, &tap_error_);
|
| }
|
| return res;
|
| }
|
| @@ -325,8 +325,7 @@ void NullStream::Close() {
|
| // FileStream
|
| ///////////////////////////////////////////////////////////////////////////////
|
|
|
| -FileStream::FileStream() : file_(NULL) {
|
| -}
|
| +FileStream::FileStream() : file_(nullptr) {}
|
|
|
| FileStream::~FileStream() {
|
| FileStream::Close();
|
| @@ -351,7 +350,7 @@ bool FileStream::Open(const std::string& filename, const char* mode,
|
| if (!file_ && error) {
|
| *error = errno;
|
| }
|
| - return (file_ != NULL);
|
| + return (file_ != nullptr);
|
| }
|
|
|
| bool FileStream::OpenShare(const std::string& filename, const char* mode,
|
| @@ -365,7 +364,7 @@ bool FileStream::OpenShare(const std::string& filename, const char* mode,
|
| *error = errno;
|
| return false;
|
| }
|
| - return file_ != NULL;
|
| + return file_ != nullptr;
|
| } else {
|
| if (error) {
|
| *error = -1;
|
| @@ -380,11 +379,11 @@ bool FileStream::OpenShare(const std::string& filename, const char* mode,
|
| bool FileStream::DisableBuffering() {
|
| if (!file_)
|
| return false;
|
| - return (setvbuf(file_, NULL, _IONBF, 0) == 0);
|
| + return (setvbuf(file_, nullptr, _IONBF, 0) == 0);
|
| }
|
|
|
| StreamState FileStream::GetState() const {
|
| - return (file_ == NULL) ? SS_CLOSED : SS_OPEN;
|
| + return (file_ == nullptr) ? SS_CLOSED : SS_OPEN;
|
| }
|
|
|
| StreamResult FileStream::Read(void* buffer, size_t buffer_len,
|
| @@ -422,7 +421,7 @@ StreamResult FileStream::Write(const void* data, size_t data_len,
|
| void FileStream::Close() {
|
| if (file_) {
|
| DoClose();
|
| - file_ = NULL;
|
| + file_ = nullptr;
|
| }
|
| }
|
|
|
| @@ -433,7 +432,7 @@ bool FileStream::SetPosition(size_t position) {
|
| }
|
|
|
| bool FileStream::GetPosition(size_t* position) const {
|
| - RTC_DCHECK(NULL != position);
|
| + RTC_DCHECK(nullptr != position);
|
| if (!file_)
|
| return false;
|
| long result = ftell(file_);
|
| @@ -445,7 +444,7 @@ bool FileStream::GetPosition(size_t* position) const {
|
| }
|
|
|
| bool FileStream::GetSize(size_t* size) const {
|
| - RTC_DCHECK(NULL != size);
|
| + RTC_DCHECK(nullptr != size);
|
| if (!file_)
|
| return false;
|
| struct stat file_stats;
|
| @@ -457,7 +456,7 @@ bool FileStream::GetSize(size_t* size) const {
|
| }
|
|
|
| bool FileStream::GetAvailable(size_t* size) const {
|
| - RTC_DCHECK(NULL != size);
|
| + RTC_DCHECK(nullptr != size);
|
| if (!GetSize(size))
|
| return false;
|
| long result = ftell(file_);
|
| @@ -493,7 +492,7 @@ bool FileStream::Flush() {
|
| #if defined(WEBRTC_POSIX) && !defined(__native_client__)
|
|
|
| bool FileStream::TryLock() {
|
| - if (file_ == NULL) {
|
| + if (file_ == nullptr) {
|
| // Stream not open.
|
| RTC_NOTREACHED();
|
| return false;
|
| @@ -503,7 +502,7 @@ bool FileStream::TryLock() {
|
| }
|
|
|
| bool FileStream::Unlock() {
|
| - if (file_ == NULL) {
|
| + if (file_ == nullptr) {
|
| // Stream not open.
|
| RTC_NOTREACHED();
|
| return false;
|
| @@ -523,9 +522,7 @@ void FileStream::DoClose() {
|
| ///////////////////////////////////////////////////////////////////////////////
|
|
|
| MemoryStreamBase::MemoryStreamBase()
|
| - : buffer_(NULL), buffer_length_(0), data_length_(0),
|
| - seek_position_(0) {
|
| -}
|
| + : buffer_(nullptr), buffer_length_(0), data_length_(0), seek_position_(0) {}
|
|
|
| StreamState MemoryStreamBase::GetState() const {
|
| return SS_OPEN;
|
| @@ -610,7 +607,7 @@ bool MemoryStreamBase::GetAvailable(size_t* size) const {
|
| }
|
|
|
| bool MemoryStreamBase::ReserveSize(size_t size) {
|
| - return (SR_SUCCESS == DoReserve(size, NULL));
|
| + return (SR_SUCCESS == DoReserve(size, nullptr));
|
| }
|
|
|
| StreamResult MemoryStreamBase::DoReserve(size_t size, int* error) {
|
| @@ -619,17 +616,14 @@ StreamResult MemoryStreamBase::DoReserve(size_t size, int* error) {
|
|
|
| ///////////////////////////////////////////////////////////////////////////////
|
|
|
| -MemoryStream::MemoryStream()
|
| - : buffer_alloc_(NULL) {
|
| -}
|
| +MemoryStream::MemoryStream() : buffer_alloc_(nullptr) {}
|
|
|
| -MemoryStream::MemoryStream(const char* data)
|
| - : buffer_alloc_(NULL) {
|
| +MemoryStream::MemoryStream(const char* data) : buffer_alloc_(nullptr) {
|
| SetData(data, strlen(data));
|
| }
|
|
|
| MemoryStream::MemoryStream(const void* data, size_t length)
|
| - : buffer_alloc_(NULL) {
|
| + : buffer_alloc_(nullptr) {
|
| SetData(data, length);
|
| }
|
|
|
| @@ -819,7 +813,7 @@ void FifoBuffer::ConsumeReadData(size_t size) {
|
| void* FifoBuffer::GetWriteBuffer(size_t* size) {
|
| CritScope cs(&crit_);
|
| if (state_ == SS_CLOSED) {
|
| - return NULL;
|
| + return nullptr;
|
| }
|
|
|
| // if empty, reset the write position to the beginning, so we can get
|
| @@ -943,8 +937,8 @@ StreamResult LoggingAdapter::Write(const void* data, size_t data_len,
|
| }
|
|
|
| void LoggingAdapter::Close() {
|
| - LogMultiline(level_, label_.c_str(), false, NULL, 0, hex_mode_, &lms_);
|
| - LogMultiline(level_, label_.c_str(), true, NULL, 0, hex_mode_, &lms_);
|
| + LogMultiline(level_, label_.c_str(), false, nullptr, 0, hex_mode_, &lms_);
|
| + LogMultiline(level_, label_.c_str(), true, nullptr, 0, hex_mode_, &lms_);
|
| LOG_V(level_) << label_ << " Closed locally";
|
| StreamAdapterInterface::Close();
|
| }
|
| @@ -953,8 +947,8 @@ void LoggingAdapter::OnEvent(StreamInterface* stream, int events, int err) {
|
| if (events & SE_OPEN) {
|
| LOG_V(level_) << label_ << " Open";
|
| } else if (events & SE_CLOSE) {
|
| - LogMultiline(level_, label_.c_str(), false, NULL, 0, hex_mode_, &lms_);
|
| - LogMultiline(level_, label_.c_str(), true, NULL, 0, hex_mode_, &lms_);
|
| + LogMultiline(level_, label_.c_str(), false, nullptr, 0, hex_mode_, &lms_);
|
| + LogMultiline(level_, label_.c_str(), true, nullptr, 0, hex_mode_, &lms_);
|
| LOG_V(level_) << label_ << " Closed with error: " << err;
|
| }
|
| StreamAdapterInterface::OnEvent(stream, events, err);
|
| @@ -1066,9 +1060,10 @@ StreamReference::StreamReference(StreamRefCount* stream_ref_count,
|
| ///////////////////////////////////////////////////////////////////////////////
|
|
|
| StreamResult Flow(StreamInterface* source,
|
| - char* buffer, size_t buffer_len,
|
| + char* buffer,
|
| + size_t buffer_len,
|
| StreamInterface* sink,
|
| - size_t* data_len /* = NULL */) {
|
| + size_t* data_len /* = nullptr */) {
|
| RTC_DCHECK(buffer_len > 0);
|
|
|
| StreamResult result;
|
| @@ -1083,8 +1078,8 @@ StreamResult Flow(StreamInterface* source,
|
| do {
|
| // Read until buffer is full, end of stream, or error
|
| while (!end_of_stream && (read_pos < buffer_len)) {
|
| - result = source->Read(buffer + read_pos, buffer_len - read_pos,
|
| - &count, NULL);
|
| + result = source->Read(buffer + read_pos, buffer_len - read_pos, &count,
|
| + nullptr);
|
| if (result == SR_EOS) {
|
| end_of_stream = true;
|
| } else if (result != SR_SUCCESS) {
|
| @@ -1100,8 +1095,8 @@ StreamResult Flow(StreamInterface* source,
|
| // Write until buffer is empty, or error (including end of stream)
|
| write_pos = 0;
|
| while (write_pos < read_pos) {
|
| - result = sink->Write(buffer + write_pos, read_pos - write_pos,
|
| - &count, NULL);
|
| + result = sink->Write(buffer + write_pos, read_pos - write_pos, &count,
|
| + nullptr);
|
| if (result != SR_SUCCESS) {
|
| if (data_len) {
|
| *data_len = read_pos - write_pos;
|
|
|