http_connection.hpp

Go to the documentation of this file.

Go to the SVN repository for this file.

#ifndef HTTP_CONNECTION__HPP
#define HTTP_CONNECTION__HPP
 
/*  $Id: http_connection.hpp 99133 2023-02-16 18:52:33Z 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: Dmitri Dmitrienko
 *
 * File Description:
 *
 */
 
#include "psgs_reply.hpp"
#include "pending_operation.hpp"
#include "pubseq_gateway_logging.hpp"
#include "pubseq_gateway_types.hpp"
 
 
class CHttpConnection
{
public:
    CHttpConnection(size_t  http_max_backlog,
                    size_t  http_max_running) :
        m_HttpMaxBacklog(http_max_backlog), m_HttpMaxRunning(http_max_running),
        m_IsClosed(false), m_ScheduledMaintainTimer{0}
    {}
 
    ~CHttpConnection();
 
    void SetupMaintainTimer(uv_loop_t *  tcp_worker_loop);
    void CleanupToStop(void);
 
    bool IsClosed(void) const
    {
        return m_IsClosed;
    }
 
    void OnClientClosedConnection(void)
    {
        m_IsClosed = true;
        x_CancelAll();
    }
 
    void OnBeforeClosedConnection(void)
    {
        m_IsClosed = true;
        x_CancelAll();
    }
 
    static void s_OnBeforeClosedConnection(void *  data)
    {
        CHttpConnection *  p = static_cast<CHttpConnection*>(data);
        p->OnBeforeClosedConnection();
    }
 
    void PeekAsync(bool  chk_data_ready);
    void ResetForReuse(void);
    void Postpone(shared_ptr<CPSGS_Request>  request,
                  shared_ptr<CPSGS_Reply>  reply,
                  list<string>  processor_names);
    void ScheduleMaintain(void);
    void DoScheduledMaintain(void);
 
    void OnTimer(void)
    {
        PeekAsync(false);
        x_MaintainFinished();
    }
 
private:
    size_t                          m_HttpMaxBacklog;
    size_t                          m_HttpMaxRunning;
 
    volatile bool                   m_IsClosed;
    uv_timer_t                      m_ScheduledMaintainTimer;
 
    struct SBacklogAttributes
    {
        shared_ptr<CPSGS_Request>   m_Request;
        shared_ptr<CPSGS_Reply>     m_Reply;
        list<string>                m_PreliminaryDispatchedProcessors;
        psg_time_point_t            m_BacklogStart;
    };
 
    list<SBacklogAttributes>        m_BacklogRequests;
    list<shared_ptr<CPSGS_Reply>>   m_RunningRequests;
 
    void x_CancelAll(void);
    void x_CancelBacklog(void);
 
    using running_list_iterator_t = typename list<shared_ptr<CPSGS_Reply>>::iterator;
    using backlog_list_iterator_t = typename list<SBacklogAttributes>::iterator;
 
    void x_UnregisterRunning(running_list_iterator_t &  it);
    void x_UnregisterBacklog(backlog_list_iterator_t &  it);
 
    void x_RegisterPending(shared_ptr<CPSGS_Request>  request,
                           shared_ptr<CPSGS_Reply>  reply,
                           list<string>  processor_names);
    void x_Start(shared_ptr<CPSGS_Request>  request,
                 shared_ptr<CPSGS_Reply>  reply,
                 list<string>  processor_names);
 
    void x_MaintainFinished(void);
    void x_MaintainBacklog(void);
};
 
#endif