Namonay/ft_ping
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Major refactor

Browse Source
This commit is contained in:
vauden
2024-09-16 19:47:54 +02:00
parent 37039d9725
commit 35c0263e1b
2 changed files with 48 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ft_ping.h
View File

@@ -9,6 +9,7 @@
#include <sys/types.h> #include <sys/types.h>
#include <sys/socket.h> #include <sys/socket.h>
#include <sys/time.h>
#include <errno.h> #include <errno.h>
#include <netinet/in.h> #include <netinet/in.h>
@@ -30,4 +31,4 @@ struct t_socket
struct sockaddr_in dst, src; struct sockaddr_in dst, src;
int fd; int fd;
int len; int len;
}; };

70
main.c
View File

@@ -17,21 +17,20 @@ uint16_t calculate_checksum(uint16_t *data, int len)
return (~checksum); return (~checksum);
} }
double get_timestamp()
{
struct timeval timestamp;
gettimeofday(&timestamp, NULL);
return (timestamp.tv_sec + (double)timestamp.tv_usec / 1000000);
}
int ft_ping(int sock, int seq, struct sockaddr_in dst) int ft_ping(int sock, int seq, struct sockaddr_in dst)
{ {
unsigned char data[2048]; unsigned char data[64];
int len;
struct icmp_header *icmp_hdr = (struct icmp_header *)data; struct icmp_header *icmp_hdr = (struct icmp_header *)data;
memset(data, 0, sizeof(data)); memset(data, 0, sizeof(data));
sock = socket(AF_INET, SOCK_RAW, IPPROTO_ICMP); memset(icmp_hdr, 0, sizeof(*icmp_hdr));
if (sock < 0)
{
fprintf(stderr, "ERROR : socket() failed\n");
return (0);
}
dst.sin_family = AF_INET;
memset(icmp_hdr, 0, sizeof(icmp_hdr));
icmp_hdr->type = ICMP_ECHO; icmp_hdr->type = ICMP_ECHO;
icmp_hdr->code = 0; icmp_hdr->code = 0;
icmp_hdr->id = getpid(); icmp_hdr->id = getpid();
@@ -42,31 +41,46 @@ int ft_ping(int sock, int seq, struct sockaddr_in dst)
fprintf(stderr, "ERROR : sendto() failed\n"); fprintf(stderr, "ERROR : sendto() failed\n");
return (0); return (0);
} }
printf("sent : type : %d code : %d id: %d seq : %d checksum : %X\n", icmp_hdr->type, icmp_hdr->code, icmp_hdr->id, icmp_hdr->seq, icmp_hdr->checksum);
return (1); return (1);
} }
int ft_recv(int sock, int seq, char *ip) int ft_recv(int sock, int seq, char *ip, double start)
{ {
unsigned char data[2048]; unsigned char data[64];
struct icmp_header *icmp_hdr = (struct icmp_header *)(data + 20); struct icmp_header *icmp_hdr = (struct icmp_header *)(data + 20);
int len;
int n_bytes; int n_bytes;
struct sockaddr_in addr; struct sockaddr_in addr;
n_bytes = recvfrom(sock, data, sizeof(data), 0, (struct sockaddr *)&addr, &len); int len = sizeof(addr);
double time;
// while (recvfrom(sock, data, sizeof(data), 0, &addr, &len) > 0 && icmp_recv_hdr->type != 0);
printf("received : type : %d code : %d id: %d seq : %d checksum : %X\n", icmp_hdr->type, icmp_hdr->code, icmp_hdr->id, icmp_hdr->seq, icmp_hdr->checksum);
printf("%d bytes from %s: icmp_seq:%d time:placeholder", n_bytes, ip, icmp_hdr->seq);
n_bytes = recvfrom(sock, data, sizeof(data), 0, (struct sockaddr *)&addr, (socklen_t *)&len);
while (icmp_hdr->type != 0 && n_bytes > 0)
n_bytes = recvfrom(sock, data, sizeof(data), 0, (struct sockaddr *)&addr, (socklen_t *)&len);
time = (get_timestamp() - start) * 1000000;
if (icmp_hdr->seq != seq || calculate_checksum((uint16_t *)data, sizeof(data)))
return (-1);
printf("%d bytes from %s: icmp_seq:%d time:%5.3fms\n", n_bytes, ip, icmp_hdr->seq, time);
return (0);
} }
char *get_ip_by_hostname(char *hostname)
{
struct hostent *he;
struct in_addr **addr_list;
he = gethostbyname(hostname);
addr_list = (struct in_addr **)he->h_addr_list;
return (inet_ntoa(*addr_list[0]));
}
int main(int argc, char **argv) int main(int argc, char **argv)
{ {
int sock; int sock;
struct sockaddr_in dst; struct sockaddr_in dst;
int seq = 1; int seq = 1;
char *ip; char *ip;
double start;
int n_packet_sent = 0;
int n_packet_recv = 0;
if (argc != 2 || argv[1] == NULL || argv[1][0] == 0) if (argc != 2 || argv[1] == NULL || argv[1][0] == 0)
{ {
fprintf(stderr, "ERROR : usage : ping {-v?} [ADRESS]\n"); fprintf(stderr, "ERROR : usage : ping {-v?} [ADRESS]\n");
@@ -77,15 +91,23 @@ int main(int argc, char **argv)
fprintf(stderr, "ERROR : %s is an invalid adress\n", argv[1]); fprintf(stderr, "ERROR : %s is an invalid adress\n", argv[1]);
return (0); return (0);
} }
ip = inet_ntoa(dst.sin_addr); dst.sin_family = AF_INET;
bind(sock, (struct sockaddr *)&dst, sizeof(dst)); dst.sin_port = 0;
sock = socket(AF_INET, SOCK_RAW, IPPROTO_ICMP);
ip = get_ip_by_hostname(argv[1]);
if (sock < 0)
{
fprintf(stderr, "ERROR : socket() failed\n");
return (0);
}
while (1) while (1)
{ {
start = get_timestamp();
ft_ping(sock, seq, dst); ft_ping(sock, seq, dst);
ft_recv(sock, seq, ip); ft_recv(sock, seq, ip, start);
seq++; seq++;
sleep(1); sleep(1);
} }
close(sock); close(sock);
return (0); return (0);
} }