diff options
Diffstat (limited to 'servers/fpga_programming_server_lin/src')
| -rw-r--r-- | servers/fpga_programming_server_lin/src/Makefile.am | 11 | ||||
| -rw-r--r-- | servers/fpga_programming_server_lin/src/fpga_conn.cpp | 271 | ||||
| -rw-r--r-- | servers/fpga_programming_server_lin/src/fpga_conn.h | 94 | ||||
| -rw-r--r-- | servers/fpga_programming_server_lin/src/main.cpp | 64 |
4 files changed, 440 insertions, 0 deletions
diff --git a/servers/fpga_programming_server_lin/src/Makefile.am b/servers/fpga_programming_server_lin/src/Makefile.am new file mode 100644 index 0000000..6224e0c --- /dev/null +++ b/servers/fpga_programming_server_lin/src/Makefile.am @@ -0,0 +1,11 @@ +INCLUDES= $(all_includes) $(KDE_INCLUDES)/tde -I/usr/include/sasl +KDE_CXXFLAGS = $(USE_EXCEPTIONS) + +bin_PROGRAMS = remotefpga_fpgaserver + +remotefpga_fpgaserver_SOURCES = main.cpp fpga_conn.cpp + +remotefpga_fpgaserver_METASOURCES = AUTO +remotefpga_fpgaserver_LDFLAGS = $(all_libraries) $(KDE_RPATH) $(LIB_QT) -lDCOP $(LIB_TDECORE) $(LIB_TDEUI) -ltdefx $(LIB_KIO) -lktexteditor -ltdekrbsocket -ltqtrla + +KDE_OPTIONS = nofinal diff --git a/servers/fpga_programming_server_lin/src/fpga_conn.cpp b/servers/fpga_programming_server_lin/src/fpga_conn.cpp new file mode 100644 index 0000000..3acd499 --- /dev/null +++ b/servers/fpga_programming_server_lin/src/fpga_conn.cpp @@ -0,0 +1,271 @@ +/* + * Remote Laboratory FPGA Server + * + * This program is free software; you can redistribute it and/or 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 your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + * + * (c) 2012 Timothy Pearson + * Raptor Engineering + * http://www.raptorengineeringinc.com + */ + +#include <stdio.h> /* perror() */ +#include <stdlib.h> /* atoi() */ +#include <sys/types.h> +#include <sys/socket.h> +#include <unistd.h> /* read() */ +#include <netinet/in.h> +#include <arpa/inet.h> +#include <netdb.h> +#include <fcntl.h> +#include <termios.h> +#include <unistd.h> +#include <sys/signal.h> +#include <sys/types.h> + +#include <tqtimer.h> + +#include <klocale.h> + +#include "fpga_conn.h" + +#define ABORT_SOCKET(s) s->close(); \ + s->disconnect(); \ + delete s; \ + s = NULL; + +/* exception handling */ +struct exit_exception { + int c; + exit_exception(int c):c(c) { } +}; + +/* + The FPGASocket class provides a socket that is connected with a client. + For every client that connects to the server, the server creates a new + instance of this class. +*/ +FPGASocket::FPGASocket(int sock, TQObject *parent, const char *name) : + TDEKerberosServerSocket(parent, name), m_criticalSection(0), m_loopTimer(NULL), m_config(static_cast<FPGAServer*>(parent)->m_config) { + + setServiceName("remotefpga"); + + line = 0; + connect(this, SIGNAL(connectionClosed()), SLOT(connectionClosedHandler())); + connect(this, SIGNAL(connectionClosed()), parent, SLOT(remoteConnectionClosed())); + setSocket(sock); +} + +FPGASocket::~FPGASocket() { + if (m_loopTimer) { + m_loopTimer->stop(); + delete m_loopTimer; + m_loopTimer = NULL; + } +} + +void FPGASocket::close() { + if (state() == TQSocket::Connected) { + TDEKerberosServerSocket::close(); + connectionClosedHandler(); + TQTimer::singleShot(0, parent(), SLOT(remoteConnectionClosed())); + } +} + +void FPGASocket::connectionClosedHandler() { + printf("[DEBUG] Connection from %s closed\n\r", m_remoteHost.ascii()); + + if (m_criticalSection > 0) { + throw exit_exception(-1); + } +} + +int FPGASocket::initiateKerberosHandshake() { + // RAJA FIXME + setUsingKerberos(true); + while (kerberosStatus() == TDEKerberosServerSocket::KerberosInitializing) { + tqApp->processEvents(); + } + if (kerberosStatus() == TDEKerberosServerSocket::KerberosInUse) { + TQDataStream ds(this); + ds << TQString("OK"); + + return 0; + } + else { + return -1; + } +} + +int FPGASocket::setupSerial() { + struct termios oldtio, newtio; + + m_config->setGroup("FPGA"); + TQString serialDevice = m_config->readEntry("serialdevice", "/dev/ttyS0"); + TQString desiredBaudRate = m_config->readEntry("baudrate", "9600"); + + m_fd_tty = ::open(serialDevice.ascii(), O_RDWR | O_NOCTTY | O_NONBLOCK | O_APPEND); + if (m_fd_tty < 0) { + printf("[FAIL] Unable to open serial device %s\n\r", serialDevice.ascii()); fflush(stdout); + return 1; + } + + tcgetattr(m_fd_tty, &oldtio); // Save current port settings + + long serialBaud; + if (desiredBaudRate == "1200") { + serialBaud = B1200; + } + else if (desiredBaudRate == "9600") { + serialBaud = B9600; + } + else if (desiredBaudRate == "19200") { + serialBaud = B19200; + } + else if (desiredBaudRate == "115200") { + serialBaud = B115200; + } + else { + printf("[WARNING] Invalid baudrate %s specified, selecting 9600 instead\n\r", desiredBaudRate.ascii()); fflush(stdout); + serialBaud = B9600; + } + + bzero(&newtio, sizeof(newtio)); + newtio.c_cflag = serialBaud | CS8 | CLOCAL | CREAD; + newtio.c_iflag = IGNPAR; + newtio.c_oflag = 0; + + // Set input mode (non-canonical, no echo,...) + newtio.c_lflag = 0; + + newtio.c_cc[VTIME] = 0; // Inter-character timer unused + newtio.c_cc[VMIN] = 0; // Blocking read unused + + tcflush(m_fd_tty, TCIFLUSH); + tcsetattr(m_fd_tty, TCSANOW, &newtio); + + return 0; +} + +void FPGASocket::commandLoop() { + int cc; + char buffer[10000]; + bool transferred_data; + + m_criticalSection++; + try { + transferred_data = false; + if (state() == TQSocket::Connected) { + cc = read(m_fd_tty, buffer, 10000); + if (cc > 0) { + writeBlock(buffer, cc); + transferred_data = true; + printf("[DEBUG] Got %d bytes from the serial port\n\r", cc); fflush(stdout); + } + if (canReadData()) { + cc = readBlock(buffer, 10000); + if (cc > 0) { + if (write(m_fd_tty, buffer, cc) < 0) { + // ERROR + } + transferred_data = true; + printf("[DEBUG] Got %d bytes from the network interface\n\r", cc); fflush(stdout); + } + } + } + m_criticalSection--; + if (transferred_data) { + if (m_loopTimer) m_loopTimer->start(0, TRUE); + } + else { + if (m_loopTimer) m_loopTimer->start(100, TRUE); + } + return; + } + catch (...) { + m_criticalSection--; + return; + } +} + +int FPGASocket::enterCommandLoop() { + if (!m_loopTimer) { + m_loopTimer = new TQTimer(); + connect(m_loopTimer, SIGNAL(timeout()), this, SLOT(commandLoop())); + } + if (m_loopTimer) m_loopTimer->start(0, TRUE); + return 0; +} + +/* + The FPGAServer class handles new connections to the server. For every + client that connects, it creates a new FPGASocket -- that instance is now + responsible for the communication with that client. +*/ +FPGAServer::FPGAServer(TQObject* parent, int port, KSimpleConfig* config) : + TQServerSocket( port, 1, parent ), m_config(config), m_numberOfConnections(0) { + + if ( !ok() ) { + printf("[ERROR] Failed to bind to port %d\n\r", port); + exit(1); + } + + printf("[INFO] Server started on port %d\n\r", port); fflush(stdout); +} + +FPGAServer::~FPGAServer() { + // +} + +void FPGAServer::newConnection(int socket) { + FPGASocket *s = new FPGASocket(socket, this); + s->m_remoteHost = s->peerAddress().toString(); + printf("[DEBUG] New connection from %s\n\r", s->m_remoteHost.ascii()); + if (m_numberOfConnections > 0) { + printf("[DEBUG] Connection from %s closed due to multiple access attempt\n\r", s->m_remoteHost.ascii()); + ABORT_SOCKET(s) + return; + } + if (s->initiateKerberosHandshake() != 0) { + printf("[DEBUG] Connection from %s closed due to Kerberos failure\n\r", s->m_remoteHost.ascii()); + ABORT_SOCKET(s) + return; + } + m_config->setGroup("Security"); + TQString masterUser = m_config->readEntry("masteruser"); + TQString masterRealm = m_config->readEntry("masterrealm"); + if (masterRealm == "") { + masterRealm = "(NULL)"; + } + if ((s->m_authenticatedUserName != masterUser) || (s->m_authenticatedRealmName != masterRealm)) { + printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", s->m_remoteHost.ascii(), masterUser.ascii(), masterRealm.ascii()); + ABORT_SOCKET(s) + return; + } + if (s->setupSerial() != 0) { + printf("[DEBUG] Connection from %s closed due to serial port initialization failure\n\r", s->m_remoteHost.ascii()); + ABORT_SOCKET(s) + return; + } + else { + m_numberOfConnections++; + connect(s, SIGNAL(connectionClosed()), s, SLOT(deleteLater())); + emit newConnect(s); + s->enterCommandLoop(); + } +} + +void FPGAServer::remoteConnectionClosed() { + m_numberOfConnections--; +}
\ No newline at end of file diff --git a/servers/fpga_programming_server_lin/src/fpga_conn.h b/servers/fpga_programming_server_lin/src/fpga_conn.h new file mode 100644 index 0000000..717a35b --- /dev/null +++ b/servers/fpga_programming_server_lin/src/fpga_conn.h @@ -0,0 +1,94 @@ +/* + * Remote Laboratory FPGA Server + * + * This program is free software; you can redistribute it and/or 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 your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + * + * (c) 2012 Timothy Pearson + * Raptor Engineering + * http://www.raptorengineeringinc.com + */ + +#include <tqsocket.h> +#include <tqserversocket.h> +#include <tqapplication.h> +#include <tqvbox.h> +#include <tqtextview.h> +#include <tqlabel.h> +#include <tqpushbutton.h> +#include <tqtextstream.h> + +#include <ksimpleconfig.h> + +#include <tdekrbserversocket.h> + +#include <tqtrla.h> + +#define MAGIC_NUMBER 1 +#define PROTOCOL_VERSION 1 + +class FPGASocket : public TDEKerberosServerSocket +{ + Q_OBJECT + + public: + FPGASocket(int sock, TQObject *parent=0, const char *name=0); + ~FPGASocket(); + + public: + void close(); + int initiateKerberosHandshake(); + int enterCommandLoop(); + + private slots: + void connectionClosedHandler(); + int setupSerial(); + void commandLoop(); + + private: + int line; + int m_criticalSection; + TQString m_remoteHost; + int m_fd_tty; + + TQTimer* m_loopTimer; + + KSimpleConfig* m_config; + + friend class FPGAServer; +}; + +class FPGAServer : public TQServerSocket +{ + Q_OBJECT + + public: + FPGAServer(TQObject* parent=0, int port=0, KSimpleConfig* config=0); + ~FPGAServer(); + + void newConnection(int socket); + + private slots: + void remoteConnectionClosed(); + + signals: + void newConnect(FPGASocket*); + + private: + KSimpleConfig* m_config; + int m_numberOfConnections; + + friend class FPGASocket; + +};
\ No newline at end of file diff --git a/servers/fpga_programming_server_lin/src/main.cpp b/servers/fpga_programming_server_lin/src/main.cpp new file mode 100644 index 0000000..5a264d5 --- /dev/null +++ b/servers/fpga_programming_server_lin/src/main.cpp @@ -0,0 +1,64 @@ +/*************************************************************************** + * Copyright (C) 2012 by Timothy Pearson * + * kb9vqf@pearsoncomputing.net * + * * + * This program is free software; you can redistribute it and/or modify * + * it under the terms of the GNU General Public License as published by * + * the Free Software Foundation; either version 2 of the License, or * + * (at your option) any later version. * + * * + * This program is distributed in the hope that it will be useful, * + * but WITHOUT ANY WARRANTY; without even the implied warranty of * + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * + * GNU General Public License for more details. * + * * + * You should have received a copy of the GNU General Public License * + * along with this program; if not, write to the * + * Free Software Foundation, Inc., * + * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * + ***************************************************************************/ + +#include <sys/types.h> +#include <sys/socket.h> +#include <netdb.h> +#include <pwd.h> +#include <limits.h> +#include <stdio.h> +#include <unistd.h> +#include <stdlib.h> + +#include <tqdatetime.h> +#include <tqfile.h> +#include <tqdir.h> + +#include <kapplication.h> +#include <kstartupinfo.h> +#include <kcmdlineargs.h> +#include <kaboutdata.h> +#include <ksimpleconfig.h> + +#include "fpga_conn.h" + +static const char description[] = I18N_NOOP("RemoteFPGA Kerberos Authentication Server"); + +static const char version[] = "v0.0.1"; + +int main(int argc, char *argv[]) +{ + KAboutData aboutData( "remotefpga_auth_server", I18N_NOOP("RemoteFPGA AuthServer"), + version, description, KAboutData::License_GPL, + "(c) 2012, Timothy Pearson"); + aboutData.addAuthor("Timothy Pearson",0, "kb9vqf@pearsoncomputing.net"); + KCmdLineArgs::init( argc, argv, &aboutData ); + KApplication::disableAutoDcopRegistration(); + + KApplication app(false, false); + + KStartupInfo::appStarted(); + + KSimpleConfig config(TQDir::currentDirPath() + "/remotefpga_fpgaserver.conf", false); + config.setGroup("Server"); + FPGAServer fpgasvr(0, config.readNumEntry("port", 4010), &config); + return app.exec(); + +} |