Ganesh: images upload to GPU performance fix (skip copying encoded data)

third_party/WebKit/Source/platform/graphics/ThreadSafeDataTransport.h

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 12 matching lines @@
  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
 
 #ifndef ThreadSafeDataTransport_h
 #define ThreadSafeDataTransport_h
 
 #include "platform/PlatformExport.h"
 #include "wtf/OwnPtr.h"
 #include "wtf/PassOwnPtr.h"
 #include "wtf/RefPtr.h"
+#include "wtf/ThreadSafeRefCounted.h"
 #include "wtf/ThreadingPrimitives.h"
 #include "wtf/Vector.h"
 
 namespace blink {
 
 class SharedBuffer;
 
 // The purpose of this class is to allow the transfer of data stored in
 // SharedBuffer in a thread-safe manner, and to minimize memory copies
 // and thread contention.
 //
 // This class is designed such that there is only one producer and
 // one consumer.
-class PLATFORM_EXPORT ThreadSafeDataTransport {
+class PLATFORM_EXPORT ThreadSafeDataTransport : public ThreadSafeRefCounted<ThreadSafeDataTransport> {
 public:
     ThreadSafeDataTransport();
     ~ThreadSafeDataTransport();
 
     // This method is being called subsequently with an expanding
     // SharedBuffer.
     void setData(SharedBuffer*, bool allDataReceived);
 
     // Get the data submitted to this class so far.
     void data(SharedBuffer**, bool* allDataReceived);
 
     // Return true of there is new data submitted to this class
     // since last time data() was called.
     bool hasNewData();
 
 private:
     Mutex m_mutex;
 
     Vector<RefPtr<SharedBuffer>> m_newBufferQueue;
+    bool m_newAllDataReceived;
     RefPtr<SharedBuffer> m_readBuffer;
     bool m_allDataReceived;
     size_t m_readPosition;
 };
 
 } // namespace blink
 
 #endif