Changeset 31ca5f for src


Ignore:
Timestamp:
May 4, 2012, 2:16:02 PM (13 years ago)
Author:
Frederik Heber <heber@…>
Branches:
Action_Thermostats, Add_AtomRandomPerturbation, Add_FitFragmentPartialChargesAction, Add_RotateAroundBondAction, Add_SelectAtomByNameAction, Added_ParseSaveFragmentResults, AddingActions_SaveParseParticleParameters, Adding_Graph_to_ChangeBondActions, Adding_MD_integration_tests, Adding_ParticleName_to_Atom, Adding_StructOpt_integration_tests, AtomFragments, Automaking_mpqc_open, AutomationFragmentation_failures, Candidate_v1.5.4, Candidate_v1.6.0, Candidate_v1.6.1, ChangeBugEmailaddress, ChangingTestPorts, ChemicalSpaceEvaluator, CombiningParticlePotentialParsing, Combining_Subpackages, Debian_Package_split, Debian_package_split_molecuildergui_only, Disabling_MemDebug, Docu_Python_wait, EmpiricalPotential_contain_HomologyGraph, EmpiricalPotential_contain_HomologyGraph_documentation, Enable_parallel_make_install, Enhance_userguide, Enhanced_StructuralOptimization, Enhanced_StructuralOptimization_continued, Example_ManyWaysToTranslateAtom, Exclude_Hydrogens_annealWithBondGraph, FitPartialCharges_GlobalError, Fix_BoundInBox_CenterInBox_MoleculeActions, Fix_ChargeSampling_PBC, Fix_ChronosMutex, Fix_FitPartialCharges, Fix_FitPotential_needs_atomicnumbers, Fix_ForceAnnealing, Fix_IndependentFragmentGrids, Fix_ParseParticles, Fix_ParseParticles_split_forward_backward_Actions, Fix_PopActions, Fix_QtFragmentList_sorted_selection, Fix_Restrictedkeyset_FragmentMolecule, Fix_StatusMsg, Fix_StepWorldTime_single_argument, Fix_Verbose_Codepatterns, Fix_fitting_potentials, Fixes, ForceAnnealing_goodresults, ForceAnnealing_oldresults, ForceAnnealing_tocheck, ForceAnnealing_with_BondGraph, ForceAnnealing_with_BondGraph_continued, ForceAnnealing_with_BondGraph_continued_betteresults, ForceAnnealing_with_BondGraph_contraction-expansion, FragmentAction_writes_AtomFragments, FragmentMolecule_checks_bonddegrees, GeometryObjects, Gui_Fixes, Gui_displays_atomic_force_velocity, ImplicitCharges, IndependentFragmentGrids, IndependentFragmentGrids_IndividualZeroInstances, IndependentFragmentGrids_IntegrationTest, IndependentFragmentGrids_Sole_NN_Calculation, JobMarket_RobustOnKillsSegFaults, JobMarket_StableWorkerPool, JobMarket_unresolvable_hostname_fix, MoreRobust_FragmentAutomation, ODR_violation_mpqc_open, PartialCharges_OrthogonalSummation, PdbParser_setsAtomName, PythonUI_with_named_parameters, QtGui_reactivate_TimeChanged_changes, Recreated_GuiChecks, Rewrite_FitPartialCharges, RotateToPrincipalAxisSystem_UndoRedo, SaturateAtoms_findBestMatching, SaturateAtoms_singleDegree, StoppableMakroAction, Subpackage_CodePatterns, Subpackage_JobMarket, Subpackage_LinearAlgebra, Subpackage_levmar, Subpackage_mpqc_open, Subpackage_vmg, Switchable_LogView, ThirdParty_MPQC_rebuilt_buildsystem, TrajectoryDependenant_MaxOrder, TremoloParser_IncreasedPrecision, TremoloParser_MultipleTimesteps, TremoloParser_setsAtomName, Ubuntu_1604_changes, stable
Children:
f93842
Parents:
963c3b
git-author:
Frederik Heber <heber@…> (11/18/11 20:29:36)
git-committer:
Frederik Heber <heber@…> (05/04/12 14:16:02)
Message:

StockClient and StockServer now exchange FragmentJob's instead of stock's.

Location:
src
Files:
2 added
1 deleted
6 edited

Legend:

