Some changes in io_layer.h; Untested Serial IOLayer implementation added

4 files changed, 218 insertions, 17 deletions

diff --git a/noncore/apps/opie-console/.cvsignore b/noncore/apps/opie-console/.cvsignore
new file mode 100644
index 0000000..acc07da
--- a/dev/null
+++ b/noncore/apps/opie-console/.cvsignore
@@ -0,0 +1,3 @@
+moc*.cpp
+Makefile
+Makefile.in
diff --git a/noncore/apps/opie-console/io_layer.h b/noncore/apps/opie-console/io_layer.h
index c8f41d7..537c851 100644
--- a/noncore/apps/opie-console/io_layer.h
+++ b/noncore/apps/opie-console/io_layer.h
@@ -1,17 +1,17 @@
 #ifndef OPIE_IO_LAYER_H
 #define OPIE_IO_LAYER_H
 
 #include <qobject.h>
-
+#include <qpe/config.h>
 
 /**
  * This is the base class for IO Layers
  * It will used to sent and recv data( QByteArray )
  * it
  */
 class Config;
 class IOLayer : public QObject {
     Q_OBJECT
 public:
     enum Error {
         NoError = -1,
@@ -20,32 +20,43 @@ public:
         ClosedUnexpected =2,
         ClosedError =3,
         Terminate = 4
         /* add more errors here */
     };
     /**
      * a small c'tor
      */
     IOLayer();
 
     /**
      * create an IOLayer instance from a config file
-     * can be used by session managemnt/profiles
+     * the currently set group stores the profile/session
+     * information
      */
     IOLayer( const Config& );
 
     /**
      * destructor
      */
     virtual ~IOLayer();
+
+    /**
+     * a small internal identifier
+     */
+    virtual QString identifier() const = 0;
+
+    /**
+     * a short name
+     */
+    virtual QString name() const = 0;
 signals:
     /**
      * received input as QCString
      */
     virtual void received( const QByteArray& ) = 0;
 
     /**
      * an error occured
      * int for the error number
      * and QString for a text
      */
     virtual void error( int, const QString& ) = 0;
@@ -61,26 +72,15 @@ public slots:
      */
     virtual bool open() = 0;
 
     /**
      * close the io
      */
     virtual void close() = 0;
 
     /**
      * closes and reloads the settings
      */
     virtual void reload( const Config& ) = 0;
-
-    /**
-     * a small internal identifier
-     */
-    virtual QString identifier()const = 0;
-
-    /**
-     * a short name
-     */
-    virtual QString name()const = 0;
-
 };
 
 #endif
diff --git a/noncore/apps/opie-console/io_serial.cpp b/noncore/apps/opie-console/io_serial.cpp
index 42c86b5..9a81de9 100644
--- a/noncore/apps/opie-console/io_serial.cpp
+++ b/noncore/apps/opie-console/io_serial.cpp
@@ -1,12 +1,163 @@
+#include <fcntl.h>
+#include <termios.h>
+#include <errno.h>
+#include <unistd.h>
 #include "io_serial.h"
 
 IOSerial::IOSerial(const Config &config) : IOLayer(config) {
+    m_fd = 0;
+    reload(config);
 }
 
 
