Partage de mémoire

Version imprimable

09/04/2015, 14h09
koiki78

Partage de mémoire

Bonjour,

Une problématique se dresse devant moi !

Je vous explique le contexte :

J'ai un programme développer en C RTX qui me permet de faire l'acquisition de packet UDP et un autre programme celui ci développer en JAVA.

J'aurai besoin de partager un segment de mémoire qui serai remplie par la partie C RTX puis lu par la partie JAVA.

Mon idée d'algorithme :

1 - Partager la mémoire entre le programme en C RTX et un autre programme en C qui ferait l'intermédiaire de pont
2 - Faire de ce pont une DLL pour pouvoir l'utiliser dans JAVA avec JNA
3 - Utiliser une fonction présente dans cette DLL pour remplir un buffer coté JAVA

Si quelqu'un à une idée ?!

Merci d'avance.

PS : Je ne sais pas si je devais poster ici ou dans la partie JAVA...
09/04/2015, 14h38
foetus
2 autres pistes que je vois :mrgreen:
1. Tu envoies ton segment mémoire via socket (programmation réseau). Si tu fais déjà de l'acquisition de paquets UDP, c'est un coup de ch'touille.
2. Tu partages une base de données en sauvegardant toutes les données. Par contre il faut faire très attention aux accès db. Et si tu as besoin de logique, via la JNI, tu injectes ton code C (partage de code): mais la JNI c'est hardcore
09/04/2015, 14h54
djuju

Salut,

foetus a raison, tu as déjà codé un client/serveur, plutôt pratique pour transférer des données non ?
Ceci dit, si tu as vraiment besoin de partager un espace mémoire entre deux process, tu peux utiliser les shared memory, c'Est justement fait pour ça.
Il y a plusieurs façon de le faire. Entre autre via boost ou l'API Windows.
09/04/2015, 16h01
koiki78

Merci pour vos réponses,

foetus :

"Tu envoies ton segment mémoire via socket (programmation réseau). Si tu fais déjà de l'acquisition de paquets UDP, c'est un coup de ch'touille."

Pourrais-tu m'en dire plus ? je ne vois pas en quoi une socket pourrait m'aider à faire transiter des information d'un langage à un autre ^^

djuju :

"Entre autre via boost ou l'API Windows. "

J'ai déjà utilisé l'API de Windows, cependant lorsque j’utilise RtOpenSharedMemory (fonction RTX) je n'arrive pas à récupérer ce segment de mémoire créé via CreateFileMapping (C), la fonction RtOpenSharedMemory me renvoie NULL donc erreur, mais lorsque j'utilise coté C RTX la fonction RtCreateSharedMemory alors RtOpenSharedMemory fonctionne bien.
09/04/2015, 16h43
djuju

Hummm, étrange...
Es tu certain d'avoir bien spécifié le nom du shared ?
Peux-tu poster les bouts de code correspondant ?

J'ai pas trop le temps de regarder tout de suite, mais si mes souvenirs sont bon il y avait des règles à respecter sur l'alignement de ton shared en page mémoire lors de la création et des écritures/lectures.
09/04/2015, 17h18
koiki78

Oui, il suffit bien de mettre un string à la con ?

Je te post tout ça d'ici lundi / mardi -> manque de temps aussi ^^

En tout cas merci =)
10/04/2015, 16h40
djuju

Citation:

Envoyé par koiki78

Oui, il suffit bien de mettre un string à la con ?

Pour ouvrir le shared oui. Par contre, ton shared doit avoir une taille multiple de la taille d'une page mémoire. De plus, tes map doivent être alignés sur un début de page.
J'ai l'impression qu ce n'est pas vrai pour tous les systèmes/compilo/langages, mais ça l'est au moins dans mon cas (et probablement le tien) : Win 7 x64, comm Java <=> C++ (VS2012 natif shared via API MS)

Bonjour,

Donc voici mon code partie JAVA :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
	  File f = new File("c:/tmp/mapped.txt");
	  f.delete();
 
	  FileChannel fc = new RandomAccessFile(f, "rw").getChannel();
 
	  long bufferSize=8*1000;
	  MappedByteBuffer mem =fc.map(FileChannel.MapMode.READ_WRITE, 0, bufferSize);
 
	  int start = 0;
	  long counter=1;
	  long HUNDREDK=100000;
	  long startT = System.currentTimeMillis();
	  long noOfMessage = HUNDREDK * 10 * 10;
	  for(;;)
	  {        
		  if(!mem.hasRemaining())
		  {
			  start+=mem.position();
			  mem =fc.map(FileChannel.MapMode.READ_WRITE, start, bufferSize);
		  }
		  mem.putLong(counter);
		  counter++;
		  if(counter > noOfMessage )
			  break;
	  }
	  long endT = System.currentTimeMillis();
	  long tot = endT - startT;
	  System.out.println(String.format("No Of Message %s , Time(ms) %s ",noOfMessage, tot));

Ce code me crée un fichier mapped.txt d'environs 78Mo

et mon code coté C RTX :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 
	HANDLE hMapFile;
	LPCTSTR buffer;
	TCHAR szName[]=TEXT("Global\\MyFileMappingObject");
 
	buffer = RtAllocateLocalMemory(1000);
 
	//RtCreateSharedMemory(0,0,100,"Global\\MyFileMappingObject",&buffer);
 
	hMapFile = RtOpenSharedMemory(SHM_MAP_READ, FALSE, szName, (VOID**)&buffer);
 
	if (hMapFile == NULL)
		RtPrintf("ERREUR PARTAGE DE MEMOIRE!!! (%d)\n", GetLastError());
	else
		RtPrintf("Buffer : %s\n", buffer);

Voici toutes les fonctions disponible sous RTX : http://www.intervalzero.com/library/...iFunctions.htm

Il me semble que je devrais plutot utiliser : RtMapMemory : mais je ne comprend pas les paramètres à lui fournir par rapport au paramètres coté java

Avec la fonction RtMapMemory :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
      BOOL success=0;
      static PVOID vAddress; // virtual memory address returned
      LARGE_INTEGER physAddr; // base physical address
      ULONG length; // length to map in
      BOOLEAN cacheEnable; // cache accesses to memory ?
      physAddr.QuadPart = 0x0000FFFFF;
      length = 1024;
      cacheEnable = 0;
      vAddress=RtMapMemory( physAddr, length, cacheEnable);
      if (vAddress==NULL) {
            printf("Failure on RtMapMemory( 0x%08X, %d, %d ).\n", physAddr.LowPart, length, cacheEnable );
      }
      else {
            printf("Success on RtMapMemory( 0x%08X, %d, %d ).\n", physAddr.LowPart, length, cacheEnable );
            printf("Virtual memory address = 0x%08X \n", vAddress);
            success = RtUnmapMemory( vAddress);
            if (!success) {
                  printf("Failure on RtUnmapMemory( 0x%08X)\t", vAddress);
            }
            else {
                  printf("Success on RtUnmapMemory( 0x%08X)\n\n", vAddress);
            }
      }
      ExitProcess(0);