MACScheduler.cc

	}
}

//
// _updateActiveList()
//
void MACScheduler::_updateActiveList()
{
	LOG_DEBUG("_updateActiveList()");

	GCFPValueArray	activeArr;

#ifndef DONT_COMPILE_OTDB_AND_PVSS_CODE
	// get new list (list is ordered on starttime)
	vector<OTDBtree> activeDBlist = itsOTDBconnection->getTreeGroup(2, 0, itsExclPLcluster);
	if (activeDBlist.empty()) {
		LOG_DEBUG ("No active OTDB Observations");
		// NOTE: do not exit routine on emptylist: we need to write an empty list to clear the DB
	}

	// walk through the list, prepare PVSS for the new obs, update own admin lists.
	int32			idx = activeDBlist.size() - 1;
	for ( ; idx >= 0; idx--)  {
		if (activeDBlist[idx].processType=="RESERVATION" || activeDBlist[idx].processType=="MAINTENANCE") {
			continue;
		}

		// construct name and timings info for observation
		string		obsName(observationName(activeDBlist[idx].treeID()));
		activeArr.push_back(new GCFPVString(obsName));

		// remove obs from planned-list if its still their.
		OLiter	prepIter = itsPreparedObs.find(activeDBlist[idx].treeID());
		if (prepIter != itsPreparedObs.end()) {
			itsPreparedObs.erase(prepIter);
		}
	} // for
#endif


	// get new list (list is/should_be ordered on starttime)
    Json::Value activeSubTasks = itsTMSSconnection->getActiveSubTasks();
	if (activeSubTasks.empty()) {
		LOG_DEBUG ("No active TMSS Observations");
		// NOTE: do not exit routine on emptylist: we need to write an empty list to clear the DB
	}

	// walk through the list, prepare PVSS for the new obs, update own admin lists.
	int32			idx2 = activeSubTasks.size() - 1;
	for ( ; idx2 >= 0; idx2--)  {
	    Json::Value subtask = activeSubTasks[idx2];

//		if (subtask.processType=="RESERVATION" || subtask.processType=="MAINTENANCE") {
//			continue;
//		}

        // get subtask_id from url. I know, ugly, needs to be in json itself.
        vector<string> tmp;
        string url(subtask["url"].asString());
        boost::split(tmp, url, [](char c){return c == '/';});
        int subtask_id = stoi(tmp[tmp.size()-2]);

		// construct name and timings info for observation
		string obsName(observationName(subtask_id));
		ptime  start_time = time_from_string(subtask["start_time"].asString().replace(10, 1, " "));
		ptime  modTime = time_from_string(subtask["updated_at"].asString().replace(10, 1, " "));

		activeArr.push_back(new GCFPVString(obsName));

		// remove obs from planned-list if its still in there.
		OLiter	prepIter = itsPreparedObs.find(subtask_id);
		if (prepIter != itsPreparedObs.end()) {
			itsPreparedObs.erase(prepIter);
		}
	} // for

#ifndef DONT_COMPILE_OTDB_AND_PVSS_CODE
	// Finally we can pass the list with active observations to PVSS.
	itsPropertySet->setValue(PN_MS_ACTIVE_OBSERVATIONS,	GCFPVDynArr(LPT_DYNSTRING, activeArr));
#endif

	itsNrActive = activeArr.size();

	// free used memory
	for (int i = activeArr.size()-1; i>=0; --i) {
		delete activeArr[i];
	}
}

