wefts_coffee_unix.h

Go to the documentation of this file.

/*
   wefts_coffee_unix.h
   Unix implementation for cooperative file functions enlarged enviroment

   $Id: wefts_coffee_unix.h,v 1.3 2004/03/08 20:28:53 jonnymind Exp $
---------------------------------------------
   Begin      : 2003-08-15 16:30
   Author     : Giancarlo Niccolai

   Last modified because:

*/

/**************************************************************************
*   This program is free software; you can redistribute it and/or modify  *
*   it under the terms of the GNU Library General Public License as       *
*   published by the Free Software Foundation; either version 2.1 of the  *
*   License, or (at your option) any later version.                       *
***************************************************************************/


#ifndef WT_COFFEE_UNIX_H
#define WT_COFFEE_UNIX_H

#include <wefts_coffee_base.h>

#include <sys/select.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

namespace Wefts {

class OSFileFuncUnix : public OSFileFuncBase
{
protected:
   /* Unix file descriptor to the open field */
   int m_fd;

   bool waitForWrite()
   {
      if ( m_timeout < 0 ) return true;
      fd_set set;
      struct timespec timeout;

      FD_SET( m_fd, &set);
      timeout.tv_sec = static_cast<long>(m_timeout);
      timeout.tv_nsec = static_cast<long>(
         (m_timeout - static_cast<long>(m_timeout)) *1000000000);
      pselect(m_fd + 1, NULL, &set, NULL, &timeout, NULL);

      return FD_ISSET( m_fd, &set );
   }


   bool waitForRead()
   {
      if ( m_timeout < 0 ) return true;
      fd_set set;
      struct timespec timeout;

      FD_SET( m_fd, &set);
      timeout.tv_sec = static_cast<long>(m_timeout);
      timeout.tv_nsec = static_cast<long>(
         (m_timeout - static_cast<long>(m_timeout)) *1000000000);
      pselect(m_fd + 1, &set, NULL, NULL, &timeout, NULL);

      return FD_ISSET( m_fd, &set );
   }


public:
   OSFileFuncUnix( void *descriptor = 0) :
         OSFileFuncBase()
   {
      if ( descriptor != 0 )
         setDescriptor( descriptor );
   }

   virtual CffStatus open(
      std::string filespec,             // the file name
      OpenMode openMode = OM_RO,        // open mode
      LockMode lockMode = LM_SHARED   // the file lock mode
      );

   virtual CffStatus create(
      std::string filespec,               // the file name
      CreateMode cMode = CM_ARCHIVE,            // system atrribute
      LockMode lockMode = LM_EXCLUSIVE  // the file lock mode
      );


   inline virtual void getDescriptor( void *data ) const
   {
      *static_cast<int *>(data) = m_fd;
   }

   inline virtual void setDescriptor( void *data )
   {
      m_fd = *static_cast<int *>(data);
   }

   virtual file_size_t read( void *buffer, const file_size_t len );
   virtual file_size_t write( void *buffer, const file_size_t len );
   virtual file_size_t seek(
      const file_size_t position,
      const SeekWhence swFrom= SW_FROM_BEGIN
      );
   virtual CffStatus close();

   inline virtual void setStdIn() { m_fd = 0; }
   inline virtual void setStdOut(){ m_fd = 1; }
   inline virtual void setStdErr(){ m_fd = 2; }

};

typedef OSFileFuncUnix OSFileFunc;

} // namespace

#endif

/* end of wefts_coffee_unix.h */

---