Compare commits

...

10 commits

Author SHA1 Message Date
Matthieu Herrb
98a53d9bd2 configure.ac: modernize for autoconf 2.71 2024-04-16 12:17:38 +02:00
Matthieu Herrb
72eba42917 Update project URL 2023-04-27 14:00:21 +02:00
Matthieu Herrb
7b587fd59f Prepare for future development 2023-04-27 13:55:23 +02:00
Matthieu Herrb
b29605e530 release echoc 0.6 2021-08-04 10:03:20 +02:00
Matthieu Herrb
e757fa8595 Add LICENSE 2021-08-04 07:57:39 +00:00
Matthieu Herrb
0153b223c0 white space police 2018-07-18 19:04:42 +02:00
Ludovic Pouzenc
4a15bdac0a Add timestamped "aborting" message 2018-07-18 19:03:22 +02:00
Ludovic Pouzenc
16d5383fb8 Add timestamped "starting" message 2018-07-18 18:51:57 +02:00
Ludovic Pouzenc
0f96d32d4c Set SIGALRM handler before setting timer 2018-07-18 18:48:08 +02:00
Ludovic Pouzenc
d791054cfe Set sockets parameters before activating up send_packet timer 2018-07-18 18:47:42 +02:00
3 changed files with 55 additions and 23 deletions

13
LICENSE Normal file
View file

@ -0,0 +1,13 @@
Copyright (c) 2012-2015 Matthieu Herrb <matthieu@herrb.eu>
Permission to use, copy, modify, and distribute this software for any
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.

View file

@ -1,5 +1,5 @@
AC_PREREQ([2.65]) AC_PREREQ([2.71])
AC_INIT([echoc], 0.5, [https://chiliproject.tetaneutral.net/projects/git-tetaneutral-net/repository/echoc], echoc) AC_INIT([echoc],[0.6.99],[https://gitlab.laas.fr/matthieu/echoc],[echoc])
AM_INIT_AUTOMAKE([foreign dist-bzip2]) AM_INIT_AUTOMAKE([foreign dist-bzip2])
AC_CONFIG_MACRO_DIR([m4]) AC_CONFIG_MACRO_DIR([m4])
AC_PROG_CC AC_PROG_CC
@ -7,4 +7,5 @@ AC_PROG_CC
AC_CHECK_HEADERS([bsd/stdlib.h]) AC_CHECK_HEADERS([bsd/stdlib.h])
AC_SEARCH_LIBS(strtonum, [bsd]) AC_SEARCH_LIBS(strtonum, [bsd])
AC_OUTPUT([Makefile]) AC_CONFIG_FILES([Makefile])
AC_OUTPUT

48
echoc.c
View file

@ -37,6 +37,7 @@
int sock = -1; int sock = -1;
int verbose = 0; int verbose = 0;
int aborting = 0;
struct sockaddr *server; struct sockaddr *server;
socklen_t serverlen; socklen_t serverlen;
unsigned int seq = 0; unsigned int seq = 0;
@ -48,11 +49,16 @@ usage(void)
errx(2, "usage: echoc [-c nbr][-d][-i ms][-l len][-p port][-t ms][-v] server"); errx(2, "usage: echoc [-c nbr][-d][-i ms][-l len][-p port][-t ms][-v] server");
} }
static void
sigint_handler(int unused)
{
aborting = 1;
}
static void static void
send_packet(int unused) send_packet(int unused)
{ {
char *buf; char *buf;
buf = malloc(len); buf = malloc(len);
if (buf == NULL) if (buf == NULL)
return; return;
@ -161,18 +167,6 @@ main(int argc, char *argv[])
disconnected = 0; disconnected = 0;
memset(&client, 0, sizeof(client)); memset(&client, 0, sizeof(client));
/* timer values */
itv.it_interval.tv_usec = interval*1000;
itv.it_interval.tv_sec = 0;
itv.it_value.tv_usec = interval*1000;
itv.it_value.tv_sec = 0;
if (setitimer(ITIMER_REAL, &itv, NULL) == -1)
err(2, "setitimer");
signal(SIGALRM, send_packet);
gettimeofday(&last_ts, NULL);
recvbuf = malloc(len); recvbuf = malloc(len);
if (recvbuf == NULL) if (recvbuf == NULL)
err(2, "malloc receive buffer"); err(2, "malloc receive buffer");
@ -186,9 +180,25 @@ main(int argc, char *argv[])
if (setsockopt(sock, IPPROTO_IP, IP_MTU_DISCOVER, &ch, sizeof(ch)) < 0) if (setsockopt(sock, IPPROTO_IP, IP_MTU_DISCOVER, &ch, sizeof(ch)) < 0)
err(2, "setsockopt IP_MTU_DISCOVER"); err(2, "setsockopt IP_MTU_DISCOVER");
#endif #endif
while (1) { signal(SIGALRM, send_packet);
signal(SIGINT, sigint_handler);
/* timer values */
itv.it_interval.tv_usec = interval*1000;
itv.it_interval.tv_sec = 0;
itv.it_value.tv_usec = interval*1000;
itv.it_value.tv_sec = 0;
if (setitimer(ITIMER_REAL, &itv, NULL) == -1)
err(2, "setitimer");
gettimeofday(&last_ts, NULL);
tm = localtime((time_t *)&last_ts.tv_sec);
strftime(date, sizeof(date), "%F %T", tm);
printf("%s.%06ld: starting\n", date, last_ts.tv_usec);
while (!aborting) {
/* poll() loop to handle interruptions by SIGALRM */ /* poll() loop to handle interruptions by SIGALRM */
while (1) { while (!aborting) {
pfd[0].fd = sock; pfd[0].fd = sock;
pfd[0].events = POLLIN; pfd[0].events = POLLIN;
nfds = poll(pfd, 1, timeout); nfds = poll(pfd, 1, timeout);
@ -204,6 +214,8 @@ main(int argc, char *argv[])
break; break;
} }
} }
if (aborting)
break;
if ((nfds == 0)) { if ((nfds == 0)) {
if (verbose) if (verbose)
printf("%d packet(s) dropped in %ld.%06ld s\n", printf("%d packet(s) dropped in %ld.%06ld s\n",
@ -259,6 +271,12 @@ main(int argc, char *argv[])
} }
} }
} }
if (aborting) {
gettimeofday(&now, NULL);
tm = localtime((time_t *)&now.tv_sec);
strftime(date, sizeof(date), "%F %T", tm);
printf("%s.%06ld: aborting\n", date, now.tv_usec);
}
close(sock); close(sock);
exit(0); exit(0);
} }