//
// _updateFinishedList()
//
void MACScheduler::_updateFinishedList()
{
	LOG_DEBUG("_updateFinishedList()");

	GCFPValueArray	finishedArr;
	int32	freeSpace = MAX_CONCURRENT_OBSERVATIONS - itsNrPlanned - itsNrActive;

#ifndef DONT_COMPILE_OTDB_AND_PVSS_CODE
	// get new list (list is ordered on starttime)
	vector<OTDBtree> finishedDBlist = itsOTDBconnection->getTreeGroup(3, itsFinishedPeriod, itsExclPLcluster);
	if (finishedDBlist.empty()) {
		LOG_DEBUG ("No finishing OTDB Observations");
		// NOTE: do not exit routine on emptylist: we need to write an empty list to clear the DB
	}

	// walk through the list, prepare PVSS for the new obs, update own admin lists.
	// We must show the last part of the (optional) limited list.
	int32	idx       = finishedDBlist.size() - 1;
	int32	limit     = idx - (MIN2(MIN2(finishedDBlist.size(), itsMaxFinished), (uint32)freeSpace) - 1);
	for ( ; idx >= limit ; idx--)  {
		if (finishedDBlist[idx].processType=="RESERVATION" || finishedDBlist[idx].processType=="MAINTENANCE") {
			continue;
		}

		// construct name and timings info for observation
		string		obsName(observationName(finishedDBlist[idx].treeID()));
		finishedArr.push_back(new GCFPVString(obsName));
	} // for

	// Finally we can pass the list with finished observations to PVSS.
	itsPropertySet->setValue(PN_MS_FINISHED_OBSERVATIONS, GCFPVDynArr(LPT_DYNSTRING, finishedArr));

	// free used memory
	for (int i = finishedArr.size()-1; i>=0; --i) {
		delete finishedArr[i];
	}
#endif

    //reset for TMSS
	finishedArr = GCFPValueArray();
	freeSpace = MAX_CONCURRENT_OBSERVATIONS - itsNrPlanned - itsNrActive;

	// get new list (list is/should_be ordered on starttime)
    Json::Value finishingSubTasks = itsTMSSconnection->getFinishingSubTasks();
	if (finishingSubTasks.empty()) {
		LOG_DEBUG ("No finishing TMSS Observations");
		// NOTE: do not exit routine on emptylist: we need to write an empty list to clear the DB
	}

	// walk through the list, prepare PVSS for the new obs, update own admin lists.
	// We must show the last part of the (optional) limited list.
	int32	idx2       = finishingSubTasks.size() - 1;
	int32	limit2     = idx2 - (MIN2(MIN2(finishingSubTasks.size(), itsMaxFinished), (uint32)freeSpace) - 1);
	for ( ; idx2 >= limit2 ; idx2--)  {
	    Json::Value subtask = finishingSubTasks[idx2];

//		if (subtask.processType=="RESERVATION" || subtask.processType=="MAINTENANCE") {
//			continue;
//		}

        // get subtask_id from url. I know, ugly, needs to be in json itself.
        vector<string> tmp;
        string url(subtask["url"].asString());
        boost::split(tmp, url, [](char c){return c == '/';});
        int subtask_id = stoi(tmp[tmp.size()-2]);

		// construct name  info for observation
		string obsName(observationName(subtask_id));
		finishedArr.push_back(new GCFPVString(obsName));
	} // for

	// Finally we can pass the list with finished observations to PVSS.
#ifndef DONT_COMPILE_OTDB_AND_PVSS_CODE
	itsPropertySet->setValue(PN_MS_FINISHED_OBSERVATIONS, GCFPVDynArr(LPT_DYNSTRING, finishedArr));
#endif

	// free used memory
	for (int i = finishedArr.size()-1; i>=0; --i) {
		delete finishedArr[i];
	}
}

//
// _setParsetOnMsgBus(parsetFile)
//
void MACScheduler::_setParsetOnMsgBus(const string&	filename) const
{
	// open file
	ParameterSet	obsSpecs(filename);
	string			obsPrefix = obsSpecs.fullModuleName("Observation");
	string			momID = obsSpecs.getString(obsPrefix + ".momID");
	string			sasID = obsSpecs.getString(obsPrefix + ".otdbID");

    //                      from, forUser, summary, protocol, protocolVersion, momID, sasID
	TaskSpecificationSystem	outMsg("LOFAR.MACScheduler", "", "", momID, sasID, obsSpecs);
#ifndef DONT_COMPILE_OTDB_AND_PVSS_CODE
	itsMsgQueue->send(outMsg);
#endif
}

//
// _connectedHandler(port)
//
void MACScheduler::_connectedHandler(GCFPortInterface& /*port*/)
{
}

//
// _disconnectedHandler(port)
//
void MACScheduler::_disconnectedHandler(GCFPortInterface& port)
{
	port.close();
}


};
};