- Boost-users - lists.preview.boost.org

[msm] access to root fsm
by Alexander Mingalev 23 Jul '13

23 Jul '13

I have main fsm with two sub-levels. The problem is, the sub-fsms need data which is held in root fsm, like: struct SomeAction { template <typename EVT, typename FSM, typename SourceState, typename TargetState> void operator()(EVT&, FSM& fsm, SourceState&, TargetState&) const { // ... } }; Instance of fsm here might be root fsm as well as sub-fsm. I see two possible solutions: 1. use sm_ptr policy and store parent pointer in each sub-fsm In this case access might look like this: fsm.parent_->data; (access from 1-level fsm) fsm.parent_->parent_->data; (access from 2-level fsm) doesn't look so nice, besides, documentation states that using sm_ptr is deprecated. 2. recursively traverse all states, detect fsm's and store root pointer typedef RootFSM::stt stt; typedef boost::msm::back::generate_state_set<stt>::type all_states; boost::mpl::for_each<all_states, boost::msm::wrap<mpl::placeholders::_1> > (find_sub_fsm<stt>()); template <typename stt> struct find_sub_fsm { template <class StateType> void operator()(boost::msm::wrap<StateType>& state) const { // ??? // state.root_ = &g_root; // do the recurs } }; How to detect that StateType is sub-fsm? 3. Maybe, there is a easier way to communicate between sub-fsm's?

3 3

packaged_task returning boost::any with BOOST_THREAD_VERSION>=3
by Nicolas P 22 Jul '13

22 Jul '13

Hello, I'm trying to enable boost (1.54) thread version >=3 with my code and i run into a package_task compilation issue I reduced my issue to a minimal test program that compiles fine on windows 7, but fails to compile on osx and linux (compilers info bellow) with BOOST_THREAD_VERSION = 3 or 4 (fine with boost thread version 2) test succeded on - Windows 7 with Visual 2010 Express sp1 with SDK 7.1 ok test failed on - Mac os x 10.6 Xcode 4.2 : gcc 4.2.1 and clang 3.0 - Mac os x 10.7 Xcode 4.4 : gcc and clang 4.0 - Ubuntu 13.04 gcc 4.7.4 The minimal test program : #define BOOST_THREAD_PROVIDES_SIGNATURE_PACKAGED_TASK #define BOOST_THREAD_VERSION 4 #include <boost/any.hpp> #include <boost/thread.hpp> #include <boost/function.hpp> boost::any process() { return 1; } int main() { boost::function< boost::any () > f = &process ; //boost::packaged_task< boost::any () > task(&process); // Works fine boost::packaged_task< boost::any () > task(f); return 0; } // Replacing 'boost::any' with 'int' make it compile. Error log with clang on os x 10.6 : In file included from /tmp/packaged_task_test/main.cpp:5: In file included from boost/thread.hpp:24: boost/thread/future.hpp:2298:27: error: no matching member function for call to 'set_value_at_thread_exit' this->set_value_at_thread_exit(f()); ~~~~~~^~~~~~~~~~~~~~~~~~~~~~~~ boost/thread/future.hpp:2857:33: note: in instantiation of member function 'boost::detail::task_object<boost::function<boost::any ()>, boost::any ()>::do_apply' requested here task = task_ptr(new task_object_type(f)); ^ /tmp/packaged_task_test/main.cpp:17:43: note: in instantiation of function template specialization 'boost::packaged_task<boost::any ()>::packaged_task<boost::function<boost::any ()> >' requested here boost::packaged_task< boost::any () > task(f); ^ boost/thread/future.hpp:673:18: note: candidate function not viable: no known conversion from 'result_type' (aka 'boost::any') to 'source_reference_type' (aka 'boost::any &') for 1st argument void set_value_at_thread_exit(source_reference_type result_) ^ boost/thread/future.hpp:687:18: note: candidate function not viable: no known conversion from 'result_type' (aka 'boost::any') to 'rvalue_source_type' (aka 'rv<boost::any> &') for 1st argument void set_value_at_thread_exit(rvalue_source_type result_) ^ boost/thread/future.hpp:2329:25: error: no matching member function for call to 'mark_finished_with_result' this->mark_finished_with_result(f()); ~~~~~~^~~~~~~~~~~~~~~~~~~~~~~~~ boost/thread/future.hpp:2857:33: note: in instantiation of member function 'boost::detail::task_object<boost::function<boost::any ()>, boost::any ()>::do_run' requested here task = task_ptr(new task_object_type(f)); ^ /tmp/packaged_task_test/main.cpp:17:43: note: in instantiation of function template specialization 'boost::packaged_task<boost::any ()>::packaged_task<boost::function<boost::any ()> >' requested here boost::packaged_task< boost::any () > task(f); ^ boost/thread/future.hpp:627:18: note: candidate function not viable: no known conversion from 'result_type' (aka 'boost::any') to 'source_reference_type' (aka 'boost::any &') for 1st argument void mark_finished_with_result(source_reference_type result_) ^ boost/thread/future.hpp:633:18: note: candidate function not viable: no known conversion from 'result_type' (aka 'boost::any') to 'rvalue_source_type' (aka 'rv<boost::any> &') for 1st argument void mark_finished_with_result(rvalue_source_type result_) ^ 2 errors generated. Am i missing something ? Regards, Nicolas

1 0

[property_tree] Parsing vectors of objects
by Michael Powell 21 Jul '13

21 Jul '13

Hello, I want to parse to and from Xml (or possibly Json) using the property tree. I've got a simple POCO parsing, but now I need to include vectors of objects. Furthermore, I understand the property tree paths are pretty cumbersome. Not so much through a thin vernier, template function, something like that, but anywho... Here's the desired output I want in Xml, something like this: <output> <apples> <apple grower="red" /> <apple grower="green" /> <apple grower="golden" /> </apples> <oranges> <orange freshness="picked" /> <orange freshness="market" /> <orange freshness="store" /> </oranges> <items> <item name="" id="">1234</item> <item name="" id="">1234</item> <item name="" id="">1234</item> </items> </output> I understand the tree path might look something like this "output.apples.apple.<xmlattr>.grower", but what about the vector? Probably want to be trimming white spaces, indenting, as well. Regards, Michael Powell

2 2

Boost integration in Visual Studio 2010
by Georg.Kellerer＠lfu.bayern.de 20 Jul '13

20 Jul '13

Hi, we're using boost inour projects and all works fine. Our projects are standing under version control in a subversion repository. Our problem is that every developper had installed boost in a diferent place. Is their a way to get the reference to boost in a user speciffic configuration place? At the moment we have a fix path c:\dev\boost... but that does not fit for every developpers machine. Thanks for help, Georg ---------------------------------------------- Bayerisches Landesamt für Umwelt Referat Z6: IuK-Steuerung, Aufbau von Informationssystemen Hans-Högn-Str. 12 95030 Hof/Saale Tel.: 09281/1800-4572

6 7

[boost-users][Container] Compilation error using new "static_vector".
by Jupp Tscheak 20 Jul '13

20 Jul '13

Hello boost users, Please consider the following example: [code] #include "CGAL/Cartesian.h" #include "CGAL/Polygon_2.h" #include "boost/container/static_vector.hpp" typedef CGAL::Cartesian<double> Kernel; typedef Kernel::Point_2 Point2d; typedef CGAL::Polygon_2<Kernel, boost::container::static_vector<Point2d, 100> > Polygon2d; Polygon2d p; p = Polygon2d(); [/code] Compiling this code snippet with GCC results in following error message: [error] error: no match for 'operator=' in 'p = CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >((*(const Traits*)(& CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >::Traits())))' note: candidate is: CGAL-4.2/include/CGAL/Polygon_2.h:68:7: note: CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >& CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >::operator=(CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >&) CGAL-4.2/include/CGAL/Polygon_2.h:68:7: note: no known conversion for argument 1 from 'sensor::Polygon2d {aka CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >}' to 'CGAL::Polygon_2<CGAL::Cartesian<double>, boost::container::static_vector<CGAL::Point_2<CGAL::Cartesian<double> >, 100u> >&' [/error] I apologize for this concrete example using CGAL, but maybe someone has advice for me? Thanks in advance! Jupp Tscheak

2 2

Boost::thread instantiation and clean up
by Riskybiz 19 Jul '13

19 Jul '13

I have a C++ DLL written in Visual Studio for use on Windows 7 using Boost 1_53_0. The following two functions, CREATE & DESTROY, are called to launch and shutdown a simple ZeroMQ server (code below). The thread is launched and the server on that thread goes into a continuous listening loop (as intended). When it comes time to shut down the server then the thread is interrupted to cause thread termination (though I cannot tell if the interrupt is actually working as I get no output from the catch block). The boost::thread object is then deleted. Problem is that the 3rd party application which this DLL is designed for is prone to crashing after DESTROY is called and I think it's because either the boost::thread resources are not being freed/cleared up properly or the boost::thread is not interrupting. Have I properly handled thread instantiation, interruption and object destruction here? With thanks, Riskybiz. static bool createCalled = false;//initialise static variable static bool destroyCalled = false;//initialise static variable static boost::thread *serverThread = nullptr; int __stdcall CREATE() { if(createCalled == false) { createCalled = true; OutputDebugStringA("TestDataAccess: CREATE"); serverThread = new boost::thread(ListenOnReplySocket);//create instance of boost::thread object return 0; } return 1; } int __stdcall DESTROY() { if(createCalled == true && destroyCalled == false) { destroyCalled = true; OutputDebugStringA("TestDataAccess: DESTROY"); serverThread->interrupt();//set flag for interruption delete serverThread; return 0; } return 1; } Simple ZeroMQ server: #ifndef ZMQ_COMMUNICATIONS_H//if not defined already #define ZMQ_COMMUNICATIONS_H//then define it #define _WINSOCK2API_ //stops windows.h including winsock2.h #include <zmq.hpp> #include "boost\thread.hpp" int ListenOnReplySocket() { // Prepare our context and socket zmq::context_t context (1); zmq::socket_t socket (context, ZMQ_REP); socket.bind ("tcp://*:5555"); boost::this_thread::interruption_enabled(); try { while (true) { zmq::message_t request; // Wait for next request from client socket.recv (&request); char buffer[50]; int j; j = sprintf_s(buffer, 50, "TestDataAccess: ZMQComms: Hello"); OutputDebugStringA(buffer); // Do some 'work' Sleep (1000); // Send reply back to client zmq::message_t reply (5); memcpy ((void *) reply.data (), "World", 5); socket.send (reply); boost::this_thread::interruption_point();//check iterruption flag } } catch(boost::thread_interrupted) { char buffer[100]; int j; j = sprintf_s(buffer, 100, "TestDataAccess: ZMQComms: Server Thread Interrupted"); OutputDebugStringA(buffer); return 0; } } #endif

3 2

[fusion] how to get the tuple of min values of 2 tuples whatever their length?
by Frédéric Bron 18 Jul '13

18 Jul '13

I have two tuples: typedef boost::tuple<double, int, std::string> Key; Key k1, k2; I would like to get the tuple of the min values for each corresponding value between k1 and k2: Key min=Key(std::min(k1.get<0>(), k2.get<0>()), std::min(k1.get<1>(), k2.get<1>()), std::min(k1.get<2>(), k2.get<2>())); but I do not know the length of the tuple so I am looking for a generic algorithm... Is this possible with boost::fusion or boost::mpl? I have tried with boost::fusion::accumulate but I need to now in the functor the index of the value that is currently accessed to compare to the right one in k1. Frédéric

5 7

Named condition not behaving as expected
by rudasi 18 Jul '13

18 Jul '13

I have 2 processes (producer and consumer) sharing an int deque in shared memory, I have the producer process put 2 numbers in the deque and then it gets in a wait state losing its mutex lock. I then have the consumer process removing the numbers and printing them. It then does a notify on the condition which the producer is waiting on. The consumer then goes on its own wait on a second condition. After this case the producer does not wake up. I am using the same mutex between the processes. I have removed some of the code where i set up the shared memory and create the mutex and conditions. Producer process: int main() { scoped_lock<named_mutex> lock(mutex); while(1) { while (MyDeque->size() == 2) { full.wait(lock); std::cout << "unlocked producer" << std::endl; } if (MyDeque->size() == 0) { *a = 2; MyDeque->push_back(a); } if (MyDeque->size() == 1) { *b = 4; MyDeque->push_back(b); empty.notify_one(); } } } Consumer process: int main() { scoped_lock<named_mutex> lock(mutex); while(1) { //volatile int size = MyDeque->size(); while (MyDeque->size() == 0) { empty.wait(lock); } if (MyDeque->size() == 2) { std::cout << "Consumer: " << *MyDeque->front() << std::endl; MyDeque->pop_front(); } if (MyDeque->size() == 1) { std::cout << "Consumer: " << *MyDeque->front() << std::endl; MyDeque->pop_front(); full.notify_one(); } } } While debugging things seem to go ok for the first iteration, the producer puts numbers 2 and 4 on the deque then waits on the full condition. The Consumer then gets the lock, prints these numbers, does a notify_one on the full condition and then goes into a wait. After this the producer does not wake up. -- View this message in context: http://boost.2283326.n4.nabble.com/Named-condition-not-behaving-as-expected… Sent from the Boost - Users mailing list archive at Nabble.com.

1 0

[serialization] platform independence (32 & 64bit windows)
by आशीष वर्मन् 18 Jul '13

18 Jul '13

Hi We are using boost serialization our product which was 32bit only till now. Now we have started building it on 64bit as well. On finding that boost::binary_archive is not platform independent, we seem to have 2 options: 1. Use text_archive - (but are worried about performance since the serialized data is approx 500MB even after gzip compression) 2. Use the eos portable archive - (but it is updated only till boost 1.49. We are using 1.53) So my questions are: 1. One (and only one) of our archives created by our 32 bit executable is successfully read in by the 64 bit executable while the rest throw exception on reading the archive signature. If the platform is encoded in the signature, why is that one archive being read in successfully. 2. Which of the above two approaches would be better and why. Thanks in advance. Yours Sincerely Ashish Varman

3 3

Boost::Interprocess mutex with condition variable
by Riskybiz 17 Jul '13

17 Jul '13

I'm trying to get a working implementation of a boost::interprocess named_mutex with a named_condition_variable. I have created the following toy console applications to try and understand what's necessary. The console application 'Sleeper' is run first; it simply creates some resources and then goes to sleep. Then 'Waker' is run with the intention that it would cause the 'Sleeper' instance to resume execution and print out a further message. Ultimately the intention is to have one Waker process and several Sleeper processes. When each application is run in a separate terminal window then the Sleeper process sleeps and the Waker process tries to wake; but it is ineffective. Can anyone advise what is wrong here and how to get the notify_all() to take effect? Thanks Riskybiz. // Sleeper.cpp : Defines the entry point for the console application. // #include "stdafx.h" #include <boost/interprocess/managed_shared_memory.hpp> #include <boost/interprocess/sync/named_mutex.hpp> #include <boost/interprocess/sync/named_condition.hpp> #include <iostream> int _tmain(int argc, _TCHAR* argv[]) { using namespace boost::interprocess; //Clean up resources from any prior instances named_condition::remove("msm_named_condition"); named_mutex::remove("msm_named_mutex"); //shared_memory_object::remove("msm"); //Setup shared memory resources managed_shared_memory *msm = new managed_shared_memory(create_only, "msm", 10000); named_mutex *nm = new named_mutex(create_only, "msm_named_mutex"); named_condition *nc = new named_condition(create_only, "msm_named_condition"); try { scoped_lock<named_mutex> lock(*nm);//acquire scoped lock for mutex std::cout << "Going to sleep now...." << std::endl; nc->wait(lock);//induce wait std::cout << "Wide awake and back in the room" << std::endl;//print this out on waking up } catch(interprocess_exception &ipe) { std::cout << "Error in Sleeper process: interprocess_exception: "<< ipe.what() << std::endl; } //Clean up delete msm; delete nm; delete nc; return 0; } // Waker.cpp : Defines the entry point for the console application. // #include "stdafx.h" #include <boost/interprocess/managed_shared_memory.hpp> #include <boost/interprocess/sync/named_mutex.hpp> #include <boost/interprocess/sync/named_condition.hpp> #include <iostream> int _tmain(int argc, _TCHAR* argv[]) { using namespace boost::interprocess; //Setup shared memory resources managed_shared_memory *msm = new managed_shared_memory(open_only, "msm"); named_mutex *nm = new named_mutex(open_only, "msm_named_mutex"); named_condition *nc = new named_condition(open_only, "msm_named_condition"); try { scoped_lock<named_mutex> lock(*nm);//acquire scoped lock for mutex std::cout << "Going to Notify...." << std::endl; nc->notify_all();//notify to release the wait condition std::cout << "Wakey Wakey....Notified...." << std::endl; } catch(interprocess_exception &ipe) { std::cout << "Error in Waker process: interprocess_exception: "<< ipe.what() << std::endl; } //Clean up delete msm; delete nm; delete nc; return 0; }

2 1