l3.libnazgul/src/nzg_spaces.c

#include "libnazgul.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 ){
  msgSpaceId nzgId;
  msgSpaceList mSList; 
  int mSFd; // shm file descriptor
  static int mSIdNum=-1;
  msgSpace * mSAddr;

  mSIdNum++;
  mSAddr=NULL;
 /** 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);
  mSFd=shm_open(
	  nzgId,
	  O_RDWR|O_CREAT|O_EXCL|O_TRUNC,
	  MSGSPACE_DEFAULT_MODE
	  );
  if (mSFd == -1 ) {
	fprintf( stderr, "msgSpace %s creation failed: %s\n",
 		(char*)nzgId,
		strerror( errno ) );
	return NULL;
  }

  //on redimentionne l'element
  if (ftruncate(mSFd, sizeof(PAGESIZE)) == -1){
	fprintf( stderr, "msgSpace resizing failed: %s\n",
		strerror( errno ) );
	return NULL;
  }
  
  /* Map the memory object */
  mSAddr = mmap( 0, sizeof( *mSAddr ),
            PROT_READ | PROT_WRITE,
            MAP_SHARED, mSFd, 0 );
    if( mSAddr == MAP_FAILED ) {
        fprintf( stderr, "mmap failed: %s\n",
            strerror( errno ) );
        return NULL;
    }

	printf( "Map addr is 0x%08x\n", (int)mSAddr );

	/* on ferme le descripteur du fichier */
	close(mSFd);

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

	/* TODO: on cr<63>e queueNb files de messages */
	
	/* on cr<63>er poolNb pool de buffers */
	/* et on "attache" tout ce beau monde au spaceId */
	for (i=0;i<poolNb;i++){
	  // creation d'une pool

	  mSAddr->
	  
	}
	

	/* on renvoie un pointeur sur le bon spaceId */
	return mSAddr;
}


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