Ryzom

uint32 humanReadableToBytes (const std::string &str);

/// Convert a time into a string that is easily readable by an human, for example 3600 -> "1h"

/// Get a bytes or time in string format and convert it in seconds or bytes

/// This function executes a program in the background and returns instantly (used for example to launch services in AES).

	 * daylight saving if applicable.

	 * This values is the same on all computer if computers are synchronized (with NTP for example).

	 */

	/** Return the number of second since midnight (00:00:00), January 1, 1970,

	 * coordinated universal time, according to the system clock.

	std::string Name;		// variable name

	int	 Update;			// delta time in second when we have to check variable

};

typedef void (*TRemoteClientCallback) (uint32 rid, const std::string &cmd, const std::string &entityNames);

	sint							getExitStatus () const { return _ExitStatus; }

	/// Returns the date of launch of the service. Unit: see CTime::getSecondsSince1970()

	/// Return true if this service don't use the NS (naming service)

	bool							getDontUseNS() const { return _DontUseNS; };

}

{

	static const char *divTable[] = { "s", "mn", "h", "d" };

	static uint  divCoef[]  = { 60, 60, 24 };

	uint div = 0;

	for(;;)

	{

		if(div > 2)

	return toString ("%u%s", res, divTable[div]);

}

{

	if (str.size() == 0)

		return 0;

	fromString(str, val);

	switch (str[str.size()-1])

	if (args.size() != 1)

		return false;

	fromString(args[0], seconds);

	log.displayNL("%s -> %s", args[0].c_str(), secondsToHumanReadable(seconds).c_str());

 * coordinated universal time, according to the system clock.

 * This values is the same on all computer if computers are synchronized (with NTP for example).

 */

{

}

/** Return the number of second since midnight (00:00:00), January 1, 1970,

	uint			NbWaiting;

	uint32			NbReceived;

	TServiceId			SId;

	TAdminViewResult Answers;

};

static void cleanRequest ()

{

	for (uint i = 0 ; i < Requests.size ();)

	{

void updateAdmin()

{

	//

	// Check graph updates

	//

	if (CurrentTime >= lastGraphUpdateCheck+1)

	{

	// Check alarms

	//

	if (CurrentTime >= lastAlarmsCheck+AlarmCheckDelay)

	{

	string UserExtended;	// extended data (for free use)

	uint32 InstanceId;		// the world instance in witch the user is awaited

	uint32 CharSlot;		// the expected character slot, any other will be denied

};

static list<CPendingUser> PendingUsers;

	// delete too old cookie

	list<CPendingUser>::iterator it = PendingUsers.begin();

	while (it != PendingUsers.end ())

	{

		if ((*it).Time < Time - TimeBeforeEraseCookie)

		TSockId			SockId;

		/// Time stamp of last message received/emitted

		CL3ServerRoute(IGatewayTransport *transport)

			if (_CallbackServer.get() != NULL)

				_CallbackServer->update2(100, 0);

			// check each connected client for keep alive

			TRouteMap::iterator first(_Routes.begin()), last(_Routes.end());

			for (; first != last; ++first)

		/// The Client callback

		mutable CCallbackClient		CallbackClient;

		/// Time stamp of last message received/emitted

		/// The last time we try to reconnect (in case of disconnection)

		// conn id

		uint32						ConnId;

			// delete any route pending

			deletePendingRoute();

			// update the client connection

			TClientRoutes::iterator first(_Routes.begin()), last(_Routes.end());

			for (; first != last; ++first)

//static CLog commandLog;

static string CompilationDate;

static uint32 NbUserUpdate = 0;

/*

 * Returns the date of launch of the service. Unit: see CTime::getSecondsSince1970()

 */

{

	return LaunchingDate;

}

//

// Namespaces

//

using namespace std;

using namespace NLMISC;

using namespace NLNET;

	uint			NbWaiting;

	uint32			NbReceived;

	TServiceId		SId;

	TAdminViewResult Answers;

};

	uint32			PId;			/// process Id used to kill the application

	bool			Relaunch;		/// if true, it means that the admin want to close and relaunch the service

	vector<uint32>	WaitingRequestId;		/// contains all request that the server hasn't reply yet

vector<string> RegisteredServices;

vector<string> AllAdminAlarms;	// contains *all* alarms

// Global Variables (scalars)

//

//

