Discussion :

[ManusDei]

Bonjour,

je cherche à faire communiquer un processus père avec plusieurs processus fils, en utilisant les sockets unix (AF_UNIX).

J'ai un processus père qui crée 3 fils, chaque fils va envoyer une chaîne de caractère via le socket, qui va être lue par le père.
Je créé mes chaînes sans problèmes, j'ouvre ma paire de sockets (dois-je créer une paire pour chaque fils ?), j'arrive apparemment à envoyer les chaînes de caractères (pas d'erreur sur le write), mais les chaînes de caractères récupérées ne sont pas bonnes.

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <string.h>
#include <sys/socket.h>
#include "common.h" 
 
#define INVALID_SOCKET -1
#define SOCKET_ERROR -1
#define closesocket(s) close (s)
#define PROCESS		3
#define SLEEP		5
#define PORT 1337
 
typedef int SOCKET;
typedef struct sockaddr_in SOCKADDR_IN;
typedef struct sockaddr SOCKADDR;
 
int process = 0;
int sv[2];
 
int threadProd(int num){
	int period=100; /* en millisecondes */
	char type_objet[3];
	char* trame = malloc(sizeof(char*));
	Objet* info = malloc(sizeof(struct Objet)); 
	char* num2;
 
	sprintf(type_objet,"t%d\0",num);
	sprintf(info->identificateur,"%s",type_objet);
	sprintf(info->objet_content,"25\0");	
	sprintf(trame,"%s%s",info->identificateur,info->objet_content);
 
	if(write(sv[1], &trame, 5) <0)
		printf("error on writing in socket\n");
	printf("child: sent '%s'\n", trame);
 
	free(info);
	free(trame);
	return 0;
}
 
int threadMACProd(){
	char* buffer[PROCESS];
	int r;
	for(int i=0;i<PROCESS;i++)
		buffer[i]=malloc(sizeof(char*));
 
	for(int i=0;i<PROCESS;i++){
		read(sv[0], buffer[i], 5);
        printf("parent: read '%c'\n", buffer[i]);
	}
 
	return 0;
}
 
 
int main()
{
    pid_t pid;
 
	if (socketpair(AF_UNIX, SOCK_STREAM, 0, sv) == -1) {
		perror("socketpair");
		exit(1);
    }
 
	while (process < PROCESS) {
 		pid = fork();
 		// Erreur à la creation du fils
		if (pid < 0) {
			perror("fork");
			exit(EXIT_FAILURE); 
		}
		// Execution du Producteur
		else if (!pid) {
			pid = getpid();
			threadProd(process);
			return 0;
		}
		++process;
 
	}
 
	for(int i=0;i<PROCESS;i++){
		threadMACProd();
	}
 
	return EXIT_SUCCESS;
}

Retour à l'exécution (besoin de Ctrl-C pour quitter) :

# ./producteur
child: sent 't025'
parent: read ''
parent: read '0'
child: sent 't125'
parent: read 'P'
child: sent 't225'

Merci

[Sve@r]

dois-je créer une paire pour chaque fils ?

Salut

Pas obligé si le père n'a pas à communiquer avec les fils en même temps.

j'arrive apparemment à envoyer les chaînes de caractères (pas d'erreur sur le write), mais les chaînes de caractères récupérées ne sont pas bonnes.

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
int threadProd(int num){
	int period=100; /* en millisecondes */
	char type_objet[3];
	char* trame = malloc(sizeof(char*));
	Objet* info = malloc(sizeof(struct Objet)); 
	char* num2;

	sprintf(type_objet,"t%d\0",num);
	sprintf(info->identificateur,"%s",type_objet);
	sprintf(info->objet_content,"25\0");	
	sprintf(trame,"%s%s",info->identificateur,info->objet_content);

	if(write(sv[1], &trame, 5) <0)
		printf("error on writing in socket\n");
	printf("child: sent '%s'\n", trame);

	free(info);
	free(trame);
	return 0;
}

Revois les paramètres attendus par write() (et peut-être aussi read() de l'autre coté j'ai pas regardé). Accessoirement, faire un malloc() + free() au sein de la même fonction est un peu inutile mais c'est toi qui voit. Toutefois, quand on alloue de la mémoire, vaut mieux allouer suffisamment de mémoire pour stocker les datas qu'on veut y mettre !!!

[Bktero]

Accessoirement, faire un malloc() + free() au sein de la même fonction est un peu inutile mais c'est toi qui voit.

Tu préfères faire des déclarations en statique ?

La phrase si dessus n'est pas absolument pas ironique mais je trouve qu'elle en a l'air. Pas d'offense hein

[Sve@r]

Tu préfères faire des déclarations en statique ?

Ben quand je vois ça

Code c :

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

1
2
3
Objet* info = malloc(sizeof(struct Objet)); 
...
free(info):

Je pense que c'est plus pratique de mettre directement

Code c :

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

struct Objet info;

A condition que la pile puisse supporter bien entendu (mais c'est généralement le cas dans la plupart des situations)

La phrase si dessus n'est pas absolument pas ironique mais je trouve qu'elle en a l'air. Pas d'offense hein

Pas de pb

[Bktero]

J'avoue qu'une fois que tu as sorti les deux lignes en question.....

Pour une structure, effectivement ça devrait aller (sauf si la structure demande un tableau de plusieurs mega... mais bon). Si tu fais un tableau de structures, le problème de pile peut apparaitre plus vite. Comment connais-tu la taille de la pile ?

[ManusDei]

J'avais un problème de paramètre du write, et j'affichais mon string avec %c.

Merci