tuyau.hpp

Go to the documentation of this file.

/*********************************************************************/
// dar - disk archive - a backup/restoration program
// Copyright (C) 2002-2024 Denis Corbin
//
// This program 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 2
// of the License, or (at your option) any later version.
//
// This program 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 this program; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
// to contact the author, see the AUTHOR file
/*********************************************************************/
 
 
#ifndef TUYAU_HPP
#define TUYAU_HPP
 
#include "../my_config.h"
#include "infinint.hpp"
#include "generic_file.hpp"
#include "thread_cancellation.hpp"
#include "mem_ui.hpp"
 
namespace libdar
{
 
 
 
    class tuyau : public generic_file, public thread_cancellation, protected mem_ui
    {
    public:
        tuyau(const std::shared_ptr<user_interaction> & dialog, 
          int fd                           
        );
        tuyau(const std::shared_ptr<user_interaction> & dialog, 
          int fd,                          
          gf_mode mode                     
        );
        tuyau(const std::shared_ptr<user_interaction> & dialog, 
          const std::string &filename,     
          gf_mode mode                     
        );
 
    tuyau(const std::shared_ptr<user_interaction> & dialog); 
    tuyau(const tuyau & ref) = default;
    tuyau(tuyau && ref) noexcept = default;
    tuyau & operator = (const tuyau & ref) = default;
    tuyau & operator = (tuyau && ref) noexcept = default;
        ~tuyau();
 
    int get_read_fd() const;
 
 
    void close_read_fd();
 
    void do_not_close_read_fd();
 
            // inherited from generic_file
    virtual bool skippable(skippability direction, const infinint & amount) override;
        virtual bool skip(const infinint & pos) override;
        virtual bool skip_to_eof() override;
        virtual bool skip_relative(signed int x) override;
    virtual bool truncatable(const infinint & pos) const override { return pos >= position; };
        virtual infinint get_position() const override { return position; };
 
    bool has_next_to_read();
 
    protected:
    virtual void inherited_read_ahead(const infinint & amount) override {}; // relying on the operating system
        virtual U_I inherited_read(char *a, U_I size) override;
        virtual void inherited_write(const char *a, U_I size) override;
    virtual void inherited_truncate(const infinint & pos) override { if(pos < position) throw SRC_BUG; };
    virtual void inherited_sync_write() override {};
    virtual void inherited_flush_read() override {};
    virtual void inherited_terminate() override;
 
    private:
    enum                
    {
        pipe_fd,        
        pipe_path,      
        pipe_both       
    } pipe_mode;        
    infinint position;  
    int filedesc;       
    int other_end_fd;   
        std::string chemin; 
    bool has_one_to_read; 
    char next_to_read;  
 
        void ouverture();
 
 
    bool read_and_drop(infinint byte);
 
    bool read_to_eof();
    };
 
 
} // end of namespace
 
#endif