Comment avoir une socket datagram bidirectionnelle locale a un Linux ?

Bonjour à tous,

Je voudrais faire communiquer 2 processus sur un même Linux (Debian,
noyau 2.6.3) par une socket bidirectionnelle datagram (càd qui conserve
la séparation entre les message, une socket stream m'oblige à refaire la
segmentation).

Après avoir lu un certain nombre de pages de man (unix(7), socket(2),
...) il me semblait que PF_UNIX, SOCK_DGRAM pouvait convenir.

J'ai donc écrit le code suivant. J'arrive à envoyer un message de la
machine B (qui fait le connect()) à la machine A.

Par contre, quand la machine A envoie un message à B, j'ai droit à un
joli :

cannot send message: Transport endpoint is not connected


Est-ce qu'une socket PF_UNIX, SOCK_DGRAM est unidirectionnelle ? Il me
faut ouvrir 2 sockets (A->B et B->A) ?

J'ai oublié une manip' ou option dans le code suivant ?

Est-ce qu'il existe un autre type de socket qui me permet de réaliser ce
que je veux ?


Merci d'avance pour tout coup de main,
Amicalement,
david


void micom_init(enum micom_side_t side)
{
struct sockaddr_un sock_addr = { AF_UNIX, SOCKET_FILE_NAME };

my_side = side;
switch (my_side) {
case A_SIDE:
/* on A side, open server socket */
if (debug)
printf("creating A side socket...\n");
com_socket = socket(PF_UNIX, SOCK_DGRAM, 0);
if (com_socket < 0) {
perror("unable to open micom socket");
exit(1);
}
if (bind(com_socket, (struct sockaddr *)&sock_addr,
sizeof(struct sockaddr_un)) < 0) {
perror("unable to bind micom socket (/tmp/micom_A_B already exists?)");
exit(1);
}
if (debug) printf(" done.\n");
break;

case B_SIDE:
/* on B side, connect to the above socket */
if (debug) printf("creating B side socket and connect to A side...\n");
com_socket = socket(PF_UNIX, SOCK_DGRAM, 0);
if (com_socket < 0) {
perror("unable to open micom socket");
exit(1);
}
if (connect(com_socket, (struct sockaddr*)&sock_addr,
sizeof(struct sockaddr_un)) < 0) {
perror("unable to connect to A side");
exit(1);
}
if (debug) printf(" connection made.\n");
break;

default:
printf("micom_init(sim): undefined side, abort.\n");
exit(1);
}
}

void micom_close(void)
{
switch (my_side) {
case A_SIDE:
case B_SIDE:
close(com_socket);
unlink(SOCKET_FILE_NAME);
break;

default:
abort();
}
}

void micom_send_msg(uint8_t *message_buffer, int size)
{
if (send(com_socket, message_buffer, size, 0) < 0) {
perror("cannot send message");
abort();
}
}

void micom_recv_msg(micom_dataless_msg_t *message_buffer, int *size)
{
*size = recv(com_socket, message_buffer, MICOM_MAX_MSG_SIZE, MSG_WAITALL);
}

--
David Mentré

--
Pour contacter l'équipe de modération : moderateurs-fcolm@efrei.fr
ATTENTION: Postez DIRECTEMENT vos articles dans le groupe, PAS dans
la liste de distribution des modérateurs.