ns_rollback.hpp

Go to the documentation of this file.

Go to the SVN repository for this file.

#ifndef NETSCHEDULE_ROLLBACK__HPP
#define NETSCHEDULE_ROLLBACK__HPP
 
/*  $Id: ns_rollback.hpp 66722 2015-03-20 13:56:42Z satskyse $
 * ===========================================================================
 *
 *                            PUBLIC DOMAIN NOTICE
 *               National Center for Biotechnology Information
 *
 *  This software/database is a "United States Government Work" under the
 *  terms of the United States Copyright Act.  It was written as part of
 *  the author's official duties as a United States Government employee and
 *  thus cannot be copyrighted.  This software/database is freely available
 *  to the public for use. The National Library of Medicine and the U.S.
 *  Government have not placed any restriction on its use or reproduction.
 *
 *  Although all reasonable efforts have been taken to ensure the accuracy
 *  and reliability of the software and data, the NLM and the U.S.
 *  Government do not and cannot warrant the performance or results that
 *  may be obtained by using this software or data. The NLM and the U.S.
 *  Government disclaim all warranties, express or implied, including
 *  warranties of performance, merchantability or fitness for any particular
 *  purpose.
 *
 *  Please cite the author in any work or product based on this material.
 *
 * ===========================================================================
 *
 * Authors:  Sergey Satskiy
 *
 * File Description:
 *   NetSchedule limited rollback support
 *
 */
 
 
#include "ns_clients.hpp"
#include "ns_precise_time.hpp"
 
 
BEGIN_NCBI_SCOPE
 
// Forward declaration
class CQueue;
 
 
class CNSRollbackInterface
{
    public:
        virtual void  Rollback(CQueue *  queue) = 0;
        virtual ~CNSRollbackInterface() {}
};
 
 
 
class CNSSubmitRollback : public CNSRollbackInterface
{
    public:
        CNSSubmitRollback(const CNSClientId &  client,
                          unsigned int         job_id,
                          const CNSPreciseTime &  op_begin,
                          const CNSPreciseTime &  written_to_db) :
            m_Client(client), m_JobId(job_id),
            m_OpBegin(op_begin), m_WrittenToDB(written_to_db)
        {}
 
        virtual ~CNSSubmitRollback() {}
 
    public:
        virtual void  Rollback(CQueue *  queue);
 
    private:
        CNSClientId     m_Client;
        unsigned int    m_JobId;
        CNSPreciseTime  m_OpBegin;
        CNSPreciseTime  m_WrittenToDB;
};
 
 
 
class CNSBatchSubmitRollback : public CNSRollbackInterface
{
    public:
        CNSBatchSubmitRollback(const CNSClientId &  client,
                               unsigned int         first_job_id,
                               size_t               batch_size) :
            m_Client(client),
            m_FirstJobId(first_job_id), m_BatchSize(batch_size)
        {}
 
        virtual ~CNSBatchSubmitRollback() {}
 
    public:
        virtual void  Rollback(CQueue *  queue);
 
    private:
        CNSClientId     m_Client;
        unsigned int    m_FirstJobId;
        size_t          m_BatchSize;
};
 
 
 
class CNSGetJobRollback : public CNSRollbackInterface
{
    public:
        CNSGetJobRollback(const CNSClientId &  client,
                          unsigned int         job_id) :
            m_Client(client), m_JobId(job_id)
        {}
 
        virtual ~CNSGetJobRollback() {}
 
    public:
        virtual void  Rollback(CQueue *  queue);
 
    private:
        CNSClientId     m_Client;
        unsigned int    m_JobId;
};
 
 
class CNSReadJobRollback : public CNSRollbackInterface
{
    public:
        CNSReadJobRollback(const CNSClientId &  client,
                          unsigned int          job_id,
                          TJobStatus            previous_status) :
            m_Client(client), m_JobId(job_id),
            m_PreviousStatus(previous_status)
        {}
 
        virtual ~CNSReadJobRollback() {}
 
    public:
        virtual void  Rollback(CQueue *  queue);
 
    private:
        CNSClientId     m_Client;
        unsigned int    m_JobId;
        TJobStatus      m_PreviousStatus;
};
 
 
 
END_NCBI_SCOPE
 
#endif /* NETSCHEDULE_ROLLBACK__HPP */