-void IOSerial::error(int number, const QString &error) {
+IOSerial::~IOSerial() {
+    if (m_fd) {
+        close();
+    }
+}
+
+void IOSerial::send(const QByteArray &data) {
+    if (m_fd) {
+        write(m_fd, data.data(), data.size());
+    } else {
+        emit error(Refuse, tr("Not connected"));
+    }
+}
+
+void IOSerial::close() {
+    if (m_fd) {
+        delete m_read;
+        delete m_error;
+        ::close(m_fd);
+        m_fd = 0;
+    } else {
+        emit error(Refuse, tr("Not connected"));
+    }
 }
 
-void IOSerial::received(const QByteArray &array) {
+bool IOSerial::open() {
+    if (!m_fd) {
+        struct termios tty;
+        m_fd = ::open(m_device, O_RDWR | O_NOCTTY | O_NONBLOCK);
+        if (m_fd < 0) {
+            emit error(CouldNotOpen, strerror(errno));
+            return FALSE;
 }
+        tcgetattr(m_fd, &tty);
+
+        /* Baud rate */
+        int speed = getBaud(m_baud);
+        if (speed == -1) {
+            emit error(Refuse, tr("Invalid baud rate"));
+        }
+        cfsetospeed(&tty, speed);
+        cfsetispeed(&tty, speed);
+
+        /* Take care of Space / Mark parity */
+        if (m_dbits == 7 && (m_parity == ParitySpace || m_parity == ParityMark)) {
+            m_dbits = 8;
+        }
+        
+        /* Data bits */
+        switch (m_dbits) {
+            case 5: tty.c_cflag = (tty.c_cflag & ~CSIZE) | CS5; break;
+            case 6: tty.c_cflag = (tty.c_cflag & ~CSIZE) | CS6; break;
+            case 7: tty.c_cflag = (tty.c_cflag & ~CSIZE) | CS7; break;
+            case 8: tty.c_cflag = (tty.c_cflag & ~CSIZE) | CS8; break;
+        }
+        
+        /* Raw, no echo mode */
+        tty.c_iflag =  IGNBRK;
+        tty.c_lflag = 0;
+        tty.c_oflag = 0;
+        tty.c_cflag |= CLOCAL | CREAD;
+
+        /* Stop bits */
+        if (m_sbits == 2) {
+            tty.c_cflag |= CSTOPB;
+        } else {
+            tty.c_cflag &= ~CSTOPB;
+        }
+        
+        tty.c_cc[VMIN] = 1;
+        tty.c_cc[VTIME] = 5;
+
+        /* Flow control */
+        if (m_flow & FlowSW)
+            tty.c_iflag |= IXON | IXOFF;
+        else
+            tty.c_iflag &= ~(IXON|IXOFF|IXANY);
+        
+        if (m_flow & FlowHW)
+            tty.c_cflag |= CRTSCTS;
+        else
+            tty.c_cflag &= ~CRTSCTS;
 
+        /* Parity */
+        tty.c_cflag &= ~(PARENB | PARODD);
+        if (m_parity & ParityEven)
+            tty.c_cflag |= PARENB;
+        else if (m_parity & ParityOdd)
+            tty.c_cflag |= (PARENB | PARODD);
+        
+        /* Set the changes */
+        tcsetattr(m_fd, TCSANOW, &tty);
+
+        /* Notifications on read & errors */
+        m_read = new QSocketNotifier(m_fd, QSocketNotifier::Read, this);
+        m_error = new QSocketNotifier(m_fd, QSocketNotifier::Exception, this);
+        connect(m_read, SIGNAL(activated(int)), this, SLOT(dataArrived()));
+        connect(m_error, SIGNAL(activated(int)), this, SLOT(errorOccured()));
+        return TRUE;
+    } else {
+        emit error(Refuse, tr("Device is already connected"));
+        return FALSE;
+    }
+}
+
+void IOSerial::reload(const Config &config) {
+    m_device = config.readEntry("Device", SERIAL_DEFAULT_DEVICE);
+    m_baud = config.readNumEntry("Baud", SERIAL_DEFAULT_BAUD);
+}
+
+int IOSerial::getBaud(int baud) const {
+    switch (baud) {
+        case 300:    return B300;    break;
+        case 600:    return B600;    break;
+        case 1200:   return B1200;   break;
+        case 2400:   return B2400;   break;
+        case 4800:   return B4800;   break;
+        case 9600:   return B9600;   break;
+        case 19200:  return B19200;  break;
+        case 38400:  return B38400;  break;
+        case 57600:  return B57600;  break;
+        case 115200: return B115200; break;
+    }
+    return -1;
+}
+
+void IOSerial::errorOccured() {
+    emit error(ClosedUnexpected, strerror(errno));
+    close();
+}
+
+void IOSerial::dataArrived() {
+    QByteArray array;
+    char buf[4096];
+
+    int len = read(m_fd, buf, 4096);
+    if (len == 0)
+        close();
+    if (len < 0)
+        return;
+    array.setRawData(buf, len);
+    emit received(array);
+}
+
+QString IOSerial::identifier() const {
+    return "serial";
+}
+
+QString IOSerial::name() const {
+    return "RS232 Serial IO Layer";
+}
diff --git a/noncore/apps/opie-console/io_serial.h b/noncore/apps/opie-console/io_serial.h
index c6a2efd..1d34411 100644
--- a/noncore/apps/opie-console/io_serial.h
+++ b/noncore/apps/opie-console/io_serial.h
@@ -1,16 +1,63 @@
 #ifndef OPIE_IO_SERIAL
 #define OPIE_IO_SERIAL
 
+#include <qsocketnotifier.h>
 #include "io_layer.h"
 
+/* Default values to be used if the profile information is incomplete */
+#define SERIAL_DEFAULT_DEVICE       "/dev/ttyS0"
+#define SERIAL_DEFAULT_BAUD         9600
+#define SERIAL_DEFAULT_PARITY       0
+#define SERIAL_DEFAULT_DBITS        8
+#define SERIAL_DEFAULT_SBITS        1
+#define SERIAL_DEFAULT_FLOW         0
+
+/* IOSerial implements a RS232 IO Layer */
+
 class IOSerial : public IOLayer {
     Q_OBJECT
 public:
+    enum Parity {
+        ParityNone = 0,
+        ParityEven,
+        ParityOdd,
+        ParitySpace,
+        ParityMark
+    };
+
+    enum Flow {
+        FlowHW = 0x01,
+        FlowSW = 0x02
+    };
+        
     IOSerial(const Config &);
-public slots:
+    ~IOSerial();
+    
+    QString identifier() const;
+    QString name() const;
+signals:
     void received(const QByteArray &);
     void error(int, const QString &);
+public slots:
+    void send(const QByteArray &);
+    bool open();
+    void close();
+    void reload(const Config &);
+protected:
+    int getBaud(int baud) const;
+protected slots:
+    void dataArrived();
+    void errorOccured();
+protected:
+    QSocketNotifier *m_read;
+    QSocketNotifier *m_error;
+    QString          m_device;
+    int              m_baud;
+    int              m_parity;
+    int              m_dbits;
+    int              m_sbits;
+    int              m_flow;
+    int              m_fd;
 };
 
-
 #endif /* OPIE_IO_SERIAL */