src/Glyr/Request.hh

Go to the documentation of this file.

#ifndef FREYA_GLYR_REQUEST_HH
#define FREYA_GLYR_REQUEST_HH

#include "../MPD/Client.hh"
#include "../Utils/Singleton.hh"
#include "UpdateInterface.hh"
#include <gdkmm/pixbuf.h>

#include <glyr/cache.h>

namespace Glyr 
{
    Glib::RefPtr<Gdk::Pixbuf> create_pixbuf_from_cache(GlyrMemCache * c, int size_x = 150, int size_y = 150, bool aspect = false);


    class Stack
    {
        DEF_SINGLETON(Stack)

        public:

            void request(UpdateInterface * intf, MPD::Song& song, GLYR_GET_TYPE type, int number = 1);
            void request(UpdateInterface * intf,const char * artist, const char *  album, const char * title, GLYR_GET_TYPE type, int number = 1);

            /*
             * @brief Deinitializes glyr, kills all running queries, closes db
             */
            void destroy();

            void enqueue(UpdateInterface * intf);

        private:

            /*
             * Actual thread function that calls
             * glyr_get() and notifies the client
             */
            void thread(GlyrQuery * q, UpdateInterface * intf, Glib::Dispatcher * disp, int reqID);

            // Vars

            /*
             * A list of Queries that are running currently,
             * this is currently used to call glyr_signal_exit()
             * at program termination
             */
            typedef std::vector<GlyrQuery*> QueryList;
            QueryList murderList;

            /*
             * A pool of parallel executing Queries,
             * each thread one request
             */
            Glib::ThreadPool pool;

            /* 
             * A counter of currently running jobs,
             * once could also just use murderList.size(),
             * which is not atomar and would require 
             * additional locking
             */
            int jobCounter;

            /*
             * Locking stuff.
             */
            Glib::Cond destroyCond;
            Glib::Mutex deliverMutex, condMutex, deleteMutex;

            /*
             * True once destroy() was called
             */
            bool gotDestroyed;

            /*
             * Database connection
             */
            GlyrDatabase * dbConnection;
    };
}

#endif /* end of include guard: FREYA_GLYR_REQUEST_HH */