#include "dataqueue.h"


DataQueue::DataQueue(QObject *parent) :
    QThread(parent), stopped(false)
{}


DataQueue::~DataQueue(){
}

void DataQueue::run() {
    mutex.lock();
    bool stop = stopped || (requestQueue.size() == 0);
    mutex.unlock();
    while (!stop) {
        mutex.lock();
        if (requestQueue.size() > 0) {
            DataResult1D data = loader->doLoad(requestQueue.front());
            resultMap.insert(std::pair<std::string, DataResult1D>(data.id, data));
            emit resultReady(QString::fromStdString(data.id));
            requestQueue.pop_front();
            stop = requestQueue.size() == 0 || stopped;
        }
        mutex.unlock();
    }
}

void DataQueue::requestData(const nix::DataArray &array, const nix::NDSize &count, const nix::NDSize &offset, std::string &requestId) {
    requestId = nix::util::createId();
    DataRequest dr(requestId, array, count, offset);
    mutex.lock();
    std::deque<DataRequest>::iterator it;
    for (it = requestQueue.begin(); it < requestQueue.end(); it++) {
        std::cerr << it->array.id() << std::endl;
        if (it->array.id() == array.id())
            std::cerr << "updating request" <<std::endl;
    }
    requestQueue.push_back(dr);
    mutex.unlock();
    start();
}

void DataQueue::stop() {
    mutex.lock();
    stopped = true;
    mutex.unlock();
}

DataResult1D DataQueue::getData(QString requestId) {
    DataResult1D ret;
    mutex.lock();
    std::map<std::string, DataResult1D>::iterator it = resultMap.find(requestId.toStdString());
    if (it != resultMap.end()) {
        ret = it->second;
        resultMap.erase(it);
    }
    mutex.unlock();
    return ret;
}