Discussion :

[koiki78]

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...

[foetus]

2 autres pistes que je vois

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

[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.

[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.

[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.

[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 =)

[djuju]

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)

[koiki78]

Bonjour,

Donc voici mon code partie JAVA :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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);