OpenCores
URL https://opencores.org/ocsvn/xulalx25soc/xulalx25soc/trunk

Subversion Repositories xulalx25soc

[/] [xulalx25soc/] [trunk/] [sw/] [llcomms.cpp] - Diff between revs 5 and 91

Go to most recent revision | Only display areas with differences | Details | Blame | View Log

Rev 5 Rev 91
////////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////
//
//
// Filename:    llcomms.cpp
// Filename:    llcomms.cpp
//
//
// Project:     XuLA2 board
// Project:     XuLA2 board
//
//
// Purpose:     This is the C++ program on the command side that will interact
// Purpose:     This is the C++ program on the command side that will interact
//              with a UART on an FPGA, both sending and receiving characters.
//              with a UART on an FPGA, both sending and receiving characters.
//              Any bus interaction will call routines from this lower level
//              Any bus interaction will call routines from this lower level
//              library to accomplish the actual connection to and
//              library to accomplish the actual connection to and
//              transmission to/from the board.
//              transmission to/from the board.
//
//
//
//
// Creator:     Dan Gisselquist, Ph.D.
// Creator:     Dan Gisselquist, Ph.D.
//              Gisselquist Technology, LLC
//              Gisselquist Technology, LLC
//
//
////////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////
//
//
// Copyright (C) 2015, Gisselquist Technology, LLC
// Copyright (C) 2015-2016, Gisselquist Technology, LLC
//
//
// This program is free software (firmware): you can redistribute it and/or
// This program is free software (firmware): you can redistribute it and/or
// modify it under the terms of  the GNU General Public License as published
// modify it under the terms of  the GNU General Public License as published
// by the Free Software Foundation, either version 3 of the License, or (at
// by the Free Software Foundation, either version 3 of the License, or (at
// your option) any later version.
// your option) any later version.
//
//
// This program is distributed in the hope that it will be useful, but WITHOUT
// This program is distributed in the hope that it will be useful, but WITHOUT
// ANY WARRANTY; without even the implied warranty of MERCHANTIBILITY or
// ANY WARRANTY; without even the implied warranty of MERCHANTIBILITY or
// FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
// FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
// for more details.
// for more details.
//
//
// License:     GPL, v3, as defined and found on www.gnu.org,
// License:     GPL, v3, as defined and found on www.gnu.org,
//              http://www.gnu.org/licenses/gpl.html
//              http://www.gnu.org/licenses/gpl.html
//
//
//
//
////////////////////////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////
//
//
//
//
//
//
#include <sys/socket.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <fcntl.h>
#include <termios.h>
#include <termios.h>
#include <netinet/in.h>
#include <netinet/in.h>
#include <netdb.h>
#include <netdb.h>
#include <stdio.h>
#include <stdio.h>
#include <string.h>
#include <string.h>
#include <stdlib.h>
#include <stdlib.h>
#include <unistd.h>
#include <unistd.h>
#include <errno.h>
#include <errno.h>
#include <arpa/inet.h> 
#include <arpa/inet.h> 
#include <assert.h> 
#include <assert.h> 
#include <strings.h> 
#include <strings.h> 
#include <poll.h> 
#include <poll.h> 
#include <ctype.h> 
#include <ctype.h> 
 
 
#include "llcomms.h"
#include "llcomms.h"
 
 
LLCOMMSI::LLCOMMSI(void) {
LLCOMMSI::LLCOMMSI(void) {
        m_fdw = -1;
        m_fdw = -1;
        m_fdr = -1;
        m_fdr = -1;
        m_total_nread = 0l;
        m_total_nread = 0l;
        m_total_nwrit = 0l;
        m_total_nwrit = 0l;
}
}
 
 
void    LLCOMMSI::write(char *buf, int len) {
void    LLCOMMSI::write(char *buf, int len) {
        int     nw;
        int     nw;
        nw = ::write(m_fdw, buf, len);
        nw = ::write(m_fdw, buf, len);
        m_total_nwrit += nw;
        m_total_nwrit += nw;
        assert(nw == len);
        assert(nw == len);
}
}
 
 
int     LLCOMMSI::read(char *buf, int len) {
int     LLCOMMSI::read(char *buf, int len) {
        int     nr;
        int     nr;
        nr = ::read(m_fdr, buf, len);
        nr = ::read(m_fdr, buf, len);
        m_total_nread += nr;
        m_total_nread += nr;
        return nr;
        return nr;
}
}
 
 
void    LLCOMMSI::close(void) {
void    LLCOMMSI::close(void) {
        if(m_fdw>=0) ::close(m_fdw);
        if(m_fdw>=0)
        if((m_fdr>=0)&&(m_fdr != m_fdw)) ::close(m_fdr);
                ::close(m_fdw);
 
        if((m_fdr>=0)&&(m_fdr != m_fdw))
 
                ::close(m_fdr);
        m_fdw = m_fdr = -1;
        m_fdw = m_fdr = -1;
}
}
 
 
bool    LLCOMMSI::poll(unsigned ms) {
bool    LLCOMMSI::poll(unsigned ms) {
        struct  pollfd  fds;
        struct  pollfd  fds;
 
 
        fds.fd = m_fdr;
        fds.fd = m_fdr;
        fds.events = POLLIN;
        fds.events = POLLIN;
        ::poll(&fds, 1, ms);
        ::poll(&fds, 1, ms);
 
 
        if (fds.revents & POLLIN) {
        if (fds.revents & POLLIN) {
                return true;
                return true;
        } else return false;
        } else return false;
}
}
 
 
 
