Menu
▾
▴
[Dsim-svn] SF.net SVN: dsim:[97] trunk/dsim/test
|
From: <sng...@us...> - 2010-07-16 12:45:05
|
Revision: 97
http://dsim.svn.sourceforge.net/dsim/?rev=97&view=rev
Author: snguyenkim
Date: 2010-07-16 12:44:59 +0000 (Fri, 16 Jul 2010)
Log Message:
-----------
master-slave-log_server model for dsim using only openMPI for communication
Added Paths:
-----------
trunk/dsim/test/master_slave/
trunk/dsim/test/master_slave/Makefile.am
trunk/dsim/test/master_slave/README
trunk/dsim/test/master_slave/log_server.cpp
trunk/dsim/test/master_slave/master.cpp
trunk/dsim/test/master_slave/myStringLib.cpp
trunk/dsim/test/master_slave/run.sh
trunk/dsim/test/master_slave/slave.cpp
Added: trunk/dsim/test/master_slave/Makefile.am
===================================================================
--- trunk/dsim/test/master_slave/Makefile.am (rev 0)
+++ trunk/dsim/test/master_slave/Makefile.am 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,33 @@
+# batches
+include $(top_srcdir)/Makefile.common
+
+## Source directory
+
+MAINTAINERCLEANFILES = Makefile.in
+
+
+# Binaries (batches)
+bin_PROGRAMS = master slave log_server
+
+master_SOURCES = master.cpp
+master_CXXFLAGS = $(BOOST_CFLAGS) $(MPIGEN_CFLAGS)
+master_LDADD =
+master_LDFLAGS = $(BOOST_PROGRAM_OPTIONS_LIB) $(BOOST_LIBS) $(BOOST_MPI_LIB) \
+ $(top_builddir)/stdair/core/libstdair.la \
+ $(top_builddir)/airsched/core/libairsched.la
+
+
+slave_SOURCES = slave.cpp
+slave_CXXFLAGS = $(BOOST_CFLAGS) $(MPIGEN_CFLAGS)
+slave_LDADD =
+slave_LDFLAGS = $(BOOST_PROGRAM_OPTIONS_LIB) $(BOOST_LIBS) $(BOOST_MPI_LIB) \
+ $(top_builddir)/stdair/core/libstdair.la \
+ $(top_builddir)/airsched/core/libairsched.la
+
+
+log_server_SOURCES = log_server.cpp
+log_server_CXXFLAGS = $(BOOST_CFLAGS) $(MPIGEN_CFLAGS)
+log_server_LDADD =
+log_server_LDFLAGS = $(BOOST_PROGRAM_OPTIONS_LIB) $(BOOST_LIBS) $(BOOST_MPI_LIB) \
+ $(top_builddir)/stdair/core/libstdair.la \
+ $(top_builddir)/airsched/core/libairsched.la
Added: trunk/dsim/test/master_slave/README
===================================================================
--- trunk/dsim/test/master_slave/README (rev 0)
+++ trunk/dsim/test/master_slave/README 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,12 @@
+* Master-slave-log_server model:
+ - Master receive demands (BookingRequest), get the TravelSolutionList and send each to the corresponding slave (by using slaveTable[]) (copied and modified from /airsched/batches/aisched.cpp)
+ - Each slave works on an inventory: one for BA, one for AA,... ( need to add AIRINV functionalities).
+ - Everytime slave receives order from master, he send log message to log_server and log_server will write this message in server.log.
+
+* log_server uses the mecanisme of locking i.e. he takes care of slave one by one. Slave will wake up every second to see if log_master has accepted his demand.
+
+* Run run.sh and see master.log for result
+
+* This model uses openMPI like mean of comunication, so log_server uses more resource than it should be (~ 33 % CPU all the time). See test/boost/asio/log_server for another log_server model which uses BOOST ASIO ( a lot better in term of CPU)
+
+* myStringLib.cpp contains some useful functions for string
\ No newline at end of file
Added: trunk/dsim/test/master_slave/log_server.cpp
===================================================================
--- trunk/dsim/test/master_slave/log_server.cpp (rev 0)
+++ trunk/dsim/test/master_slave/log_server.cpp 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,97 @@
+/*
+* Object: Make a simple log server
+* Utilisation: Run log_server_client.sh
+* Problem: avoid competitive sending, i.d 2 slaves send in a same time
+* Solution: Server takes care of slave one by one
+* Note: Usage of inactive_wait funtion, which reduces CPU charge evidently
+*/
+
+#include <boost/mpi.hpp>
+#include <iostream>
+#include <fstream>
+#include <string>
+#include <unistd.h>
+#include <time.h>
+#include <sys/types.h>
+#include<stdio.h>
+
+using namespace std;
+namespace mpi=boost::mpi;
+
+/* Write message to filename */
+void logToFile(string filename, string message){
+ ofstream out;
+ out.open(filename.c_str(), ios_base::app);
+ out << message << "\n" ;
+ out.close();
+}
+
+//inactive waiting: wake up every 1s for verifying if there is a message
+void inactive_wait(mpi::communicator& world){
+ boost::optional<mpi::status> stat = boost::none;//stat is not initialised
+ while(1){
+ stat = world.iprobe(mpi::any_source, mpi::any_tag); //inactive waiting
+
+ //usleep(100);//we have the faster result but it takes more CPU
+ sleep(1); //better choice
+
+ if (stat){
+ stat = boost::none; //stat goes back to waiting state
+ return;//ah, someone calls me !
+ }
+
+ }
+ //world.probe(root,tag);//active waiting: take much more resources
+}
+
+int main(int argc, char ** argv){
+ mpi::environment env(argc, argv);
+ mpi::communicator world;
+
+ int root = 0; //server's rank
+ int log_server=1;
+ int tag = 0; // the tag (or the port) used for communication
+ int dest;
+
+ int rank = world.rank(); //process's rank
+ int nbSlave = world.size() -2; //number of slaves
+ string message; // message received from client
+ bool yes=true;
+
+ int nb_of_quit_signal = 0;
+
+ if (rank==log_server){
+ cout << "Log server rank:" << rank << endl;
+ cout << "=============================================================" << endl;
+
+ while (1){
+ //waits for a demand, might takes a while as client aren't always gossip
+// inactive_wait(world);
+ world.recv(mpi::any_source,tag,dest);
+
+ // Exit if nb_of_quit_signal = nbSlave
+ if (dest == -1){
+ cout << "log server receive quit signal from 1 slave... " << endl;
+ nb_of_quit_signal ++;
+ cout << "nb of quit signal:" << nb_of_quit_signal << endl;
+ if (nb_of_quit_signal == nbSlave)
+ break;
+
+ cout << "still " << nbSlave - nb_of_quit_signal << " quit signal to wait...." << endl;
+ continue;
+ }
+
+ cout << "server received from client: " << dest << endl ;
+ world.send(dest,tag,yes); //ok, you can do it
+
+ // waiting for message from client
+// inactive_wait(world);
+ world.recv(dest,tag,message);
+
+ logToFile("server.log", message);
+ cout << "server received: " << message << endl ;
+ }
+ }
+
+ return 0;
+};
Added: trunk/dsim/test/master_slave/master.cpp
===================================================================
--- trunk/dsim/test/master_slave/master.cpp (rev 0)
+++ trunk/dsim/test/master_slave/master.cpp 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,440 @@
+// STL
+#include <cassert>
+#include <iostream>
+#include <sstream>
+#include <fstream>
+#include <string>
+#include<string>
+#include<map>
+// Boost (Extended STL)
+#include <boost/date_time/posix_time/posix_time.hpp>
+#include <boost/date_time/gregorian/gregorian.hpp>
+#include <boost/program_options.hpp>
+#include <boost/tokenizer.hpp>
+#include <boost/lexical_cast.hpp>
+// StdAir
+#include <stdair/STDAIR_Types.hpp>
+#include <stdair/STDAIR_Service.hpp>
+#include <stdair/bom/BookingRequestStruct.hpp>
+#include <stdair/bom/TravelSolutionStruct.hpp>
+#include <stdair/bom/BomSource.hpp>
+#include <stdair/bom/BomTypes.hpp>
+#include <stdair/factory/FacBomContent.hpp>
+// AIRSCHED
+#include <airsched/AIRSCHED_Service.hpp>
+#include <airsched/config/airsched-paths.hpp>
+// MPI
+#include <boost/mpi.hpp>
+// Some string functions
+#include "myStringLib.cpp"
+
+namespace mpi=boost::mpi;
+using namespace std;
+
+
+
+// //////// Type definitions ///////
+typedef std::vector<std::string> WordList_T;
+
+
+// //////// Constants //////
+/** Default name and location for the log file. */
+const std::string K_AIRSCHED_DEFAULT_LOG_FILENAME ("master.log");
+
+/** Default name and location for the (CSV) input file. */
+const std::string K_AIRSCHED_DEFAULT_INPUT_FILENAME ("../../test/samples/schedule03.csv");
+
+/** Default booking request string, to be seached against the AirSched
+ network. */
+const std::string K_AIRSCHED_DEFAULT_BOOKING_REQUEST ("NCE BKK NCE 2007-04-21 2007-03-21 08:32:00 C 1 DF RO 5 NONE 10:00:00 2000.0 20.0");
+
+// //////////////////////////////////////////////////////////////////////
+void tokeniseStringIntoWordList (const std::string& iPhrase,
+ WordList_T& ioWordList) {
+// Empty the word list
+ioWordList.clear();
+
+// Boost Tokeniser
+typedef boost::tokenizer<boost::char_separator<char> > Tokeniser_T;
+
+// Define the separators
+const boost::char_separator<char> lSepatorList(" .,;:|+-*/_=!@#$%`~^&(){}[]?'<>\"");
+
+// Initialise the phrase to be tokenised
+Tokeniser_T lTokens (iPhrase, lSepatorList);
+for (Tokeniser_T::const_iterator tok_iter = lTokens.begin();
+ tok_iter != lTokens.end(); ++tok_iter) {
+ const std::string& lTerm = *tok_iter;
+ ioWordList.push_back (lTerm);
+}
+
+}
+
+// //////////////////////////////////////////////////////////////////////
+std::string createStringFromWordList (const WordList_T& iWordList) {
+std::ostringstream oStr;
+
+unsigned short idx = iWordList.size();
+for (WordList_T::const_iterator itWord = iWordList.begin();
+ itWord != iWordList.end(); ++itWord, --idx) {
+ const std::string& lWord = *itWord;
+ oStr << lWord;
+ if (idx > 1) {
+ oStr << " ";
+ }
+}
+
+return oStr.str();
+}
+
+// ///////// Parsing of Options & Configuration /////////
+// A helper function to simplify the main part.
+template<class T> std::ostream& operator<< (std::ostream& os,
+ const std::vector<T>& v) {
+std::copy (v.begin(), v.end(), std::ostream_iterator<T> (std::cout, " "));
+return os;
+}
+
+/** Early return status (so that it can be differentiated from an error). */
+const int K_AIRSCHED_EARLY_RETURN_STATUS = 99;
+
+/** Read and parse the command line options. */
+int readConfiguration (int argc, char* argv[], int& ioRandomDraws,
+ stdair::Filename_T& ioInputFilename,
+ std::string& ioLogFilename,
+ std::string& ioBookingRequestString) {
+
+// Initialise the travel query string, if that one is empty
+if (ioBookingRequestString.empty() == true) {
+ ioBookingRequestString = K_AIRSCHED_DEFAULT_BOOKING_REQUEST;
+}
+
+// Transform the query string into a list of words (STL strings)
+WordList_T lWordList;
+tokeniseStringIntoWordList (ioBookingRequestString, lWordList);
+
+
+// Declare a group of options that will be allowed only on command line
+boost::program_options::options_description generic ("Generic options");
+generic.add_options()
+ ("prefix", "print installation prefix")
+ ("version,v", "print version string")
+ ("help,h", "produce help message");
+
+// Declare a group of options that will be allowed both on command
+// line and in config file
+boost::program_options::options_description config ("Configuration");
+config.add_options()
+ ("input,i",
+ boost::program_options::value< std::string >(&ioInputFilename)->default_value(K_AIRSCHED_DEFAULT_INPUT_FILENAME),
+ "(CVS) input file for the demand distributions")
+ ("log,l",
+ boost::program_options::value< std::string >(&ioLogFilename)->default_value(K_AIRSCHED_DEFAULT_LOG_FILENAME),
+ "Filename for the logs")
+ ("bkg_req,b",
+ boost::program_options::value< WordList_T >(&lWordList)->multitoken(),
+ "Booking request word list (e.g. NCE BKK NCE 2007-04-21 2007-04-21 10:00:00 C 1 DF RO 5 NONE 10:0:0 2000.0 20.0), which sould be located at the end of the command line (otherwise, the other options would be interpreted as part of that booking request word list)")
+ ;
+
+// Hidden options, will be allowed both on command line and
+// in config file, but will not be shown to the user.
+boost::program_options::options_description hidden ("Hidden options");
+hidden.add_options()
+ ("copyright",
+ boost::program_options::value< std::vector<std::string> >(),
+ "Show the copyright (license)");
+
+boost::program_options::options_description cmdline_options;
+cmdline_options.add(generic).add(config).add(hidden);
+
+boost::program_options::options_description config_file_options;
+config_file_options.add(config).add(hidden);
+
+boost::program_options::options_description visible ("Allowed options");
+visible.add(generic).add(config);
+
+boost::program_options::positional_options_description p;
+p.add ("copyright", -1);
+
+boost::program_options::variables_map vm;
+boost::program_options::
+ store (boost::program_options::command_line_parser (argc, argv).
+ options (cmdline_options).positional(p).run(), vm);
+
+std::ifstream ifs ("airsched.cfg");
+boost::program_options::store (parse_config_file (ifs, config_file_options),
+ vm);
+boost::program_options::notify (vm);
+
+if (vm.count ("help")) {
+ std::cout << visible << std::endl;
+ return K_AIRSCHED_EARLY_RETURN_STATUS;
+}
+
+if (vm.count ("version")) {
+ std::cout << PACKAGE_NAME << ", version " << PACKAGE_VERSION << std::endl;
+ return K_AIRSCHED_EARLY_RETURN_STATUS;
+}
+
+if (vm.count ("prefix")) {
+ std::cout << "Installation prefix: " << PREFIXDIR << std::endl;
+ return K_AIRSCHED_EARLY_RETURN_STATUS;
+}
+
+if (vm.count ("input")) {
+ ioInputFilename = vm["input"].as< std::string >();
+ std::cout << "Input filename is: " << ioInputFilename << std::endl;
+}
+
+if (vm.count ("log")) {
+ ioLogFilename = vm["log"].as< std::string >();
+ std::cout << "Log filename is: " << ioLogFilename << std::endl;
+}
+
+// Rebuild the booking request query string
+ioBookingRequestString = createStringFromWordList (lWordList);
+
+// Suppress some potential separators (such as ':', '-' or '/')
+tokeniseStringIntoWordList (ioBookingRequestString, lWordList);
+ioBookingRequestString = createStringFromWordList (lWordList);
+std::cout << "The booking request string is: " << ioBookingRequestString
+ << std::endl;
+
+return 0;
+}
+
+// //////////////////////////////////////////////////////////////
+stdair::BookingRequestStruct
+parseBookingRequest (const std::string& iRequestOption) {
+
+typedef boost::tokenizer<boost::char_separator<char> > tokenizer;
+boost::char_separator<char> sep(" ");
+
+tokenizer tokens (iRequestOption, sep);
+
+// Origin (e.g., "NCE")
+tokenizer::iterator tok_iter = tokens.begin();
+assert (tok_iter != tokens.end());
+const stdair::AirportCode_T iOrigin (*tok_iter);
+
+// Destination (e.g., "BKK")
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::AirportCode_T iDestination (*tok_iter);
+
+// POS (e.g., "NCE")
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::AirportCode_T iPOS (*tok_iter);
+
+// Preferred departure date (e.g., "2007-04-21")
+++tok_iter; assert (tok_iter != tokens.end());
+const short lDepDateYear = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lDepDateMonth = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lDepDateDay = boost::lexical_cast<short> (*tok_iter);
+const stdair::Date_T iDepartureDate(lDepDateYear, lDepDateMonth, lDepDateDay);
+
+// Request date (e.g., "2007-03-21")
+++tok_iter; assert (tok_iter != tokens.end());
+const short lReqDateYear = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lReqDateMonth = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lReqDateDay = boost::lexical_cast<short> (*tok_iter);
+const stdair::Date_T iRequestDate (lReqDateYear, lReqDateMonth, lReqDateDay);
+
+// Request time (e.g., "08:34:23")
+++tok_iter; assert (tok_iter != tokens.end());
+const short lReqTimeHours = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lReqTimeMinutes = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lReqTimeSeconds = boost::lexical_cast<short> (*tok_iter);
+const stdair::Duration_T iRequestTime (lReqTimeHours, lReqTimeMinutes,
+ lReqTimeSeconds);
+
+// Request date-time (aggregation of the two items above)
+const stdair::DateTime_T iRequestDateTime (iRequestDate, iRequestTime);
+
+// Preferred cabin (e.g., "C")
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::CabinCode_T iPreferredCabin (*tok_iter);
+
+// Party size (e.g., 1)
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::NbOfSeats_T iPartySize = 1;
+
+// Channel (e.g., "DF")
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::ChannelLabel_T iChannel (*tok_iter);
+
+// Trip type (e.g., "RO")
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::TripType_T iTripType (*tok_iter);
+
+// Stay duration (e.g., 5)
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::DayDuration_T iStayDuration = 5;
+
+// Frequent flyer (e.g., "NONE")
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::FrequentFlyer_T iFrequentFlyerType ("NONE");
+
+// Preferred departure time (e.g., "10:00:00")
+++tok_iter; assert (tok_iter != tokens.end());
+const short lPrefTimeHours = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lPrefTimeMinutes = boost::lexical_cast<short> (*tok_iter);
+++tok_iter; assert (tok_iter != tokens.end());
+const short lPrefTimeSeconds = boost::lexical_cast<short> (*tok_iter);
+const stdair::Duration_T iPreferredDepartureTime (lPrefTimeHours,
+ lPrefTimeMinutes,
+ lPrefTimeSeconds);
+
+// Willingness-to-pay (e.g., 2000.0)
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::WTP_T iWTP = 2000.0;
+
+// Value of time (e.g., 20.0)
+++tok_iter; assert (tok_iter != tokens.end());
+const stdair::PriceValue_T iValueOfTime = 20.0;
+
+// Build and return the booking request structure
+return stdair::BookingRequestStruct (iOrigin, iDestination, iPOS,
+ iDepartureDate, iRequestDateTime,
+ iPreferredCabin, iPartySize, iChannel,
+ iTripType, iStayDuration,
+ iFrequentFlyerType,
+ iPreferredDepartureTime, iWTP,
+ iValueOfTime);
+}
+
+
+
+// ///////// M A I N ////////////
+int main (int argc, char* argv[]) {
+// try {
+ // Maps contains (name_of_airline, num_of_correspondant_slave)
+ std::map<string,int> slaveTable;
+ slaveTable["BA"] = 2;
+ slaveTable["AA"] = 3;
+
+ mpi::environment env(argc, argv);
+ mpi::communicator world;
+
+ int root = 0; //server's rank
+ int tag = 0; // the tag (or the port) used for communication
+ int dest;
+ int log_server=1;
+
+ int rank = world.rank(); //process's rank
+ int nbSlave = world.size() -2; // number of slaves
+ string message; // message received from client
+ bool yes=true;
+
+
+ if (rank==0){
+ cout << "We have " << world.size() -2 << " clients " << endl;
+ cout << "=============================================================" << endl;
+
+
+ // Number of random draws to be generated (best if greater than 100)
+ int lRandomDraws = 0;
+
+ // Input file name
+ stdair::Filename_T lInputFilename;
+
+ // Output log File
+ std::string lLogFilename;
+
+ // Booking request string
+ std::string lBookingRequestString;
+
+ // Call the command-line option parser
+ const int lOptionParserStatus =
+ readConfiguration (argc, argv, lRandomDraws, lInputFilename,
+ lLogFilename, lBookingRequestString);
+
+ if (lOptionParserStatus == K_AIRSCHED_EARLY_RETURN_STATUS) {
+ return 0;
+ }
+
+ // Check wether or not a (CSV) input file should be read
+ bool hasInputFile = false;
+ if (lInputFilename.empty() == false) {
+ hasInputFile = true;
+ }
+
+ // Set the log parameters
+ std::ofstream logOutputFile;
+ // Open and clean the log outputfile
+ logOutputFile.open (lLogFilename.c_str());
+ logOutputFile.clear();
+
+ // Initialise the AirSched service object
+ const stdair::BasLogParams lLogParams (stdair::LOG::DEBUG, logOutputFile);
+ AIRSCHED::AIRSCHED_Service airschedService (lLogParams, lInputFilename);
+
+
+ // Create a booking request
+ const stdair::BookingRequestStruct& lBookingRequest =
+ parseBookingRequest (lBookingRequestString);
+
+ // DEBUG
+ // std::cout << "Booking request: " << lBookingRequest << std::endl;
+
+ // Get the corresponding travel solutions
+ stdair::TravelSolutionList_T lTravelSolutionList;
+ airschedService.getTravelSolutions (lTravelSolutionList, lBookingRequest);
+
+ unsigned short idx = 1;
+ for (stdair::TravelSolutionList_T::const_iterator itTS =
+ lTravelSolutionList.begin();
+ itTS != lTravelSolutionList.end(); ++itTS, ++idx) {
+ cout << "==============================================" << endl;
+ const stdair::TravelSolutionStruct& lTS = *itTS;
+
+ using namespace std;
+// cout << "TravelSolution:"<< idx <<":description:" << lTS.describe() << endl;
+
+ const stdair::KeyList_T& lSegmentDateKeyList = lTS.getSegmentDateKeyList();
+ for (int i=0; i< lSegmentDateKeyList.size(); i++){
+ string lSegmentDateKey = lSegmentDateKeyList[i] ;
+// cout << "SegmentDateKey:" << i << ":" << lSegmentDateKey << endl ;
+
+ //get the corresponding slave
+ int slaveNum = slaveTable[getFirstOccurence(lSegmentDateKey, ",")];
+// cout << "Corresponding slave:" << slaveNum << endl;
+
+ // Sending to corresponding slave
+ ostringstream oss;
+ oss << "master sent to slave:" << slaveNum << ":SegmentDateKey:"<< lSegmentDateKey ;
+ message = oss.str();
+ world.send(slaveNum,tag,message);
+ }
+
+// const stdair::ClassList_String_T& BCKeyList= lTS.getBookingClassKeyList ();
+// cout << "BC key:" << BCKeyList << endl ;
+
+ }
+
+// Sending finishing singal to slaves
+ for (int slaveNum=2; slaveNum < world.size(); slaveNum++)
+ world.send(slaveNum,tag,"finish");
+
+ }
+
+
+ // Start a mini-simulation
+ // airschedService.simulate();
+
+// } catch (const std::exception& stde) {
+// std::cerr << "Standard exception: " << stde.what() << std::endl;
+// return -1;
+
+// } catch (...) {
+// return -1;
+// }
+
+return 0;
+}
Added: trunk/dsim/test/master_slave/myStringLib.cpp
===================================================================
--- trunk/dsim/test/master_slave/myStringLib.cpp (rev 0)
+++ trunk/dsim/test/master_slave/myStringLib.cpp 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,69 @@
+#include <iostream>
+#include <sstream>
+#include <string>
+
+/*
+* Return phrase if phrase doesn't contain delimiter
+* if not, for ex, with delimiter=":", phrase="abc:def"
+* StringSplit returns abc
+* and phrase="def"
+*/
+std::string StringSplit(std::string & phrase, std::string delimiter){
+ using namespace std;
+ int cutAt = phrase.find(delimiter);
+ if (phrase == "")
+ return "";
+ if( cutAt != std::string::npos ){
+ if(cutAt > 0){
+ std::string tmp = phrase.substr(0,cutAt);
+ phrase = phrase.substr(cutAt+1);
+ return tmp;
+ }
+ }else{
+ std::string tmp = phrase;
+ phrase = "";
+ return tmp;
+ }
+}
+
+/*
+* Same as StringSplit but doesn't destroy phrase
+*/
+std::string getFirstOccurence(std::string phrase, std::string delimiter){
+ using namespace std;
+ int cutAt = phrase.find(delimiter);
+ if (phrase == "")
+ return "";
+ if( cutAt != std::string::npos ){
+ if(cutAt > 0){
+ std::string tmp = phrase.substr(0,cutAt);
+ return tmp;
+ }
+ }else{
+ std::string tmp = phrase;
+ return tmp;
+ }
+}
+
+/* return s+a */
+std::string joinString(std::string s,int a){
+ std::ostringstream oss;
+ oss << s;
+ oss << a;
+ return oss.str();
+}
+
+/* return s+a */
+std::string joinString(std::string s,std::string a){
+ std::ostringstream oss;
+ oss << s;
+ oss << a;
+ return oss.str();
+}
+
+std::string joinString(int s,int a){
+ std::ostringstream oss;
+ oss << s;
+ oss << a;
+ return oss.str();
+}
\ No newline at end of file
Added: trunk/dsim/test/master_slave/run.sh
===================================================================
--- trunk/dsim/test/master_slave/run.sh (rev 0)
+++ trunk/dsim/test/master_slave/run.sh 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,7 @@
+# Execute log_server on localhost, 4 client on localhost (or fed1, fed2)
+#!/bin/sh
+rm -fv log
+
+/usr/lib/openmpi/bin/mpirun --host localhost -n 1 ./master :\
+ --host localhost -n 1 ./log_server :\
+ --host localhost -n 2 ./slave
Property changes on: trunk/dsim/test/master_slave/run.sh
___________________________________________________________________
Added: svn:executable
+ *
Added: trunk/dsim/test/master_slave/slave.cpp
===================================================================
--- trunk/dsim/test/master_slave/slave.cpp (rev 0)
+++ trunk/dsim/test/master_slave/slave.cpp 2010-07-16 12:44:59 UTC (rev 97)
@@ -0,0 +1,75 @@
+#include <boost/mpi.hpp>
+#include <iostream>
+#include <string>
+#include <unistd.h>
+#include <time.h>
+#include <sys/types.h>
+#include<stdio.h>
+
+using namespace std;
+namespace mpi=boost::mpi;
+
+//inactive waiting: wake up every 1s for verifying if there is a message
+void inactive_wait(mpi::communicator& world, int source=mpi::any_source){
+ boost::optional<mpi::status> stat = boost::none;//stat is not initialised
+ while(1){
+ stat = world.iprobe(source, mpi::any_tag); //inactive waiting
+
+ //usleep(100);//we have the faster result but it takes more CPU
+ sleep(1); //better choice
+
+ if (stat){
+ stat = boost::none; //stat goes back to waiting state
+ return;//ah, someone calls me !
+ }
+
+ }
+ //world.probe(root,tag);//active waiting: take much more resources
+}
+
+
+
+int main(int argc, char ** argv ){
+ mpi::environment env(argc, argv);
+ mpi::communicator world;
+
+ int root = 0; //server's rank
+ int log_server=1;
+ int tag = 0; // the tag (or the port) used for communication
+ int dest;
+
+ int rank = world.rank(); //process's rank
+ string message; // message received from master
+ bool tmp;
+
+ if (rank > 1){
+ cout << "Slave rank:" << rank << endl;
+ while (1){
+ //waits for demand from master, which is not frequent
+// inactive_wait(world, root);
+ world.recv(root, tag, message);
+
+ //Exit if receive "finish" from master
+ if (message.find ("finish") != string::npos){
+ cout << "slave:" << rank << " is quitting..." << endl;
+
+ world.send(log_server, tag, -1);
+ break;
+ }
+
+ cout << "slave:" << rank << " received:" << message << endl;
+
+ world.send(log_server, tag, rank); //try to get a place
+
+ //waits for a response, might takes a while as server takes care of someone else
+// inactive_wait(world, log_server);
+ world.recv(log_server, tag, tmp );
+
+ // Now I can send my message
+ cout << "slave " << rank << " is sending to log server:" << message << endl;
+ world.send(log_server,tag, message);
+ }
+ }
+ return 0;
+};
+
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
