FIFOConnection.hpp

Go to the documentation of this file.

// DUNE DAQ modification notice:
// This file has been modified from the original ATLAS system source for the DUNE DAQ project.
// Fork baseline commit: system-00-00-20 (2020-09-25).
// Renamed since fork: yes (from system/FIFOConnection.h to include/okssystem/FIFOConnection.hpp).
 
/*
 *  FIFOConnection.h
 *  OksSystem
 *
 *  Created by Matthias Wiesmann on 07.04.05.
 *  Copyright 2005 CERN. All rights reserved.
 *
 */
 
#ifndef OKSSYSTEM_FIFO_CONNECTION
#define OKSSYSTEM_FIFO_CONNECTION
 
#include "okssystem/File.hpp"
#include "okssystem/Descriptor.hpp"
 
namespace OksSystem {
    
    
    class FIFOConnection : public File {
    
    public:
    static const unsigned int MAX_MESSAGE_LEN ;
 
    FIFOConnection(const std::string &name) ; 
    FIFOConnection(const File &file) ; 
 
    ~FIFOConnection() ;
 
    void make(mode_t perm=0622) const ; 
 
    std::string read_message() const ; 
    void send_message(const std::string &message) const ; 
 
    OksSystem::Descriptor* open_r(bool block = true);
    OksSystem::Descriptor* open_w(bool block = true);
    OksSystem::Descriptor* open_rw(bool block = true);
    void send(const std::string &message) const;
    std::string read() const;
    int fd() const;
    void close();
 
    private:
    OksSystem::Descriptor* m_fifo_fd;
    bool m_is_blocking;
    
    } ; // FIFOConnection
    
} // OksSystem
 
#endif