Merge pull request #223 from usdot-fhwa-OPS/218-fix-stale-data

Issue-218: Fix stale data

src/v2i-hub/TimPlugin/src/TimPlugin.cpp

@@ -25,29 +25,11 @@ namespace TimPlugin {
  */
 TimPlugin::TimPlugin(string name) :
 		PluginClient(name) {
-
-		// xml parser setup 
-	    std::lock_guard<mutex> lock(_cfgLock);
-
-		if (GetConfigValue<string>("MapFile", _mapFile))
-			_isMapFileNew = true;
-
-        GetConfigValue<string>("Start_Broadcast_Date", _startDate);
-        GetConfigValue<string>("Stop_Broadcast_Date", _stopDate);
-        GetConfigValue<string>("Start_Broadcast_Time", _startTime);
-        GetConfigValue<string>("Stop_Broadcast_Time", _stopTime);
-		GetConfigValue<string>("WebServiceIP",webip);
-		GetConfigValue<uint16_t>("WebServicePort",webport);
-
-		tmpTIM.open("/tmp/tmpTIM.xml", std::ofstream::out);	
-
-		std::thread webthread(&TimPlugin::StartWebService,this);
-		webthread.detach(); // wait for the thread to finish 
+
 }
 
 TimPlugin::~TimPlugin() {
 
-	tmpTIM.close();
 }
 
 void TimPlugin::TimRequestHandler(QHttpEngine::Socket *socket)
@@ -72,6 +54,8 @@ void TimPlugin::TimRequestHandler(QHttpEngine::Socket *socket)
 
 	// Catch XML parse exceptions 
 	try { 
+		// Using open command with std::ofstream::out mode overwrites existing files 
+		tmpTIM.open("/tmp/tmpTIM.xml", std::ofstream::out);
 		read_xml(ss,ptr);
 
 		lock_guard<mutex> lock(_cfgLock);
@@ -93,11 +77,14 @@ void TimPlugin::TimRequestHandler(QHttpEngine::Socket *socket)
 
 			if(labeltext == "timupdate"){
 				tmpTIM<<n.second.get_value<std::string>();
+
 				_mapFile = "/tmp/tmpTIM.xml";
 				_isMapFileNew = true;
 			}
 
 		}
+		// Close file each time to avoid appending to open file
+		tmpTIM.close();
 		writeResponse(QHttpEngine::Socket::Created, socket);
 	}
 	catch( const ptree_error &e ) {
@@ -159,18 +146,24 @@ void TimPlugin::UpdateConfigSettings() {
 
 	GetConfigValue<uint64_t>("Frequency", _frequency);
 
-
-	if (GetConfigValue<string>("MapFile", _mapFile))
-		_isMapFileNew = true;
-
+	if (GetConfigValue<string>("MapFile", _mapFile)) {
+		if ( boost::filesystem::exists( _mapFile ) ){
+            _isMapFileNew = true;
+			PLOG(logINFO) << "Loading MapFile " << _mapFile << "." << std::endl;
+        }
+		else {
+			PLOG(logWARNING) << "MapFile " << _mapFile << " does not exist!" << std::endl;
+		}
+
+	}
 
 	GetConfigValue<string>("Start_Broadcast_Date", _startDate);
 	GetConfigValue<string>("Stop_Broadcast_Date", _stopDate);
 	GetConfigValue<string>("Start_Broadcast_Time", _startTime);
 	GetConfigValue<string>("Stop_Broadcast_Time", _stopTime);
 	GetConfigValue<string>("WebServiceIP",webip);
 	GetConfigValue<uint16_t>("WebServicePort",webport);
-	
+
 }
 
 void TimPlugin::OnConfigChanged(const char *key, const char *value) {
@@ -184,6 +177,12 @@ void TimPlugin::OnStateChange(IvpPluginState state) {
 
 	if (state == IvpPluginState_registered) {
 		UpdateConfigSettings();
+
+		// Start webservice needs to occur after the first updateConfigSettings call
+		// to acquire port and ip configurations.
+		// Also needs to be called from Main thread to work.
+		std::thread webthread(&TimPlugin::StartWebService,this);
+		webthread.detach(); // wait for the thread to finish 
 	}
 }
 
@@ -278,6 +277,7 @@ int TimPlugin::Main() {
 
 	uint64_t lastSendTime = 0;
 	string mapFileCopy;
+
 	while (_plugin->state != IvpPluginState_error) {
 
 		while (TimDuration()) {

src/v2i-hub/TimPlugin/src/TimPlugin.h

@@ -63,6 +63,8 @@
 #include <qhttpengine/server.h>
 #include <qserverPedestrian/OAIApiRouter.h>
 #include <qserverPedestrian/OAIPSM.h>
+#include <boost/filesystem.hpp>
+
 
 
 
@@ -74,6 +76,7 @@ using namespace std;
 using namespace tmx;
 using namespace tmx::utils;
 using namespace tmx::messages;
+using namespace boost::filesystem;
 
 
 #define INPUTSREADY "Have Map/Spat/Veh"