@ -20,7 +20,21 @@
* http : //www.raptorengineeringinc.com
*/
# include <stdlib.h>
# 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>
@ -38,12 +52,13 @@ struct exit_exception {
instance of this class .
*/
FPGASocket : : FPGASocket ( int sock , TQObject * parent , const char * name ) :
TDEKerberosServerSocket ( parent , name ) , m_criticalSection ( 0 ) , m_ stationID( - 1 ) , m_ config( static_cast < FPGAServer * > ( parent ) - > m_config ) , m_database ( NULL ) , m_databaseStationsCursor ( NULL ) {
TDEKerberosServerSocket ( parent , name ) , m_criticalSection ( 0 ) , 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 ) ;
}
@ -52,8 +67,11 @@ FPGASocket::~FPGASocket() {
}
void FPGASocket : : close ( ) {
TDEKerberosServerSocket : : close ( ) ;
connectionClosedHandler ( ) ;
if ( state ( ) = = TQSocket : : Connected ) {
TDEKerberosServerSocket : : close ( ) ;
connectionClosedHandler ( ) ;
TQTimer : : singleShot ( 0 , parent ( ) , SLOT ( remoteConnectionClosed ( ) ) ) ;
}
}
void FPGASocket : : connectionClosedHandler ( ) {
@ -76,8 +94,76 @@ int FPGASocket::initiateKerberosHandshake() {
}
}
void FPGASocket : : enterCommandLoop ( ) {
// RAJA FIXME
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 = = " 9600 " ) {
serialBaud = B9600 ;
}
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 ;
}
int FPGASocket : : enterCommandLoop ( ) {
m_criticalSection + + ;
try {
while ( state ( ) = = TQSocket : : Connected ) {
// RAJA FIXME
// cc = read(fd_tty, readbuf, 100000);
// if (cc > 0) {
// write_data_to_client(fd, readbuf, cc);
// fsync(fd_tty);
// printf("[DEBUG] Got %d bytes from the serial port\n\r", cc); fflush(stdout);
// }
// cc = read(fd, writebuf, 100000);
// if (cc > 0) {
// write(fd_tty, writebuf, cc);
// fsync(fd);
// printf("[DEBUG] Got %d bytes from the network interface\n\r", cc); fflush(stdout);
// }
}
m_criticalSection - - ;
return 0 ;
}
catch ( . . . ) {
m_criticalSection - - ;
return - 1 ;
}
}
/*
@ -93,8 +179,6 @@ FPGAServer::FPGAServer(TQObject* parent, int port, KSimpleConfig* config) :
exit ( 1 ) ;
}
socketDevice ( ) - > setAddressReusable ( false ) ;
printf ( " [INFO] Server started on port %d \n \r " , port ) ; fflush ( stdout ) ;
}
@ -107,21 +191,42 @@ void FPGAServer::newConnection(int socket) {
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 " , . ascii ( ) ) ;
printf ( " [DEBUG] Connection from %s closed due to multiple access attempt \n \r " , s- > m_remoteHost. ascii ( ) ) ;
s - > close ( ) ;
delete s ;
s = NULL ;
return ;
}
if ( s - > initiateKerberosHandshake ( ) ! = 0 ) {
printf ( " [DEBUG] Connection from %s closed due to Kerberos failure \n \r " , m_remoteHost . ascii ( ) ) ;
printf ( " [DEBUG] Connection from %s closed due to Kerberos failure \n \r " , s - > m_remoteHost . ascii ( ) ) ;
s - > close ( ) ;
delete s ;
s = NULL ;
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 ( ) ) ;
s - > close ( ) ;
delete s ;
s = NULL ;
return ;
}
if ( s - > setupSerial ( ) ! = 0 ) {
printf ( " [DEBUG] Connection from %s closed due to serial port initialization failure \n \r " , s - > m_remoteHost . ascii ( ) ) ;
s - > close ( ) ;
delete s ;
s = NULL ;
return ;
}
else {
m_numberOfConnections + + ;
connect ( s , SIGNAL ( connectionClosed ( ) ) , s , SLOT ( deleteLater ( ) ) ) ;
connect ( s , SIGNAL ( connectionClosed ( ) ) , this , SLOT ( remoteConnectionClosed ( ) ) ) ;
emit newConnect ( s ) ;
s - > enterCommandLoop ( ) ;
}
Timothy Pearson
12 years ago