Add timestamp option, print strings after CR

This commit is contained in:
David Kopf 2011-08-24 11:05:58 -04:00
parent c42085c00b
commit 7eff518d8f

View file

@ -86,7 +86,7 @@ int ssystem(const char *fmt, ...)
__attribute__((__format__ (__printf__, 1, 2))); __attribute__((__format__ (__printf__, 1, 2)));
void write_to_serial(void *inbuf, int len); void write_to_serial(void *inbuf, int len);
#define PRINTF(...) if(verbose)printf(__VA_ARGS__) #define PRINTF(...) if(verbose)fprintf(stderr,__VA_ARGS__)
//#define PROGRESS(s) fprintf(stderr, s) //#define PROGRESS(s) fprintf(stderr, s)
#define PROGRESS(s) do { } while (0) #define PROGRESS(s) do { } while (0)
@ -113,6 +113,7 @@ static bool clean_route = false;
static bool clean_neighb = false; static bool clean_neighb = false;
static struct uip_eth_addr adapter_eth_addr; static struct uip_eth_addr adapter_eth_addr;
static char * if_name; static char * if_name;
static int timestamp = 1;
OSVERSIONINFO osVersionInfo; OSVERSIONINFO osVersionInfo;
@ -150,6 +151,7 @@ void print_help()
fprintf(stderr, "Options:\r\n"); fprintf(stderr, "Options:\r\n");
fprintf(stderr, "-s siodev\tDevice that identifies the bridge or the boder router.\r\n"); fprintf(stderr, "-s siodev\tDevice that identifies the bridge or the boder router.\r\n");
fprintf(stderr, "-B baudrate\tBaudrate of the serial port (default:115200).\r\n"); fprintf(stderr, "-B baudrate\tBaudrate of the serial port (default:115200).\r\n");
fprintf(stderr, "-L Log time\t-L1 HH:MM:SS -L2 HH:MM:SS.xxx -L3 SSSS -L4 SSSS.xxxx\r\n");
fprintf(stderr, " One between:\n"); fprintf(stderr, " One between:\n");
fprintf(stderr, " -a ipaddress/[prefixlen] The address to be assigned to the local interface.\r\n"); fprintf(stderr, " -a ipaddress/[prefixlen] The address to be assigned to the local interface.\r\n");
fprintf(stderr, "\t\tadapter.\r\n"); fprintf(stderr, "\t\tadapter.\r\n");
@ -236,7 +238,52 @@ execProcess(LPDWORD exitCode,const char *fmt, ...)
} }
void
stamptime(void)
{
static long startsecs=0,startmsecs=0;
long secs,msecs;
struct timeval tv;
time_t t;
struct tm *tmp;
char timec[20];
gettimeofday(&tv, NULL) ;
msecs=tv.tv_usec/1000;
secs=tv.tv_sec;
if (startsecs) {
if (timestamp<3) {
t=time(NULL);
tmp=localtime(&t);
strftime(timec,sizeof(timec),"%T",tmp);
if (timestamp==2) {
fprintf(stderr,"%s.%03lu ",timec,msecs);
} else {
fprintf(stderr,"%s ",timec);
}
} else {
secs -=startsecs;
msecs-=startmsecs;
if (msecs<0) {secs--;msecs+=1000;}
if (timestamp==3) {
fprintf(stderr,"%04lu ", secs);
} else {
fprintf(stderr,"%04lu.%03lu ", secs, msecs);
}
}
} else {
startsecs=secs;
startmsecs=msecs;
t=time(NULL);
tmp=localtime(&t);
strftime(timec,sizeof(timec),"%T",tmp);
if ((timestamp==2) || (timestamp>3)) {
fprintf(stderr,"\n%s.%03lu ",timec,msecs);
} else {
fprintf(stderr,"\n%s ",timec);
}
}
}
#define SLIP_END 0300 #define SLIP_END 0300
@ -257,7 +304,7 @@ print_packet(u_int8_t *p, int len) {
} }
printf("\n"); printf("\n");
}*/ }*/
#if 0
int int
is_sensible_string(const unsigned char *s, int len) is_sensible_string(const unsigned char *s, int len)
{ {
@ -266,12 +313,13 @@ is_sensible_string(const unsigned char *s, int len)
if(s[i] == 0 || s[i] == '\r' || s[i] == '\n' || s[i] == '\t') { if(s[i] == 0 || s[i] == '\r' || s[i] == '\n' || s[i] == '\t') {
continue; continue;
} else if(s[i] < ' ' || '~' < s[i]) { } else if(s[i] < ' ' || '~' < s[i]) {
printf("\nbad character at %d:%x\n",i,s[i]);
return 0; return 0;
} }
} }
return 1; return 1;
} }
#endif
/* /*
* Read from serial, when we have a packet write it to tun. No output * Read from serial, when we have a packet write it to tun. No output
@ -286,7 +334,7 @@ serial_to_wpcap(FILE *inslip)
u16_t buf_aligned[BUF_SIZE/2 + 42]; //extra for possible eth_hdr and ip_process expansion u16_t buf_aligned[BUF_SIZE/2 + 42]; //extra for possible eth_hdr and ip_process expansion
u8_t *buf = (u8_t *)buf_aligned; u8_t *buf = (u8_t *)buf_aligned;
static int inbufptr = 0; static int inbufptr = 0, issensiblestring=1;
int ret; int ret;
unsigned char c; unsigned char c;
@ -313,6 +361,7 @@ read_more:
if(ret == 0) { if(ret == 0) {
clearerr(inslip); clearerr(inslip);
return; return;
if (timestamp) stamptime();
fprintf(stderr, "serial_to_tun: EOF\n"); fprintf(stderr, "serial_to_tun: EOF\n");
exit(1); exit(1);
} }
@ -333,7 +382,8 @@ read_more:
} }
} }
macs64[pos] = '\0'; macs64[pos] = '\0';
printf("*** Gateway's MAC address: %s\n", macs64); if (timestamp) stamptime();
fprintf(stderr, "*** Gateway's MAC address: %s\n", macs64);
mac_received = true; mac_received = true;
sscanf(macs64, "%2X-%2X-%2X-%2X-%2X-%2X-%2X-%2X", sscanf(macs64, "%2X-%2X-%2X-%2X-%2X-%2X-%2X-%2X",
@ -361,13 +411,13 @@ read_more:
dev_eth_addr.addr[3], dev_eth_addr.addr[3],
dev_eth_addr.addr[4], dev_eth_addr.addr[4],
dev_eth_addr.addr[5]); dev_eth_addr.addr[5]);
if (timestamp) stamptime();
printf("Fictitious MAC-48: %s\n", macs48); fprintf(stderr,"Fictitious MAC-48: %s\n", macs48);
if(autoconf){ if(autoconf){
if(IPAddrFromPrefix(autoconf_addr, ipprefix, macs64)!=0){ if(IPAddrFromPrefix(autoconf_addr, ipprefix, macs64)!=0){
if (timestamp) stamptime();
fprintf(stderr, "Invalid IPv6 address.\n"); fprintf(stderr, "Invalid IPv6 address.\n");
exit(1); exit(1);
} }
@ -379,6 +429,7 @@ read_more:
/* RPL Border Router mode. Add route towards LoWPAN. */ /* RPL Border Router mode. Add route towards LoWPAN. */
if(IPAddrFromPrefix(rem_ipaddr, br_prefix, macs64)!=0){ if(IPAddrFromPrefix(rem_ipaddr, br_prefix, macs64)!=0){
if (timestamp) stamptime();
fprintf(stderr, "Invalid IPv6 address.\n"); fprintf(stderr, "Invalid IPv6 address.\n");
exit(1); exit(1);
} }
@ -404,11 +455,31 @@ read_more:
} }
} }
else if(inpktbuf[0] == DEBUG_LINE_MARKER) { else if(inpktbuf[0] == DEBUG_LINE_MARKER) {
/* Dont insert timestamp on wireshark packet dumps starting with 0000 */
if (timestamp) {
if (inpktbuf[0]!='0' || inpktbuf[1]!=0 || inpktbuf[2]!=0 || inpktbuf[3]!=0) stamptime();
}
fwrite(inpktbuf + 1, inbufptr - 1, 1, stderr); fwrite(inpktbuf + 1, inbufptr - 1, 1, stderr);
issensiblestring=1;
} }
#if 0
else if(is_sensible_string(inpktbuf, inbufptr)) { else if(is_sensible_string(inpktbuf, inbufptr)) {
/* Dont insert timestamp on wireshark packet dumps starting with 0000 */
if (timestamp) {
if (inpktbuf[0]!='0' || inpktbuf[1]!=0 || inpktbuf[2]!=0 || inpktbuf[3]!=0) stamptime();
}
fwrite(inpktbuf, inbufptr, 1, stderr); fwrite(inpktbuf, inbufptr, 1, stderr);
} }
#else
else if(issensiblestring) {
/* Dont insert timestamp on wireshark packet dumps starting with 0000 */
if (timestamp) {
if (inpktbuf[0]!='0' || inpktbuf[1]!=0 || inpktbuf[2]!=0 || inpktbuf[3]!=0) stamptime();
}
fwrite(inpktbuf, inbufptr, 1, stderr);
}
#endif
else { else {
PRINTF("Sending to wpcap\n"); PRINTF("Sending to wpcap\n");
@ -436,6 +507,7 @@ read_more:
/* printf("After sending to wpcap\n");*/ /* printf("After sending to wpcap\n");*/
} }
inbufptr = 0; inbufptr = 0;
issensiblestring=1;
} }
break; break;
@ -458,6 +530,19 @@ read_more:
/* FALLTHROUGH */ /* FALLTHROUGH */
default: default:
inpktbuf[inbufptr++] = c; inpktbuf[inbufptr++] = c;
if (issensiblestring) {
if(c == '\n') {
/* Dont insert timestamp on wireshark packet dumps starting with 0000 */
if (timestamp) {
if (inpktbuf[0]!='0' || inpktbuf[1]!=0 || inpktbuf[2]!=0 || inpktbuf[3]!=0) stamptime();
}
fwrite(inpktbuf, inbufptr, 1, stderr);
inbufptr=0;
} else if (c == 0 || c == '\t' || c == '\r') {
} else if(c < ' ' || '~' < c) {
issensiblestring=0;
}
}
break; break;
} }
@ -673,6 +758,7 @@ cleanup(void)
void void
sigcleanup(int signo) sigcleanup(int signo)
{ {
if (timestamp) stamptime();
fprintf(stderr, "signal %d\n", signo); fprintf(stderr, "signal %d\n", signo);
exit(0); /* exit(0) will call cleanup() */ exit(0); /* exit(0) will call cleanup() */
} }
@ -681,6 +767,7 @@ void
sigalarm(int signo) sigalarm(int signo)
{ {
if(!mac_received){ if(!mac_received){
if (timestamp) stamptime();
fprintf(stderr, "Bridge/Router not found!\n"); fprintf(stderr, "Bridge/Router not found!\n");
exit(2); exit(2);
} }
@ -763,7 +850,7 @@ void send_commands(void)
int i; int i;
inet_pton(AF_INET6, br_prefix, &addr); inet_pton(AF_INET6, br_prefix, &addr);
if (timestamp) stamptime();
fprintf(stderr,"*** Address:%s => %02x%02x:%02x%02x:%02x%02x:%02x%02x\n", fprintf(stderr,"*** Address:%s => %02x%02x:%02x%02x:%02x%02x:%02x%02x\n",
br_prefix, br_prefix,
addr.s6_addr[0], addr.s6_addr[1], addr.s6_addr[0], addr.s6_addr[1],
@ -794,25 +881,30 @@ void addAddress(const char * ifname, const char * ipaddr)
strncpy(tmpaddr,ipaddr,sizeof(tmpaddr)); strncpy(tmpaddr,ipaddr,sizeof(tmpaddr));
strtok(tmpaddr,"/"); // Remove possible prefix length. strtok(tmpaddr,"/"); // Remove possible prefix length.
if (timestamp) stamptime();
execProcess(&exitCode,"netsh interface ipv6 add address \"%s\" %s",if_name,tmpaddr); execProcess(&exitCode,"netsh interface ipv6 add address \"%s\" %s",if_name,tmpaddr);
substr = strtok(NULL,"/"); substr = strtok(NULL,"/");
if(substr == NULL){ // A prefix length is not specified. if(substr == NULL){ // A prefix length is not specified.
// Use a 64 bit prefix // Use a 64 bit prefix
strcat(tmpaddr,"/64"); strcat(tmpaddr,"/64");
if (timestamp) stamptime();
execProcess(NULL,"netsh interface ipv6 add route %s \"%s\"",tmpaddr,if_name); execProcess(NULL,"netsh interface ipv6 add route %s \"%s\"",tmpaddr,if_name);
} }
else { else {
if (timestamp) stamptime();
execProcess(NULL,"netsh interface ipv6 add route %s \"%s\"",ipaddr,if_name); execProcess(NULL,"netsh interface ipv6 add route %s \"%s\"",ipaddr,if_name);
} }
} }
else{ else{
if (timestamp) stamptime();
execProcess(&exitCode,"netsh interface ipv6 add address \"%s\" %s",if_name,ipaddr); execProcess(&exitCode,"netsh interface ipv6 add address \"%s\" %s",if_name,ipaddr);
} }
if(exitCode==0){ if(exitCode==0){
clean_addr = true; clean_addr = true;
} }
else { else {
if (timestamp) stamptime();
fprintf(stderr, "WARNING: subprocess exited with code %ld\n", exitCode); fprintf(stderr, "WARNING: subprocess exited with code %ld\n", exitCode);
} }
} }
@ -823,11 +915,13 @@ void delAddress(const char * ifname, const char * ipaddr)
strncpy(tmpaddr,ipaddr,sizeof(tmpaddr)); strncpy(tmpaddr,ipaddr,sizeof(tmpaddr));
strtok(tmpaddr,"/"); // Remove possible prefix length. strtok(tmpaddr,"/"); // Remove possible prefix length.
if (timestamp) stamptime();
if(osVersionInfo.dwMajorVersion < 6){ // < Windows Vista (i.e., Windows XP; check if this command is ok for Windows Server 2003 too). if(osVersionInfo.dwMajorVersion < 6){ // < Windows Vista (i.e., Windows XP; check if this command is ok for Windows Server 2003 too).
char * substr; char * substr;
execProcess(NULL,"netsh interface ipv6 delete address \"%s\" %s",if_name,tmpaddr); execProcess(NULL,"netsh interface ipv6 delete address \"%s\" %s",if_name,tmpaddr);
if (timestamp) stamptime();
substr = strtok(NULL,"/"); substr = strtok(NULL,"/");
if(substr == NULL){ // A prefix length is not specified. if(substr == NULL){ // A prefix length is not specified.
// Use a 64 bit prefix // Use a 64 bit prefix
@ -849,18 +943,20 @@ void delAddress(const char * ifname, const char * ipaddr)
void addLoWPANRoute(const char * ifname, const char * net, const char * gw) void addLoWPANRoute(const char * ifname, const char * net, const char * gw)
{ {
DWORD exitCode = -1; DWORD exitCode = -1;
if (timestamp) stamptime();
execProcess(&exitCode,"netsh interface ipv6 add route %s/64 \"%s\" %s", net, if_name, gw); execProcess(&exitCode,"netsh interface ipv6 add route %s/64 \"%s\" %s", net, if_name, gw);
if(exitCode==0){ if(exitCode==0){
clean_route = true; clean_route = true;
} }
else { else {
if (timestamp) stamptime();
fprintf(stderr, "WARNING: subprocess exited with code %ld\n", exitCode); fprintf(stderr, "WARNING: subprocess exited with code %ld\n", exitCode);
} }
} }
void delLoWPANRoute(const char * ifname, const char * net) void delLoWPANRoute(const char * ifname, const char * net)
{ {
if (timestamp) stamptime();
execProcess(NULL,"netsh interface ipv6 delete route %s/64 \"%s\"", net, if_name); execProcess(NULL,"netsh interface ipv6 delete route %s/64 \"%s\"", net, if_name);
} }
@ -869,11 +965,13 @@ void addNeighbor(const char * ifname, const char * neighb, const char * neighb_m
DWORD exitCode = -1; DWORD exitCode = -1;
if(osVersionInfo.dwMajorVersion >= 6){ if(osVersionInfo.dwMajorVersion >= 6){
if (timestamp) stamptime();
execProcess(&exitCode,"netsh interface ipv6 add neighbor \"%s\" %s \"%s\"", if_name, neighb, neighb_mac); execProcess(&exitCode,"netsh interface ipv6 add neighbor \"%s\" %s \"%s\"", if_name, neighb, neighb_mac);
if(exitCode==0){ if(exitCode==0){
clean_neighb = true; clean_neighb = true;
} }
else { else {
if (timestamp) stamptime();
fprintf(stderr, "WARNING: subprocess exited with code %ld\n", exitCode); fprintf(stderr, "WARNING: subprocess exited with code %ld\n", exitCode);
} }
} }
@ -881,6 +979,7 @@ void addNeighbor(const char * ifname, const char * neighb, const char * neighb_m
void delNeighbor(const char * ifname, const char * neighb) void delNeighbor(const char * ifname, const char * neighb)
{ {
if (timestamp) stamptime();
execProcess(NULL,"netsh interface ipv6 delete neighbor \"%s\" %s", if_name, neighb); execProcess(NULL,"netsh interface ipv6 delete neighbor \"%s\" %s", if_name, neighb);
} }
@ -995,12 +1094,21 @@ main(int argc, char **argv)
osVersionInfo.dwOSVersionInfoSize = sizeof(OSVERSIONINFO); osVersionInfo.dwOSVersionInfoSize = sizeof(OSVERSIONINFO);
GetVersionEx(&osVersionInfo); GetVersionEx(&osVersionInfo);
while((c = getopt(argc, argv, "B:D:hs:c:ra:p:vtb:")) != -1) { while((c = getopt(argc, argv, "B:D:L:hs:c:ra:p:vtb:")) != -1) {
switch (c) { switch (c) {
case 'B': case 'B':
baudrate = atoi(optarg); baudrate = atoi(optarg);
break; break;
case 'L':
if(strncmp("0", optarg, 1) == 0) {
timestamp = 0;
} else {
timestamp = atoi(optarg);
if (timestamp==0) timestamp=1;
}
break;
case 's': case 's':
if(strncmp("/dev/", optarg, 5) == 0) { if(strncmp("/dev/", optarg, 5) == 0) {
strncpy(siodev,optarg + 5,sizeof(siodev)-1); strncpy(siodev,optarg + 5,sizeof(siodev)-1);
@ -1035,6 +1143,7 @@ main(int argc, char **argv)
} }
local_ipaddr = optarg; local_ipaddr = optarg;
if (!validIPAddr(local_ipaddr, 0)){ if (!validIPAddr(local_ipaddr, 0)){
if (timestamp) stamptime();
fprintf(stderr, "Invalid IPv6 address: %s", local_ipaddr); fprintf(stderr, "Invalid IPv6 address: %s", local_ipaddr);
exit(1); exit(1);
} }
@ -1047,6 +1156,7 @@ main(int argc, char **argv)
autoconf = true; autoconf = true;
ipprefix = optarg; ipprefix = optarg;
if (!validIPAddr(ipprefix, 0)){ if (!validIPAddr(ipprefix, 0)){
if (timestamp) stamptime();
fprintf(stderr, "Invalid IPv6 prefix: %s", ipprefix); fprintf(stderr, "Invalid IPv6 prefix: %s", ipprefix);
exit(1); exit(1);
} }
@ -1067,6 +1177,7 @@ main(int argc, char **argv)
tun = true; tun = true;
if (!validIPAddr(br_prefix, 64)){ if (!validIPAddr(br_prefix, 64)){
if (timestamp) stamptime();
fprintf(stderr, "Invalid IPv6 64-bit prefix: %s", br_prefix); fprintf(stderr, "Invalid IPv6 64-bit prefix: %s", br_prefix);
exit(1); exit(1);
} }
@ -1088,6 +1199,7 @@ main(int argc, char **argv)
} }
if(autoconf == true && br_prefix != NULL){ if(autoconf == true && br_prefix != NULL){
if (timestamp) stamptime();
fprintf(stderr, "-p and -b options cannot be used together.\r\n"); fprintf(stderr, "-p and -b options cannot be used together.\r\n");
print_help(); print_help();
} }
@ -1135,13 +1247,12 @@ main(int argc, char **argv)
} }
slipfd = devopen(siodev, O_RDWR | O_NONBLOCK | O_NOCTTY | O_NDELAY | O_DIRECT | O_SYNC ); slipfd = devopen(siodev, O_RDWR | O_NONBLOCK | O_NOCTTY | O_NDELAY | O_DIRECT | O_SYNC );
if(slipfd == -1) { if(slipfd == -1) {
err(1, "can't open siodev ``/dev/%s''", siodev); err(1, "can't open siodev ``/dev/%s''", siodev);
} }
if (timestamp) stamptime();
fprintf(stderr, "slip started on ``/dev/%s''\n", siodev); fprintf(stderr, "wpcapslip6 started on ``/dev/%s''\n", siodev);
stty_telos(slipfd); stty_telos(slipfd);
slip_send(SLIP_END); slip_send(SLIP_END);
inslip = fdopen(slipfd, "r"); inslip = fdopen(slipfd, "r");