diff options
author | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2012-09-19 12:50:53 -0500 |
---|---|---|
committer | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2012-09-19 12:50:53 -0500 |
commit | 851d4c9bea54059b375cc6b90b08887bc2ed3e25 (patch) | |
tree | 0f39f5dd776c5fee9eee62b8e599d5806c43f32b | |
parent | 9178fa8161fa97247a4b660e0eaa5c1a763969d6 (diff) | |
download | ulab-851d4c9bea54059b375cc6b90b08887bc2ed3e25.tar.gz ulab-851d4c9bea54059b375cc6b90b08887bc2ed3e25.zip |
Add administration console
19 files changed, 1524 insertions, 43 deletions
diff --git a/clients/tde/configure.in b/clients/tde/configure.in index 072a245..c317196 100644 --- a/clients/tde/configure.in +++ b/clients/tde/configure.in @@ -86,6 +86,7 @@ AC_CONFIG_FILES([ src/app/Makefile ]) AC_CONFIG_FILES([ src/app/views/Makefile ]) AC_CONFIG_FILES([ src/dialogs/Makefile ]) AC_CONFIG_FILES([ src/part/Makefile ]) +AC_CONFIG_FILES([ src/part/adminconsole/Makefile ]) AC_CONFIG_FILES([ src/part/commanalyzer/Makefile ]) AC_CONFIG_FILES([ src/part/fpgaprogram/Makefile ]) AC_CONFIG_FILES([ src/part/fpgaview/Makefile ]) diff --git a/clients/tde/src/app/remotemdi.cpp b/clients/tde/src/app/remotemdi.cpp index 223996e..32043c2 100644 --- a/clients/tde/src/app/remotemdi.cpp +++ b/clients/tde/src/app/remotemdi.cpp @@ -281,7 +281,7 @@ void RemoteMDI::finishConnectingToServer() { void RemoteMDI::masterPoll() { // Query current termination timestamp if (m_rsvSvrSocket) { - if (m_rsvSvrSocket->state() == TQSocket::Connected) { + if ((m_rsvSvrSocket->state() == TQSocket::Connected) && (!connToServerConnecting)) { TQDataStream ds(m_rsvSvrSocket); ds.setPrintableData(true); TQ_ULLONG terminationStamp; diff --git a/clients/tde/src/part/Makefile.am b/clients/tde/src/part/Makefile.am index 55afedd..7d3bcfe 100644 --- a/clients/tde/src/part/Makefile.am +++ b/clients/tde/src/part/Makefile.am @@ -1 +1 @@ -SUBDIRS = scope commanalyzer fpgaview fpgaprogram sensormonitor +SUBDIRS = scope commanalyzer fpgaview fpgaprogram sensormonitor adminconsole diff --git a/clients/tde/src/part/adminconsole/Makefile.am b/clients/tde/src/part/adminconsole/Makefile.am new file mode 100644 index 0000000..9db32f5 --- /dev/null +++ b/clients/tde/src/part/adminconsole/Makefile.am @@ -0,0 +1,11 @@ +INCLUDES = $(all_includes) -I$(top_srcdir)/src -I$(top_srcdir)/src/widgets $(KDE_INCLUDES)/tde +KDE_CXXFLAGS = $(USE_EXCEPTIONS) +METASOURCES = AUTO + +KDE_ICON = libremotelab_adminconsole + +# Part +kde_module_LTLIBRARIES = libremotelab_adminconsole.la +libremotelab_adminconsole_la_LIBADD = ../../widgets/libtracewidget.la ../../widgets/libfloatspinbox.la $(LIB_KFILE) $(LIB_KPARTS) $(LIB_TDEUI) $(LIB_QT) -ltdekrbsocket -ltqtrla +libremotelab_adminconsole_la_LDFLAGS = $(all_libraries) $(KDE_PLUGIN) $(LIB_TDECORE) $(LIB_TDEUI) -lkio -ltdefx +libremotelab_adminconsole_la_SOURCES = part.cpp layout.ui terminatedlg.cpp terminatedlgbase.ui diff --git a/clients/tde/src/part/adminconsole/hi16-action-libremotelab_adminconsole.png b/clients/tde/src/part/adminconsole/hi16-action-libremotelab_adminconsole.png Binary files differnew file mode 100644 index 0000000..a8d720b --- /dev/null +++ b/clients/tde/src/part/adminconsole/hi16-action-libremotelab_adminconsole.png diff --git a/clients/tde/src/part/adminconsole/layout.ui b/clients/tde/src/part/adminconsole/layout.ui new file mode 100644 index 0000000..5a56809 --- /dev/null +++ b/clients/tde/src/part/adminconsole/layout.ui @@ -0,0 +1,341 @@ +<!DOCTYPE UI><UI version="3.0" stdsetdef="1"> + <class>AdminConsoleBase</class> + <widget class="TQWidget"> + <property name="name"> + <cstring>AdminConsoleBase</cstring> + </property> + <property name="geometry"> + <rect> + <x>0</x> + <y>0</y> + <width>519</width> + <height>356</height> + </rect> + </property> + <grid> + <property name="name"> + <cstring>unnamed_grid</cstring> + </property> + <widget class="TQGroupBox" row="0" column="0"> + <property name="name"> + <cstring>groupTerminalServices</cstring> + </property> + <property name="title"> + <string>Terminal Services</string> + </property> + <grid> + <property name="name"> + <cstring>unnamed_grid</cstring> + </property> + <widget class="TQSplitter" row="1" column="0" colspan="4"> + <property name="name"> + <cstring>splitter1</cstring> + </property> + <property name="orientation"> + <enum>Vertical</enum> + </property> + <widget class="KListView" row="1" column="0" colspan="4"> + <column> + <property name="text"> + <string>Session ID</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>User Name</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Server Name</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Control PID</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Window Manager PID</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>X11 Display Number</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Logon Date</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Last Session Management Activity</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <property name="name"> + <cstring>ts_list</cstring> + </property> + <property name="rootIsDecorated"> + <bool>false</bool> + </property> + </widget> + <widget class="TQLayoutWidget" row="2" column="0" colspan="4"> + <property name="name"> + <cstring>unnamed_layoutwidget1</cstring> + </property> + <grid> + <property name="margin"> + <number>0</number> + </property> + <widget class="TQLayoutWidget" row="0" column="0"> + <property name="name"> + <cstring>ts_controls</cstring> + </property> + <grid> + <property name="name"> + <cstring>unnamed_grid3</cstring> + </property> + <widget class="TQPushButton" row="0" column="0" colspan="1"> + <property name="name"> + <cstring>ts_buttonKill</cstring> + </property> + <property name="text"> + <string>Terminate Session</string> + </property> + </widget> + </grid> + </widget> + <spacer row="4" column="0"> + <property name="name" stdset="0"> + <cstring>Spacer4</cstring> + </property> + <property name="orientation"> + <enum>Vertical</enum> + </property> + <property name="sizeType"> + <enum>Expanding</enum> + </property> + <property name="sizeHint"> + <size> + <width>20</width> + <height>20</height> + </size> + </property> + </spacer> + </grid> + </widget> + </widget> + </grid> + </widget> + <widget class="TQGroupBox" row="1" column="0"> + <property name="name"> + <cstring>groupWorkspaces</cstring> + </property> + <property name="title"> + <string>Workspaces</string> + </property> + <grid> + <property name="name"> + <cstring>unnamed_grid</cstring> + </property> + <widget class="TQSplitter" row="1" column="0" colspan="4"> + <property name="name"> + <cstring>splitter1</cstring> + </property> + <property name="orientation"> + <enum>Vertical</enum> + </property> + <widget class="KListView" row="1" column="0" colspan="4"> + <column> + <property name="text"> + <string>Session ID</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>User Name</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Realm Name</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Server ID</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Logon Date</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <column> + <property name="text"> + <string>Forced Logoff Date</string> + </property> + <property name="clickable"> + <bool>true</bool> + </property> + <property name="resizeable"> + <bool>true</bool> + </property> + </column> + <property name="name"> + <cstring>workspace_list</cstring> + </property> + <property name="rootIsDecorated"> + <bool>false</bool> + </property> + </widget> + <widget class="TQLayoutWidget" row="2" column="0" colspan="4"> + <property name="name"> + <cstring>unnamed_layoutwidget1</cstring> + </property> + <grid> + <property name="margin"> + <number>0</number> + </property> + <widget class="TQLayoutWidget" row="0" column="0"> + <property name="name"> + <cstring>workspace_controls</cstring> + </property> + <grid> + <property name="name"> + <cstring>unnamed_grid3</cstring> + </property> + <widget class="TQPushButton" row="0" column="0" colspan="1"> + <property name="name"> + <cstring>workspace_buttonTerminate</cstring> + </property> + <property name="text"> + <string>Terminate Workspace</string> + </property> + </widget> + <widget class="TQPushButton" row="0" column="1" colspan="1"> + <property name="name"> + <cstring>workspace_buttonCancelTermination</cstring> + </property> + <property name="text"> + <string>Cancel Termination</string> + </property> + </widget> + </grid> + </widget> + <spacer row="4" column="0"> + <property name="name" stdset="0"> + <cstring>Spacer4</cstring> + </property> + <property name="orientation"> + <enum>Vertical</enum> + </property> + <property name="sizeType"> + <enum>Expanding</enum> + </property> + <property name="sizeHint"> + <size> + <width>20</width> + <height>20</height> + </size> + </property> + </spacer> + </grid> + </widget> + </widget> + </grid> + </widget> + </grid> + </widget> + <includes> + <include location="local" impldecl="in implementation">AdminConsoleBase.ui.h</include> + </includes> + <includes> + <include location="local" impldecl="in implementation">tracewidget.h</include> + <include location="local" impldecl="in implementation">floatspinbox.h</include> + <include location="local" impldecl="in implementation">part.h</include> + </includes> + <layoutdefaults spacing="3" margin="6"/> + <layoutfunctions spacing="KDialog::spacingHint" margin="KDialog::marginHint"/> +</UI> diff --git a/clients/tde/src/part/adminconsole/part.cpp b/clients/tde/src/part/adminconsole/part.cpp new file mode 100644 index 0000000..2b5a619 --- /dev/null +++ b/clients/tde/src/part/adminconsole/part.cpp @@ -0,0 +1,621 @@ +/* + * Remote Laboratory Administration Console Part + * + * 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 "define.h" +#include "part.h" + +#include <kaboutdata.h> //::createAboutData() +#include <kaction.h> +#include <klocale.h> +#include <ktextedit.h> +#include <kfiledialog.h> +#include <kmessagebox.h> //::start() +#include <kparts/genericfactory.h> +#include <kstatusbar.h> +#include <kstdaction.h> +#include <knuminput.h> +#include <kmdcodec.h> +#include <kurlrequester.h> +#include <tqfile.h> //encodeName() +#include <tqtimer.h> //postInit() hack +#include <tqvbox.h> +#include <tqsocket.h> +#include <tqmutex.h> +#include <tqeventloop.h> +#include <tqapplication.h> +#include <tqgroupbox.h> +#include <tqcheckbox.h> +#include <tqpushbutton.h> +#include <tqprogressbar.h> +#include <tqlistview.h> +#include <klistview.h> +#include <unistd.h> //access() +#include <stdint.h> + +#include <tqpainter.h> + +#include "tracewidget.h" +#include "floatspinbox.h" +#include "layout.h" +#include "terminatedlg.h" + +#define NETWORK_COMM_TIMEOUT_MS 2500 + +enum connectionModes { + ModeIdle = 0, + ModeTerminate = 1 +}; + +enum connectionStates { + ModeIdle_None = 0, + ModeIdle_StateTerminalListRequest = 1, + ModeIdle_StateProcessTerminalList = 2, + ModeIdle_StateWorkspaceListRequest = 3, + ModeIdle_StateProcessWorkspaceList = 4, + ModeIdle_StateDelay = 5, + ModeTerminate_TerminalServices = 6, + ModeTerminate_LaboratoryWorkspace = 7, + ModeTerminate_CancelTerminationOfWorkspace = 8, + ModeTerminate_ProcessResponse = 9 +}; + +namespace RemoteLab { + +typedef KParts::GenericFactory<RemoteLab::AdminConsolePart> Factory; +#define CLIENT_LIBRARY "libremotelab_adminconsole" +K_EXPORT_COMPONENT_FACTORY(libremotelab_adminconsole, RemoteLab::Factory) + +AdminConsolePart::AdminConsolePart(TQWidget *parentWidget, const char *widgetName, TQObject *parent, const char *name, const TQStringList&) + : RemoteInstrumentPart( parent, name ), m_base(NULL), m_commHandlerState(0), m_connectionActiveAndValid(false), m_tickerState(0) +{ + // Initialize important base class variables + m_clientLibraryName = CLIENT_LIBRARY; + + // Initialize mutex + m_connectionMutex = new TQMutex(false); + + // Initialize kpart + setInstance(Factory::instance()); + setWidget(new TQVBox(parentWidget, widgetName)); + + // Create timers + m_forcedUpdateTimer = new TQTimer(this); + connect(m_forcedUpdateTimer, SIGNAL(timeout()), this, SLOT(mainEventLoop())); + m_updateTimeoutTimer = new TQTimer(this); + connect(m_updateTimeoutTimer, SIGNAL(timeout()), this, SLOT(mainEventLoop())); + m_pingDelayTimer = new TQTimer(this); + connect(m_pingDelayTimer, SIGNAL(timeout()), this, SLOT(mainEventLoop())); + + // Create widgets + m_base = new AdminConsoleBase(widget()); + + // Initialize widgets + connect(m_base->ts_buttonKill, SIGNAL(clicked()), this, SLOT(terminalServiceKillButtonClicked())); + connect(m_base->workspace_buttonTerminate, SIGNAL(clicked()), this, SLOT(workspaceTerminateButtonClicked())); + connect(m_base->workspace_buttonCancelTermination, SIGNAL(clicked()), this, SLOT(workspaceCancelTerminationButtonClicked())); + + m_base->ts_list->setAllColumnsShowFocus(true); + connect(m_base->ts_list, SIGNAL(selectionChanged()), this, SLOT(terminalServiceListSelect())); + m_base->workspace_list->setAllColumnsShowFocus(true); + connect(m_base->workspace_list, SIGNAL(selectionChanged()), this, SLOT(workspaceListSelect())); + + TQTimer::singleShot(0, this, TQT_SLOT(postInit())); +} + +AdminConsolePart::~AdminConsolePart() { + if (m_connectionMutex->locked()) { + printf("[WARNING] Exiting when data transfer still in progress!\n\r"); fflush(stdout); + } + + disconnectFromServer(); + delete m_connectionMutex; +} + +void AdminConsolePart::processLockouts() { + TQWidget* mainWidget = widget(); + if (mainWidget) { + if ((m_socket) && (m_socket->state() == TQSocket::Connected) && (connToServerState > 0) && (connToServerConnecting == false) && (m_commHandlerNextMode == ModeIdle)) { + mainWidget->setEnabled(true); + } + else { + mainWidget->setEnabled(false); + } + } + + if ((m_connectionActiveAndValid == true) && (m_base->ts_list->selectedItem())) { + m_base->ts_buttonKill->setEnabled(true); + } + else { + m_base->ts_buttonKill->setEnabled(false); + } + + if ((m_connectionActiveAndValid == true) && (m_base->workspace_list->selectedItem())) { + m_base->workspace_buttonTerminate->setEnabled(true); + } + else { + m_base->workspace_buttonTerminate->setEnabled(false); + } + + if ((m_connectionActiveAndValid == true) && (m_base->workspace_list->selectedItem())) { + m_base->workspace_buttonCancelTermination->setEnabled(true); + } + else { + m_base->workspace_buttonCancelTermination->setEnabled(false); + } +} + +void AdminConsolePart::resizeToHint() { + resize(widget()->sizeHint()); +} + +void AdminConsolePart::connectionClosed() { + closeURL(); +} + +void AdminConsolePart::postInit() { + setUsingFixedSize(false); +} + +bool AdminConsolePart::openURL(const KURL &url) { + int ret; + ret = connectToServer(url.url()); + processLockouts(); + return (ret != 0); +} + +bool AdminConsolePart::closeURL() { + disconnectFromServer(); + m_url = KURL(); + return true; +} + +void AdminConsolePart::disconnectFromServerCallback() { + m_forcedUpdateTimer->stop(); + m_updateTimeoutTimer->stop(); +} + +void AdminConsolePart::connectionFinishedCallback() { + connect(m_socket, SIGNAL(readyRead()), m_socket, SLOT(processPendingData())); + m_socket->processPendingData(); + connect(m_socket, SIGNAL(newDataReceived()), this, SLOT(mainEventLoop())); + m_tickerState = 0; + m_commHandlerState = ModeIdle_StateTerminalListRequest; + m_commHandlerMode = ModeIdle; + m_commHandlerNextState = ModeIdle_None; + m_commHandlerNextMode = ModeIdle; + m_socket->setDataTimeout(NETWORK_COMM_TIMEOUT_MS); + m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE); + processLockouts(); + mainEventLoop(); + return; +} + +void AdminConsolePart::connectionStatusChangedCallback() { + processLockouts(); +} + +void AdminConsolePart::terminalServiceKillButtonClicked() { + TQListViewItem* item = m_base->ts_list->selectedItem(); + + TerminateDialog termdlg(0); + termdlg.setWarningLabelText(i18n("Configure termination of Terminal Services for user %1").arg(item->text(1))); + termdlg.enableDelayedTermination(false); + if (termdlg.exec() == TQDialog::Accepted) { + terminateSessionID = item->text(0); + terminateSessionDelayMinutes = termdlg.minutes(); + m_commHandlerNextState = ModeTerminate_TerminalServices; + m_commHandlerNextMode = ModeTerminate; + } + + processLockouts(); +} + +void AdminConsolePart::workspaceTerminateButtonClicked() { + TQListViewItem* item = m_base->workspace_list->selectedItem(); + + TerminateDialog termdlg(0); + termdlg.setWarningLabelText(i18n("Configure termination of Laboratory Workspace for user %1").arg(item->text(1))); + termdlg.enableDelayedTermination(true); + if (termdlg.exec() == TQDialog::Accepted) { + terminateSessionID = item->text(0); + terminateSessionDelayMinutes = termdlg.minutes(); + m_commHandlerNextState = ModeTerminate_LaboratoryWorkspace; + m_commHandlerNextMode = ModeTerminate; + } + + processLockouts(); +} + +void AdminConsolePart::workspaceCancelTerminationButtonClicked() { + TQListViewItem* item = m_base->workspace_list->selectedItem(); + + terminateSessionID = item->text(0); + m_commHandlerNextState = ModeTerminate_CancelTerminationOfWorkspace; + m_commHandlerNextMode = ModeTerminate; + + processLockouts(); +} + +void AdminConsolePart::terminalServiceListSelect() { + // Highlight the matching user session in the workspace list, + // or deselect all workspace list items if no matching workspace session is found + + TQListViewItem* item = m_base->ts_list->selectedItem(); + if (item) { + TQString username = item->text(1); + + TQListViewItemIterator it; + it = TQListViewItemIterator(m_base->workspace_list); + bool found = false; + TQListViewItem* item2 = NULL; + while (it.current()) { + item2 = *it; + if (item2->text(1) == username) { + found = true; + break; + } + ++it; + } + if (found) { + m_base->workspace_list->setCurrentItem(item2); + } + else { + m_base->workspace_list->clearSelection(); + } + } + else { + m_base->workspace_list->clearSelection(); + } + + processLockouts(); +} + +void AdminConsolePart::workspaceListSelect() { + // Highlight the matching user session in the terminal services list, + // or deselect all workspace list items if no matching terminal services session is found + + TQListViewItem* item = m_base->workspace_list->selectedItem(); + if (item) { + TQString username = item->text(1); + + TQListViewItemIterator it; + it = TQListViewItemIterator(m_base->ts_list); + bool found = false; + TQListViewItem* item2 = NULL; + while (it.current()) { + item2 = *it; + if (item2->text(1) == username) { + found = true; + break; + } + ++it; + } + if (found) { + m_base->ts_list->setCurrentItem(item2); + } + else { + m_base->ts_list->clearSelection(); + } + } + else { + m_base->ts_list->clearSelection(); + } + + processLockouts(); +} + +#define UPDATEDISPLAY_TIMEOUT m_connectionActiveAndValid = false; \ + m_tickerState = 0; \ + m_commHandlerState = ModeIdle_StateTerminalListRequest; \ + m_commHandlerMode = ModeIdle; \ + m_commHandlerNextState = ModeIdle_None; \ + m_commHandlerNextMode = ModeIdle; \ + m_socket->clearIncomingData(); \ + setStatusMessage(i18n("Server ping timeout. Please verify the status of your network connection.")); \ + m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE); \ + m_connectionMutex->unlock(); \ + return; + +#define SET_WATCHDOG_TIMER if (!m_updateTimeoutTimer->isActive()) m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE); +#define PAT_WATCHDOG_TIMER m_updateTimeoutTimer->stop(); m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE); + +#define SET_NEXT_STATE(x) m_commHandlerState = x; + +#define EXEC_NEXT_STATE_IMMEDIATELY m_forcedUpdateTimer->start(0, TRUE); + +void AdminConsolePart::setTickerMessage(TQString message) { + m_connectionActiveAndValid = true; + TQString tickerChar; + switch (m_tickerState) { + case 0: + tickerChar = "-"; + break; + case 1: + tickerChar = "\\"; + break; + case 2: + tickerChar = "|"; + break; + case 3: + tickerChar = "/"; + break; + } + setStatusMessage(message + TQString("... %1").arg(tickerChar)); + m_tickerState++; + if (m_tickerState > 3) { + m_tickerState = 0; + } +} + +void AdminConsolePart::mainEventLoop() { + TQDataStream ds(m_socket); + ds.setPrintableData(true); + + if (!m_connectionMutex->tryLock()) { + EXEC_NEXT_STATE_IMMEDIATELY + return; + } + + if (m_socket) { + if (m_commHandlerMode == ModeIdle) { + // Normal operation + switch (m_commHandlerState) { + case ModeIdle_StateTerminalListRequest: + // Get status of remote system + // Clear buffers to synchronize frames in case of data corruption + m_socket->clearIncomingData(); + ds << TQString("USERS"); + ds << TQString("TERMINALS"); + m_socket->writeEndOfFrame(); + + SET_NEXT_STATE(ModeIdle_StateProcessTerminalList) + break; + case ModeIdle_StateProcessTerminalList: + // Get all data + if (m_socket->canReadFrame()) { + PAT_WATCHDOG_TIMER + + TQString status; + TerminalServiceStatusList list; + ds >> status; + if (status == "OK") { + ds >> list; + m_socket->clearFrameTail(); + + TerminalServiceStatusList::iterator it; + TQListViewItemIterator it2; + + for (it = list.begin(); it != list.end(); ++it) { + TerminalServiceStatusType info = *it; + it2 = TQListViewItemIterator(m_base->ts_list); + bool found = false; + while (it2.current()) { + TQListViewItem* item = *it2; + if (info.sessionID == item->text(0).toInt()) { + found = true; + } + ++it2; + } + if (!found) { + new TQListViewItem(m_base->ts_list, TQString("%1").arg(info.sessionID), info.username, info.serverName, TQString("%1").arg(info.serverPID), TQString("%1").arg(info.wmPID), TQString(":%1").arg(info.display), info.loginStamp.toString(), info.activityStamp.toString()); + } + } + it2 = TQListViewItemIterator(m_base->ts_list); + while (it2.current()) { + TQListViewItem* item = *it2; + bool found = false; + for (it = list.begin(); it != list.end(); ++it) { + TerminalServiceStatusType info = *it; + if (info.sessionID == item->text(0).toInt()) { + found = true; + } + } + if (!found) { + delete item; + } + ++it2; + } + + setTickerMessage(i18n("Connected")); + } + + SET_NEXT_STATE(ModeIdle_StateWorkspaceListRequest); + EXEC_NEXT_STATE_IMMEDIATELY + } + else { + if (!m_updateTimeoutTimer->isActive()) { + UPDATEDISPLAY_TIMEOUT + } + } + break; + case ModeIdle_StateWorkspaceListRequest: + // Get status of remote system + // Clear buffers to synchronize frames in case of data corruption + m_socket->clearIncomingData(); + ds << TQString("USERS"); + ds << TQString("WORKSPACES"); + m_socket->writeEndOfFrame(); + + SET_NEXT_STATE(ModeIdle_StateProcessWorkspaceList) + EXEC_NEXT_STATE_IMMEDIATELY + break; + case ModeIdle_StateProcessWorkspaceList: + // Get all data + if (m_socket->canReadFrame()) { + PAT_WATCHDOG_TIMER + + TQString status; + WorkspaceServiceStatusList list; + ds >> status; + if (status == "OK") { + ds >> list; + m_socket->clearFrameTail(); + + WorkspaceServiceStatusList::iterator it; + TQListViewItemIterator it2; + + for (it = list.begin(); it != list.end(); ++it) { + WorkspaceServiceStatusType info = *it; + if (info.serviceID != 0) { + continue; + } + it2 = TQListViewItemIterator(m_base->workspace_list); + bool found = false; + while (it2.current()) { + TQListViewItem* item = *it2; + if (info.sessionID == item->text(0).toInt()) { + found = true; + } + ++it2; + } + if (!found) { + new TQListViewItem(m_base->workspace_list, TQString("%1").arg(info.sessionID), info.username, info.realmname, TQString("%1").arg(info.stationName), info.loginStamp.toString(), (info.terminateStamp.toTime_t()==0)?i18n("Not Set"):info.terminateStamp.toString()); + } + } + it2 = TQListViewItemIterator(m_base->workspace_list); + while (it2.current()) { + TQListViewItem* item = *it2; + bool found = false; + for (it = list.begin(); it != list.end(); ++it) { + WorkspaceServiceStatusType info = *it; + if (info.serviceID != 0) { + continue; + } + if (info.sessionID == item->text(0).toInt()) { + found = true; + } + } + if (!found) { + delete item; + } + ++it2; + } + + setTickerMessage(i18n("Connected")); + } + + if (m_commHandlerState == ModeIdle_StateProcessWorkspaceList) { + m_pingDelayTimer->start(250, TRUE); + SET_NEXT_STATE(ModeIdle_StateDelay); + } + } + else { + if (!m_updateTimeoutTimer->isActive()) { + UPDATEDISPLAY_TIMEOUT + } + } + break; + case ModeIdle_StateDelay: + if (m_commHandlerNextMode == ModeIdle) { + // Let the client and server rest for a bit to lower CPU/network overhead + if (!m_pingDelayTimer->isActive()) { + EXEC_NEXT_STATE_IMMEDIATELY + // Execute query on next event loop + SET_NEXT_STATE(ModeIdle_StateTerminalListRequest); + } + PAT_WATCHDOG_TIMER + } + else { + m_commHandlerMode = m_commHandlerNextMode; + SET_NEXT_STATE(m_commHandlerNextState); + EXEC_NEXT_STATE_IMMEDIATELY + m_commHandlerNextState = ModeIdle_None; + m_commHandlerNextMode = ModeIdle; + } + break; + } + } + else if (m_commHandlerMode == ModeTerminate) { + switch (m_commHandlerState) { + case ModeTerminate_TerminalServices: + ds << TQString("SESSION"); + ds << TQString("KILL_TERMINAL"); + ds << terminateSessionID; + m_socket->writeEndOfFrame(); + + SET_NEXT_STATE(ModeTerminate_ProcessResponse) + EXEC_NEXT_STATE_IMMEDIATELY + break; + case ModeTerminate_LaboratoryWorkspace: + ds << TQString("SESSION"); + ds << TQString("KILL_WORKSPACE"); + ds << terminateSessionID; + ds << terminateSessionDelayMinutes; + m_socket->writeEndOfFrame(); + + SET_NEXT_STATE(ModeTerminate_ProcessResponse) + EXEC_NEXT_STATE_IMMEDIATELY + break; + case ModeTerminate_CancelTerminationOfWorkspace: + ds << TQString("SESSION"); + ds << TQString("CANCEL_KILL_WORKSPACE"); + ds << terminateSessionID; + m_socket->writeEndOfFrame(); + + SET_NEXT_STATE(ModeTerminate_ProcessResponse) + EXEC_NEXT_STATE_IMMEDIATELY + break; + case ModeTerminate_ProcessResponse: + // Get all data + if (m_socket->canReadFrame()) { + PAT_WATCHDOG_TIMER + + TQString status; + WorkspaceServiceStatusList list; + ds >> status; + + if (status != "OK") { + // Command failed! + KMessageBox::error(0, i18n("Command Failure"), i18n("Unable to execute command!")); + } + + m_commHandlerMode = ModeIdle; + SET_NEXT_STATE(ModeIdle_StateTerminalListRequest); + EXEC_NEXT_STATE_IMMEDIATELY + } + else { + if (!m_updateTimeoutTimer->isActive()) { + UPDATEDISPLAY_TIMEOUT + } + } + break; + } + } + + processLockouts(); + SET_WATCHDOG_TIMER + } + else { + SET_NEXT_STATE(ModeIdle_StateTerminalListRequest); + m_commHandlerMode = ModeIdle; + } + + m_connectionMutex->unlock(); +} + +KAboutData* AdminConsolePart::createAboutData() { + return new KAboutData( APP_NAME, I18N_NOOP( APP_PRETTYNAME ), APP_VERSION ); +} + +} //namespace RemoteLab + +#include "part.moc" diff --git a/clients/tde/src/part/adminconsole/part.h b/clients/tde/src/part/adminconsole/part.h new file mode 100644 index 0000000..d8a9076 --- /dev/null +++ b/clients/tde/src/part/adminconsole/part.h @@ -0,0 +1,105 @@ +/* + * Remote Laboratory Administration Console Part + * + * 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 + */ + +#ifndef REMOTELAB_ADMINCONSOLEPART_H +#define REMOTELAB_ADMINCONSOLEPART_H + +#include <tdekrbclientsocket.h> + +#include <tqcstring.h> +#include <tqframe.h> +#include <tqimage.h> + +#include <kparts/browserextension.h> +#include <kparts/statusbarextension.h> +#include <kparts/part.h> +#include <kurl.h> +#include <kled.h> + +#include <tqtrla.h> + +class KAboutData; +using KParts::StatusBarExtension; +class TraceWidget; +class TQSocket; +class TQTimer; +class TQMutex; +class TQFile; +class AdminConsoleBase; + +namespace RemoteLab +{ + class AdminConsolePart : public KParts::RemoteInstrumentPart + { + Q_OBJECT + + public: + AdminConsolePart(TQWidget *, const char *, TQObject *, const char *, const TQStringList&); + ~AdminConsolePart(); + + virtual bool openFile() { return false; } // pure virtual in the base class + virtual bool closeURL(); + static KAboutData *createAboutData(); + + public slots: + virtual bool openURL(const KURL &url); + + private slots: + void postInit(); + void resizeToHint(); + void mainEventLoop(); + void processLockouts(); + void connectionClosed(); + void connectionFinishedCallback(); + void disconnectFromServerCallback(); + void connectionStatusChangedCallback(); + void setTickerMessage(TQString message); + + void terminalServiceKillButtonClicked(); + void workspaceTerminateButtonClicked(); + void workspaceCancelTerminationButtonClicked(); + + void terminalServiceListSelect(); + void workspaceListSelect(); + + private: + AdminConsoleBase* m_base; + TQMutex* m_connectionMutex; + TQTimer* m_pingDelayTimer; + TQTimer* m_forcedUpdateTimer; + TQTimer* m_updateTimeoutTimer; + + int m_commHandlerState; + int m_commHandlerMode; + int m_commHandlerNextState; + int m_commHandlerNextMode; + TQString terminateSessionID; + TQ_INT32 terminateSessionDelayMinutes; + bool m_connectionActiveAndValid; + unsigned char m_tickerState; + TQByteArray m_programmingFileData; + TQ_ULONG m_programmingFileTotalSize; + TQ_ULONG m_programmingFileTransferredBytes; + }; +} + +#endif diff --git a/clients/tde/src/part/adminconsole/terminatedlg.cpp b/clients/tde/src/part/adminconsole/terminatedlg.cpp new file mode 100644 index 0000000..f87ae4b --- /dev/null +++ b/clients/tde/src/part/adminconsole/terminatedlg.cpp @@ -0,0 +1,95 @@ +/*************************************************************************** + * 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 <klocale.h> +#include <klineedit.h> +#include <ktextedit.h> +#include <knuminput.h> +#include <kactionselector.h> +#include <tqlistbox.h> +#include <kpushbutton.h> +#include <tqpixmap.h> +#include <tqiconset.h> +#include <tqlabel.h> +#include <kconfig.h> +#include <tqcheckbox.h> +#include <tqradiobutton.h> + +#include "terminatedlgbase.h" +#include "terminatedlg.h" + +TerminateDialog::TerminateDialog(TQWidget* parent, const char* name) + : KDialogBase(parent, name, true, i18n("Terminate Session"), Ok|Cancel, Ok, true) +{ + m_base = new TerminateDlgBase(this); + + setMainWidget(m_base); + + connect(m_base->m_btnImmediate, SIGNAL(clicked()), this, SLOT(processLockouts())); + connect(m_base->m_btnDelayed, SIGNAL(clicked()), this, SLOT(processLockouts())); + + m_base->m_btnDelayed->setChecked(false); + m_base->m_btnImmediate->setChecked(true); + processLockouts(); +} + +void TerminateDialog::processLockouts() { + if (m_base->m_btnDelayed->isChecked()) { + m_base->terminateMinutes->setEnabled(true); + } + if (m_base->m_btnImmediate->isChecked()) { + m_base->terminateMinutes->setEnabled(false); + } +} + +void TerminateDialog::setWarningLabelText(TQString text) { + m_base->m_warningLabel->setText(text); +} + +void TerminateDialog::enableDelayedTermination(bool enabled) { + if (enabled) { + m_base->m_btnImmediate->setEnabled(true); + m_base->m_btnDelayed->setEnabled(true); + } + else { + m_base->m_btnImmediate->setChecked(true); + m_base->m_btnImmediate->setEnabled(true); + m_base->m_btnDelayed->setEnabled(false); + } +} + +bool TerminateDialog::delayed() { + return m_base->m_btnDelayed->isChecked(); +} + +int TerminateDialog::minutes() { + if (m_base->m_btnDelayed->isChecked()) { + return m_base->terminateMinutes->value(); + } + else { + return -1; + } +} + +void TerminateDialog::slotOk() { + accept(); +} + +#include "terminatedlg.moc" diff --git a/clients/tde/src/part/adminconsole/terminatedlg.h b/clients/tde/src/part/adminconsole/terminatedlg.h new file mode 100644 index 0000000..eff6080 --- /dev/null +++ b/clients/tde/src/part/adminconsole/terminatedlg.h @@ -0,0 +1,53 @@ +/*************************************************************************** + * 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. * + ***************************************************************************/ + +#ifndef _TERMINATEDIALOG_H_ +#define _TERMINATEDIALOG_H_ + +#include <kdialogbase.h> +#include <kcombobox.h> + +class TerminateDlgBase; +class TopLevel; + +class TerminateDialog : public KDialogBase +{ + Q_OBJECT + +public: + TerminateDialog(TQWidget* parent = 0, const char* name = 0); + +public slots: + void slotOk(); + +public: + void enableDelayedTermination(bool enabled); + void setWarningLabelText(TQString text); + bool delayed(); + int minutes(); + +private slots: + void processLockouts(); + +private: + TerminateDlgBase *m_base; +}; + +#endif diff --git a/clients/tde/src/part/adminconsole/terminatedlgbase.ui b/clients/tde/src/part/adminconsole/terminatedlgbase.ui new file mode 100644 index 0000000..385f0b6 --- /dev/null +++ b/clients/tde/src/part/adminconsole/terminatedlgbase.ui @@ -0,0 +1,84 @@ +<!DOCTYPE UI><UI version="3.0" stdsetdef="1"> +<class>TerminateDlgBase</class> +<widget class="TQWidget"> + <property name="name"> + <cstring>TerminateDlgBase</cstring> + </property> + <grid> + <widget class="TQButtonGroup"> + <property name="name"> + <cstring>m_frameTerminate</cstring> + </property> + <property name="frameShape"> + <enum>NoFrame</enum> + </property> + <property name="frameShadow"> + <enum>Plain</enum> + </property> + <property name="title"> + <string></string> + </property> + <grid> + <property name="name"> + <cstring>unnamed</cstring> + </property> + <property name="margin"> + <number>0</number> + </property> + <widget class="TQLabel" row="0" column="0" colspan="2"> + <property name="name"> + <cstring>m_warningLabel</cstring> + </property> + <property name="text"> + <string></string> + </property> + </widget> + <widget class="TQRadioButton" row="1" column="0"> + <property name="name"> + <cstring>m_btnImmediate</cstring> + </property> + <property name="focusPolicy"> + <enum>NoFocus</enum> + </property> + <property name="text"> + <string>Terminate Now</string> + </property> + </widget> + <widget class="TQRadioButton" row="2" column="0"> + <property name="name"> + <cstring>m_btnDelayed</cstring> + </property> + <property name="focusPolicy"> + <enum>NoFocus</enum> + </property> + <property name="text"> + <string>Terminate After</string> + </property> + </widget> + <widget class="TQLayoutWidget" row="2" column="1"> + <grid> + <property name="name"> + <cstring>unnamed</cstring> + </property> + <widget class="KIntNumInput" row="0" column="1"> + <property name="name"> + <cstring>terminateMinutes</cstring> + </property> + </widget> + <widget class="TQLabel" row="0" column="2"> + <property name="name"> + <cstring>unnamed</cstring> + </property> + <property name="text"> + <string>minutes</string> + </property> + </widget> + </grid> + </widget> + </grid> + </widget> + </grid> +</widget> +<layoutdefaults spacing="3" margin="6"/> +<layoutfunctions spacing="KDialog::spacingHint" margin="KDialog::marginHint"/> +</UI> diff --git a/lib/libtqtrla/src/tqtrla.cpp b/lib/libtqtrla/src/tqtrla.cpp index 34b78d0..4434a3d 100644 --- a/lib/libtqtrla/src/tqtrla.cpp +++ b/lib/libtqtrla/src/tqtrla.cpp @@ -504,5 +504,97 @@ TQDataStream &operator>>( TQDataStream &s, SensorType &st ) s >> st.nominalinterval; return s; } + +/*! + \relates TerminalServiceStatusType + + Writes the TerminalServiceStatusType \a str to the stream \a s. + + See also \link datastreamformat.html Format of the TQDataStream operators \endlink +*/ + +TQDataStream &operator<<( TQDataStream &s, const TerminalServiceStatusType &st ) +{ + s << st.protocolVersion; + s << st.sessionID; + s << st.username; + s << st.serverName; + s << st.serverPID; + s << st.wmPID; + s << st.state; + s << st.display; + s << st.loginStamp; + s << st.activityStamp; + return s; +} + +/*! + \relates SensorType + + Reads a SensorType from the stream \a s into SensorType \a str. + + See also \link datastreamformat.html Format of the TQDataStream operators \endlink +*/ + +TQDataStream &operator>>( TQDataStream &s, TerminalServiceStatusType &st ) +{ + s >> st.protocolVersion; + s >> st.sessionID; + s >> st.username; + s >> st.serverName; + s >> st.serverPID; + s >> st.wmPID; + s >> st.state; + s >> st.display; + s >> st.loginStamp; + s >> st.activityStamp; + return s; +} + +/*! + \relates WorkspaceServiceStatusType + + Writes the WorkspaceServiceStatusType \a str to the stream \a s. + + See also \link datastreamformat.html Format of the TQDataStream operators \endlink +*/ + +TQDataStream &operator<<( TQDataStream &s, const WorkspaceServiceStatusType &st ) +{ + s << st.protocolVersion; + s << st.sessionID; + s << st.stationID; + s << st.username; + s << st.realmname; + s << st.serverID; + s << st.serviceID; + s << st.stationName; + s << st.loginStamp; + s << st.terminateStamp; + return s; +} + +/*! + \relates SensorType + + Reads a SensorType from the stream \a s into SensorType \a str. + + See also \link datastreamformat.html Format of the TQDataStream operators \endlink +*/ + +TQDataStream &operator>>( TQDataStream &s, WorkspaceServiceStatusType &st ) +{ + s >> st.protocolVersion; + s >> st.sessionID; + s >> st.stationID; + s >> st.username; + s >> st.realmname; + s >> st.serverID; + s >> st.serviceID; + s >> st.stationName; + s >> st.loginStamp; + s >> st.terminateStamp; + return s; +} #endif // QT_NO_DATASTREAM diff --git a/lib/libtqtrla/src/tqtrla.h b/lib/libtqtrla/src/tqtrla.h index ad6eef2..64a8ef5 100644 --- a/lib/libtqtrla/src/tqtrla.h +++ b/lib/libtqtrla/src/tqtrla.h @@ -24,6 +24,7 @@ #include <tqobject.h> #include <tqptrlist.h> #include <tqtimer.h> +#include <tqdatetime.h> #include <kaction.h> @@ -190,4 +191,52 @@ typedef TQValueList<SensorType> SensorList; // ============================================================================= +class TerminalServiceStatusType +{ + public: + TQ_UINT32 protocolVersion; + TQ_INT32 sessionID; + TQString username; + TQString serverName; + TQ_INT32 serverPID; + TQ_INT32 wmPID; + TQ_INT32 state; + TQ_INT32 display; + TQDateTime loginStamp; + TQDateTime activityStamp; +}; + +#ifndef QT_NO_DATASTREAM +Q_EXPORT TQDataStream &operator<<(TQDataStream &, const TerminalServiceStatusType &); +Q_EXPORT TQDataStream &operator>>(TQDataStream &, TerminalServiceStatusType &); +#endif + +typedef TQValueList<TerminalServiceStatusType> TerminalServiceStatusList; + +// ============================================================================= + +class WorkspaceServiceStatusType +{ + public: + TQ_UINT32 protocolVersion; + TQ_INT32 sessionID; + TQ_INT32 stationID; + TQString username; + TQString realmname; + TQ_INT32 serverID; + TQ_INT32 serviceID; + TQString stationName; + TQDateTime loginStamp; + TQDateTime terminateStamp; +}; + +#ifndef QT_NO_DATASTREAM +Q_EXPORT TQDataStream &operator<<(TQDataStream &, const WorkspaceServiceStatusType &); +Q_EXPORT TQDataStream &operator>>(TQDataStream &, WorkspaceServiceStatusType &); +#endif + +typedef TQValueList<WorkspaceServiceStatusType> WorkspaceServiceStatusList; + +// ============================================================================= + #endif // TQTRLA_H
\ No newline at end of file diff --git a/servers/admin_sys_ctl_server_lin/src/admin_sys_ctl.cpp b/servers/admin_sys_ctl_server_lin/src/admin_sys_ctl.cpp index f0cf958..7418de1 100644 --- a/servers/admin_sys_ctl_server_lin/src/admin_sys_ctl.cpp +++ b/servers/admin_sys_ctl_server_lin/src/admin_sys_ctl.cpp @@ -137,7 +137,7 @@ void SysCtlSocket::finishKerberosHandshake() { masterRealm = "(NULL)"; } if ((m_authenticatedUserName != masterUser) || (m_authenticatedRealmName != masterRealm)) { - printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), masterUser.ascii(), masterRealm.ascii()); + printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), m_authenticatedUserName.ascii(), m_authenticatedRealmName.ascii()); close(); return; } @@ -182,48 +182,56 @@ void SysCtlSocket::commandLoop() { if (subCommand == "TERMINALS") { clearFrameTail(); ds << TQString("OK"); - writeEndOfFrame(); + TerminalServiceStatusList list; TQSqlCursor databaseActivityCursor("sessions", TRUE, m_terminals_database); databaseActivityCursor.select(); while (databaseActivityCursor.next()) { - TQ_UINT32 protocolVersion = 1; - TQDateTime loginStamp; - TQDateTime activityStamp; - loginStamp.setTime_t(databaseActivityCursor.value("stamp_start").toInt()); - activityStamp.setTime_t(databaseActivityCursor.value("stamp_statechange").toInt()); - - ds << protocolVersion; - ds << databaseActivityCursor.value("pk").toInt(); - ds << databaseActivityCursor.value("username").toString(); - ds << databaseActivityCursor.value("servername").toString(); - ds << databaseActivityCursor.value("server_pid").toInt(); - ds << databaseActivityCursor.value("wm_pid").toInt(); - ds << databaseActivityCursor.value("state").toInt(); - ds << databaseActivityCursor.value("display").toInt(); - ds << loginStamp; - ds << activityStamp; + TerminalServiceStatusType status; + + status.protocolVersion = 1; + status.sessionID = databaseActivityCursor.value("pk").toInt(); + status.username = databaseActivityCursor.value("username").toString(); + status.serverName = databaseActivityCursor.value("servername").toString(); + status.serverPID = databaseActivityCursor.value("server_pid").toInt(); + status.wmPID = databaseActivityCursor.value("wm_pid").toInt(); + status.state = databaseActivityCursor.value("state").toInt(); + status.display = databaseActivityCursor.value("display").toInt(); + status.loginStamp.setTime_t(databaseActivityCursor.value("stamp_start").toLongLong()); + status.activityStamp.setTime_t(databaseActivityCursor.value("stamp_statechange").toLongLong()); + + list.append(status); } + ds << list; writeEndOfFrame(); } else if (subCommand == "WORKSPACES") { clearFrameTail(); ds << TQString("OK"); - writeEndOfFrame(); + WorkspaceServiceStatusList list; TQSqlCursor databaseActivityCursor("activity", TRUE, m_workspaces_database); databaseActivityCursor.select(); while (databaseActivityCursor.next()) { - TQ_UINT32 protocolVersion = 1; - TQDateTime loginStamp; - loginStamp.setTime_t(databaseActivityCursor.value("logontime").toInt()); - - ds << protocolVersion; - ds << databaseActivityCursor.value("pk").toInt(); - ds << databaseActivityCursor.value("station").toInt(); - ds << databaseActivityCursor.value("username").toString(); - ds << databaseActivityCursor.value("realmname").toString(); - ds << databaseActivityCursor.value("serverid").toInt(); - ds << loginStamp; + WorkspaceServiceStatusType status; + + status.protocolVersion = 1; + status.sessionID = databaseActivityCursor.value("pk").toInt(); + status.stationID = databaseActivityCursor.value("station").toInt(); + status.username = databaseActivityCursor.value("username").toString(); + status.realmname = databaseActivityCursor.value("realmname").toString(); + status.serverID = databaseActivityCursor.value("serverid").toInt(); + status.serviceID = databaseActivityCursor.value("serviceid").toInt(); + status.stationID = databaseActivityCursor.value("station").toInt(); + TQSqlCursor databaseStationsCursor("stations", TRUE, m_workspaces_database); + databaseStationsCursor.select(TQString("pk=%1").arg(status.stationID)); + if (databaseStationsCursor.next()) { + status.stationName = databaseStationsCursor.value("name").toString(); + } + status.loginStamp.setTime_t(databaseActivityCursor.value("logontime").toLongLong()); + status.terminateStamp.setTime_t(databaseActivityCursor.value("terminate").toLongLong()); + + list.append(status); } + ds << list; writeEndOfFrame(); } else { @@ -281,19 +289,40 @@ void SysCtlSocket::commandLoop() { writeEndOfFrame(); } else if (subCommand == "KILL_WORKSPACE") { + TQ_INT32 terminationOffset; + ds >> terminationOffset; clearFrameTail(); + TQDateTime terminationTime = TQDateTime::currentDateTime(); + terminationTime = terminationTime.addSecs(terminationOffset*60); TQSqlCursor databaseActivityCursor("activity", TRUE, m_workspaces_database); databaseActivityCursor.select(TQString("pk=%1").arg(sessionID)); if (databaseActivityCursor.next()) { - databaseActivityCursor.select(TQString("pk=%1").arg(sessionID)); - if (databaseActivityCursor.next()) { - TQSqlRecord *buffer = databaseActivityCursor.primeUpdate(); - buffer->setValue("terminate", true); - databaseActivityCursor.update(); + TQSqlRecord *buffer = databaseActivityCursor.primeUpdate(); + if (terminationOffset > -2) { + buffer->setValue("terminate", terminationTime.toTime_t()); + } + else { + buffer->setValue("terminate", 0); } + databaseActivityCursor.update(); + + ds << TQString("OK"); + } + else { + ds << TQString("ERRINVCMD"); + } + writeEndOfFrame(); + } + else if (subCommand == "CANCEL_KILL_WORKSPACE") { + clearFrameTail(); + TQSqlCursor databaseActivityCursor("activity", TRUE, m_workspaces_database); + databaseActivityCursor.select(TQString("pk=%1").arg(sessionID)); + if (databaseActivityCursor.next()) { + TQSqlRecord *buffer = databaseActivityCursor.primeUpdate(); + buffer->setValue("terminate", 0); + databaseActivityCursor.update(); ds << TQString("OK"); - writeEndOfFrame(); } else { ds << TQString("ERRINVCMD"); diff --git a/servers/admin_sys_ctl_server_lin/src/main.cpp b/servers/admin_sys_ctl_server_lin/src/main.cpp index 5d793eb..aa2a661 100644 --- a/servers/admin_sys_ctl_server_lin/src/main.cpp +++ b/servers/admin_sys_ctl_server_lin/src/main.cpp @@ -56,7 +56,7 @@ int main(int argc, char *argv[]) KStartupInfo::appStarted(); - KSimpleConfig config(TQDir::currentDirPath() + "/remotefpga_adminsysctlserver.conf", false); + KSimpleConfig config("remotefpga_adminsysctlserver.conf", false); config.setGroup("Server"); SysCtlServer fpgasvr(0, config.readNumEntry("port", 4015), &config); return app.exec(); diff --git a/servers/fpga_programming_server_lin/src/fpga_conn.cpp b/servers/fpga_programming_server_lin/src/fpga_conn.cpp index 406c76c..cd8ed0b 100644 --- a/servers/fpga_programming_server_lin/src/fpga_conn.cpp +++ b/servers/fpga_programming_server_lin/src/fpga_conn.cpp @@ -139,7 +139,7 @@ void FPGASocket::finishKerberosHandshake() { masterRealm = "(NULL)"; } if ((m_authenticatedUserName != masterUser) || (m_authenticatedRealmName != masterRealm)) { - printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), masterUser.ascii(), masterRealm.ascii()); + printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), m_authenticatedUserName.ascii(), m_authenticatedRealmName.ascii()); close(); return; } diff --git a/servers/fpga_server_lin/src/fpga_conn.cpp b/servers/fpga_server_lin/src/fpga_conn.cpp index 2fc2537..ea5c477 100644 --- a/servers/fpga_server_lin/src/fpga_conn.cpp +++ b/servers/fpga_server_lin/src/fpga_conn.cpp @@ -118,7 +118,7 @@ void FPGASocket::finishKerberosHandshake() { masterRealm = "(NULL)"; } if ((m_authenticatedUserName != masterUser) || (m_authenticatedRealmName != masterRealm)) { - printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), masterUser.ascii(), masterRealm.ascii()); + printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), m_authenticatedUserName.ascii(), m_authenticatedRealmName.ascii()); close(); return; } diff --git a/servers/gpib_server_lin/src/gpib_conn.cpp b/servers/gpib_server_lin/src/gpib_conn.cpp index 6f20316..34e5300 100644 --- a/servers/gpib_server_lin/src/gpib_conn.cpp +++ b/servers/gpib_server_lin/src/gpib_conn.cpp @@ -137,7 +137,7 @@ void GPIBSocket::finishKerberosHandshake() { masterRealm = "(NULL)"; } if ((m_authenticatedUserName != masterUser) || (m_authenticatedRealmName != masterRealm)) { - printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), masterUser.ascii(), masterRealm.ascii()); + printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), m_authenticatedUserName.ascii(), m_authenticatedRealmName.ascii()); close(); return; } diff --git a/servers/sensor_monitor_server_lin/src/sensor_conn.cpp b/servers/sensor_monitor_server_lin/src/sensor_conn.cpp index 60a42c9..e9298db 100644 --- a/servers/sensor_monitor_server_lin/src/sensor_conn.cpp +++ b/servers/sensor_monitor_server_lin/src/sensor_conn.cpp @@ -147,7 +147,7 @@ void SensorSocket::finishKerberosHandshake() { masterRealm = "(NULL)"; } if ((m_authenticatedUserName != masterUser) || (m_authenticatedRealmName != masterRealm)) { - printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), masterUser.ascii(), masterRealm.ascii()); + printf("[DEBUG] Connection from %s closed due to authentication failure (attempted connection as user %s@%s)\n\r", m_remoteHost.ascii(), m_authenticatedUserName.ascii(), m_authenticatedRealmName.ascii()); close(); return; } |