int     LLCOMMSI::available(void) {
 
        return poll(0)?1:0;
 
}
 
 
TTYCOMMS::TTYCOMMS(const char *dev) {
TTYCOMMS::TTYCOMMS(const char *dev) {
        m_fdr = ::open(dev, O_RDWR | O_NONBLOCK);
        m_fdr = ::open(dev, O_RDWR | O_NONBLOCK);
        if (m_fdr < 0) {
        if (m_fdr < 0) {
                printf("\n Error : Could not open %s\n", dev);
                printf("\n Error : Could not open %s\n", dev);
                perror("O/S Err:");
                perror("O/S Err:");
                exit(-1);
                exit(-1);
        }
        }
 
 
        if (isatty(m_fdr)) {
        if (isatty(m_fdr)) {
                struct termios tb;
                struct termios tb;
                tcgetattr(m_fdr, &tb);
                tcgetattr(m_fdr, &tb);
                cfmakeraw(&tb);
                cfmakeraw(&tb);
                // tb.c_iflag &= (~(IXON|IXOFF));
                // tb.c_iflag &= (~(IXON|IXOFF));
                tb.c_cflag &= (~(CRTSCTS));
                tb.c_cflag &= (~(CRTSCTS));
                tcsetattr(m_fdr, TCSANOW, &tb);
                tcsetattr(m_fdr, TCSANOW, &tb);
                tcflow(m_fdr, TCOON);
                tcflow(m_fdr, TCOON);
        }
        }
 
 
        m_fdw = m_fdr;
        m_fdw = m_fdr;
}
}
 
 
NETCOMMS::NETCOMMS(const char *host, const int port) {
NETCOMMS::NETCOMMS(const char *host, const int port) {
        struct sockaddr_in serv_addr;
        struct sockaddr_in serv_addr;
        struct  hostent *hp;
        struct  hostent *hp;
 
 
        if ((m_fdr = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        if ((m_fdr = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
                printf("\n Error : Could not create socket \n");
                printf("\n Error : Could not create socket \n");
                exit(-1);
                exit(-1);
        }
        }
 
 
        memset(&serv_addr, '0', sizeof(serv_addr));
        memset(&serv_addr, '0', sizeof(serv_addr));
 
 
        hp = gethostbyname(host);
        hp = gethostbyname(host);
        if (hp == NULL) {
        if (hp == NULL) {
                printf("Could not get host entity for %s\n", host);
                printf("Could not get host entity for %s\n", host);
                perror("O/S Err:");
                perror("O/S Err:");
                exit(-1);
                exit(-1);
        }
        }
        bcopy(hp->h_addr, &serv_addr.sin_addr.s_addr, hp->h_length);
        bcopy(hp->h_addr, &serv_addr.sin_addr.s_addr, hp->h_length);
 
 
        serv_addr.sin_family = AF_INET;
        serv_addr.sin_family = AF_INET;
        serv_addr.sin_port = htons(port);
        serv_addr.sin_port = htons(port);
 
 
        if (connect(m_fdr,(struct sockaddr *)&serv_addr, sizeof(serv_addr))< 0){
        if (connect(m_fdr,(struct sockaddr *)&serv_addr, sizeof(serv_addr))< 0){
                perror("Connect Failed Err");
                perror("Connect Failed Err");
                exit(-1);
                exit(-1);
        }
        }
 
 
        m_fdw = m_fdr;
        m_fdw = m_fdr;
}
}
 
 
 
 

powered by: WebSVN 2.1.0

© copyright 1999-2024 OpenCores.org, equivalent to Oliscience, all rights reserved. OpenCores®, registered trademark.