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/Descriptor.hpp"
#include "okssystem/File.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