libtransport.git Changeset - cd2501c4360d

Changeset - cd2501c4360d

Parent rev.

Child rev.

[Not reviewed]

0 4 0

Jan Kaluza - 14 years ago 2011-10-20 11:49:42
hanzz.k@gmail.com

pseudo-working 'spectrum2_manager start' command

4 files changed with 180 insertions and 50 deletions:

spectrum/src/main.cpp

spectrum_manager/src/main.cpp

164

spectrum_manager/src/managerconfig.cpp

spectrum_manager/src/spectrum_manager.cfg

0 comments (0 inline, 0 general)

spectrum/src/main.cpp

➞

Show inline comments

 	pid_t pid, sid;
 	FILE* lock_file_f;
 	char process_pid[20];
 	/* already a daemon */
 	if ( getppid() == 1 ) return;
+	}
 	/* If we got a good PID, then we can exit the parent process. */
 	if (pid > 0) {
 		if (lock_file) {
 			/* write our pid into it & close the file. */
 			lock_file_f = fopen(lock_file, "w+");
 			if (lock_file_f == NULL) {
 				std::cerr << "Cannot create lock file " << lock_file << ". Exiting\n";
 				exit(1);
+			}
 			sprintf(process_pid,"%d\n",pid);
 			if (fwrite(process_pid,1,strlen(process_pid),lock_file_f) < strlen(process_pid)) {
 				std::cerr << "Cannot write to lock file " << lock_file << ". Exiting\n";
 				exit(1);
+			}
 			fclose(lock_file_f);
+		}
 		exit(0);
+	}
 	/* At this point we are executing as the child process */
 	/* Change the file mode mask */
 	umask(0);
 	if ((chdir(cwd)) < 0) {
 		exit(1);
+	}
 	if (lock_file) {
 		/* write our pid into it & close the file. */
 		lock_file_f = fopen(lock_file, "w+");
 		if (lock_file_f == NULL) {
 			std::cout << "EE cannot create lock file " << lock_file << ". Exiting\n";
 			exit(1);
+		}
 		sprintf(process_pid,"%d\n",getpid());
 		if (fwrite(process_pid,1,strlen(process_pid),lock_file_f) < strlen(process_pid)) {
 			std::cout << "EE cannot write to lock file " << lock_file << ". Exiting\n";
 			exit(1);
+		}
 		fclose(lock_file_f);
+	}
 	if (freopen( "/dev/null", "r", stdin) == NULL) {
 		std::cout << "EE cannot open /dev/null. Exiting\n";

spectrum_manager/src/main.cpp

➞

Show inline comments

@@ @@ -7,8 +7,22 @@ @@
 #include "transport/networkpluginserver.h"
 #include "Swiften/EventLoop/SimpleEventLoop.h"
 #include <boost/foreach.hpp>
 #include <iostream>
 #include <fstream>
 #include <iterator>
 #include <algorithm>
 #include <boost/filesystem.hpp>
 #include "signal.h"
 #include "sys/wait.h"
 using namespace Transport;
 using namespace boost::filesystem;
 using namespace boost;
 static int finished;
 static std::string *m;
+	}
+}
 static std::string searchForBinary(const std::string &binary) {
 	std::vector<std::string> path_list;
 	char * env_path = getenv("PATH");
 	if (env_path != NULL) {
 		std::string buffer = "";
 		for (int s = 0; s < strlen(env_path); s++) {
 			if (env_path[s] == ':') {
 				path_list.insert(path_list.end(), std::string(buffer));
 				buffer = "";
+			}
 			else {
 				buffer += env_path[s];
+			}
+		}
 		if (buffer != "") {
 			path_list.insert(path_list.end(), std::string(buffer));
 			buffer = "";
+		}
 		for (std::vector<std::string>::iterator dit = path_list.begin(); dit < path_list.end(); dit++) {
 			std::string bpath = *dit;
 			bpath += "/";
 			bpath += binary;
 			path p(bpath);
 			if (exists(p) && !is_directory(p)) {
 				return bpath;
+			}
+		}
+	}
 	return "";
+}
 // Executes new backend
 static unsigned long exec_(std::string path, std::string config) {
 	// fork and exec
 	pid_t pid = fork();
 	if ( pid == 0 ) {
 		// child process
 		exit(execl(path.c_str(), path.c_str(), config.c_str(), NULL));
 	} else if ( pid < 0 ) {
 		// fork failed
+	}
 	else {
 		waitpid(pid, 0, 0);
+	}
 	return (unsigned long) pid;
+}
 static bool isRunning(const std::string &pidfile) {
 	path p(pidfile);
 	if (!exists(p) || is_directory(p)) {
 		return false;
+	}
 	std::ifstream f(p.string().c_str(), std::ios_base::in);
 	std::string pid;
 	f >> pid;
 	if (pid.empty())
 		return false;
 	if (kill(boost::lexical_cast<int>(pid), 0) != 0)
 		return false;
 	return true;
+}
 static void start_all_instances(ManagerConfig *config) {
 		path p(CONFIG_STRING(config, "service.config_directory"));
 		try {
 			if (!exists(p)) {
 				std::cerr << "Config directory " << CONFIG_STRING(config, "service.config_directory") << " does not exist\n";
 				exit(6);
+			}
 			if (!is_directory(p)) {
 				std::cerr << "Config directory " << CONFIG_STRING(config, "service.config_directory") << " does not exist\n";
 				exit(7);
+			}
 			std::string spectrum2_binary = searchForBinary("spectrum2");
 			if (spectrum2_binary.empty()) {
 				std::cerr << "spectrum2 binary not found in PATH\n";
 				exit(8);
+			}
 			directory_iterator end_itr;
 			for (directory_iterator itr(p); itr != end_itr; ++itr) {
 				if (is_regular(itr->path()) && extension(itr->path()) == ".cfg") {
 					Config cfg;
 					if (cfg.load(itr->path().string()) == false) {
 						std::cerr << "Can't load config file " << itr->path().string() << ". Skipping...\n";
+					}
 					if (!isRunning(CONFIG_STRING(&cfg, "service.pidfile"))) {
 						exec_(spectrum2_binary, itr->path().string());
+					}
+				}
+			}
+		}
 		catch (const filesystem_error& ex) {
 			std::cerr << "error 1\n";
 			exit(5);
+		}
+}
 int main(int argc, char **argv)
