l3.libnazgul/src/nzg_create.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, // identifiant externe de l'espace de msg
	int queueNb, // nombre de files de messages
	int poolNb, // nombre de pool de buffers
	msgPool * queueNbCar // tableau de caracteristiques des different pool
	){
  int shmId;
  printf("PAGESIZE : %d\n",(int)PAGESIZE);
  // on cr<63>ee
  msgSpaceId nzgId=msgSp2nzgId(spaceId);
  if ((shmId=shm_open(nzgId,O_RDWR,MSGSPACE_DEFAULT_MODE)) < 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

  msgSpace * result=NULL;
  return result;
}


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+4));
  sprintf(resNzgId,"/NZG%s",(char *)spaceId);
  return ((msgSpaceId)resNzgId);
}