Unmodified
Added
Removed
  • src/Fragmentation/Automation/Makefile.am

    r963c3b r31ca5f  
    1515  connection.hpp \
    1616  server.cpp \
    17   stock.hpp \
     17  FragmentJob.cpp \
     18  FragmentJob.hpp \
    1819  StockServer.cpp \
    1920  StockServer.hpp
     
    3031  client.cpp \
    3132  connection.hpp \
    32   stock.hpp \
     33  FragmentJob.cpp \
     34  FragmentJob.hpp \
    3335  StockClient.cpp \
    3436  StockClient.hpp
  • src/Fragmentation/Automation/StockClient.cpp

    r963c3b r31ca5f  
    1212#include "connection.hpp" // Must come before boost/serialization headers.
    1313#include <boost/serialization/vector.hpp>
    14 #include "stock.hpp"
     14#include "FragmentJob.hpp"
    1515#include "StockClient.hpp"
    1616
     
    4343    // of stocks. The connection::async_read() function will automatically
    4444    // decode the data that is read from the underlying socket.
    45     connection_.async_read(stocks_,
     45    connection_.async_read(jobs_,
    4646      boost::bind(&StockClient::handle_read, this,
    4747      boost::asio::placeholders::error));
     
    6262  {
    6363    // Print out the data that was received.
    64     for (std::size_t i = 0; i < stocks_.size(); ++i)
     64    for (std::size_t i = 0; i < jobs_.size(); ++i)
    6565    {
    66     std::cout << "Stock number " << i << "\n";
    67     std::cout << "  code: " << stocks_[i].code << "\n";
    68     std::cout << "  name: " << stocks_[i].name << "\n";
    69     std::cout << "  open_price: " << stocks_[i].open_price << "\n";
    70     std::cout << "  high_price: " << stocks_[i].high_price << "\n";
    71     std::cout << "  low_price: " << stocks_[i].low_price << "\n";
    72     std::cout << "  last_price: " << stocks_[i].last_price << "\n";
    73     std::cout << "  buy_price: " << stocks_[i].buy_price << "\n";
    74     std::cout << "  buy_quantity: " << stocks_[i].buy_quantity << "\n";
    75     std::cout << "  sell_price: " << stocks_[i].sell_price << "\n";
    76     std::cout << "  sell_quantity: " << stocks_[i].sell_quantity << "\n";
     66        std::cout << "Job number " << i << "\n";
     67        std::cout << "  output: " << jobs_[i].outputfile << "\n";
     68        std::cout << "  id: " << jobs_[i].JobId << "\n";
    7769    }
    7870  }
  • src/Fragmentation/Automation/StockClient.hpp

    r963c3b r31ca5f  
    1212#include <vector>
    1313#include "connection.hpp" // Must come before boost/serialization headers.
    14 #include "stock.hpp"
     14#include "FragmentJob.hpp"
    1515
    1616/// Downloads stock quote information from a server.
     
    3333
    3434  /// The data received from the server.
    35   std::vector<stock> stocks_;
     35  std::vector<FragmentJob> jobs_;
    3636};
    3737
  • src/Fragmentation/Automation/StockServer.cpp

    r963c3b r31ca5f  
    1313#include "connection.hpp" // Must come before boost/serialization headers.
    1414#include <boost/serialization/vector.hpp>
    15 #include "stock.hpp"
     15#include "FragmentJob.hpp"
    1616
    1717#include "StockServer.hpp"
     
    2222  )
    2323{
    24   // Create the data to be sent to each client.
    25   stock s;
    26   s.code = "ABC";
    27   s.name = "A Big Company";
    28   s.open_price = 4.56;
    29   s.high_price = 5.12;
    30   s.low_price = 4.33;
    31   s.last_price = 4.98;
    32   s.buy_price = 4.96;
    33   s.buy_quantity = 1000;
    34   s.sell_price = 4.99;
    35   s.sell_quantity = 2000;
    36   stocks_.push_back(s);
    37   s.code = "DEF";
    38   s.name = "Developer Entertainment Firm";
    39   s.open_price = 20.24;
    40   s.high_price = 22.88;
    41   s.low_price = 19.50;
    42   s.last_price = 19.76;
    43   s.buy_price = 19.72;
    44   s.buy_quantity = 34000;
    45   s.sell_price = 19.85;
    46   s.sell_quantity = 45000;
    47   stocks_.push_back(s);
     24  FragmentJob s(std::string("test"), 1);
     25  jobs_.push_back(s);
    4826
    4927  // Start an accept operation for a new connection.
     
    6240    // client. The connection::async_write() function will automatically
    6341    // serialize the data structure for us.
    64     conn->async_write(stocks_,
     42    conn->async_write(jobs_,
    6543      boost::bind(&StockServer::handle_write, this,
    6644      boost::asio::placeholders::error, conn));
  • src/Fragmentation/Automation/StockServer.hpp

    r963c3b r31ca5f  
    1212#include <vector>
    1313#include "connection.hpp" // Must come before boost/serialization headers.
    14 #include "stock.hpp"
     14#include "FragmentJob.hpp"
    1515
    1616/// Serves stock quote information to any client that connects to it.
     
    3333
    3434  /// The data to be sent to each client.
    35   std::vector<stock> stocks_;
     35  std::vector<FragmentJob> jobs_;
    3636};
    3737
  • src/unittests/Makefile.am

    r963c3b r31ca5f  
    5252        $(BOOST_PROGRAM_OPTIONS_LDFLAGS) $(BOOST_PROGRAM_OPTIONS_LIBS) \
    5353        $(BOOST_FILESYSTEM_LDFLAGS) $(BOOST_FILESYSTEM_LIBS) \
    54         $(BOOST_SERIALIZATION_LDFLAGS) $(BOOST_SERIALIZATION_LIBS)
     54        $(BOOST_SERIALIZATION_LDFLAGS) $(BOOST_SERIALIZATION_LIBS) \
     55        $(BOOST_SYSTEM_LDFLAGS) $(BOOST_SYSTEM_LIBS)
    5556
    5657GENERALLIBS = \
     
    131132        ../libMolecuilderShapes.la \
    132133        ../libMolecuilderHelpers.la \
    133         $(top_builddir)/LinearAlgebra/src/LinearAlgebra/libLinearAlgebra.la
     134        $(top_builddir)/LinearAlgebra/src/LinearAlgebra/libLinearAlgebra.la \
     135        ${CodePatterns_LIBS}
    134136
    135137AtomIdSetUnitTest_SOURCES = $(top_srcdir)/src/unittests/UnitTestMain.cpp \
Note: See TracChangeset for help on using the changeset viewer.