scsniff.c

#define _DEFAULT_SOURCE

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/time.h>

#include "packet.h"
#include "serial.h"
#include "session.h"

static int reset_active(int fd) {
    int reset = serial_reset_active(fd);
    if (reset == -1) {
        fprintf(stderr, "Connection lost\n");
        exit(1);
    }
    return reset;
}

static struct timeval reset_time;

static void wait_reset(int fd) {
    fprintf(stderr, "== Waiting for reset..  ");
    fflush(stderr);
    serial_wait_reset(fd);
    fprintf(stderr, "Done\n");
}

static void usage(char *name) {
    fprintf(stderr, "\nUsage: %s <device> [<baudrate>]\n", name);
    exit(2);
}

static void handle_packet(struct packet *packet) {
    struct timeval diff;
    unsigned i;
    timersub(&packet->time, &reset_time, &diff);
    fprintf(stderr,"+%ld.%06lds | ", diff.tv_sec, diff.tv_usec);
    switch (packet->result) {
        case NOISE:             fprintf(stderr,"NOISE??"); break;
        case PACKET_TO_CARD:    fprintf(stderr,"FCARD"); break;
        case PACKET_FROM_CARD:  fprintf(stderr,"TARD"); break;
        case PACKET_UNKNOWN:    fprintf(stderr,"UCARD"); break;
        default:                fprintf(stderr,"ERROR!!"); break;
    }
    fprintf(stderr," |");
    for (i = 0; i < packet->data_length; i++) {
        fprintf(stderr," %02X", packet->data[i]);
    }
    fprintf(stderr,"\n");
}

static void log_message(const char *message) {
    fprintf(stderr, "== %s\n", message);
}

int main(int argc, char **argv) {
    if (argc < 2) usage(argv[0]);
    int fd = serial_open(argv[1]);
    if(fd < 0) {
        fprintf(stderr, "Opening %s ", argv[1]);
        perror("failed");
        usage(argv[0]);
    }
    int baudrate = 9600;
    if (argc > 2) {
        baudrate = atoi(argv[2]);
    }
    if (baudrate <= 0) {
        fprintf(stderr, "Failed to parse baudrate '%s'\n", argv[2]);
        usage(argv[0]);
    }
    fprintf(stderr, "== Opened %s\n", argv[1]);

    struct session session;
    session_init(&session, handle_packet, serial_configure, log_message,
                 fd, baudrate);

    while (1) {
        fprintf(stderr, "== Speed: %d baud\n", baudrate);
        if (!reset_active(fd)) wait_reset(fd);
        gettimeofday(&reset_time, NULL);
        while (reset_active(fd)) {
            // Eat noise while reset active.
            unsigned char c;
            read(fd, &c, 1);
        }
        int loops = 0;
        int resets = 0;
        while (1) {
            unsigned char c;
            if (read(fd, &c, 1) >0) {
                loops = 0;
                if (resets < 15) session_add_byte(&session, c);
            }
            if (reset_active(fd)) {
                resets++;
                if (resets > 50) {
                    fprintf(stderr, "\n========================="
                                    "\n== Got warm reset or deactivate\n");
                    break;
                }
            } else {
                resets = 0;
            }
            loops++;
            if (loops > 3000000) {
                fprintf(stderr, "\n=========================\n== Timeout!\n");
                break;
            }
        }
        session_reset(&session);
    }
    return 0;
}