Boost-Commit :

Date view	Thread view	Subject view	Author view

Subject: [Boost-commit] svn:boost r51217 - sandbox/synchro/libs/synchro/example
From: vicente.botet_at_[hidden]
Date: 2009-02-12 08:15:55

Author: viboes
Date: 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
New Revision: 51217
URL: http://svn.boost.org/trac/boost/changeset/51217

Log:
Boost.Synchro V0.0.0
Text files modified:
   sandbox/synchro/libs/synchro/example/Accumulator.cpp | 4
   sandbox/synchro/libs/synchro/example/BankAccount.cpp | 6 +-
   sandbox/synchro/libs/synchro/example/EL_BancAccount.cpp | 17 +++++-
   sandbox/synchro/libs/synchro/example/Factorial.cpp | 4
   sandbox/synchro/libs/synchro/example/Histogram.cpp | 41 +++++++++++++---
   sandbox/synchro/libs/synchro/example/HotelReservation.cpp | 97 ++++++++++++++++++++++++++++-----------
   sandbox/synchro/libs/synchro/example/IEL_Rec_Lockable_BancAccount.cpp | 16 +++++-
   sandbox/synchro/libs/synchro/example/IL_BancAccount.cpp | 10 ++++
   sandbox/synchro/libs/synchro/example/IL_Lockable_BancAccount.cpp | 14 ++++
   sandbox/synchro/libs/synchro/example/IL_Rec_Lockable_BancAccount.cpp | 14 ++++
   sandbox/synchro/libs/synchro/example/Master_Slave.cpp | 12 ++--
   sandbox/synchro/libs/synchro/example/QualifiedSingleBuf.cpp | 12 ++--
   sandbox/synchro/libs/synchro/example/SingleBuf.cpp | 12 ++--
   sandbox/synchro/libs/synchro/example/TrafficLight.cpp | 4
   14 files changed, 187 insertions(+), 76 deletions(-)

Modified: sandbox/synchro/libs/synchro/example/Accumulator.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/Accumulator.cpp (original)
+++ sandbox/synchro/libs/synchro/example/Accumulator.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,7 +8,7 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/coroutine/coroutine.hpp"
+#include <boost/coroutine/coroutine.hpp>

namespace coro=boost::coroutines;

Modified: sandbox/synchro/libs/synchro/example/BankAccount.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/BankAccount.cpp (original)
+++ sandbox/synchro/libs/synchro/example/BankAccount.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,8 +8,8 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/monitor.hpp"
-#include "boost/thread.hpp"
+#include <boost/synchro/monitor.hpp>
+#include <boost/thread.hpp>
#include <iostream>

using namespace boost::synchro;

Modified: sandbox/synchro/libs/synchro/example/EL_BancAccount.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/EL_BancAccount.cpp (original)
+++ sandbox/synchro/libs/synchro/example/EL_BancAccount.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,10 +1,19 @@
-#include <boost/synchro/make_lockable.hpp>
+//////////////////////////////////////////////////////////////////////////////
+//
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
+// Software License, Version 1.0. (See accompanying file
+// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+// See http://www.boost.org/libs/synchro for documentation.
+//
+//////////////////////////////////////////////////////////////////////////////
+
+#include <boost/synchro/lockable_adapter.hpp>
#include <boost/synchro/thread/mutex.hpp>
#include <boost/synchro/thread/locks.hpp>
#include <boost/synchro/lockers/strict_locker.hpp>
#include <boost/synchro/lockers/externally_locked.hpp>

-
using namespace boost::synchro;
using namespace boost;

@@ -25,10 +34,10 @@

