src/cc/resources/texture_uploader.cc

   1 // Copyright 2014 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 "cc/resources/texture_uploader.h"
   6
   7 #include <algorithm>
   8 #include <vector>
   9
  10 #include "base/debug/trace_event.h"
  11 #include "base/metrics/histogram.h"
  12 #include "cc/base/util.h"
  13 #include "cc/resources/prioritized_resource.h"
  14 #include "cc/resources/resource.h"
  15 #include "gpu/GLES2/gl2extchromium.h"
  16 #include "gpu/command_buffer/client/gles2_interface.h"
  17 #include "third_party/khronos/GLES2/gl2.h"
  18 #include "third_party/khronos/GLES2/gl2ext.h"
  19 #include "ui/gfx/rect.h"
  20 #include "ui/gfx/vector2d.h"
  21
  22 using gpu::gles2::GLES2Interface;
  23
  24 namespace {
  25
  26 // How many previous uploads to use when predicting future throughput.
  27 static const size_t kUploadHistorySizeMax = 1000;
  28 static const size_t kUploadHistorySizeInitial = 100;
  29
  30 // Global estimated number of textures per second to maintain estimates across
  31 // subsequent instances of TextureUploader.
  32 // More than one thread will not access this variable, so we do not need to
  33 // synchronize access.
  34 static const double kDefaultEstimatedTexturesPerSecond = 48.0 * 60.0;
  35
  36 // Flush interval when performing texture uploads.
  37 static const size_t kTextureUploadFlushPeriod = 4;
  38
  39 }  // anonymous namespace
  40
  41 namespace cc {
  42
  43 TextureUploader::Query::Query(GLES2Interface* gl)
  44     : gl_(gl),
  45       query_id_(0),
  46       value_(0),
  47       has_value_(false),
  48       is_non_blocking_(false) {
  49   gl_->GenQueriesEXT(1, &query_id_);
  50 }
  51
  52 TextureUploader::Query::~Query() { gl_->DeleteQueriesEXT(1, &query_id_); }
  53
  54 void TextureUploader::Query::Begin() {
  55   has_value_ = false;
  56   is_non_blocking_ = false;
  57   gl_->BeginQueryEXT(GL_COMMANDS_ISSUED_CHROMIUM, query_id_);
  58 }
  59
  60 void TextureUploader::Query::End() {
  61   gl_->EndQueryEXT(GL_COMMANDS_ISSUED_CHROMIUM);
  62 }
  63
  64 bool TextureUploader::Query::IsPending() {
  65   unsigned available = 1;
  66   gl_->GetQueryObjectuivEXT(
  67       query_id_, GL_QUERY_RESULT_AVAILABLE_EXT, &available);
  68   return !available;
  69 }
  70
  71 unsigned TextureUploader::Query::Value() {
  72   if (!has_value_) {
  73     gl_->GetQueryObjectuivEXT(query_id_, GL_QUERY_RESULT_EXT, &value_);
  74     has_value_ = true;
  75   }
  76   return value_;
  77 }
  78
  79 TextureUploader::TextureUploader(GLES2Interface* gl)
  80     : gl_(gl),
  81       num_blocking_texture_uploads_(0),
  82       sub_image_size_(0),
  83       num_texture_uploads_since_last_flush_(0) {
  84   for (size_t i = kUploadHistorySizeInitial; i > 0; i--)
  85     textures_per_second_history_.insert(kDefaultEstimatedTexturesPerSecond);
  86 }
  87
  88 TextureUploader::~TextureUploader() {}
  89
  90 size_t TextureUploader::NumBlockingUploads() {
  91   ProcessQueries();
  92   return num_blocking_texture_uploads_;
  93 }
  94
  95 void TextureUploader::MarkPendingUploadsAsNonBlocking() {
  96   for (ScopedPtrDeque<Query>::iterator it = pending_queries_.begin();
  97        it != pending_queries_.end();
  98        ++it) {
  99     if ((*it)->is_non_blocking())
 100       continue;
 101
 102     num_blocking_texture_uploads_--;
 103     (*it)->mark_as_non_blocking();
 104   }
 105
 106   DCHECK(!num_blocking_texture_uploads_);
 107 }
 108
 109 double TextureUploader::EstimatedTexturesPerSecond() {
 110   ProcessQueries();
 111
 112   // Use the median as our estimate.
 113   std::multiset<double>::iterator median = textures_per_second_history_.begin();
 114   std::advance(median, textures_per_second_history_.size() / 2);
 115   return *median;
 116 }
 117
 118 void TextureUploader::BeginQuery() {
 119   if (available_queries_.empty())
 120     available_queries_.push_back(Query::Create(gl_));
 121
 122   available_queries_.front()->Begin();
 123 }
 124
 125 void TextureUploader::EndQuery() {
 126   available_queries_.front()->End();
 127   pending_queries_.push_back(available_queries_.take_front());
 128   num_blocking_texture_uploads_++;
 129 }
 130
 131 void TextureUploader::Upload(const uint8* image,
 132                              const gfx::Rect& image_rect,
 133                              const gfx::Rect& source_rect,
 134                              gfx::Vector2d dest_offset,
 135                              ResourceFormat format,
 136                              const gfx::Size& size) {
 137   CHECK(image_rect.Contains(source_rect));
 138
 139   bool is_full_upload = dest_offset.IsZero() && source_rect.size() == size;
 140
 141   if (is_full_upload)
 142     BeginQuery();
 143
 144   if (format == ETC1) {
 145     // ETC1 does not support subimage uploads.
 146     DCHECK(is_full_upload);
 147     UploadWithTexImageETC1(image, size);
 148   } else {
 149     UploadWithMapTexSubImage(
 150         image, image_rect, source_rect, dest_offset, format);
 151   }
 152
 153   if (is_full_upload)
 154     EndQuery();
 155
 156   num_texture_uploads_since_last_flush_++;
 157   if (num_texture_uploads_since_last_flush_ >= kTextureUploadFlushPeriod)
 158     Flush();
 159 }
 160
 161 void TextureUploader::Flush() {
 162   if (!num_texture_uploads_since_last_flush_)
 163     return;
 164
 165   gl_->ShallowFlushCHROMIUM();
 166
 167   num_texture_uploads_since_last_flush_ = 0;
 168 }
 169
 170 void TextureUploader::ReleaseCachedQueries() {
 171   ProcessQueries();
 172   available_queries_.clear();
 173 }
 174
 175 void TextureUploader::UploadWithTexSubImage(const uint8* image,
 176                                             const gfx::Rect& image_rect,
 177                                             const gfx::Rect& source_rect,
 178                                             gfx::Vector2d dest_offset,
 179                                             ResourceFormat format) {
 180   TRACE_EVENT0("cc", "TextureUploader::UploadWithTexSubImage");
 181
 182   // Early-out if this is a no-op, and assert that |image| be valid if this is
 183   // not a no-op.
 184   if (source_rect.IsEmpty())
 185     return;
 186   DCHECK(image);
 187
 188   // Offset from image-rect to source-rect.
 189   gfx::Vector2d offset(source_rect.origin() - image_rect.origin());
 190
 191   const uint8* pixel_source;
 192   unsigned bytes_per_pixel = BitsPerPixel(format) / 8;
 193   // Use 4-byte row alignment (OpenGL default) for upload performance.
 194   // Assuming that GL_UNPACK_ALIGNMENT has not changed from default.
 195   unsigned upload_image_stride =
 196       RoundUp(bytes_per_pixel * source_rect.width(), 4u);
 197
 198   if (upload_image_stride == image_rect.width() * bytes_per_pixel &&
 199       !offset.x()) {
 200     pixel_source = &image[image_rect.width() * bytes_per_pixel * offset.y()];
 201   } else {
 202     size_t needed_size = upload_image_stride * source_rect.height();
 203     if (sub_image_size_ < needed_size) {
 204       sub_image_.reset(new uint8[needed_size]);
 205       sub_image_size_ = needed_size;
 206     }
 207     // Strides not equal, so do a row-by-row memcpy from the
 208     // paint results into a temp buffer for uploading.
 209     for (int row = 0; row < source_rect.height(); ++row)
 210       memcpy(&sub_image_[upload_image_stride * row],
 211              &image[bytes_per_pixel *
 212                     (offset.x() + (offset.y() + row) * image_rect.width())],
 213              source_rect.width() * bytes_per_pixel);
 214
 215     pixel_source = &sub_image_[0];
 216   }
 217
 218   gl_->TexSubImage2D(GL_TEXTURE_2D,
 219                      0,
 220                      dest_offset.x(),
 221                      dest_offset.y(),
 222                      source_rect.width(),
 223                      source_rect.height(),
 224                      GLDataFormat(format),
 225                      GLDataType(format),
 226                      pixel_source);
 227 }
 228
 229 void TextureUploader::UploadWithMapTexSubImage(const uint8* image,
 230                                                const gfx::Rect& image_rect,
 231                                                const gfx::Rect& source_rect,
 232                                                gfx::Vector2d dest_offset,
 233                                                ResourceFormat format) {
 234   TRACE_EVENT0("cc", "TextureUploader::UploadWithMapTexSubImage");
 235
 236   // Early-out if this is a no-op, and assert that |image| be valid if this is
 237   // not a no-op.
 238   if (source_rect.IsEmpty())
 239     return;
 240   DCHECK(image);
 241   // Compressed textures have no implementation of mapTexSubImage.
 242   DCHECK_NE(ETC1, format);
 243
 244   // Offset from image-rect to source-rect.
 245   gfx::Vector2d offset(source_rect.origin() - image_rect.origin());
 246
 247   unsigned bytes_per_pixel = BitsPerPixel(format) / 8;
 248   // Use 4-byte row alignment (OpenGL default) for upload performance.
 249   // Assuming that GL_UNPACK_ALIGNMENT has not changed from default.
 250   unsigned upload_image_stride =
 251       RoundUp(bytes_per_pixel * source_rect.width(), 4u);
 252
 253   // Upload tile data via a mapped transfer buffer
 254   uint8* pixel_dest =
 255       static_cast<uint8*>(gl_->MapTexSubImage2DCHROMIUM(GL_TEXTURE_2D,
 256                                                         0,
 257                                                         dest_offset.x(),
 258                                                         dest_offset.y(),
 259                                                         source_rect.width(),
 260                                                         source_rect.height(),
 261                                                         GLDataFormat(format),
 262                                                         GLDataType(format),
 263                                                         GL_WRITE_ONLY));
 264
 265   if (!pixel_dest) {
 266     UploadWithTexSubImage(image, image_rect, source_rect, dest_offset, format);
 267     return;
 268   }
 269
 270   if (upload_image_stride == image_rect.width() * bytes_per_pixel &&
 271       !offset.x()) {
 272     memcpy(pixel_dest,
 273            &image[image_rect.width() * bytes_per_pixel * offset.y()],
 274            source_rect.height() * image_rect.width() * bytes_per_pixel);
 275   } else {
 276     // Strides not equal, so do a row-by-row memcpy from the
 277     // paint results into the pixel_dest.
 278     for (int row = 0; row < source_rect.height(); ++row) {
 279       memcpy(&pixel_dest[upload_image_stride * row],
 280              &image[bytes_per_pixel *
 281                     (offset.x() + (offset.y() + row) * image_rect.width())],
 282              source_rect.width() * bytes_per_pixel);
 283     }
 284   }
 285
 286   gl_->UnmapTexSubImage2DCHROMIUM(pixel_dest);
 287 }
 288
 289 void TextureUploader::UploadWithTexImageETC1(const uint8* image,
 290                                              const gfx::Size& size) {
 291   TRACE_EVENT0("cc", "TextureUploader::UploadWithTexImageETC1");
 292   DCHECK_EQ(0, size.width() % 4);
 293   DCHECK_EQ(0, size.height() % 4);
 294
 295   gl_->CompressedTexImage2D(GL_TEXTURE_2D,
 296                             0,
 297                             GLInternalFormat(ETC1),
 298                             size.width(),
 299                             size.height(),
 300                             0,
 301                             Resource::MemorySizeBytes(size, ETC1),
 302                             image);
 303 }
 304
 305 void TextureUploader::ProcessQueries() {
 306   while (!pending_queries_.empty()) {
 307     if (pending_queries_.front()->IsPending())
 308       break;
 309
 310     unsigned us_elapsed = pending_queries_.front()->Value();
 311     UMA_HISTOGRAM_CUSTOM_COUNTS(
 312         "Renderer4.TextureGpuUploadTimeUS", us_elapsed, 0, 100000, 50);
 313
 314     // Clamp the queries to saner values in case the queries fail.
 315     us_elapsed = std::max(1u, us_elapsed);
 316     us_elapsed = std::min(15000u, us_elapsed);
 317
 318     if (!pending_queries_.front()->is_non_blocking())
 319       num_blocking_texture_uploads_--;
 320
 321     // Remove the min and max value from our history and insert the new one.
 322     double textures_per_second = 1.0 / (us_elapsed * 1e-6);
 323     if (textures_per_second_history_.size() >= kUploadHistorySizeMax) {
 324       textures_per_second_history_.erase(textures_per_second_history_.begin());
 325       textures_per_second_history_.erase(--textures_per_second_history_.end());
 326     }
 327     textures_per_second_history_.insert(textures_per_second);
 328
 329     available_queries_.push_back(pending_queries_.take_front());
 330   }
 331 }
 332
 333 }  // namespace cc