Make stream_id internal to StreamTextureHost.

content/renderer/media/android/stream_texture_wrapper_impl.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/renderer/media/android/stream_texture_wrapper_impl.h"
 
 #include "base/callback.h"
 #include "cc/layers/video_frame_provider.h"
 #include "gpu/GLES2/gl2extchromium.h"
 #include "gpu/command_buffer/client/gles2_interface.h"
@@ skipping 15 matching lines @@
   gl->ShallowFlushCHROMIUM();
 }
 }
 
 namespace content {
 
 StreamTextureWrapperImpl::StreamTextureWrapperImpl(
     scoped_refptr<StreamTextureFactory> factory,
     scoped_refptr<base::SingleThreadTaskRunner> main_task_runner)
     : texture_id_(0),
-      stream_id_(0),
       factory_(factory),
       main_task_runner_(main_task_runner),
       weak_factory_(this) {}
 
 StreamTextureWrapperImpl::~StreamTextureWrapperImpl() {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
 
-  if (stream_id_) {
+  if (texture_id_) {
     GLES2Interface* gl = factory_->ContextGL();
     gl->DeleteTextures(1, &texture_id_);
     // Flush to ensure that the stream texture gets deleted in a timely fashion.
     gl->ShallowFlushCHROMIUM();
   }
 
   SetCurrentFrameInternal(nullptr);
 }
 
 media::ScopedStreamTextureWrapper StreamTextureWrapperImpl::Create(
@@ skipping 44 matching lines @@
           base::TimeDelta());
 
   // TODO(tguilbert): Create and pipe the enable_texture_copy_ flag for Webview
   // scenarios. See crbug.com/628066.
 
   SetCurrentFrameInternal(new_frame);
 }
 
 void StreamTextureWrapperImpl::ForwardStreamTextureForSurfaceRequest(
     const base::UnguessableToken& request_token) {
-  return factory_->ForwardStreamTextureForSurfaceRequest(stream_id_,
-                                                         request_token);
+  stream_texture_proxy_->ForwardStreamTextureForSurfaceRequest(request_token);
 }
 
 void StreamTextureWrapperImpl::SetCurrentFrameInternal(
     const scoped_refptr<media::VideoFrame>& video_frame) {
   base::AutoLock auto_lock(current_frame_lock_);
   current_frame_ = video_frame;
 }
 
 void StreamTextureWrapperImpl::UpdateTextureSize(const gfx::Size& new_size) {
   DVLOG(2) << __FUNCTION__;
 
   if (!main_task_runner_->BelongsToCurrentThread()) {
     main_task_runner_->PostTask(
         FROM_HERE, base::Bind(&StreamTextureWrapperImpl::UpdateTextureSize,
                               weak_factory_.GetWeakPtr(), new_size));
     return;
   }
 
   if (natural_size_ == new_size)
     return;
 
   natural_size_ = new_size;
 
   ReallocateVideoFrame(new_size);
-  factory_->SetStreamTextureSize(stream_id_, new_size);
+  stream_texture_proxy_->SetStreamTextureSize(new_size);
 }
 
 void StreamTextureWrapperImpl::Initialize(
     const base::Closure& received_frame_cb,
     const gfx::Size& natural_size,
     scoped_refptr<base::SingleThreadTaskRunner> compositor_task_runner,
     const base::Closure& init_cb) {
   DVLOG(2) << __FUNCTION__;
 
   compositor_task_runner_ = compositor_task_runner;
   natural_size_ = natural_size;
 
   main_task_runner_->PostTask(
       FROM_HERE, base::Bind(&StreamTextureWrapperImpl::InitializeOnMainThread,
                             weak_factory_.GetWeakPtr(), received_frame_cb,
                             media::BindToCurrentLoop(init_cb)));
 }
 
 void StreamTextureWrapperImpl::InitializeOnMainThread(
     const base::Closure& received_frame_cb,
     const base::Closure& init_cb) {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
   DVLOG(2) << __FUNCTION__;
 
-  stream_texture_proxy_.reset(factory_->CreateProxy());
+  stream_texture_proxy_.reset(factory_->CreateProxy(
+      kGLTextureExternalOES, &texture_id_, &texture_mailbox_));
+  if (!stream_texture_proxy_)
+    return;
 
-  stream_id_ = factory_->CreateStreamTexture(kGLTextureExternalOES,
-                                             &texture_id_, &texture_mailbox_);
   ReallocateVideoFrame(natural_size_);
 
-  stream_texture_proxy_->BindToTaskRunner(stream_id_, received_frame_cb,
+  stream_texture_proxy_->BindToTaskRunner(received_frame_cb,
                                           compositor_task_runner_);
 
   // TODO(tguilbert): Register the surface properly. See crbug.com/627658.
 
   // |init_cb| is bound to the thread that originally called Initialize().
   init_cb.Run();
 }
 
 void StreamTextureWrapperImpl::Destroy() {
   // Note: StreamTextureProxy stop calling back the provided frame received
   // callback immediately, and delete itself on the right thread.
   stream_texture_proxy_.reset();
 
   if (!main_task_runner_->BelongsToCurrentThread()) {
     // base::Unretained is safe here because this function is the only one that
     // can can call delete.
     main_task_runner_->PostTask(
         FROM_HERE,
         base::Bind(&StreamTextureWrapperImpl::Destroy, base::Unretained(this)));
     return;
   }
 
   delete this;
 }
 
 }  // namespace content