---

NamedPipe.cpp

Go to the documentation of this file.

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>

#include "OSDependent/NamedPipe.h"

void NamedPipe::buildFileName(const char* name, char* buffer) {
   char* tmp_dir = getenv("TMPDIR");
   if (tmp_dir == NULL)
      tmp_dir = P_tmpdir;
   sprintf(buffer,"%s/%s.fifo",tmp_dir,name);
}

NamedPipe::NamedPipe() : _pipe(-1)
{
}

NamedPipe::~NamedPipe() {
   this->close();
}

void NamedPipe::close() {
   if (_pipe != -1) {
      ::close(_pipe);
      if (_is_server)
         unlink(_pname);
      _pipe = -1;
   }
}

int NamedPipe::create(const char* name, int mode, long timeout) {
   this->buildFileName(name,_pname);
   _is_server = 1;

   if (mkfifo(_pname,S_IFIFO|0600))
      return -1;

   int access_mode = O_RDONLY;
   if ((mode & NPIPE_READ) && (mode & NPIPE_WRITE))
      access_mode = O_RDWR;
   else if (mode & NPIPE_WRITE)
      access_mode = O_WRONLY;

   _pipe = open(_pname,access_mode);

   if (_pipe == -1) {
      unlink(_pname);
      return -1;
   }
   return 0;
}

int NamedPipe::connect(const char* name, int mode, long timeout) {
   this->buildFileName(name,_pname);
   _is_server = 0;

   int access_mode = O_RDONLY;
   if ((mode & NPIPE_READ) && (mode & NPIPE_WRITE))
      access_mode = O_RDWR;
   else if (mode & NPIPE_WRITE)
      access_mode = O_WRONLY;

   short tries = 0;
   do {
      _pipe = open(_pname,access_mode);
      tries++;
   }
   while ((_pipe==-1) && (timeout != -1) &&
          (usleep(timeout*100), tries <= 10));

   if (_pipe == -1)
      return -1;
   return 0;
}

long NamedPipe::write(char*buffer, long size) {
   return ::write(_pipe,buffer,size);
}

long NamedPipe::read(char*buffer, long size) {
   return ::read(_pipe,buffer,size);
}

void NamedPipe::flush() {
   fsync(_pipe);
}

---