diff --git a/src/server/EventWatcher.cpp b/src/server/EventWatcher.cpp index 1134a8f..8c77b10 100644 --- a/src/server/EventWatcher.cpp +++ b/src/server/EventWatcher.cpp @@ -159,6 +159,7 @@ void EventWatcher::CheckLogFiles(){ void EventWatcher::ReadLPLogFile(){ //Open/Read any new info in the file QFile LPlogfile(LPLOG); + if( !LPlogfile.exists() ){ return; } if( !LPlogfile.open(QIODevice::ReadOnly) ){ return; } //could not open file QTextStream STREAM(&LPlogfile); qint64 LPlog_pos = CONFIG->value("internal/"+QString(WS_MODE ? "ws" : "tcp")+"/lp-log-pos",0).toLongLong(); @@ -259,7 +260,8 @@ void EventWatcher::ReadLPRepFile(){ QString repTotK = CONFIG->value("internal/"+QString(WS_MODE ? "ws" : "tcp")+"/lp-rep-totk","").toString(); QString lastSize = CONFIG->value("internal/"+QString(WS_MODE ? "ws" : "tcp")+"/lp-rep-lastsize","").toString(); //Open/Read any new info in the file - QFile LPlogfile(LPLOG); + QFile LPlogfile(tmpLPRepFile); + if( !LPlogfile.exists() ){ return; } if( !LPlogfile.open(QIODevice::ReadOnly) ){ return; } //could not open file QTextStream STREAM(&LPlogfile); qint64 LPrep_pos = CONFIG->value("internal/"+QString(WS_MODE ? "ws" : "tcp")+"/lp-rep-pos",0).toLongLong(); diff --git a/src/server/main.cpp b/src/server/main.cpp index aefd466..8f4456e 100644 --- a/src/server/main.cpp +++ b/src/server/main.cpp @@ -37,18 +37,17 @@ void MessageOutput(QtMsgType type, const QMessageLogContext &context, const QStr break; case QtWarningMsg: txt = QString("WARNING: %1").arg(msg); - txt += "\n Context: "+QString(context.file)+" Line: "+QString(context.line)+" Function: "+QString(context.function); break; case QtCriticalMsg: txt = QString("CRITICAL: %1").arg(msg); - txt += "\n Context: "+QString(context.file)+" Line: "+QString(context.line)+" Function: "+QString(context.function); break; case QtFatalMsg: txt = QString("FATAL: %1").arg(msg); - txt += "\n Context: "+QString(context.file)+" Line: "+QString(context.line)+" Function: "+QString(context.function); break; } - + if( type!=QtDebugMsg && !QString(context.file).isEmpty() ){ + txt += "\n Context: "+QString(context.file)+" Line: "+QString(context.line)+" Function: "+QString(context.function); + } QTextStream out(&logfile); out << txt; if(!txt.endsWith("\n")){ out << "\n"; } @@ -79,7 +78,6 @@ qDebug() << " \"bridge_export_key [file]\": Export the public SSL key the serve int main( int argc, char ** argv ) { - //Check whether running as root if( getuid() != 0){ qDebug() << "sysadm-server must be started as root!"; @@ -121,7 +119,7 @@ int main( int argc, char ** argv ) QSslCertificate cert(&cfile); cfile.close(); if(!cert.isNull()){ - if(i+1sync(); //re-sync settings structure conf.clear(); //No config yet } //Load the settings from the config file // - port number if(port==0){ - if(websocket){ + if(websocket){ int index = conf.indexOf(QRegExp("PORT=*",Qt::CaseSensitive,QRegExp::Wildcard)); bool ok = false; if(index>=0){ port = conf[index].section("=",1,1).toInt(&ok); } @@ -213,7 +213,7 @@ int main( int argc, char ** argv ) int index = conf.indexOf(QRegExp("PORT_REST=*",Qt::CaseSensitive,QRegExp::Wildcard)); bool ok = false; if(index>=0){ port = conf[index].section("=",1,1).toInt(&ok); } - if(port<=0 || !ok){ port = PORTNUMBER; } + if(port<=0 || !ok){ port = PORTNUMBER; } } } // - Blacklist options @@ -238,7 +238,7 @@ int main( int argc, char ** argv ) rg = QRegExp("BRIDGE_CONNECTIONS_ONLY=*",Qt::CaseSensitive,QRegExp::Wildcard); if(!conf.filter(rg).isEmpty()){ BRIDGE_ONLY = conf.filter(rg).first().section("=",1,1).simplified().toLower()=="true"; - } + } //Setup the log file LogManager::checkLogDir(); //ensure the logging directory exists @@ -254,18 +254,17 @@ int main( int argc, char ** argv ) } logfile.open(QIODevice::WriteOnly | QIODevice::Append); qInstallMessageHandler(MessageOutput); - //Connect the background classes QObject::connect(DISPATCHER, SIGNAL(DispatchEvent(QJsonObject)), EVENTS, SLOT(DispatchEvent(QJsonObject)) ); QObject::connect(DISPATCHER, SIGNAL(DispatchStarting(QString)), EVENTS, SLOT(DispatchStarting(QString)) ); - + //Create the daemon - qDebug() << "Starting the PC-BSD sysadm server...." << (websocket ? "(WebSocket)" : "(TCP)"); - WebServer *w = new WebServer(); + qDebug() << "Starting the sysadm server...." << (websocket ? "(WebSocket)" : "(TCP)"); + WebServer *w = new WebServer(); //Start the daemon int ret = 1; //error return value if( w->startServer(port, websocket) ){ - qDebug() << " - Configuration File:" << CONFIG->fileName(); + //qDebug() << " - Configuration File:" << CONFIG->fileName(); QThread TBACK, TBACK2; EVENTS->moveToThread(&TBACK); DISPATCHER->moveToThread(&TBACK2); @@ -283,7 +282,7 @@ int main( int argc, char ** argv ) //Cleanup any globals delete CONFIG; logfile.close(); - + //Return return ret; }