//[AccountManager
class AccountManager
- : public make_exclusive_lockable<boost::mutex>
+ : public exclusive_lockable_adapter<boost::mutex>
{
public:
- typedef make_exclusive_lockable<boost::mutex> lockable_base_type;
+ typedef exclusive_lockable_adapter<boost::mutex> lockable_base_type;
     AccountManager()
         : checkingAcct_(*this)
         , savingsAcct_(*this)

Modified: sandbox/synchro/libs/synchro/example/Factorial.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/Factorial.cpp (original)
+++ sandbox/synchro/libs/synchro/example/Factorial.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,7 +8,7 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/alt/alternating_component.hpp"
+#include <boost/synchro/alt/alternating_component.hpp>

using namespace boost::alt;
using namespace boost;

Modified: sandbox/synchro/libs/synchro/example/Histogram.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/Histogram.cpp (original)
+++ sandbox/synchro/libs/synchro/example/Histogram.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,12 +8,17 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/conc/concurrent_component.hpp"
-#include "boost/synchro/monitor.hpp"
-#include "boost/synchro/thread/mutex.hpp"
-#include "boost/thread.hpp"
-#include "boost/ref.hpp"
-#include "boost/synchro/conc/conc_tuple.hpp"
+#include <boost/synchro/conc/concurrent_component.hpp>
+#include <boost/synchro/monitor.hpp>
+#include <boost/synchro/thread/mutex.hpp>
+#include <boost/thread.hpp>
+#include <boost/ref.hpp>
+#if 0
+#include <boost/synchro/conc/conc_tuple.hpp>
+#else
+#include <boost/interthreads/algorithm.hpp>
+#include <boost/interthreads/typeof/threader.hpp>
+#endif

namespace {
     volatile int Run = 1;
@@ -48,6 +53,7 @@
     class Display : boost::synchro::concurrent_component {
         HistogramData& histogramData_;
     public:
+ typedef void result_type;
         Display(HistogramData& histogramData) : histogramData_(histogramData) {}
         void operator()()
         {
@@ -64,6 +70,7 @@
     class Update : boost::synchro::concurrent_component {
         Histogram::port& request_;
     public:
+ typedef void result_type;
         Update(Histogram::port& req) : request_(req) {}
         void operator()()
         {
@@ -78,6 +85,7 @@
     Display disp_;
     Update updater_;
public:
+ typedef void result_type;
     Histogram()
     : disp_(histogramData_)
     , updater_(request_)
@@ -88,15 +96,23 @@
         else histogramData_.Sub(-V);
     }
     void operator()() {
+ #if 0
         conc_tuple<Display,Update> conc_(disp_, updater_);
- conc_();
- conc_.join();
+ conc_();
+ conc_.join();
+ #else
+ boost::interthreads::shared_threader ae;
+ BOOST_AUTO(conc_, boost::interthreads::fork_all(ae, boost::bind(boost::ref(disp_)), boost::bind(boost::ref(updater_))));
+ boost::interthreads::join_all(conc_);
+ #endif
+
     }
};
//]
class S : boost::synchro::concurrent_component {
     Histogram& histogram_;
public:
+ typedef void result_type;
     S(Histogram& histogram) : histogram_(histogram) {}
     void operator()()
     {
@@ -113,11 +129,18 @@
{
     Histogram histo;
     S snd(histo);
+ #if 0
     conc_tuple<Histogram, S> conc(histo, snd);
     conc();
     boost::this_thread::sleep(boost::posix_time::seconds(10));

     conc.join();
+ #else
+ boost::interthreads::shared_threader ae;
+ BOOST_AUTO(conc, boost::interthreads::fork_all(ae, boost::bind(boost::ref(histo)), boost::bind(boost::ref(snd))));
+ boost::this_thread::sleep(boost::posix_time::seconds(10));
+ boost::interthreads::join_all(conc);
+ #endif

     return 0;
}

Modified: sandbox/synchro/libs/synchro/example/HotelReservation.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/HotelReservation.cpp (original)
+++ sandbox/synchro/libs/synchro/example/HotelReservation.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,17 +8,31 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/conc/concurrent_component.hpp"
-#include "boost/synchro/thread/mutex.hpp"
-#include "boost/thread.hpp"
-#include "boost/ref.hpp"
+#include <boost/synchro/conc/concurrent_component.hpp>
+#include <boost/synchro/thread/mutex.hpp>
+#include <boost/thread.hpp>
+#include <boost/ref.hpp>
#include <string>
-#include "boost/synchro/conc/conc_tuple.hpp"
-#include "boost/test/unit_test.hpp"

+#if 0
+#include <boost/synchro/conc/conc_tuple.hpp>
+#endif
+
+#include <boost/interthreads/algorithm.hpp>
+#include <boost/interthreads/typeof/threader.hpp>
+
+#include <boost/test/unit_test.hpp>
+boost::mutex MTX;

-#define ABOOST_TEST_MESSAGE(MSG) std::cout << MSG << std::endl
-#define ABOOST_TEST_CHECKPOINT(MSG) std::cout << MSG << std::endl
+#define ABOOST_TEST_MESSAGE(MSG) { \
+/*boost::lock_guard<boost::mutex> g(MTX);*/ \
+std::cout << __LINE__ << MSG << std::endl; \
+}
+
+#define ABOOST_TEST_CHECKPOINT(MSG) { \
+ /*boost::lock_guard<boost::mutex> g(MTX); */\
+ std::cout << __LINE__ << MSG << std::endl; \
+}

using namespace boost::synchro;
using namespace boost;
@@ -31,23 +45,25 @@
class ReservationHandler : public boost::synchro::concurrent_component
{
protected:
- port start_;
+ port lock_or_interrupt_;
     object_port request_;
     const concurrent_component_base* sender_;
     bool closed_;
- bool end_;
+ bool interrupted_;
public:
- ReservationHandler() : sender_(0), closed_(true), end_(false) {}
+ typedef void result_type;
+ ReservationHandler() : sender_(0), closed_(true), interrupted_(false) {}
     void Lock(const concurrent_component_base* snd) {
- ABOOST_TEST_CHECKPOINT("Lock");
- port::synchronizer _(start_);
+ ABOOST_TEST_CHECKPOINT("Lock")
+ port::synchronizer _(lock_or_interrupt_);
+ ABOOST_TEST_CHECKPOINT("Locked")
         sender_ = snd;
         closed_ =false;
     }
     void Interrupt() {
- ABOOST_TEST_CHECKPOINT("Interrupt");
- port::synchronizer _(start_);
- end_ =true;
+ ABOOST_TEST_CHECKPOINT("Interrupt")
+ port::synchronizer _(lock_or_interrupt_);
+ interrupted_ =true;
     }
// void Reserve(const concurrent_component_base& snd) {
// object_port::synchronizer _(request_, snd);
@@ -56,7 +72,7 @@
// virtual void Reserve()=0;

     void Close(const concurrent_component_base* snd) {
- ABOOST_TEST_CHECKPOINT("Close");
+ ABOOST_TEST_CHECKPOINT("Close")
         object_port::synchronizer _(request_, snd);
         closed_ =true;
         sender_ = 0;
@@ -64,9 +80,9 @@
     }
     virtual void DoClose() {};
     void operator()() {
- while (!end_) {
- accept(start_);
- if (end_) break;
+ while (!interrupted_) {
+ accept(lock_or_interrupt_);
+ if (interrupted_) break;
             while (!closed_) {
                 accept(request_, sender_);
             }
@@ -87,11 +103,11 @@
     unsigned Reserve(const concurrent_component_base* snd
                     , std::string guestName
                     , unsigned noOfPersons) {
- ABOOST_TEST_CHECKPOINT("Reserve");
+ ABOOST_TEST_CHECKPOINT("Reserve")
         object_port::synchronizer _(request_, snd);
         // ...
         ++roomNo;
- ABOOST_TEST_CHECKPOINT(roomNo<<":"<<guestName<<" #"<<noOfPersons);
+ ABOOST_TEST_CHECKPOINT(roomNo<<":"<<guestName<<" #"<<noOfPersons)
         return roomNo;
     }
     virtual void DoClose(){};
@@ -102,15 +118,20 @@
//[HotelResHandler_P
class P : public boost::synchro::concurrent_component {
public:
+ typedef void result_type;
     HotelResHandler& hrh_;
     P(HotelResHandler& hrh):hrh_(hrh) {}
     void operator()() {
+ ABOOST_TEST_MESSAGE("P Lock")
         hrh_.Lock(this);
+ ABOOST_TEST_MESSAGE("P Reserve")
         unsigned rno1 = hrh_.Reserve(this, std::string("Peter Olsen"),4);
- ABOOST_TEST_CHECKPOINT(rno1);
+ ABOOST_TEST_CHECKPOINT(rno1)
+ ABOOST_TEST_MESSAGE("P Reserve")
         unsigned rno2 = hrh_.Reserve(this, std::string("Anne Nielsen"),2);
- ABOOST_TEST_CHECKPOINT(rno2);
+ ABOOST_TEST_CHECKPOINT(rno2)
         hrh_.Close(this);
+ ABOOST_TEST_MESSAGE("P Close")
     }
};
//]
@@ -118,28 +139,35 @@
//[HotelResHandler_Q
class Q : public boost::synchro::concurrent_component {
public:
+ typedef void result_type;
     HotelResHandler& hrh_;
     Q(HotelResHandler& hrh):hrh_(hrh) {}
     void operator()() {
+ ABOOST_TEST_MESSAGE("Q Lock")
         hrh_.Lock(this);
+ ABOOST_TEST_MESSAGE("Q Reserve")
         unsigned rno1 = hrh_.Reserve(this, std::string("Carmen"),5);
- ABOOST_TEST_CHECKPOINT(rno1);
+ ABOOST_TEST_CHECKPOINT(rno1)
+ ABOOST_TEST_MESSAGE("Q Reserve")
         unsigned rno2 = hrh_.Reserve(this, std::string("Javier"),1);
- ABOOST_TEST_CHECKPOINT(rno2);
+ ABOOST_TEST_CHECKPOINT(rno2)
         hrh_.Close(this);
+ ABOOST_TEST_MESSAGE("Q Close")
     }
};
//]

class R : public boost::synchro::concurrent_component {
public:
+ typedef void result_type;
     HotelResHandler& hrh_;
     R(HotelResHandler& hrh):hrh_(hrh) {}
     void operator()() {
         try {
+ ABOOST_TEST_MESSAGE("R Reserve")
             unsigned rno1 = hrh_.Reserve(this, std::string("Carmen"),5);
         }catch (bad_sender& exp) {
- ABOOST_TEST_MESSAGE("You need to Lock first");
+ ABOOST_TEST_MESSAGE("You need to Lock first")
         }catch (...) {
             std::cout << "... You need to Lock first" << std::endl;
         }
@@ -154,6 +182,13 @@
     Q q(hrh);
     R r(hrh);
#if 1
+ boost::interthreads::shared_threader ae;
+ BOOST_AUTO(hrh_act, boost::interthreads::fork(ae, boost::bind(boost::ref(hrh))));
+ BOOST_AUTO(conc, boost::interthreads::fork_all(ae, boost::bind(boost::ref(p)), boost::bind(boost::ref(q)), boost::bind(boost::ref(r))));
+ boost::interthreads::join_all(conc);
+ hrh.Interrupt();
+ boost::interthreads::join(hrh_act);
+#else
     conc_tuple<HotelResHandler, P, Q, R> conc(hrh, p, q, r);
     conc();

@@ -161,7 +196,8 @@

     hrh.Interrupt();
     conc.join();
-#else
+
+#if 0
     boost::thread thread1(boost::ref(hrh));
     boost::thread thread2(boost::ref(p));
     boost::thread thread3(boost::ref(q));
@@ -174,6 +210,9 @@
     thread3.join();
     thread4.join();
     thread1.join();
+
+#endif
+
#endif
     return 0;
}

Modified: sandbox/synchro/libs/synchro/example/IEL_Rec_Lockable_BancAccount.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/IEL_Rec_Lockable_BancAccount.cpp (original)
+++ sandbox/synchro/libs/synchro/example/IEL_Rec_Lockable_BancAccount.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,4 +1,14 @@
-#include <boost/synchro/make_lockable.hpp>
+//////////////////////////////////////////////////////////////////////////////
+//
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
+// Software License, Version 1.0. (See accompanying file
+// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+// See http://www.boost.org/libs/synchro for documentation.
+//
+//////////////////////////////////////////////////////////////////////////////
+
+#include <boost/synchro/lockable_adapter.hpp>
#include <boost/synchro/thread/recursive_mutex.hpp>
#include <boost/thread/locks.hpp>
#include <boost/synchro/lockers/strict_locker.hpp>
@@ -22,7 +32,7 @@

class BankAccount
: protected BankAccount_TN
-, public make_exclusive_lockable<boost::recursive_mutex>
+, public exclusive_lockable_adapter<boost::recursive_mutex>
{
// int balance_;
     void throw_if_not_owned(strict_locker<BankAccount>&locker) {
@@ -31,7 +41,7 @@
     }

public:
- typedef make_exclusive_lockable<boost::recursive_mutex> lockable_base_type;
+ typedef exclusive_lockable_adapter<boost::recursive_mutex> lockable_base_type;
     void Deposit(int amount) {
         lock_guard<BankAccount> guard(*this);
// lock_guard<boost::recursive_mutex> guard(*this->mutex());

Modified: sandbox/synchro/libs/synchro/example/IL_BancAccount.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/IL_BancAccount.cpp (original)
+++ sandbox/synchro/libs/synchro/example/IL_BancAccount.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,3 +1,13 @@
+//////////////////////////////////////////////////////////////////////////////
+//
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
+// Software License, Version 1.0. (See accompanying file
+// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+// See http://www.boost.org/libs/synchro for documentation.
+//
+//////////////////////////////////////////////////////////////////////////////
+
#include <boost/synchro/thread/mutex.hpp>
#include <boost/thread/locks.hpp>

Modified: sandbox/synchro/libs/synchro/example/IL_Lockable_BancAccount.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/IL_Lockable_BancAccount.cpp (original)
+++ sandbox/synchro/libs/synchro/example/IL_Lockable_BancAccount.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,4 +1,14 @@
-#include <boost/synchro/make_lockable.hpp>
+//////////////////////////////////////////////////////////////////////////////
+//
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
+// Software License, Version 1.0. (See accompanying file
+// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+// See http://www.boost.org/libs/synchro for documentation.
+//
+//////////////////////////////////////////////////////////////////////////////
+
+#include <boost/synchro/lockable_adapter.hpp>
#include <boost/synchro/thread/mutex.hpp>
#include <boost/thread/locks.hpp>

@@ -29,7 +39,7 @@
#else
//[IL_Lockable_BancAccount_BankAccount_inherit
class BankAccount
-: public make_exclusive_lockable<boost::mutex>
+: public exclusive_lockable_adapter<boost::mutex>
{
int balance_;
public:

Modified: sandbox/synchro/libs/synchro/example/IL_Rec_Lockable_BancAccount.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/IL_Rec_Lockable_BancAccount.cpp (original)
+++ sandbox/synchro/libs/synchro/example/IL_Rec_Lockable_BancAccount.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,4 +1,14 @@
-#include <boost/synchro/make_lockable.hpp>
+//////////////////////////////////////////////////////////////////////////////
+//
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
+// Software License, Version 1.0. (See accompanying file
+// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+// See http://www.boost.org/libs/synchro for documentation.
+//
+//////////////////////////////////////////////////////////////////////////////
+
+#include <boost/synchro/lockable_adapter.hpp>
#include <boost/synchro/thread/recursive_mutex.hpp>
#include <boost/thread/locks.hpp>

@@ -6,7 +16,7 @@
using namespace boost;
//[IL_Rec_Lockable_BancAccount_BankAccount
class BankAccount
-: public make_exclusive_lockable<boost::recursive_mutex>
+: public exclusive_lockable_adapter<boost::recursive_mutex>
{
/*<-*/
int balance_;

Modified: sandbox/synchro/libs/synchro/example/Master_Slave.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/Master_Slave.cpp (original)
+++ sandbox/synchro/libs/synchro/example/Master_Slave.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,11 +8,11 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/conc/concurrent_component.hpp"
-#include "boost/synchro/thread/mutex.hpp"
-#include "boost/thread.hpp"
-#include "boost/ref.hpp"
-#include "boost/synchro/conc/conc_tuple.hpp"
+#include <boost/synchro/conc/concurrent_component.hpp>
+#include <boost/synchro/thread/mutex.hpp>
+#include <boost/thread.hpp>
+#include <boost/ref.hpp>
+#include <boost/synchro/conc/conc_tuple.hpp>

using namespace boost::synchro;
using namespace boost;

Modified: sandbox/synchro/libs/synchro/example/QualifiedSingleBuf.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/QualifiedSingleBuf.cpp (original)
+++ sandbox/synchro/libs/synchro/example/QualifiedSingleBuf.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,11 +8,11 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/conc/concurrent_component.hpp"
-#include "boost/synchro/thread/mutex.hpp"
-#include "boost/thread.hpp"
-#include "boost/ref.hpp"
-#include "boost/synchro/conc/conc_tuple.hpp"
+#include <boost/synchro/conc/concurrent_component.hpp>
+#include <boost/synchro/thread/mutex.hpp>
+#include <boost/thread.hpp>
+#include <boost/ref.hpp>
+#include <boost/synchro/conc/conc_tuple.hpp>

namespace {
volatile int Run = 1;

Modified: sandbox/synchro/libs/synchro/example/SingleBuf.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/SingleBuf.cpp (original)
+++ sandbox/synchro/libs/synchro/example/SingleBuf.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,11 +8,11 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/conc/concurrent_component.hpp"
-#include "boost/synchro/thread/mutex.hpp"
-#include "boost/thread.hpp"
-#include "boost/ref.hpp"
-#include "boost/synchro/conc/conc_tuple.hpp"
+#include <boost/synchro/conc/concurrent_component.hpp>
+#include <boost/synchro/thread/mutex.hpp>
+#include <boost/thread.hpp>
+#include <boost/ref.hpp>
+#include <boost/synchro/conc/conc_tuple.hpp>

namespace {
volatile int Run = 1;

Modified: sandbox/synchro/libs/synchro/example/TrafficLight.cpp
==============================================================================
--- sandbox/synchro/libs/synchro/example/TrafficLight.cpp (original)
+++ sandbox/synchro/libs/synchro/example/TrafficLight.cpp 2009-02-12 08:15:54 EST (Thu, 12 Feb 2009)
@@ -1,6 +1,6 @@
//////////////////////////////////////////////////////////////////////////////
//
-// (C) Copyright Vicente J. Botet Escriba 2008. Distributed under the Boost
+// (C) Copyright Vicente J. Botet Escriba 2008-2009. Distributed under the Boost
// Software License, Version 1.0. (See accompanying file
// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
@@ -8,7 +8,7 @@
//
//////////////////////////////////////////////////////////////////////////////

-#include "boost/synchro/alt/alternating_component.hpp"
+#include <boost/synchro/alt/alternating_component.hpp>

using namespace boost::alt;
using namespace boost;

Date view	Thread view	Subject view	Author view

Boost-Commit list run by bdawes at acm.org, david.abrahams at rcn.com, gregod at cs.rpi.edu, cpdaniel at pacbell.net, john at johnmaddock.co.uk