nbillard/tsock_Abderrahman_Nathan
2
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

puits udp

Browse source
This commit is contained in:
nbillard 2023-02-07 12:52:49 +01:00
parent 1cdcedf8c1
commit 968e3c6bd1
1 changed files with 29 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
tsock_v0.c
View file

@ -43,6 +43,18 @@ void recvudp(int sock, char* buffer, int buf_len, void* addr, unsigned int addr_
} }
} }
void sendudp(int sock, char* message, int msg_len, void* addr, unsigned int addr_len) {
int lg_sent = sendto(sock, message, msg_len, 0, (struct sockaddr*) addr, addr_len);
if (lg_sent == -1) {
perror("Message could not be sent, Error: ");
exit(1);
} else if (lg_sent < MSG_LENGTH) {
fprintf(stderr, "Only %i from %i characters have been sent.", lg_sent, MSG_LENGTH);
exit(1);
}
printf("message sent: %s\n", message);
}
void afficher_message(char* message, int lg) { void afficher_message(char* message, int lg) {
message[lg] = '\0'; message[lg] = '\0';
printf("message construit: %s", message); printf("message construit: %s", message);
@ -173,18 +185,26 @@ int main (int argc, char **argv)
message = malloc((MSG_LENGTH + 1) * sizeof(char)); message = malloc((MSG_LENGTH + 1) * sizeof(char));
if (source) { if (source) {
construire_message(message, 'a', MSG_LENGTH); construire_message(message, 'a', MSG_LENGTH);
for (int i = 0; i < nb_message; ++i) { if (nb_message < 0) {
int lg_sent = sendto(sock, message, MSG_LENGTH, 0, (struct sockaddr*) &addr, sizeof(addr)); while (1) {
if (lg_sent == -1) { sendudp(sock, message, MSG_LENGTH, &addr, sizeof(addr));
perror("Message could not be sent, Error: "); }
exit(1); } else {
} else if (lg_sent < MSG_LENGTH) { for (int i = 0; i < nb_message; ++i) {
fprintf(stderr, "Only %i from %i characters have been sent.", lg_sent, MSG_LENGTH); sendudp(sock, message, MSG_LENGTH, &addr, sizeof(addr));
exit(1);
} }
printf("message sent: %s\n", message);
} }
} else { } else {
if (nb_message < 0) {
while (1) {
recvudp(sock, message, MSG_LENGTH, &addr, sizeof(addr));
}
} else {
for (int i = 0; i < nb_message; ++i) {
recvudp(sock, message, MSG_LENGTH, &addr, sizeof(addr));
}
}
printf("puit not implemented\n"); printf("puit not implemented\n");
} }