//  SuperTuxKart - a fun racing game with go-kart
//  Copyright (C) 2013-2015 Glenn De Jonghe
//  This program is free software; you can redistribute it and/or
//  modify it under the terms of the GNU General Public License
//  as published by the Free Software Foundation; either version 3
//  of the License, or (at your option) any later version.
//
//  This program 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 General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program; if not, write to the Free Software
//  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

#include "online/request.hpp"

#include "config/user_config.hpp"
#include "online/request_manager.hpp"

#ifdef WIN32
#  include <winsock2.h>
#endif

#include <assert.h>

namespace Online
{
    // ========================================================================
    /**
     *  Creates a request that can be handled by the RequestManager
     *  \param priority by what priority should the RequestManager take care of
     *         this request
     *  \param type indicates whether the request has a special task for the
     *         RequestManager
     */
    Request::Request(int priority, int type)
        : m_type(type), m_priority(priority)
    {
        m_cancel.setAtomic(false);
        m_state.setAtomic(S_PREPARING);
        m_is_abortable.setAtomic(true);
    }   // Request

    // ------------------------------------------------------------------------
    /** Inserts this request into the RequestManager's queue for executing.
     */
    void Request::queue()
    {
        RequestManager::get()->addRequest(shared_from_this());
    }   // queue

    // ------------------------------------------------------------------------
    /** Executes the request. This calles prepareOperation, operation, and
     *  afterOperation.
     */
    void Request::execute()
    {
        assert(isBusy());
        // Abort as early as possible if abort is requested
        if (RequestManager::isRunning() &&
            RequestManager::get()->getAbort() && isAbortable()) return;
        prepareOperation();
        if (RequestManager::isRunning() &&
            RequestManager::get()->getAbort() && isAbortable()) return;
        operation();
        if (RequestManager::isRunning() &&
            RequestManager::get()->getAbort() && isAbortable()) return;
        setExecuted();
        if (RequestManager::isRunning() &&
            RequestManager::get()->getAbort() && isAbortable()) return;
        afterOperation();
    }   // execute

    // ------------------------------------------------------------------------
    /** Executes the request now, i.e. in the main thread and without involving
     *  the manager thread.. This calles prepareOperation, operation, and
     *  afterOperation.
     */
    void Request::executeNow()
    {
        assert(isPreparing());
        setBusy();
        execute();
        if (RequestManager::isRunning() &&
            RequestManager::get()->getAbort() && isAbortable()) return;
        callback();
        if (RequestManager::isRunning() &&
            RequestManager::get()->getAbort() && isAbortable()) return;
        setDone();
    }   // executeNow

} // namespace Online