daemon.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_f06019c0635c00639ca65f74f67bed1a4db6bb3d506993ed4bac336c93eb48bb
#define USGOV_f06019c0635c00639ca65f74f67bed1a4db6bb3d506993ed4bac336c93eb48bb
 
#include "server.h"
#include <atomic>
#include <unordered_set>
#include <us/gov/config.h>
#include <us/gov/bgtask.h>
#include "thpool.h"
 
namespace us { namespace gov {
namespace socket {
    using namespace std;
    struct peer_t;
 
    struct daemon: server {
        typedef server b;
        static const char* KO_4093;
        daemon();
        daemon(const daemon&)=delete;
        daemon& operator = (const daemon&)=delete;
        daemon(uint16_t port, uint8_t workers);
        ~daemon() override;
        client* create_client(int sock) override;
        ko start() override;
        ko wait_ready(const chrono::system_clock::time_point& deadline) const override;
        void stop() override;
        void join() override;
        void dump(const string& prefix, ostream& os) const;
        void receive_and_process(client*) override;
        void process_work(peer_t *c);
        virtual bool process_work(peer_t *c, datagram*d);
        virtual string homedir() const=0;
        #if CFG_COUNTERS==1
            struct counters_t {
                uint32_t disconnection_normal{0};
                uint32_t disconnection_unknown_service{0};
                void dump(ostream& os) const;
            };
            static counters_t counters;
        #endif
        typedef thpool pool_t;
        pool_t pool;
        uint8_t num_workers;
    };
 
}
}}
 
#endif