{

	char *text;

	NLMISC_CONVERT_VARGS(text, format, 4096);

	CMessage msgout("ADMIN_EMAIL");

	string str = text;

	msgout.serial(str);

	// make sure the alias, command, etc were setup ok

	if (!ok) return false;

	nlinfo("Starting the service alias '%s'", alias.c_str());

	bool dontLaunchServicesDirectly= IService::getInstance()->ConfigFile.exists("DontLaunchServicesDirectly")? IService::getInstance()->ConfigFile.getVar("DontLaunchServicesDirectly").asBool(): false;

	if (!dontLaunchServicesDirectly)

		// give the service alias to the service to forward it back when it will connected to the aes.

		arg += " -N";

		arg += alias;

		// set the path for running

		arg += " -A";

		arg += path;

		// suppress output to stdout

		#ifdef NL_OS_WINDOWS

			arg += " >NUL:";

		// launch the service

		bool res = launchProgram(command, arg);

		// if launching ok, leave 1 second to the new launching service before lauching next one

		if (res)

			nlSleep(1000);

		return res;

	}

	else

void checkWaitingServices()

{

	for(uint i = 0; i < WaitingToLaunchServices.size(); )

	{

static void checkPingPong()

{

	bool allPonged = true;

	bool haveService = false;

	for(uint i = 0; i < Services.size(); i++)

	{

		if(Services[i].Ready)

			Requests[i].NbReceived++;

			nldebug("REQUEST: ++ i %d rid %d NbWaiting %d NbReceived+ %d", i, Requests[i].Id, Requests[i].NbWaiting, Requests[i].NbReceived);

			return;

		}

	}

void cleanRequests()

{

	// just a debug check

	for (uint t = 0 ; t < Requests.size(); t++)

			}

		}

		nlinfo("REQUEST: Waiting request %d: NbRef %d NbWaiting %d NbReceived %d", Requests[t].Id, NbRef, NbWaiting, NbReceived);

		if (NbRef != NbWaiting - NbReceived)

		{

			nlwarning("REQUEST: **** i %d rid %d -> NbRef(%d) != NbWaiting(%d) - NbReceived(%d) ", t, Requests[t].Id, NbRef, NbWaiting, NbReceived);

			TAdminViewVarNames varNames;

			TAdminViewValues values;

			varNames.push_back("service");

			for (uint j = 0; j < Services.size(); j++)

			{

							else

								s = Services[j].AliasName;

							s += "-"+toString(Services[j].ServiceId);

							values.clear();

							values.push_back(s);

							aesAddRequestAnswer(Requests[i].Id, varNames, values);

					}

					InfoLog->displayRawNL("");

					InfoLog->displayRawNL("----------------------------------------------");

			}

			else

				CUnifiedNetwork::getInstance()->send(Requests[i].SId, msgout);

	// not found in alias, try with short name

	for (sit = Services.begin(); sit != Services.end(); sit++)

	{

		{

			services.push_back(sit);

		}

	serviceGetView(rid, viewStr, answer);

	aesAddRequestAnswer(rid, answer);

	nlinfo("REQUEST: Treated view myself directly: '%s'", viewStr.c_str());

void treatRequestForOfflineService(uint32 rid, const string& serviceName, const string& viewStr)

{

	TAdminViewVarNames varNames;

	TAdminViewValues values;

	// add default row

	varNames.push_back("service");

	values.push_back(serviceName);

	for (uint k = 0; k < subvarpath.Destination.size(); k++)

	{

		size_t pos = subvarpath.Destination[k].first.find("=");

	aesAddRequestAnswer(rid, varNames, values);

	nlinfo("REQUEST: Sent and received view '%s' to offline service '%s'", viewStr.c_str(), serviceName.c_str());

}

void addRequestForOnlineServices(uint32 rid, const string& viewStr)

{

	// add services that I manage

	// add myself

	treatRequestOneself(rid,viewStr);

void addRequestForAllServices(uint32 rid, const string& viewStr)

{

	// add all running services (and for oneself)

	addRequestForOnlineServices(rid,viewStr);

void addRequestForNamedService(uint32 rid, const string& service, const string& viewStr)

{

			}

		}

	}

void addRequest(uint32 rid, const string &rawvarpath, TServiceId sid)

{

		for (uint t = 0; t < vp.Destination.size(); t++)

		{

			string service = vp.Destination[t].first;

			if (service == "*")

			{

				addRequestForOnlineServices(rid,varpath.Destination[i].second);

	//

	msgin.serialCont(AllAdminAlarms);

	msgin.serialCont(AllGraphUpdates);

	// set our own alarms for this service

	setInformations(AllAdminAlarms, AllGraphUpdates);

{

	// receive an view answer from the service

	TServices::iterator sit = findService(sid);

	uint32 rid;

	msgin.serial(rid);

	{

		varNames.clear();

		values.clear();

		// adding default row

		uint32 i, nb;

		string var, val;

		msgin.serial(nb);

		for (i = 0; i < nb; i++)

		{

			msgin.serial(var);

			varNames.push_back(var);

		}

		msgin.serial(nb);

		for (i = 0; i < nb; i++)

		{

		answer.push_back(SAdminViewRow(varNames,values));

	}

	aesAddRequestAnswer(rid, answer);

	// remove the waiting request

	for (uint i = 0; i < (*sit).WaitingRequestId.size();)

	{

		if (i != 0) cmd += " ";

		cmd += args[i];

	}

	static uint32 requestId=0;

	addRequest(requestId++, cmd, TServiceId(0));

{

	if(args.size() <= 0)

		return false;

	string text;

	for (uint i =0; i < args.size(); i++)

	{

		text += args[i]+" ";

	}

	sendAdminEmail(text.c_str());

	return true;

}

{

	if(args.size() <= 0)

		return false;

	string cmd;

	for (uint i =0; i < args.size(); i++)

	{

		cmd += args[i]+" ";

	}

	string path;

#ifdef NL_OS_UNIX

	path = "/tmp/";

	string fn = path+CFile::findNewFile("aessys.tmp");

	string fne = path+CFile::findNewFile("aessyse.tmp");

	cmd += " >" + fn + " 2>" + fne;

	log.displayNL("Executing: '%s' in directory '%s'", cmd.c_str(), CPath::getCurrentPath().c_str());

	system(cmd.c_str());

	char str[1024];

	FILE *fp = fopen(fn.c_str(), "rt");

				break;

			log.displayRaw(res);

		}

		fclose(fp);

	}

	else

	{

		log.displayNL("No stdout");

	}

	fp = fopen(fne.c_str(), "rt");

	if (fp != NULL)

	{

				break;

			log.displayRaw(res);

		}

		fclose(fp);

	}

	else

		}

		else

			log.displayNL( "Task is not running" );

	return true;

}

	uint			NbWaiting;

	uint32			NbReceived;

	TSockId			From;

	uint32			NbRow;

	uint32			NbLines;

	for (aesit = AdminExecutorServices.begin(); aesit != AdminExecutorServices.end(); aesit++)

		if ((*aesit).SId == sid)

			break;

		if (asrt)

			nlassert (aesit != AdminExecutorServices.end());

		return aesit;

	for (aesit = AdminExecutorServices.begin(); aesit != AdminExecutorServices.end(); aesit++)

		if ((*aesit).Name == name)

			break;

		if (asrt)

			nlassert (aesit != AdminExecutorServices.end());

		return aesit;

}

	char *query;

	NLMISC_CONVERT_VARGS (query, format, 1024);

	if (DatabaseConnection == 0)

	{

		nlwarning ("MYSQL: mysql_query (%s) failed: DatabaseConnection is 0", query);

		return NULL;

	}

	int ret = mysql_query (DatabaseConnection, query);

	if (ret != 0)

	{

		nlwarning ("MYSQL: mysql_query () failed for query '%s': %s", query,  mysql_error(DatabaseConnection));

		return 0;

	}

	sqlCurrentQueryResult = mysql_store_result(DatabaseConnection);

	if (sqlCurrentQueryResult == 0)

	{

		nlwarning ("MYSQL: mysql_store_result () failed for query '%s': %s", query,  mysql_error(DatabaseConnection));

		return 0;

	}

	MYSQL_ROW row = mysql_fetch_row(sqlCurrentQueryResult);

	if (row == 0)

	{

		nlwarning ("MYSQL: mysql_fetch_row () failed for query '%s': %s", query,  mysql_error(DatabaseConnection));

	}

	nldebug ("MYSQL: sqlQuery(%s) returns %d rows", query, mysql_num_rows(sqlCurrentQueryResult));

}

MYSQL_ROW sqlNextRow ()

	if (sqlCurrentQueryResult == 0)

		return 0;

	return mysql_fetch_row(sqlCurrentQueryResult);

}

//

string Email;

void sendAdminAlert (const char *format, ...)

{

				{

					subject = "Multiple problems";

				}

				std::string from;

				if(IService::getInstance()->ConfigFile.exists("AdminEmailFrom"))

					from = IService::getInstance()->ConfigFile.getVar("AdminEmailFrom").asString();

		msgin.serial (service, var, val);

		AESIT aesit = findAES (sid);

		string shard, server;

		shard = (*aesit).Shard;

		server = (*aesit).Name;

		if (!shard.empty() && !server.empty() && !service.empty() && !var.empty())

		{

			string path = CPath::standardizePath (IService::getInstance()->ConfigFile.getVar("RRDVarPath").asString());

			string rrdfilename = path + shard+"."+server+"."+service+"."+var+".rrd";

			string arg;

			if (!NLMISC::CFile::fileExists(rrdfilename))

			{

				MYSQL_ROW row = sqlQuery ("select graph_update from variable where path like '%%%s' and graph_update!=0", var.c_str());

void cleanRequest ()

{

	bool timeout;

			{

				nlwarning ("REQUEST: Request %d timeouted, only %d on %d services have replied", Requests[i].Id, Requests[i].NbReceived, Requests[i].NbWaiting);

			}

			if (Requests[i].Log.empty())

			{

				if (Requests[i].NbRow == 0 && timeout)

	vector<string> informations;

	CMessage msgout("AES_INFO");

	//

	// send services that should be running on this AES

	//

	}

	sqlFlushResult();

	msgout.serialCont (informations);

	//

	// send graph update for services that should running on this AES

	//

	}

	sqlFlushResult();

	msgout.serialCont (informations);

	nlinfo ("Sending all informations about %s AES-%hu (hostedservices, alarms,grapupdate)", (*aesit).Name.c_str(), (*aesit).SId.get());

	CUnifiedNetwork::getInstance ()->send (sid, msgout);

}

	}

	string shard = row[0];

	sqlFlushResult();

	AdminExecutorServices.push_back (CAdminExecutorService(shard, server, sid));

	nlinfo ("%s-%hu, server name %s, for shard %s connected and added in the list", serviceName.c_str(), sid.get(), server.c_str(), shard.c_str());

	// send him services that should run on this server

	sendAESInformations (sid);

}

	AdminExecutorServices.push_back (CAdminExecutorService(shard, server, sid));

	nlinfo ("%s-%hu, server name %s, for shard %s connected and added in the list", serviceName.c_str(), sid.get(), server.c_str(), shard.c_str());

	// send him services that should run on this server

	sendAESInformations (sid);

}

			else if (shard == "*" && server == "#")

			{

				// Select all shard all server including offline one

				MYSQL_ROW row = sqlQuery ("select distinct server, shard from service");

				while (row != NULL)

				{

					AESIT aesit = findAES (row[0], false);

					if (aesit != AdminExecutorServices.end())

					{

						addRequestWaitingNb (rid);

						(*aesit).WaitingRequestId.push_back (rid);

						CMessage msgout("AES_GET_VIEW");

						msgout.serial (rid);

						msgout.serial (subvarpath.Destination[j].second);

						CUnifiedNetwork::getInstance ()->send ((*aesit).SId, msgout);

						nlinfo ("REQUEST: Sent view '%s' to shard name %s 'AES-%hu'", subvarpath.Destination[j].second.c_str(), (*aesit).Name.c_str(), (*aesit).SId.get());

					}

					else if (server == "#")

					{

						vector<string> vara, vala;

						// adding default row

						vara.push_back ("shard");

						vala.push_back (row[1]);

						vara.push_back ("service");

						vala.push_back ("AES");

						vara.push_back ("State");

						vala.push_back ("Offline");

						addRequestAnswer (rid, vara, vala);

					}

					row = sqlNextRow ();

					else if (server == "#")

					{

						vector<string> vara, vala;

						// adding default row

						vara.push_back ("shard");

						vala.push_back (shard);

						vara.push_back ("server");

						vala.push_back (row[0]);

						vara.push_back ("service");

						vala.push_back ("AES");

						vara.push_back ("State");

						vala.push_back ("Offline");

		varRequestTimeout (ConfigFile.getVar ("RequestTimeout"));

		ConfigFile.setCallback("RequestTimeout", &varRequestTimeout);

		varAdminAlertAccumlationTime (ConfigFile.getVar ("AdminAlertAccumlationTime"));

		ConfigFile.setCallback("AdmimAlertAccumlationTime", &varAdminAlertAccumlationTime);

	}

	bool update ()

	{

		cleanRequest ();

		connectionWebUpdate ();

		updateSendAdminAlert ();

		return true;

	}

NLMISC_COMMAND (generateAlert, "generate an alert", "<text>")

{

	if(args.size() != 1) return false;

	sendAdminAlert (args[0].c_str());

	return true;