l3.libnazgul/src/nzg_spaces.c

#include "nzg_global.h"
#include "nzg_iface.h"
#include "nzg_proto.h"
#include <sys/types.h>
#include <sys/mman.h> 

/*
 * spaceId : identifiant externe de l'espace de msg
 * queueNb : nombre de files de messages
 * poolNb : nombre de pool de buffers
 * queueNbCar : tableau de caracteristiques des different pool
 */

msgSpace * msgSpaceCreate(
	msgSpaceId spaceId, 
	int queueNb, 
	int poolNb, 
	msgPool * queueNbCar ){
  msgSpace * result;
  int shmId;
  msgSpaceId nzgId;
  msgSpaceList mSList; 
  static int mSIdNum=-1;

  mSIdNum++;
 /** recuperation de la liste des msgSpace **/
 /* (creation si elle n'existe pas */

  /** on cr<63>ee le nouvel element **/
  printf("PAGESIZE : %d\n",(int)PAGESIZE);
  nzgId=msgSp2nzgId(spaceId);
  shmId=shm_open(
	  nzgId,
	  O_RDWR|O_CREAT|O_EXCL,
	  MSGSPACE_DEFAULT_MODE
	  );
  if (shmId < 0 ) {
	perror("shm_open");
	return NULL;
  }


  /* on ajoute spaceId a la liste des msgSpace connus */

  /* on cr<63>e queueNb files de messages */

  /* on cr<63>er poolNb pool de buffers */

  /* on attache tout ce beau monde au spaceId */

  /* on renvoie un pointeur sur le bon spaceId */
  result=NULL;
  return result;
}


/*
 * spaceId : blabla
 */

msgSpace * msgSpaceOpen(msgSpaceId spaceId){
  int shmId;
  char * nzgId=msgSp2nzgId(spaceId);
  if ((shmId=shm_open(nzgId,O_RDWR,MSGSPACE_DEFAULT_MODE)) < 0){
	perror("shm_open");
	return NULL;
  }
  return NULL;
}

void msgSpaceDelete(msgSpaceId spaceId){
  //int shmId;
  msgSpaceId nzgId=msgSp2nzgId(spaceId);
  int er;
  if ((er=shm_unlink(nzgId))<0){
	perror("shm_unlink");
  };
}

msgSpaceId msgSp2nzgId(msgSpaceId spaceId){
  char * resNzgId;
  int slen;
  slen=strlen(spaceId);
  resNzgId = (char *)malloc(sizeof(char)*(slen+11));
  sprintf(resNzgId,"/tmp/.nzg-%s",(char *)spaceId);
  return ((msgSpaceId)resNzgId);
}