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

The callback of the timer inside a thread is not called
by mozdemir 11 May '12

11 May '12

Hi, I am trying to make the attached code run but no luck. I use the compiler, gcc (Ubuntu/Linaro 4.6.3-1ubuntu5) 4.6.3. I tried all combinations. The timer callback, handle_timeout is never called. The weird thing is that the similar code in windows using msvc works fine. Could anybody help me out to figure out the issue in the code below? Thanks a lot in advance, mustafa ============================================================ #include <boost/asio.hpp> #include <boost/thread.hpp> #include <boost/date_time.hpp> #include <boost/date_time/gregorian/gregorian.hpp> #include <ctime> #include <iostream> struct time_t_traits { // The time type. typedef std::time_t time_type; // The duration type. struct duration_type { duration_type() : value(0) {} duration_type(std::time_t v) : value(v) {} std::time_t value; }; // Get the current time. static time_type now() { return std::time(0); } // Add a duration to a time. static time_type add(const time_type& t, const duration_type& d) { return t + d.value; } // Subtract one time from another. static duration_type subtract(const time_type& t1, const time_type& t2) { return duration_type(t1 - t2); } // Test whether one time is less than another. static bool less_than(const time_type& t1, const time_type& t2) { return t1 < t2; } // Convert to POSIX duration type. static boost::posix_time::time_duration to_posix_duration( const duration_type& d) { return boost::posix_time::seconds(d.value); } }; typedef boost::asio::basic_deadline_timer< std::time_t, time_t_traits> time_t_timer; void handle_timeout(const boost::system::error_code&) { std::cout << "handle_timeout\n"; } boost::asio::io_service io_service; void workerFunc() { using namespace boost::gregorian; boost::posix_time::seconds workTime(8); std::cout << "Worker: running" << std::endl; try { boost::asio::strand io_strand(io_service); time_t_timer timer(io_service); timer.expires_from_now(5); std::cout << "Starting synchronous wait\n"; timer.wait(); std::cout << "Finished synchronous wait\n"; timer.expires_from_now(5); std::cout << "Starting asynchronous wait\n"; // timer.async_wait(&handle_timeout); // timer.async_wait(&handle_timeout); // std::cout << "current UTC time is '" << to_simple_string(microsec_clock::universal_time()) << "'" << std::endl; // std::cout << "current local time is '" << to_simple_string(microsec_clock::local_time()) << "'" << std::endl; std::cout << "timer is set to expire at '" << timer.expires_at() << "'" << std::endl; timer.async_wait(io_strand.wrap(&handle_timeout)); std::cout << "Finished asynchronous wait\n"; } catch (std::exception& e) { std::cout << "Exception: " << e.what() << "\n"; } // Pretend to do something useful... boost::this_thread::sleep(workTime); std::cout << "Worker: finished" << std::endl; while(true) { boost::this_thread::sleep(boost::posix_time::seconds(1)); } } int main(int argc, char* argv[]) { std::cout << "main: startup" << std::endl; boost::thread thrd_io(boost::bind(&boost::asio::io_service::run, &io_service)); std::cout << "main: after thrd_io" << std::endl; boost::thread workerThread(workerFunc); std::cout << "main: after workerThread" << std::endl; // std::cout << "main: waiting for thread" << std::endl; while ( true ) { try { // io_service.poll(); io_service.run(); // boost::this_thread::sleep(boost::posix_time::milliseconds( 20 )); } catch (const boost::thread_interrupted&) { // Thread interruption request received, break the loop std::cout << "[" << boost::this_thread::get_id() << "] WorkerThread Thread interrupted. Exiting thread."; break; } catch ( std::exception & ex ) { std::cout << "[" << boost::this_thread::get_id() << "] Exception: " << ex.what(); } } workerThread.join(); std::cout << "main: done" << std::endl; return 0; } ===================================================== this is the output when the exe file is run. You don't see this line: "handle_timeout" ===================================================== $./timer main: startup main: after workerThread main: after thrd_io Worker: running Starting synchronous wait Finished synchronous wait Starting asynchronous wait timer is set to expire at '1336627143' Finished asynchronous wait Worker: finished -- View this message in context: http://boost.2283326.n4.nabble.com/The-callback-of-the-timer-inside-a-threa… Sent from the Boost - Users mailing list archive at Nabble.com.

2 3

How can i install 32bit libboost lib on Debian6-64bit platform
by clive 11 May '12

