Search  

---

C:/temp/src/j2k/nto/bakJuly/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:
  name_attach_t* attach_info;
  int    rcvid;
  char*  name;
  size_t nameLen;

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

public:
  NameSpace(    const char* name0 = "myname", int nbClients = 1, int 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 nbServers, size_t nbClients )
  {
    // Add 1 each for the caller.
    pthread_barrier_init( &barrier1_ServerStarted,  NULL, nbServers + 1 );
    pthread_barrier_init( &barrier2_ClientFinished, NULL, nbClients + 1 );
  }

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

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

  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

---