remoting/base/util.cc

   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
   3 // found in the LICENSE file.
   4
   5 #include "remoting/base/util.h"
   6
   7 #include <math.h>
   8
   9 #include "base/logging.h"
  10 #include "base/strings/stringprintf.h"
  11 #include "base/time/time.h"
  12 #include "media/base/video_frame.h"
  13 #include "media/base/yuv_convert.h"
  14 #include "third_party/libyuv/include/libyuv/convert.h"
  15 #include "third_party/webrtc/modules/desktop_capture/desktop_region.h"
  16
  17 using media::VideoFrame;
  18
  19 namespace remoting {
  20
  21 enum { kBytesPerPixelRGB32 = 4 };
  22
  23 // Do not write LOG messages in this routine since it is called from within
  24 // our LOG message handler. Bad things will happen.
  25 std::string GetTimestampString() {
  26   base::Time t = base::Time::NowFromSystemTime();
  27   base::Time::Exploded tex;
  28   t.LocalExplode(&tex);
  29   return base::StringPrintf("%02d%02d/%02d%02d%02d:",
  30                             tex.month, tex.day_of_month,
  31                             tex.hour, tex.minute, tex.second);
  32 }
  33
  34 int CalculateRGBOffset(int x, int y, int stride) {
  35   return stride * y + kBytesPerPixelRGB32 * x;
  36 }
  37
  38 int CalculateYOffset(int x, int y, int stride) {
  39   DCHECK(((x & 1) == 0) && ((y & 1) == 0));
  40   return stride * y + x;
  41 }
  42
  43 int CalculateUVOffset(int x, int y, int stride) {
  44   DCHECK(((x & 1) == 0) && ((y & 1) == 0));
  45   return stride * y / 2 + x / 2;
  46 }
  47
  48 void ConvertAndScaleYUVToRGB32Rect(
  49     const uint8* source_yplane,
  50     const uint8* source_uplane,
  51     const uint8* source_vplane,
  52     int source_ystride,
  53     int source_uvstride,
  54     const webrtc::DesktopSize& source_size,
  55     const webrtc::DesktopRect& source_buffer_rect,
  56     uint8* dest_buffer,
  57     int dest_stride,
  58     const webrtc::DesktopSize& dest_size,
  59     const webrtc::DesktopRect& dest_buffer_rect,
  60     const webrtc::DesktopRect& dest_rect) {
  61   // N.B. It is caller's responsibility to check if strides are large enough. We
  62   // cannot do it here anyway.
  63   DCHECK(DoesRectContain(webrtc::DesktopRect::MakeSize(source_size),
  64                          source_buffer_rect));
  65   DCHECK(DoesRectContain(webrtc::DesktopRect::MakeSize(dest_size),
  66                          dest_buffer_rect));
  67   DCHECK(DoesRectContain(dest_buffer_rect, dest_rect));
  68   DCHECK(DoesRectContain(ScaleRect(source_buffer_rect, source_size, dest_size),
  69                          dest_rect));
  70
  71   // If the source and/or destination buffers don't start at (0, 0)
  72   // offset the pointers to pretend we have complete buffers.
  73   int y_offset = - CalculateYOffset(source_buffer_rect.left(),
  74                                     source_buffer_rect.top(),
  75                                     source_ystride);
  76   int uv_offset = - CalculateUVOffset(source_buffer_rect.left(),
  77                                       source_buffer_rect.top(),
  78                                       source_uvstride);
  79   int rgb_offset = - CalculateRGBOffset(dest_buffer_rect.left(),
  80                                         dest_buffer_rect.top(),
  81                                         dest_stride);
  82
  83   // See if scaling is needed.
  84   if (source_size.equals(dest_size)) {
  85     // Calculate the inner rectangle that can be copied by the optimized
  86     // libyuv::I420ToARGB().
  87     webrtc::DesktopRect inner_rect =
  88         webrtc::DesktopRect::MakeLTRB(RoundToTwosMultiple(dest_rect.left() + 1),
  89                                       RoundToTwosMultiple(dest_rect.top() + 1),
  90                                       dest_rect.right(), dest_rect.bottom());
  91
  92     // Offset pointers to point to the top left corner of the inner rectangle.
  93     y_offset += CalculateYOffset(inner_rect.left(), inner_rect.top(),
  94                                  source_ystride);
  95     uv_offset += CalculateUVOffset(inner_rect.left(), inner_rect.top(),
  96                                    source_uvstride);
  97     rgb_offset += CalculateRGBOffset(inner_rect.left(), inner_rect.top(),
  98                                      dest_stride);
  99
 100     libyuv::I420ToARGB(source_yplane + y_offset, source_ystride,
 101                        source_uplane + uv_offset, source_uvstride,
 102                        source_vplane + uv_offset, source_uvstride,
 103                        dest_buffer + rgb_offset, dest_stride,
 104                        inner_rect.width(), inner_rect.height());
 105
 106     // Now see if some pixels weren't copied due to alignment.
 107     if (!dest_rect.equals(inner_rect)) {
 108       webrtc::DesktopRect outer_rect =
 109           webrtc::DesktopRect::MakeLTRB(RoundToTwosMultiple(dest_rect.left()),
 110                                         RoundToTwosMultiple(dest_rect.top()),
 111                                         dest_rect.right(), dest_rect.bottom());
 112
 113       webrtc::DesktopVector offset(outer_rect.left() - inner_rect.left(),
 114                                    outer_rect.top() - inner_rect.top());
 115
 116       // Offset the pointers to point to the top left corner of the outer
 117       // rectangle.
 118       y_offset += CalculateYOffset(offset.x(), offset.y(), source_ystride);
 119       uv_offset += CalculateUVOffset(offset.x(), offset.y(), source_uvstride);
 120       rgb_offset += CalculateRGBOffset(offset.x(), offset.y(), dest_stride);
 121
 122       // Draw unaligned edges.
 123       webrtc::DesktopRegion edges(dest_rect);
 124       edges.Subtract(inner_rect);
 125       for (webrtc::DesktopRegion::Iterator i(edges); !i.IsAtEnd();
 126            i.Advance()) {
 127         webrtc::DesktopRect rect = i.rect();
 128         rect.Translate(-outer_rect.left(), -outer_rect.top());
 129         media::ScaleYUVToRGB32WithRect(source_yplane + y_offset,
 130                                        source_uplane + uv_offset,
 131                                        source_vplane + uv_offset,
 132                                        dest_buffer + rgb_offset,
 133                                        source_size.width(),
 134                                        source_size.height(),
 135                                        dest_size.width(),
 136                                        dest_size.height(),
 137                                        rect.left(),
 138                                        rect.top(),
 139                                        rect.right(),
 140                                        rect.bottom(),
 141                                        source_ystride,
 142                                        source_uvstride,
 143                                        dest_stride);
 144       }
 145     }
 146   } else {
 147     media::ScaleYUVToRGB32WithRect(source_yplane + y_offset,
 148                                    source_uplane + uv_offset,
 149                                    source_vplane + uv_offset,
 150                                    dest_buffer + rgb_offset,
 151                                    source_size.width(),
 152                                    source_size.height(),
 153                                    dest_size.width(),
 154                                    dest_size.height(),
 155                                    dest_rect.left(),
 156                                    dest_rect.top(),
 157                                    dest_rect.right(),
 158                                    dest_rect.bottom(),
 159                                    source_ystride,
 160                                    source_uvstride,
 161                                    dest_stride);
 162   }
 163 }
 164
 165 int RoundToTwosMultiple(int x) {
 166   return x & (~1);
 167 }
 168
 169 webrtc::DesktopRect AlignRect(const webrtc::DesktopRect& rect) {
 170   int x = RoundToTwosMultiple(rect.left());
 171   int y = RoundToTwosMultiple(rect.top());
 172   int right = RoundToTwosMultiple(rect.right() + 1);
 173   int bottom = RoundToTwosMultiple(rect.bottom() + 1);
 174   return webrtc::DesktopRect::MakeLTRB(x, y, right, bottom);
 175 }
 176
 177 webrtc::DesktopRect ScaleRect(const webrtc::DesktopRect& rect,
 178                               const webrtc::DesktopSize& in_size,
 179                               const webrtc::DesktopSize& out_size) {
 180   int left = (rect.left() * out_size.width()) / in_size.width();
 181   int top = (rect.top() * out_size.height()) / in_size.height();
 182   int right = (rect.right() * out_size.width() + in_size.width() - 1) /
 183       in_size.width();
 184   int bottom = (rect.bottom() * out_size.height() + in_size.height() - 1) /
 185       in_size.height();
 186   return webrtc::DesktopRect::MakeLTRB(left, top, right, bottom);
 187 }
 188
 189 void CopyRGB32Rect(const uint8* source_buffer,
 190                    int source_stride,
 191                    const webrtc::DesktopRect& source_buffer_rect,
 192                    uint8* dest_buffer,
 193                    int dest_stride,
 194                    const webrtc::DesktopRect& dest_buffer_rect,
 195                    const webrtc::DesktopRect& dest_rect) {
 196   DCHECK(DoesRectContain(dest_buffer_rect, dest_rect));
 197   DCHECK(DoesRectContain(source_buffer_rect, dest_rect));
 198
 199   // Get the address of the starting point.
 200   source_buffer += CalculateRGBOffset(
 201       dest_rect.left() - source_buffer_rect.left(),
 202       dest_rect.top() - source_buffer_rect.top(),
 203       source_stride);
 204   dest_buffer += CalculateRGBOffset(
 205       dest_rect.left() - dest_buffer_rect.left(),
 206       dest_rect.top() - dest_buffer_rect.top(),
 207       source_stride);
 208
 209   // Copy pixels in the rectangle line by line.
 210   const int bytes_per_line = kBytesPerPixelRGB32 * dest_rect.width();
 211   for (int i = 0 ; i < dest_rect.height(); ++i) {
 212     memcpy(dest_buffer, source_buffer, bytes_per_line);
 213     source_buffer += source_stride;
 214     dest_buffer += dest_stride;
 215   }
 216 }
 217
 218 std::string ReplaceLfByCrLf(const std::string& in) {
 219   std::string out;
 220   out.resize(2 * in.size());
 221   char* out_p_begin = &out[0];
 222   char* out_p = out_p_begin;
 223   const char* in_p_begin = &in[0];
 224   const char* in_p_end = &in[in.size()];
 225   for (const char* in_p = in_p_begin; in_p < in_p_end; ++in_p) {
 226     char c = *in_p;
 227     if (c == '\n') {
 228       *out_p++ = '\r';
 229     }
 230     *out_p++ = c;
 231   }
 232   out.resize(out_p - out_p_begin);
 233   return out;
 234 }
 235
 236 std::string ReplaceCrLfByLf(const std::string& in) {
 237   std::string out;
 238   out.resize(in.size());
 239   char* out_p_begin = &out[0];
 240   char* out_p = out_p_begin;
 241   const char* in_p_begin = &in[0];
 242   const char* in_p_end = &in[in.size()];
 243   for (const char* in_p = in_p_begin; in_p < in_p_end; ++in_p) {
 244     char c = *in_p;
 245     if ((c == '\r') && (in_p + 1 < in_p_end) && (*(in_p + 1) == '\n')) {
 246       *out_p++ = '\n';
 247       ++in_p;
 248     } else {
 249       *out_p++ = c;
 250     }
 251   }
 252   out.resize(out_p - out_p_begin);
 253   return out;
 254 }
 255
 256 bool StringIsUtf8(const char* data, size_t length) {
 257   const char* ptr = data;
 258   const char* ptr_end = data + length;
 259   while (ptr != ptr_end) {
 260     if ((*ptr & 0x80) == 0) {
 261       // Single-byte symbol.
 262       ++ptr;
 263     } else if ((*ptr & 0xc0) == 0x80 || (*ptr & 0xfe) == 0xfe) {
 264       // Invalid first byte.
 265       return false;
 266     } else {
 267       // First byte of a multi-byte symbol. The bits from 2 to 6 are the count
 268       // of continuation bytes (up to 5 of them).
 269       for (char first = *ptr << 1; first & 0x80; first <<= 1) {
 270         ++ptr;
 271
 272         // Missing continuation byte.
 273         if (ptr == ptr_end)
 274           return false;
 275
 276         // Invalid continuation byte.
 277         if ((*ptr & 0xc0) != 0x80)
 278           return false;
 279       }
 280
 281       ++ptr;
 282     }
 283   }
 284
 285   return true;
 286 }
 287
 288 bool DoesRectContain(const webrtc::DesktopRect& a,
 289                      const webrtc::DesktopRect& b) {
 290   webrtc::DesktopRect intersection(a);
 291   intersection.IntersectWith(b);
 292   return intersection.equals(b);
 293 }
 294
 295 }  // namespace remoting