peer_t.h

Go to the documentation of this file.

/*
-------------------------------------------------------------------------------
                            PLEBBLE
-------------------------------------------------------------------------------
 Copyright (C) 2019-2020 KATLAS Technology. (http://katlastechnology.com)
 Copyright (C) 2017-2020 Marcos Mayorga. (mm@mm-studios.com)
 
 This file is part of our Plebble(R) Platform.
 
 The code below cannot be copied, used for any purpose other than the one
 agreed and/or distributed without the express permission of
 KATLAS Technology.
-------------------------------------------------------------------------------
 
 
*/
#ifndef USGOV_2d8af251450aa79ce1d82cd9d9330072930013905de9945ca29228083ef3eee4
#define USGOV_2d8af251450aa79ce1d82cd9d9330072930013905de9945ca29228083ef3eee4
 
#include "client.h"
#include <atomic>
 
namespace us { namespace gov {
namespace socket {
    using namespace std;
    struct daemon;
 
    struct peer_t: client {
        typedef client b;
 
        constexpr static chrono::seconds stall{5s};
        static const char* finished_reason_1;
        static const char* finished_reason_2;
 
        peer_t();
        peer_t(int sock);
        peer_t(const peer_t&)=delete;
        peer_t& operator = (const peer_t&)=delete;
        ~peer_t() override;
        void dump_all(const string& prefix, ostream& os) const override;
        pair<security_level_t,string> security_level() const override;
        bool stalled_datagram() const;
        bool process_work(datagram* d);
        void dump(const string& prefix, ostream& os) const;
        virtual void on_peer_disconnected(const string& reason);
 
        datagram* curd{nullptr};
        mutable mutex mx_curd;
    };
}
}}
 
#endif