#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é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 creation failed: %s\n",
		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", mSAddr );

	/* on ferme le descripteur du fichier */
	close(mSFd);
  /* on ajoute spaceId a la liste des msgSpace connus */

  /* on crée queueNb files de messages */

  /* on créer poolNb pool de buffers */

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

  /* 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);
  return ((msgSpaceId)resNzgId);
}