+{
 	ManagerConfig config;
 	std::string config_file;
 	std::string command;
 	boost::program_options::variables_map vm;
-	boost::program_options::options_description desc("Usage: spectrum_manager <config_file.cfg> <command>\nAllowed options");
+	boost::program_options::options_description desc("Usage: spectrum [OPTIONS] <COMMAND>\nAllowed options");
 	desc.add_options()
 		("help,h", "help")
 		("help,h", "Show help output")
 		("config,c", boost::program_options::value<std::string>(&config_file)->default_value("/etc/spectrum2/spectrum-manager.cfg"), "Spectrum manager config file")
 		("command", boost::program_options::value<std::string>(&command)->default_value(""), "Command")
+		;
 	try
+	{
 		boost::program_options::variables_map vm;
 		boost::program_options::store(boost::program_options::parse_command_line(argc, argv, desc), vm);
 		boost::program_options::positional_options_description p;
 		p.add("command", -1);
 		boost::program_options::store(boost::program_options::command_line_parser(argc, argv).
           options(desc).positional(p).run(), vm);
 		boost::program_options::notify(vm);
 		if(vm.count("help"))
+		{
 			std::cout << desc << "\n";
@@ @@ -59,44 +191,44 @@ int main(int argc, char **argv) @@
 	catch (std::runtime_error& e)
+	{
 		std::cout << desc << "\n";
-		return 1;
+		return 2;
+	}
 	catch (...)
+	{
 		std::cout << desc << "\n";
 		return 1;
+	}
 	if (argc != 3) {
 		std::cout << desc << "\n";
 		return 1;
 		return 3;
+	}
-	if (!config.load(argv[1])) {
+	if (!config.load(config_file)) {
 		std::cerr << "Can't load configuration file.\n";
-		return 1;
+		return 4;
+	}
 	Swift::SimpleEventLoop eventLoop;
 	Swift::BoostNetworkFactories networkFactories(&eventLoop);
 	std::string message = argv[2];
 	m = &message;
 	std::vector<std::string> servers = CONFIG_VECTOR(&config, "servers.server");
 	for (std::vector<std::string>::const_iterator it = servers.begin(); it != servers.end(); it++) {
 		finished++;
 		Swift::Client *client = new Swift::Client(CONFIG_STRING(&config, "service.admin_username") + "@" + (*it), CONFIG_STRING(&config, "service.admin_password"), &networkFactories);
 		client->setAlwaysTrustCertificates();
  		client->onConnected.connect(boost::bind(&handleConnected, client));
 		client->onDisconnected.connect(bind(&handleDisconnected, client, _1));
 		client->onMessageReceived.connect(bind(&handleMessageReceived, client, _1));
 		Swift::ClientOptions opt;
 		opt.allowPLAINWithoutTLS = true;
 		client->connect(opt);
 // 		std::cout << *it << "\n";
 	if (command == "start") {
 		start_all_instances(&config);
+	}
 	else {
 		Swift::SimpleEventLoop eventLoop;
 		Swift::BoostNetworkFactories networkFactories(&eventLoop);
 		std::string message = argv[1];
 		m = &message;
 	eventLoop.run();
 		std::vector<std::string> servers = CONFIG_VECTOR(&config, "servers.server");
 		for (std::vector<std::string>::const_iterator it = servers.begin(); it != servers.end(); it++) {
 			finished++;
 			Swift::Client *client = new Swift::Client(CONFIG_STRING(&config, "service.admin_username") + "@" + (*it), CONFIG_STRING(&config, "service.admin_password"), &networkFactories);
 			client->setAlwaysTrustCertificates();
 			client->onConnected.connect(boost::bind(&handleConnected, client));
 			client->onDisconnected.connect(bind(&handleDisconnected, client, _1));
 			client->onMessageReceived.connect(bind(&handleMessageReceived, client, _1));
 			Swift::ClientOptions opt;
 			opt.allowPLAINWithoutTLS = true;
 			client->connect(opt);
 	// 		std::cout << *it << "\n";
+		}
 		eventLoop.run();
+	}
+}

spectrum_manager/src/managerconfig.cpp

➞

Show inline comments

 	opts.add_options()
 		("service.admin_username", value<std::string>()->default_value(""), "Administrator username.")
 		("service.admin_password", value<std::string>()->default_value(""), "Administrator password.")
 		("service.config_directory", value<std::string>()->default_value("/etc/spectrum2/transports/"), "Directory with spectrum2 configuration files. One .cfg file per one instance")
 		("servers.server", value<std::vector<std::string> >()->multitoken(), "Server.")
+	;

spectrum_manager/src/spectrum_manager.cfg

➞

Show inline comments

 [service]
 admin_username=admin
 admin_password=test
 config_directory=/etc/spectrum2/transports/
 [servers]
 server=localhost

0 comments (0 inline, 0 general)