1 files changed, 147 insertions, 0 deletions
diff --git a/src/player/BitmapManager.cpp b/src/player/BitmapManager.cpp
new file mode 100644
index 0000000..6151f1e
--- /dev/null
+++ b/src/player/BitmapManager.cpp
@@ -0,0 +1,147 @@
+//
+//  libavg - Media Playback Engine. 
+//  Copyright (C) 2003-2014 Ulrich von Zadow
+//
+//  This library is free software; you can redistribute it and/or
+//  modify it under the terms of the GNU Lesser General Public
+//  License as published by the Free Software Foundation; either
+//  version 2 of the License, or (at your option) any later version.
+//
+//  This library is distributed in the hope that it will be useful,
+//  but WITHOUT ANY WARRANTY; without even the implied warranty of
+//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+//  Lesser General Public License for more details.
+//
+//  You should have received a copy of the GNU Lesser General Public
+//  License along with this library; if not, write to the Free Software
+//  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+//
+//  Current versions can be found at www.libavg.de
+//
+
+#include "BitmapManager.h"
+#include "IBitmapLoadedListener.h"
+
+#ifdef WIN32
+#include  <io.h>
+#endif
+#include  <stdio.h>
+#include  <stdlib.h>
+
+#include "../base/OSHelper.h"
+
+using namespace std;
+
+namespace avg {
+
+BitmapManager * BitmapManager::s_pBitmapManager=0;
+
+BitmapManager::BitmapManager()
+{
+    if (s_pBitmapManager) {
+        throw Exception(AVG_ERR_UNKNOWN, "BitmapMananger has already been instantiated.");
+    }
+    
+    m_pCmdQueue = BitmapManagerThread::CQueuePtr(new BitmapManagerThread::CQueue);
+    m_pMsgQueue = BitmapManagerMsgQueuePtr(new BitmapManagerMsgQueue(8));
+
+    startThreads(1);
+
+    s_pBitmapManager = this;
+}
+
+BitmapManager::~BitmapManager()
+{
+    while (!m_pCmdQueue->empty()) {
+        m_pCmdQueue->pop();
+    }
+    while (!m_pMsgQueue->empty()) {
+        m_pMsgQueue->pop();
+    }
+    stopThreads();
+    s_pBitmapManager = 0;
+}
+
+BitmapManager* BitmapManager::get()
+{
+    if (!s_pBitmapManager) {
+        s_pBitmapManager = new BitmapManager();
+    }
+    return s_pBitmapManager;
+}
+
+void BitmapManager::loadBitmapPy(const UTF8String& sUtf8FileName,
+        const boost::python::object& pyFunc, PixelFormat pf)
+{
+    std::string sFileName = convertUTF8ToFilename(sUtf8FileName);
+    BitmapManagerMsgPtr pMsg = BitmapManagerMsgPtr(
+            new BitmapManagerMsg(sUtf8FileName, pyFunc, pf));
+    internalLoadBitmap(pMsg);
+}
+
+void BitmapManager::loadBitmap(const UTF8String& sUtf8FileName,
+        IBitmapLoadedListener* pLoadedListener, PixelFormat pf)
+{
+    std::string sFileName = convertUTF8ToFilename(sUtf8FileName);
+    BitmapManagerMsgPtr pMsg = BitmapManagerMsgPtr(
+            new BitmapManagerMsg(sUtf8FileName, pLoadedListener, pf));
+    internalLoadBitmap(pMsg);
+}
+
+void BitmapManager::setNumThreads(int numThreads)
+{
+    stopThreads();
+    startThreads(numThreads);
+}
+
+void BitmapManager::onFrameEnd()
+{
+    while (!m_pMsgQueue->empty()) {
+        BitmapManagerMsgPtr pMsg = m_pMsgQueue->pop();
+        pMsg->executeCallback();
+    }
+}
+
+void BitmapManager::internalLoadBitmap(BitmapManagerMsgPtr pMsg)
+{
+#ifdef WIN32
+    int rc = _access(pMsg->getFilename().c_str(), 04);
+#else
+    int rc = access(pMsg->getFilename().c_str(), R_OK);
+#endif
+
+    if (rc != 0) {
+        pMsg->setError(Exception(AVG_ERR_FILEIO, 
+                std::string("BitmapManager can't open output file '") +
+                pMsg->getFilename() + "'. Reason: " +
+                strerror(errno)));
+        m_pMsgQueue->push(pMsg);
+    } else {
+        m_pCmdQueue->pushCmd(boost::bind(&BitmapManagerThread::loadBitmap, _1, pMsg));
+    }
+}
+
+void BitmapManager::startThreads(int numThreads)
+{
+    for (int i=0; i<numThreads; ++i) {
+        boost::thread* pThread = new boost::thread(
+                BitmapManagerThread(*m_pCmdQueue, *m_pMsgQueue));
+        m_pBitmapManagerThreads.push_back(pThread);
+    }
+}
+
+void BitmapManager::stopThreads()
+{
+    int numThreads = m_pBitmapManagerThreads.size();
+    for (int i=0; i<numThreads; ++i) {
+        m_pCmdQueue->pushCmd(boost::bind(&BitmapManagerThread::stop, _1));
+    }
+    for (int i=0; i<numThreads; ++i) {
+        boost::thread* pThread = m_pBitmapManagerThreads[i];
+        pThread->join();
+        delete pThread;
+    }
+    m_pBitmapManagerThreads.clear();
+}
+
+}