OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "remoting/codec/video_decoder_row_based.h" | 5 #include "remoting/codec/video_decoder_row_based.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "remoting/base/decompressor.h" | 8 #include "remoting/base/decompressor.h" |
9 #include "remoting/base/decompressor_zlib.h" | 9 #include "remoting/base/decompressor_zlib.h" |
10 #include "remoting/base/decompressor_verbatim.h" | 10 #include "remoting/base/decompressor_verbatim.h" |
11 #include "remoting/base/util.h" | 11 #include "remoting/base/util.h" |
12 | 12 |
13 namespace remoting { | 13 namespace remoting { |
14 | 14 |
15 namespace { | 15 namespace { |
16 // Both input and output data are assumed to be RGBA32. | 16 // Both input and output data are assumed to be RGBA32. |
17 const int kBytesPerPixel = 4; | 17 const int kBytesPerPixel = 4; |
18 } | 18 } |
19 | 19 |
20 DecoderRowBased* DecoderRowBased::CreateZlibDecoder() { | 20 VideoDecoderRowBased* VideoDecoderRowBased::CreateZlibDecoder() { |
21 return new DecoderRowBased(new DecompressorZlib(), | 21 return new VideoDecoderRowBased(new DecompressorZlib(), |
22 VideoPacketFormat::ENCODING_ZLIB); | 22 VideoPacketFormat::ENCODING_ZLIB); |
23 } | 23 } |
24 | 24 |
25 DecoderRowBased* DecoderRowBased::CreateVerbatimDecoder() { | 25 VideoDecoderRowBased* VideoDecoderRowBased::CreateVerbatimDecoder() { |
26 return new DecoderRowBased(new DecompressorVerbatim(), | 26 return new VideoDecoderRowBased(new DecompressorVerbatim(), |
27 VideoPacketFormat::ENCODING_VERBATIM); | 27 VideoPacketFormat::ENCODING_VERBATIM); |
28 } | 28 } |
29 | 29 |
30 DecoderRowBased::DecoderRowBased(Decompressor* decompressor, | 30 VideoDecoderRowBased::VideoDecoderRowBased(Decompressor* decompressor, |
31 VideoPacketFormat::Encoding encoding) | 31 VideoPacketFormat::Encoding encoding) |
32 : state_(kUninitialized), | 32 : state_(kUninitialized), |
33 clip_(SkIRect::MakeEmpty()), | 33 clip_(SkIRect::MakeEmpty()), |
34 decompressor_(decompressor), | 34 decompressor_(decompressor), |
35 encoding_(encoding), | 35 encoding_(encoding), |
36 row_pos_(0), | 36 row_pos_(0), |
37 row_y_(0), | 37 row_y_(0), |
38 screen_size_(SkISize::Make(0, 0)) { | 38 screen_size_(SkISize::Make(0, 0)) { |
39 } | 39 } |
40 | 40 |
41 DecoderRowBased::~DecoderRowBased() { | 41 VideoDecoderRowBased::~VideoDecoderRowBased() { |
42 } | 42 } |
43 | 43 |
44 bool DecoderRowBased::IsReadyForData() { | 44 bool VideoDecoderRowBased::IsReadyForData() { |
45 switch (state_) { | 45 switch (state_) { |
46 case kUninitialized: | 46 case kUninitialized: |
47 case kError: | 47 case kError: |
48 return false; | 48 return false; |
49 case kReady: | 49 case kReady: |
50 case kProcessing: | 50 case kProcessing: |
51 case kPartitionDone: | 51 case kPartitionDone: |
52 case kDone: | 52 case kDone: |
53 return true; | 53 return true; |
54 } | 54 } |
55 NOTREACHED(); | 55 NOTREACHED(); |
56 return false; | 56 return false; |
57 } | 57 } |
58 | 58 |
59 void DecoderRowBased::Initialize(const SkISize& screen_size) { | 59 void VideoDecoderRowBased::Initialize(const SkISize& screen_size) { |
60 decompressor_->Reset(); | 60 decompressor_->Reset(); |
61 updated_region_.setEmpty(); | 61 updated_region_.setEmpty(); |
62 screen_buffer_.reset(NULL); | 62 screen_buffer_.reset(NULL); |
63 | 63 |
64 screen_size_ = screen_size; | 64 screen_size_ = screen_size; |
65 // Allocate the screen buffer, if necessary. | 65 // Allocate the screen buffer, if necessary. |
66 if (!screen_size_.isEmpty()) { | 66 if (!screen_size_.isEmpty()) { |
67 screen_buffer_.reset(new uint8[ | 67 screen_buffer_.reset(new uint8[ |
68 screen_size_.width() * screen_size_.height() * kBytesPerPixel]); | 68 screen_size_.width() * screen_size_.height() * kBytesPerPixel]); |
69 } | 69 } |
70 | 70 |
71 state_ = kReady; | 71 state_ = kReady; |
72 } | 72 } |
73 | 73 |
74 Decoder::DecodeResult DecoderRowBased::DecodePacket(const VideoPacket* packet) { | 74 VideoDecoder::DecodeResult VideoDecoderRowBased::DecodePacket( |
| 75 const VideoPacket* packet) { |
75 UpdateStateForPacket(packet); | 76 UpdateStateForPacket(packet); |
76 | 77 |
77 if (state_ == kError) { | 78 if (state_ == kError) { |
78 return DECODE_ERROR; | 79 return DECODE_ERROR; |
79 } | 80 } |
80 | 81 |
81 const uint8* in = reinterpret_cast<const uint8*>(packet->data().data()); | 82 const uint8* in = reinterpret_cast<const uint8*>(packet->data().data()); |
82 const int in_size = packet->data().size(); | 83 const int in_size = packet->data().size(); |
83 const int row_size = clip_.width() * kBytesPerPixel; | 84 const int row_size = clip_.width() * kBytesPerPixel; |
84 | 85 |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
123 decompressor_->Reset(); | 124 decompressor_->Reset(); |
124 } | 125 } |
125 | 126 |
126 if (state_ == kDone) { | 127 if (state_ == kDone) { |
127 return DECODE_DONE; | 128 return DECODE_DONE; |
128 } else { | 129 } else { |
129 return DECODE_IN_PROGRESS; | 130 return DECODE_IN_PROGRESS; |
130 } | 131 } |
131 } | 132 } |
132 | 133 |
133 void DecoderRowBased::UpdateStateForPacket(const VideoPacket* packet) { | 134 void VideoDecoderRowBased::UpdateStateForPacket(const VideoPacket* packet) { |
134 if (state_ == kError) { | 135 if (state_ == kError) { |
135 return; | 136 return; |
136 } | 137 } |
137 | 138 |
138 if (packet->flags() & VideoPacket::FIRST_PACKET) { | 139 if (packet->flags() & VideoPacket::FIRST_PACKET) { |
139 if (state_ != kReady && state_ != kDone && state_ != kPartitionDone) { | 140 if (state_ != kReady && state_ != kDone && state_ != kPartitionDone) { |
140 state_ = kError; | 141 state_ = kError; |
141 LOG(WARNING) << "Received unexpected FIRST_PACKET."; | 142 LOG(WARNING) << "Received unexpected FIRST_PACKET."; |
142 return; | 143 return; |
143 } | 144 } |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
176 state_ = kError; | 177 state_ = kError; |
177 LOG(WARNING) << "Received unexpected LAST_PARTITION."; | 178 LOG(WARNING) << "Received unexpected LAST_PARTITION."; |
178 return; | 179 return; |
179 } | 180 } |
180 state_ = kDone; | 181 state_ = kDone; |
181 } | 182 } |
182 | 183 |
183 return; | 184 return; |
184 } | 185 } |
185 | 186 |
186 VideoPacketFormat::Encoding DecoderRowBased::Encoding() { | 187 VideoPacketFormat::Encoding VideoDecoderRowBased::Encoding() { |
187 return encoding_; | 188 return encoding_; |
188 } | 189 } |
189 | 190 |
190 void DecoderRowBased::Invalidate(const SkISize& view_size, | 191 void VideoDecoderRowBased::Invalidate(const SkISize& view_size, |
191 const SkRegion& region) { | 192 const SkRegion& region) { |
192 updated_region_.op(region, SkRegion::kUnion_Op); | 193 updated_region_.op(region, SkRegion::kUnion_Op); |
193 } | 194 } |
194 | 195 |
195 void DecoderRowBased::RenderFrame(const SkISize& view_size, | 196 void VideoDecoderRowBased::RenderFrame(const SkISize& view_size, |
196 const SkIRect& clip_area, | 197 const SkIRect& clip_area, |
197 uint8* image_buffer, | 198 uint8* image_buffer, |
198 int image_stride, | 199 int image_stride, |
199 SkRegion* output_region) { | 200 SkRegion* output_region) { |
200 output_region->setEmpty(); | 201 output_region->setEmpty(); |
201 | 202 |
202 // TODO(alexeypa): scaling is not implemented. | 203 // TODO(alexeypa): scaling is not implemented. |
203 SkIRect clip_rect = SkIRect::MakeSize(screen_size_); | 204 SkIRect clip_rect = SkIRect::MakeSize(screen_size_); |
204 if (!clip_rect.intersect(clip_area)) | 205 if (!clip_rect.intersect(clip_area)) |
205 return; | 206 return; |
206 | 207 |
207 int screen_stride = screen_size_.width() * kBytesPerPixel; | 208 int screen_stride = screen_size_.width() * kBytesPerPixel; |
208 | 209 |
209 for (SkRegion::Iterator i(updated_region_); !i.done(); i.next()) { | 210 for (SkRegion::Iterator i(updated_region_); !i.done(); i.next()) { |
210 SkIRect rect(i.rect()); | 211 SkIRect rect(i.rect()); |
211 if (!rect.intersect(clip_rect)) | 212 if (!rect.intersect(clip_rect)) |
212 continue; | 213 continue; |
213 | 214 |
214 CopyRGB32Rect(screen_buffer_.get(), screen_stride, | 215 CopyRGB32Rect(screen_buffer_.get(), screen_stride, |
215 clip_rect, | 216 clip_rect, |
216 image_buffer, image_stride, | 217 image_buffer, image_stride, |
217 clip_area, | 218 clip_area, |
218 rect); | 219 rect); |
219 output_region->op(rect, SkRegion::kUnion_Op); | 220 output_region->op(rect, SkRegion::kUnion_Op); |
220 } | 221 } |
221 | 222 |
222 updated_region_.setEmpty(); | 223 updated_region_.setEmpty(); |
223 } | 224 } |
224 | 225 |
225 } // namespace remoting | 226 } // namespace remoting |
OLD | NEW |