Search  

---

C:/temp/src/j2k/nto/NameSpace.cpp

Go to the documentation of this file.

#ifndef __J2K__NameSpace_CPP__
#define __J2K__NameSpace_CPP__

#include <j2k/nto/NameSpace.hpp>

NameSpace::NameSpace( const char* name0 = "myname", size_t nbConsumers = 1, size_t nbProducers = 1, size_t nbServers = 1 )
: name( NULL ), 
  nameLen( 0 ), 
  attach_info( NULL ), 
  rcvid( 0 )
{
  initName( name0 );
  initSync( nbConsumers, nbProducers, nbServers );
}

void NameSpace::initName( const char* name0 = NULL )
{
  if ( name0 != NULL )
  {
    nameLen = strlen( name0 );
    name    = new char[ nameLen + 1 ];
    memcpy( name, name0, nameLen );
    name[ nameLen ] = '\0';
  }
}

NameSpace::~NameSpace()
{
  if ( name != NULL ) 
  { 
    delete[] name;
  }
}

void NameSpace::Nattach( const char* name0 = NULL )
{
  initName( name0 );

  /* Create a local name (/dev/name/local/...) */
  attach_info = name_attach( NULL, name, 0 );

  if ( attach_info == NULL )
  {
    printf( "Couldn't create an attach point named: [%s]. \n", name );
    switch( errno )
    {
      case EINVAL:
        printf( "Invalid arguments: \n" );
        printf( " - a NULL or empty path \n" );
        printf( " - a path starts with a leading slash / or contains .. characters \n" ); 
      break;

      case ENOMEM:
        printf( " Not enough free memory to complete the operation. \n" );
      break;

      case ENOTDIR:
        printf( "A component of the pathname wasn't a directory entry. \n" );
      break;

      default:
        printf( "Unknown Error %s \n", strerror( errno ) );
      break;
    }

    exit( 1 );
  }

  // Server Done, go forward with Clients...
  waitForServer();
}

void NameSpace::Ndetach()
{
  register int r = name_detach( attach_info, 0 );

  if ( r == -1 )
  {
    printf( "Couldn't detach the possibly existing attach point. \n" );

    switch ( errno )
    {
      case EINVAL:
        printf( "The mount ID (mntid) was never attached with name_attach(). \n" );
      break;

      default:
        printf( "Unknown Error %s \n", strerror( errno ) );
      break;
    }
    exit( 1 );
  } 
}

int NameSpace::Nopen( const char* name0 = NULL )
{
  initName( name0 );

  register int fd = name_open( name, 0 );

  if ( fd == -1 ) 
  {
    printf( "Couldn't open attach point: %s. \n", name );

    switch( errno )
    {
      case EACCES: 
        printf( "Search permission is denied on a component of the name." );
      break;

      case EBADFSYS:
        printf( "While attempting to open the named file, \n" );
        printf( "either the file itself or a component of the path prefix was found to be corrupted. \n" );
        printf( "A system failure -- from which no automatic recovery is possible -- occurred   \n" );
        printf( "while the file was being written to, or while the directory was being updated. \n" );
        printf( "You'll need to invoke appropriate systems-administration procedures \n" );
        printf( "to correct this situation before proceeding. \n" );
      break;

      case EBUSY: 
        printf( "The connection specified by name has already been opened \n" );
        printf( "and additional connections aren't permitted. \n" );
      break;

      case EINTR:
        printf( "The name_open() operation was interrupted by a signal. \n" );
      break;

      case EISDIR:
        printf( "The named path is a directory. \n" );
      break;

      case ELOOP:
        printf( "Too many levels of symbolic links or prefixes. \n" );
      break;

      case EMFILE: 
        printf( "Too many file descriptors are currently in use by this process. \n" );
      break;

      case ENAMETOOLONG:
        printf( "The length of the name string exceeds PATH_MAX, \n" );
        printf( "or a pathname component is longer than NAME_MAX. \n" );
      break;

      case ENFILE:
        printf( "Too many files are currently open in the system. \n" );
      break;

      case ENOENT:
        printf( "The connection specified by name doesn't exist. \n" );
      break;

      case ENOTDIR: 
        printf( "A component of the name prefix isn't a directory. \n" );
      break;

      default:
        printf( "Unknown Error %s \n", strerror( errno ) );
      break;
    }
         
    exit( 1 );
  }

  return fd;
}

void NameSpace::Nclose( int fd )
{
  register int r = name_close( fd );

  if ( r == -1 )
  {
    printf( "Couldn't close attach point file handle. \n" );

    switch ( errno )
    {
      case EBADF:
        printf( "Invalid file descriptor filedes. \n" );
      break;

      case EINTR:
        printf( "The name_close() call was interrupted by a signal.  \n" );
      break;

      case ENOSYS:
        printf( "The name_close() function isn't implemented for the filesystem specified by filedes. \n" );
      break;

      default:
        printf( "Unknown Error %s \n", strerror( errno ) );
      break;
    }
  }

  // Client Done, go forward with caller...
  waitForClient();
}

#endif  // End of NameSpace.cpp

---