11 May '12

Hi,all friends I build my project on Debian6-32bit platform, It works ok. I copy the build result to Debian6-64bit platform and run, it shows:error while loading shared libraries:libboost_regex.so.1.42.0:can not open shared object file:No such file or directory Then i do whereis libboost_regex.so.1.42.0, it shows: libboost_regex.so.1.42: /usr/lib/libboost_regex.so.1.42.0 /usr/lib64/libboost_regex.so.1.42.0 Then i add /usr/lib/ in ld.so.conf, then i run my project, it shows:error while loading shared libraries: libboost_regex.so.1.42.0: wrong ELF class: ELFCLASS64 I'm sure that install libboost-regex on Debian6-64bit platform, the lib don't compatible 32bit. How can i install 32bit libboost lib on Debian6-64bit platform?

1 0

Re: [Boost-users] Is boost::asio::ip::tcp::iostream thread safe?
by boost 11 May '12

11 May '12

Thank you all ----- Original Message -----From: Michael Chisholm <chisholm(a)mitre.org> To: boost-users(a)lists.boost.org On 5/10/2012 5:34 PM, Michael Chisholm wrote: > On 5/10/2012 10:38 AM, Igor R wrote: >>> hi all, >>> I use ip::tcp::iostream but I don't know if it is thread safe, and I >>> cannot find the answer in boost document. >>> I read from ip::tcp::iostream in the receiver thread, and send >>> request in another thread. >>> Now I protected the stream with a mutex. But the problem is that, if >>> I do not send request, the server will not response, >>> and the receiver will block on read with lock, and the sender cannot >>> hold the lock and cannot send the request, deadlock. >>> >>> Is there anyone know that? Please kindly give me an answer. >> >> >> As far as I can see, it's not thread-safe. >> _______________________________________________ >> Boost-users mailing list >> Boost-users(a)lists.boost.org >> http://lists.boost.org/mailman/listinfo.cgi/boost-users >> >> > > Definitely not. I had to create my own socket-based stream with > boost.iostreams to avoid crashes. > > Andy I should add that boost.iostreams isn't thread-safe either. But you can create different istream and ostream objects which wrap the same underlying raw socket descriptor, to get concurrent reads and writes to the socket. Andy _______________________________________________ Boost-users mailing list Boost-users(a)lists.boost.org http://lists.boost.org/mailman/listinfo.cgi/boost-users

1 0

Is boost::asio::ip::tcp::iostream thread safe?
by boost 10 May '12

10 May '12

hi all, I use ip::tcp::iostream but I don't know if it is thread safe, and I cannot find the answer in boost document. I read from ip::tcp::iostream in the receiver thread, and send request in another thread. Now I protected the stream with a mutex. But the problem is that, if I do not send request, the server will not response, and the receiver will block on read with lock, and the sender cannot hold the lock and cannot send the request, deadlock. Is there anyone know that? Please kindly give me an answer. Best Regards Zhanwei Wang

3 3

[Boost users] [ublas] Type conversion warning with ublas::bounded_vector
by Matija Kecman 10 May '12

10 May '12

