Fix running of GRAPH module
[vlp.git] / src / kernel / kernel.cpp
index c943c48930500408c4d83df06927a861b9ead1e4..72900280de4a2c02d0ad207e5452def81c26658d 100644 (file)
 #include <X11/Xlib.h>
 
 #include "kernel.h"
-#include "ui/kernelwindow.h"
-#include "lock.h"
-#include "options.h"
-#include "kill_interpreter_dialog.h"
-#include "connect_dialog.h"
+#include "ui/KernelWindow.h"
+#include "ConnectDialog.h"
+#include "KillDialog.h"
+#include "LockDialog.h"
+#include "OptionsDialog.h"
+#include "MessageDialog.h"
 
 #include "vlp/config.h"
+#include "vlp/QtConfigurationFinder.h"
+#include "vlp/exception/ConfigFileNotFound.h"
 
+#include <sys/prctl.h>
 /* File resides in top directory (where are Makefiles)*/
 #include "../../config.h"
 
 
+namespace loglan {
+namespace vlp {
+
 char CharLine[25] = "________________________";
 
 /**
@@ -121,12 +128,6 @@ QKernel::QKernel(int argc, char **argv)
 {
        setupUi(this);
 
-       QString arg0(argv[0]);
-       arg0 += "/";
-       homeDir = QDir(arg0);
-       homeDir.cdUp();
-
-       
        int i;
        for(i = 0; (i < 5) && (i < argc-1); i++) {
                strcpy(myargs[i], "");
@@ -135,6 +136,9 @@ QKernel::QKernel(int argc, char **argv)
                }
        }
 
+       loglan::vlp::QtConfigurationFinder configFinder;
+       configFinder.initSearchDirs();
+
        QDir q(getRemoteDir());
 
        if (!q.exists()) {
@@ -153,7 +157,7 @@ QKernel::QKernel(int argc, char **argv)
        ActiveConnections = 0;
        strcpy(LockPasswd, "");
 
-       loadConfig(getConfigFilePath());
+       loadConfig(configFinder.findConfig().c_str());
 
        RunNetModule();
 
@@ -210,6 +214,8 @@ void QKernel::loadConfig(const char * fname)
                }
 
                strncpy(progdir, config.getProgramDir(), 256);
+
+               homeDir = QDir(QCoreApplication::applicationDirPath());
        }
 }
 
@@ -240,9 +246,11 @@ void QKernel::on_actionEditor_triggered()
        QString program = getHomeDir();
        program += "/modules/logedit";
 
+       fprintf(stderr, "Run EDIT Module: %s, %s\n", program.toStdString().c_str(), getHomeDir());
        pid_t pid = fork();
        if (pid == 0) {
                if (execl(program.toStdString().c_str(),
+                       "logedit",
                        getHomeDir(),
                        myargs[0],
                        myargs[1],
@@ -274,9 +282,12 @@ void QKernel::on_actionHelp_triggered()
        QString docDir = getHomeDir();
        docDir += "/doc";
 
+       fprintf(stderr, "Run HELP Module: %s, %s\n", program.toStdString().c_str(), docDir.toStdString().c_str());
+
        pid_t pid = fork();
        if (pid == 0) {
                if (execl(program.toStdString().c_str(),
+                       "loghelp",
                        docDir.toStdString().c_str(),
                        myargs[0],
                        myargs[1],
@@ -306,10 +317,12 @@ void QKernel::RunGraphModule(char *sk)
        QString program = getHomeDir();
        program += "/modules/loggraph";
 
+       fprintf(stderr, "Run GRAPH Module: %s, %s\n", program.toStdString().c_str(), sk);
+
        pid_t pid = fork();
        if (pid == 0) {
                if (execl(program.toStdString().c_str(),
-                       program.toStdString().c_str(),
+                       "loggraph",
                        sk,
                        myargs[0],
                        myargs[1],
@@ -339,6 +352,7 @@ void QKernel::RunGraphModule(char *sk)
  */
 void QKernel::RunNetModule()
 {
+
        struct sockaddr_un svr;
        int len;
        int on;
@@ -347,10 +361,11 @@ void QKernel::RunNetModule()
        QString program = getHomeDir();
        program += "/modules/lognet";
 
+       fprintf(stderr, "Run NET Module: %s, %s %s\n", program.toStdString().c_str(), getNetModuleSocket(), getConfigFilePath().toStdString().c_str());
        pid_t pid = fork();
        if (pid == 0) {
                if (execl(program.toStdString().c_str(),
-                       program.toStdString().c_str(),
+                       "lognet",
                        getNetModuleSocket(),
                        getConfigFilePath().toStdString().c_str(),
                        myargs[0],
@@ -408,8 +423,7 @@ void QKernel::on_actionConnect_triggered()
 {
        MESSAGE m;
 
-       ConnectDialog dialog(this);
-       dialog.setWindowTitle("IP Address:");
+       dialog::ConnectDialog dialog(this);
 
        if (dialog.exec()) {
                m.msg_type = MSG_NET;
@@ -471,48 +485,17 @@ void QKernel::on_actionQuit_triggered()
  */
 void QKernel::on_actionMessage_triggered()
 {
-       QDialog *dlg;
-       QLineEdit *nodenr;
+       dialog::MessageDialog dialog(this);
        MESSAGE m;
 
-       dlg = new QDialog(this, Qt::Dialog);
-       dlg->setWindowTitle("Send message to node");
-
-       nodenr = new QLineEdit("number", dlg);
-       nodenr->setGeometry(90, 10, 50, 30);
-       nodenr->setText("");
-
-       QLabel *tmpQLabel;
-       tmpQLabel = new QLabel("Node number:", dlg);
-       tmpQLabel->setGeometry(10, 10, 77, 30);
-
-       tmpQLabel = new QLabel("Message:", dlg);
-       tmpQLabel->setGeometry(10, 50, 70, 30);
-
-       QLineEdit *msg;
-       msg = new QLineEdit("", dlg);
-       msg->setGeometry(80, 60, 330, 30);
-
-       QPushButton *ob;
-       ob = new QPushButton("Send", dlg);
-       ob->setGeometry(230, 10, 80, 30);
-       ob->setDefault(TRUE);
-       
-       QPushButton *cb;
-       cb = new QPushButton("Cancel", dlg);
-       cb->setGeometry(330, 10, 80, 30);
-       dlg->resize(430, 110);
-       connect(ob, SIGNAL(clicked()), dlg, SLOT(accept()));
-       connect(cb, SIGNAL(clicked()), dlg, SLOT(reject()));
-
-       if (dlg->exec()) {
+       if (dialog.exec()) {
                m.msg_type = MSG_NET;
                m.param.pword[0] = NET_PROPAGATE;
                m.param.pword[1] = MSG_VLP;
                m.param.pword[2] = NodeNumber;
-               m.param.pword[4] = atoi(nodenr->text().toAscii().data());
+               m.param.pword[4] = dialog.getNodeNumber();
                m.param.pword[6] = VLP_WRITE;
-               strcpy(m.param.pstr, msg->text().toAscii().data());
+               strcpy(m.param.pstr, dialog.getMessage().toStdString().c_str());
                write(net_sock, &m, sizeof(MESSAGE));
        }
 }
@@ -524,8 +507,7 @@ void QKernel::on_actionMessage_triggered()
  */
 void QKernel::on_actionKill_triggered()
 {
-       KillInterpreterDialog dialog(this);
-       dialog.setWindowTitle("Kill interpreter");
+       dialog::KillInterpreterDialog dialog(this);
 
        if (dialog.exec()) {
                MESSAGE m;
@@ -551,6 +533,8 @@ void QKernel::on_actionKill_triggered()
 
 /**
  * Sends message to the net module.
+ *
+ * \todo method needs to be refactored
  */
 void QKernel::NetMessage()
 {
@@ -581,17 +565,17 @@ void QKernel::NetMessage()
                                case VLP_WRITE:
                                        QApplication::beep();
                                        WriteMessage(CharLine);
-                                       WriteMessage(
-                                               "### Incoming Messsage ###");
-                                       sprintf(ss, "Mesg from Node %d: %s",
-                                                       msg.param.pword[2],
-                                                       msg.param.pstr);
+                                       WriteMessage("### Incoming Messsage ###");
+                                       sprintf(ss,
+                                               "Mesg from Node %d: %s",
+                                               msg.param.pword[2],
+                                               msg.param.pstr
+                                       );
                                        WriteMessage(ss);
                                        WriteMessage(CharLine);
                                        break;
                                case VLP_REMOTE_INSTANCE:
-                                       sprintf(ss, "%s/%s", getRemoteDir(),
-                                                               msg.param.pstr);
+                                       sprintf(ss, "%s/%s", getRemoteDir(), msg.param.pstr);
 
                                        if (info_messages) { 
                                                WriteMessage("Running program:");
@@ -676,6 +660,7 @@ void QKernel::IntMessage(int sock)
                switch (msg.msg_type) { 
                case MSG_GRAPH:
                        if (msg.param.pword[0] == GRAPH_ALLOCATE) {
+                               fprintf(stderr, "Running graph module with arg: %s\n", msg.param.pstr);
                                RunGraphModule(msg.param.pstr);
                        }
                        break;
@@ -692,8 +677,6 @@ void QKernel::IntMessage(int sock)
                case MSG_INT:
                        switch(msg.param.pword[0]) {
                        case INT_EXITING:
-                               char ss[255];
-
                                MESSAGE m;
                                m.msg_type = MSG_VLP;
                                m.param.pword[0] = VLP_INTERPRETER_DOWN;
@@ -708,6 +691,7 @@ void QKernel::IntMessage(int sock)
                                delete e;
 
                                if (info_messages) {
+                                       char ss[255];
                                        sprintf(ss, "%s : End of program "
                                                "execution", msg.param.pstr);
                                        WriteMessage(ss);
@@ -780,7 +764,7 @@ void QKernel::on_actionInfo_messages_triggered()
  */
 void QKernel::on_actionOptions_triggered()
 {
-       OptionsDialog optionsDialog(getConfigFilePath(), this);
+       dialog::OptionsDialog optionsDialog(getConfigFilePath(), this);
        if (optionsDialog.exec()) {
                optionsDialog.saveConfig(getConfigFilePath());
 
@@ -795,7 +779,7 @@ void QKernel::on_actionOptions_triggered()
  */
 void QKernel::on_actionLock_console_triggered()
 {
-       LockDialog lockDialog(this);
+       dialog::LockDialog lockDialog(this);
 
        if (lockDialog.exec()) {
                QString password = lockDialog.getPassword();
@@ -829,7 +813,7 @@ void QKernel::on_actionLock_console_triggered()
  */
 void QKernel::on_actionUnlock_console_triggered()
 {
-       LockDialog lockDialog(this);
+       dialog::LockDialog lockDialog(this);
 
        if (lockDialog.exec()) {
                QString password = lockDialog.getPassword();
@@ -894,6 +878,7 @@ InterpEntry *QKernel::findINTbyID(int _id)
  */
 InterpEntry *QKernel::RunIntModule(char *ss, int r)
 {
+       fprintf(stderr, "Run INT Module: %s, %d\n", ss, r);
        char a[256], b[255];
        struct sockaddr_un svr;
        int len, sock, on;
@@ -940,7 +925,7 @@ InterpEntry *QKernel::RunIntModule(char *ss, int r)
        strcpy(newINT->shortname, b);
        strcpy(newINT->fullname, ss);
 
-       sprintf(a, "%s%d", IPATH, newint);
+       sprintf(a, "%s%d", homeDir.absoluteFilePath(IPATH).toStdString().c_str(), newint);
        sprintf(cmd, "%s/modules/logint %s %s",
                getHomeDir(),
                a,
@@ -948,9 +933,11 @@ InterpEntry *QKernel::RunIntModule(char *ss, int r)
        if (r) {
                strcat(cmd, " r");
        }
-       sprintf(b, " %s %s %s %s %s",
-               myargs[0], myargs[1], myargs[2], myargs[3], myargs[4]);
-       strcat(cmd, b);
+//     sprintf(b, " %s %s %s %s %s",
+//             myargs[0], myargs[1], myargs[2], myargs[3], myargs[4]);
+//     sprintf(cmd, "%s %s", cmd, b);
+//     strcat(cmd, b);
+       fprintf(stderr, "%s\n", cmd);
        strcat(cmd, " &");
 
        sock = socket(AF_UNIX, SOCK_STREAM, 0);
@@ -1110,6 +1097,9 @@ void QKernel::on_actionInfo_triggered()
        wait_for_info = TRUE;
 }
 
+}
+}
+
 /**
  * Program main function
  * All program arguments but the first one (argv[0]: program name) are saved and
@@ -1122,8 +1112,8 @@ int main(int argc, char **argv)
        XInitThreads();
 
        QApplication * app = new QApplication(argc, argv);
-       QKernel kernel(argc, argv);
+       loglan::vlp::QKernel kernel(argc, argv);
        kernel.show();
        
        return app->exec();
-}
+}
\ No newline at end of file