henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 1 | /* |
| 2 | * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
| 3 | * |
| 4 | * Use of this source code is governed by a BSD-style license |
| 5 | * that can be found in the LICENSE file in the root of the source |
| 6 | * tree. An additional intellectual property rights grant can be found |
| 7 | * in the file PATENTS. All contributing project authors may |
| 8 | * be found in the AUTHORS file in the root of the source tree. |
| 9 | */ |
Jonas Olsson | a4d8737 | 2019-07-05 19:08:33 +0200 | [diff] [blame] | 10 | #include "rtc_base/stream.h" |
| 11 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 12 | #include <errno.h> |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 13 | #include <string.h> |
Jonas Olsson | a4d8737 | 2019-07-05 19:08:33 +0200 | [diff] [blame] | 14 | |
andresp@webrtc.org | ff689be | 2015-02-12 11:54:26 +0000 | [diff] [blame] | 15 | #include <algorithm> |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 16 | #include <string> |
andresp@webrtc.org | ff689be | 2015-02-12 11:54:26 +0000 | [diff] [blame] | 17 | |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 18 | #include "rtc_base/checks.h" |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 19 | #include "rtc_base/location.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 20 | #include "rtc_base/thread.h" |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 21 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 22 | namespace rtc { |
| 23 | |
| 24 | /////////////////////////////////////////////////////////////////////////////// |
| 25 | // StreamInterface |
| 26 | /////////////////////////////////////////////////////////////////////////////// |
Yves Gerey | 665174f | 2018-06-19 15:03:05 +0200 | [diff] [blame] | 27 | StreamInterface::~StreamInterface() {} |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 28 | |
Yves Gerey | 665174f | 2018-06-19 15:03:05 +0200 | [diff] [blame] | 29 | StreamResult StreamInterface::WriteAll(const void* data, |
| 30 | size_t data_len, |
| 31 | size_t* written, |
| 32 | int* error) { |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 33 | StreamResult result = SR_SUCCESS; |
| 34 | size_t total_written = 0, current_written; |
| 35 | while (total_written < data_len) { |
| 36 | result = Write(static_cast<const char*>(data) + total_written, |
| 37 | data_len - total_written, ¤t_written, error); |
| 38 | if (result != SR_SUCCESS) |
| 39 | break; |
| 40 | total_written += current_written; |
| 41 | } |
| 42 | if (written) |
| 43 | *written = total_written; |
| 44 | return result; |
| 45 | } |
| 46 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 47 | void StreamInterface::PostEvent(Thread* t, int events, int err) { |
Taylor Brandstetter | 5d97a9a | 2016-06-10 14:17:27 -0700 | [diff] [blame] | 48 | t->Post(RTC_FROM_HERE, this, MSG_POST_EVENT, |
| 49 | new StreamEventData(events, err)); |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 50 | } |
| 51 | |
| 52 | void StreamInterface::PostEvent(int events, int err) { |
| 53 | PostEvent(Thread::Current(), events, err); |
| 54 | } |
| 55 | |
kwiberg@webrtc.org | 67186fe | 2015-03-09 22:21:53 +0000 | [diff] [blame] | 56 | bool StreamInterface::Flush() { |
| 57 | return false; |
| 58 | } |
| 59 | |
Yves Gerey | 665174f | 2018-06-19 15:03:05 +0200 | [diff] [blame] | 60 | StreamInterface::StreamInterface() {} |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 61 | |
| 62 | void StreamInterface::OnMessage(Message* msg) { |
| 63 | if (MSG_POST_EVENT == msg->message_id) { |
| 64 | StreamEventData* pe = static_cast<StreamEventData*>(msg->pdata); |
| 65 | SignalEvent(this, pe->events, pe->error); |
| 66 | delete msg->pdata; |
| 67 | } |
| 68 | } |
| 69 | |
| 70 | /////////////////////////////////////////////////////////////////////////////// |
| 71 | // StreamAdapterInterface |
| 72 | /////////////////////////////////////////////////////////////////////////////// |
| 73 | |
| 74 | StreamAdapterInterface::StreamAdapterInterface(StreamInterface* stream, |
| 75 | bool owned) |
| 76 | : stream_(stream), owned_(owned) { |
deadbeef | 37f5ecf | 2017-02-27 14:06:41 -0800 | [diff] [blame] | 77 | if (nullptr != stream_) |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 78 | stream_->SignalEvent.connect(this, &StreamAdapterInterface::OnEvent); |
| 79 | } |
| 80 | |
kwiberg@webrtc.org | 67186fe | 2015-03-09 22:21:53 +0000 | [diff] [blame] | 81 | StreamState StreamAdapterInterface::GetState() const { |
| 82 | return stream_->GetState(); |
| 83 | } |
| 84 | StreamResult StreamAdapterInterface::Read(void* buffer, |
| 85 | size_t buffer_len, |
| 86 | size_t* read, |
| 87 | int* error) { |
| 88 | return stream_->Read(buffer, buffer_len, read, error); |
| 89 | } |
| 90 | StreamResult StreamAdapterInterface::Write(const void* data, |
| 91 | size_t data_len, |
| 92 | size_t* written, |
| 93 | int* error) { |
| 94 | return stream_->Write(data, data_len, written, error); |
| 95 | } |
| 96 | void StreamAdapterInterface::Close() { |
| 97 | stream_->Close(); |
| 98 | } |
| 99 | |
kwiberg@webrtc.org | 67186fe | 2015-03-09 22:21:53 +0000 | [diff] [blame] | 100 | bool StreamAdapterInterface::Flush() { |
| 101 | return stream_->Flush(); |
| 102 | } |
| 103 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 104 | void StreamAdapterInterface::Attach(StreamInterface* stream, bool owned) { |
deadbeef | 37f5ecf | 2017-02-27 14:06:41 -0800 | [diff] [blame] | 105 | if (nullptr != stream_) |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 106 | stream_->SignalEvent.disconnect(this); |
| 107 | if (owned_) |
| 108 | delete stream_; |
| 109 | stream_ = stream; |
| 110 | owned_ = owned; |
deadbeef | 37f5ecf | 2017-02-27 14:06:41 -0800 | [diff] [blame] | 111 | if (nullptr != stream_) |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 112 | stream_->SignalEvent.connect(this, &StreamAdapterInterface::OnEvent); |
| 113 | } |
| 114 | |
| 115 | StreamInterface* StreamAdapterInterface::Detach() { |
deadbeef | 37f5ecf | 2017-02-27 14:06:41 -0800 | [diff] [blame] | 116 | if (nullptr != stream_) |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 117 | stream_->SignalEvent.disconnect(this); |
| 118 | StreamInterface* stream = stream_; |
deadbeef | 37f5ecf | 2017-02-27 14:06:41 -0800 | [diff] [blame] | 119 | stream_ = nullptr; |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 120 | return stream; |
| 121 | } |
| 122 | |
| 123 | StreamAdapterInterface::~StreamAdapterInterface() { |
| 124 | if (owned_) |
| 125 | delete stream_; |
| 126 | } |
| 127 | |
kwiberg@webrtc.org | 67186fe | 2015-03-09 22:21:53 +0000 | [diff] [blame] | 128 | void StreamAdapterInterface::OnEvent(StreamInterface* stream, |
| 129 | int events, |
| 130 | int err) { |
| 131 | SignalEvent(this, events, err); |
| 132 | } |
| 133 | |
henrike@webrtc.org | f048872 | 2014-05-13 18:00:26 +0000 | [diff] [blame] | 134 | } // namespace rtc |