Hi Boost users! Is there a way for boost.ublas to warn of type conversions with ublas::bounded_vector's? I'm using this library for scientific computations and I came across this problem, I have quite a large code so I would be useful to know if this mistake occurs elsewhere. Here is a code example: int main() { double d = M_PI; unsigned u = d; cout << "d = " << d << endl; cout << "u = " << u << endl; bounded_vector<double,3> dVec = ublas::scalar_vector<double>(3,M_PI); bounded_vector<unsigned,3> uVec = dVec; // ATTENTION: type conversion! cout << "dVec = " << dVec << endl; cout << "uVec = " << uVec << endl; return 0; } When I compile this using g++ 4.6.1: g++ -g3 -Wall -Wextra -ansi -pedantic -Wconversion -std=c++0x test.cpp -o test I get the following warnings: test.cpp: In function ‘int main()’: test.cpp:11:22: warning: conversion to ‘unsigned int’ from ‘double’ may alter its value [-Wconversion] Program output: $ ./test d = 3.14159 u = 3 dVec = [3](3.14159,3.14159,3.14159) uVec = [3](3,3,3) The compiler produced a warning for the conversion of the scalars but there was no warning for the ublas conversion, is there a way of having the compiler write a warning in that case? -Wconversion or any of the other options don't do this. Best, Matija

1 0

[Boost users] [Program_options] Is Boost.Program_options available as a header?
by Matija Kecman 10 May '12

10 May '12

Hi Boost users, I'm quite new to boost. I have written a program using the Boost Program Options library. In order to compile it I have to link with the boost program options library. I would like to run my program on a computer which only has access to boost headers. I was wondering if the program options library is available as a header only? If not, it would be interesting to know the reason for that :) Best, Matija

1 0

time variant uuid
by Victor Whiskey Yankee 10 May '12

10 May '12

Hello List, How can I create uuids so that the first one compares less than the next one.. something like this: boost::uuids::t1 = boost::uuids::random_generator()(); boost::uuids::t2 = boost::uuids::random_generator()(); BOOST_REQUIRE (t1 < t2); I don't see how to replace random_generator() with a time-based variant, if that even makes sense. If this can be done, then is there a way to extract the date+time from it? Thanks, Vic

3 2

[Pool] Why is pool allocator slower than ordinary allocator?
by Mr.C64 10 May '12

10 May '12

Please see this thread on StackOverflow: http://tinyurl.com/chh4yxj Thanks.

5 13

[Statechart] Pass variable parameter to Player ctor?
by Dick Bridges 10 May '12

10 May '12

In the PingPong example, I'm trying to pass a std::string variable to the Player ctor through the fifo_schedular<>create_processor<>() in main(). No joy. Error: no matching signature. I'm missing something obvious. I've stared at that first override in the boost header and tried everything I could think of. Dead give away that I don't understand: I'm "trying" things. %>[ I'd sure appreciate it if someone could point me in the right direction. Are there async examples that pass variables through create_processor() to the ctorS? Thanks for taking the time to read this, Dick

2 1

[build] How can I change how the linker is called?
by Daryle Walker 10 May '12

10 May '12

This is for my PowerPC Tiger Mac system. I've installed GCC 4.7 fromMacPorts on it. I have it set in C++11 mode. Yesterday, I wrote on the list that I couldn't get the example file torun in my new trial project. (It's at<https://github.com/CTMacUser/Unionize>.) As soon as I added acompile-fail test and the corresponding line to Jamfile, everything worked! Sort of. The compile-fail test fails as expected (at compile-time).The example file still doesn't run due to a linking error I've seen before: //========================================[daryle@daryle-walkers-emac:test]$ b2 toolset=gcc-4.7...found 30 targets......updating 14 targets...common.mkdir bincommon.mkdir bin/super_union_basics.testcommon.mkdir bin/super_union_basics.test/gcc-4.7common.mkdir bin/super_union_basics.test/gcc-4.7/debuggcc.compile.c++ bin/super_union_basics.test/gcc-4.7/debug/super_union_basics.ogcc.link bin/super_union_basics.test/gcc-4.7/debug/super_union_basicsld: unknown option: --start-groupcollect2: error: ld returned 1 exit status "g++-mp-4.7" -o "bin/super_union_basics.test/gcc-4.7/debug/super_union_basics" -Wl,--start-group "bin/super_union_basics.test/gcc-4.7/debug/super_union_basics.o" -Wl,-Bstatic -Wl,-Bdynamic -Wl,--end-group -g ...failed gcc.link bin/super_union_basics.test/gcc-4.7/debug/super_union_basics......skipped <pbin/super_union_basics.test/gcc-4.7/debug>super_union_basics.run for lack of <pbin/super_union_basics.test/gcc-4.7/debug>super_union_basics...common.mkdir bin/super_union_fail_test.testcommon.mkdir bin/super_union_fail_test.test/gcc-4.7common.mkdir bin/super_union_fail_test.test/gcc-4.7/debuggcc.compile.c++ bin/super_union_fail_test.test/gcc-4.7/debug/super_union_fail_test.oIn file included from super_union_fail_test.cpp:9:0://======================================== Now "ld" points to a version of ld64 from MacPorts, but that error hasshown up before this. I don't think my versions of "ld" have"--start-group" or "--end-group" options. What should they be instead,and where do I make these changes? (Even if no one here can answer thefirst part, they should be able to answer the second. That's where I'llmake the changes if I have to ask about the first part elsewhere.) Oh, I've uploaded the version of the project used here. Its SHA ID is"535241c3f13a9488bd845549ce3b1cf661ffcbac". (It's the latest as of this writing.) Daryle W.

2 2