Search  

---

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

Go to the documentation of this file.

#ifndef __J2K__NameSpace_HPP__
#define __J2K__NameSpace_HPP__

#include <j2k/Fred/Standard.hpp>
#include <j2k/nto/Basic_PThread.hpp>
#include <j2k/nto/Message.hpp>

#include <stdio.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <sys/neutrino.h>
#include <sys/dispatch.h>

#define ATTACH_POINT  "myname"

class NameSpace 
{ 
private:
  char*  name;
  size_t nameLen;
  name_attach_t* attach_info;
  int    rcvid;

  // Creation/Destruction Synchronization mechanisms
  // Make sure Servers are started  before Clients can query
  // Make sure Clients are started  before any Clients can query
  // Make sure Clients are finished before the main() caller can exit.
  pthread_barrier_t  barrier1_ServerStarted;
  pthread_barrier_t  barrier2_ClientStarted;
  pthread_barrier_t  barrier3_ClientFinished;

public:
  NameSpace(    const char* name0 = "myname", size_t nbConsumers = 1, size_t nbProducers = 1, size_t nbServers = 1 );

  virtual ~NameSpace();

  void Nattach( const char* name0 = NULL );
  void Ndetach();

  int  Nopen(   const char* name0 = NULL );
  void Nclose( int fd );

  void initName( const char* name0 = NULL );

  inline int getChannel()  {   return attach_info->chid;   }

  inline void initSync( size_t nbConsumers = 1, size_t nbProducers = 1, size_t nbServers = 1 )
  {
    // Add 1 each for the caller.
    pthread_barrier_init( &barrier1_ServerStarted,  NULL, nbServers + 1 );
    pthread_barrier_init( &barrier2_ClientStarted,  NULL, nbConsumers + nbProducers + 1 );
    pthread_barrier_init( &barrier3_ClientFinished, NULL, nbConsumers + 1 );
  }

  inline void waitForServer()
  {
    pthread_barrier_wait( &barrier1_ServerStarted );
  }

  inline void waitForThreads()
  {
    pthread_barrier_wait( &barrier2_ClientStarted );
  }

  inline void waitForClient()
  {
    pthread_barrier_wait( &barrier3_ClientFinished );
  }

  inline const char* getName() { return (const char*)name; }

private:
  inline NameSpace( const NameSpace& src );
  inline const NameSpace& operator=( const NameSpace& src );
};


#endif  // End of NameSpace.hpp

---