1/* 2 * Copyright (C) 2012 Google Inc. All rights reserved. 3 * 4 * Redistribution and use in source and binary forms, with or without 5 * modification, are permitted provided that the following conditions 6 * are met: 7 * 1. Redistributions of source code must retain the above copyright 8 * notice, this list of conditions and the following disclaimer. 9 * 2. Redistributions in binary form must reproduce the above copyright 10 * notice, this list of conditions and the following disclaimer in the 11 * documentation and/or other materials provided with the distribution. 12 * 13 * THIS SOFTWARE IS PROVIDED BY APPLE COMPUTER, INC. ``AS IS'' AND ANY 14 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 15 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 16 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE COMPUTER, INC. OR 17 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 18 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 19 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 20 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY 21 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 23 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 24 */ 25 26#include "config.h" 27 28#include "platform/graphics/ThreadSafeDataTransport.h" 29 30#include "platform/SharedBuffer.h" 31 32namespace blink { 33 34ThreadSafeDataTransport::ThreadSafeDataTransport() 35 : m_readBuffer(SharedBuffer::create()) 36 , m_allDataReceived(false) 37 , m_readPosition(0) 38{ 39} 40 41ThreadSafeDataTransport::~ThreadSafeDataTransport() 42{ 43} 44 45void ThreadSafeDataTransport::setData(SharedBuffer* buffer, bool allDataReceived) 46{ 47 ASSERT(buffer->size() >= m_readPosition); 48 Vector<RefPtr<SharedBuffer> > newBufferQueue; 49 50 const char* segment = 0; 51 while (size_t length = buffer->getSomeData(segment, m_readPosition)) { 52 m_readPosition += length; 53 newBufferQueue.append(SharedBuffer::create(segment, length)); 54 } 55 56 MutexLocker locker(m_mutex); 57 m_newBufferQueue.appendVector(newBufferQueue); 58 m_allDataReceived = allDataReceived; 59} 60 61void ThreadSafeDataTransport::data(SharedBuffer** buffer, bool* allDataReceived) 62{ 63 ASSERT(buffer); 64 ASSERT(allDataReceived); 65 Vector<RefPtr<SharedBuffer> > newBufferQueue; 66 { 67 MutexLocker lock(m_mutex); 68 m_newBufferQueue.swap(newBufferQueue); 69 *allDataReceived = m_allDataReceived; 70 } 71 for (size_t i = 0; i < newBufferQueue.size(); ++i) 72 m_readBuffer->append(newBufferQueue[i].get()); 73 *buffer = m_readBuffer.get(); 74} 75 76bool ThreadSafeDataTransport::hasNewData() 77{ 78 MutexLocker lock(m_mutex); 79 return !m_newBufferQueue.isEmpty(); 80} 81 82} // namespace blink 83