File Coverage

Serial.xs

Criterion	Covered	Total	%
statement	0	88	0.0
branch	0	36	0.0
condition			n/a
subroutine			n/a
pod			n/a
total	0	124	0.0

#include "EXTERN.h"
#include "perl.h"
#include "XSUB.h"

#include
#include
#include
#include
#include
#include
#include
#include
#include

#define POLY 0x8408

unsigned short crc16(char *data_p, unsigned short length){
      unsigned char i;
      unsigned int data;
      unsigned int crc = 0xffff;

      if (length == 0)
            return (~crc);
      do {
            for (i=0, data=(unsigned int)0xff & *data_p++; i < 8; i++, data >>= 1){
                  if ((crc & 0x0001) ^ (data & 0x0001))
                        crc = (crc >> 1) ^ POLY;
                  else  crc >>= 1;
            }
      } while (--length);

      crc = ~crc;
      data = crc;
      crc = (crc << 8) | (data >> 8 & 0xff);

      return crc;
}

void tty_close (int fd){
  close (fd);
}

int tty_available (int fd){
    int bytes_available;
    ioctl(fd, FIONREAD, &bytes_available);
    return bytes_available;
}

int tty_putc(int fd, char b){
    int n = write(fd,&b,1);
    if( n!=1)
        return -1;
    return 0;
}

int tty_puts(int fd, const char* str){
    int len = strlen(str);
    int n = write(fd, str, len);
    if( n!=len )
        return -1;
    return 0;
}

int tty_getc (int fd){
  uint8_t x;

  if (read (fd, &x, 1) != 1)
    return -1;

  return ((int)x) & 0xFF;
}

int tty_open(const char *serialport, int baud){
    struct termios toptions;
    int fd;

    fd = open(serialport, O_RDWR | O_NOCTTY | O_NDELAY);

    if (fd == -1)  {
        perror("open(): Unable to open port ");
        return -1;
    }

    if (tcgetattr(fd, &toptions) < 0) {
        perror("init_serialport: Couldn't get term attributes");
        return -1;
    }
    speed_t brate = baud;
    switch(baud) {
    case 4800:   brate=B4800;   break;
    case 9600:   brate=B9600;   break;
#ifdef B14400
    case 14400:  brate=B14400;  break;
#endif
    case 19200:  brate=B19200;  break;
#ifdef B28800
    case 28800:  brate=B28800;  break;
#endif
    case 38400:  brate=B38400;  break;
    case 57600:  brate=B57600;  break;
    case 115200: brate=B115200; break;
    }

    cfsetispeed(&toptions, brate);
    cfsetospeed(&toptions, brate);

    // 8N1
    toptions.c_cflag &= ~PARENB;
    toptions.c_cflag &= ~CSTOPB;
    toptions.c_cflag &= ~CSIZE;
    toptions.c_cflag |= CS8;
    // no flow control
    toptions.c_cflag &= ~CRTSCTS;

    toptions.c_cflag |= CREAD | CLOCAL;  // turn on READ & ignore ctrl lines
    toptions.c_iflag &= ~(IXON | IXOFF | IXANY); // turn off s/w flow ctrl

    toptions.c_lflag &= ~(ICANON | ECHO | ECHOE | ISIG); // make raw
    toptions.c_oflag &= ~OPOST; // make raw

    toptions.c_cc[VMIN]  = 0;
    toptions.c_cc[VTIME] = 10;

    if( tcsetattr(fd, TCSANOW, &toptions) < 0) {
        perror("init_serialport: Couldn't set term attributes");
        return -1;
    }

    return fd;
}

MODULE = RPi::Serial  PACKAGE = RPi::Serial

PROTOTYPES: DISABLE

int
tty_available (fd)
	int	fd

int
tty_putc (fd, b)
	int	fd
	char b

int
tty_puts (fd, str)
	int	fd
	const char *str

int
tty_getc (fd)
	int	fd

void
tty_gets (fd, nbytes)
	int	fd
	int	nbytes
    PREINIT:
        char *buf;
        int got = 0;
        int flags;
        int result;
    PPCODE:
        if (nbytes < 0)
            croak("tty_gets: nbytes must be a non-negative integer");
        /* tty_open() opens with O_NDELAY (non-blocking), which defeats the
           port's VMIN/VTIME read timeout. Clear it so a read blocks up to
           that timeout instead of returning EAGAIN immediately. */
        flags = fcntl(fd, F_GETFL, 0);
        if (flags != -1 && (flags & O_NONBLOCK))
            fcntl(fd, F_SETFL, flags & ~O_NONBLOCK);
        Newx(buf, nbytes > 0 ? nbytes : 1, char);
        while (got < nbytes) {
            result = read(fd, buf + got, nbytes - got);
            if (result > 0) {
                got += result;
                continue;
            }
            if (result == 0)
                break;                  /* VTIME timeout or EOF */
            if (errno == EINTR)
                continue;               /* interrupted by a signal; retry */
            Safefree(buf);
            croak("tty_gets: read error: %s", strerror(errno));
        }
        ST(0) = sv_2mortal(newSVpvn(buf, got));
        Safefree(buf);
        XSRETURN(1);

int
tty_open (serialport, baud)
	const char *serialport
	int	baud

void
tty_close (fd)
    int fd

unsigned short
crc16(data_p, length)
    char *data_p
    unsigned short length