proto_connexion.hpp

/*********************************************************************/
// webdar - a web server and interface program to libdar
// Copyright (C) 2013-2025 Denis Corbin
//
// This file is part of Webdar
//
//  Webdar 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.
//
//  Webdar 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 Webdar.  If not, see <http://www.gnu.org/licenses/>
//
//----
//  to contact the author: dar.linux@free.fr
/*********************************************************************/
 
#ifndef PROTO_CONNEXION_HPP
#define PROTO_CONNEXION_HPP
 
#include "my_config.h"
 
    // C++ system header files
#include <string>
 
    // webdar headers
#include "exceptions.hpp"
 
 
 
class proto_connexion
{
public:
    enum status
    {
    connected,    //< both read and write are allowed
    not_connected //< session is closed both directions
    };
 
    proto_connexion(const std::string & peerip, unsigned int peerport);
 
    proto_connexion(const proto_connexion & ref) = delete;
    proto_connexion(proto_connexion && ref) noexcept = delete;
    proto_connexion & operator = (const proto_connexion & ref) = delete;
    proto_connexion & operator = (proto_connexion && ref) noexcept = delete;
 
    virtual ~proto_connexion();
 
    status get_status() const { return etat; };
    const std::string & get_ip() const { return ip; };
    unsigned int get_port() const { return port; };
 
    char read_one(bool blocking);
 
    char read_test_first(bool blocking);
 
    char read_test_second(bool blocking);
 
 
    void write(const char *a, unsigned int size);
 
    void flush_write();
 
 
protected:
 
    virtual void write_impl(const char *a, unsigned int size) = 0;
 
    virtual unsigned int read_impl(char *a, unsigned int size, bool blocking) = 0;
 
    void set_status(status st) { etat = st; };
 
private:
    status etat;       //< proto_connexion status
    std::string ip;    //< IP of the peer host
    unsigned int port; //< port of the peer port
 
    // buffer management for reading
    unsigned buffer_size;      //< size of the buffer
    char *buffer;              //< temporary area used for parsing, reading data FROM network
    unsigned int already_read; //< amount of data already read
    unsigned int data_size;    //< total of data in buffer, already read or not
 
    // output buffer
    unsigned out_buf_size;     //< allocated space for the output buffer (out_buf)
    char *out_buf;             //< temporary areas used to gather bytes for writing
    unsigned int last_unwrote; //< amount of byte pending for writing
 
    void fill_buffer(bool blocking);
};
 
#endif