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

[Interprocess] : problem with large vector of maps in memory mapped file
by Steven Maenhout 11 Jul '11

11 Jul '11

Dear all, I'm using Boost 1.47 on Linux x86_64 in combination with gcc version 4.5.1. I'm trying to implement a large vector of maps in a memory mapped file. My code works fine on small example cases but crashes randomly when trying to store larger datasets. The application generally runs fine for a few days before a segementation fault occurs which makes debugging very time consuming. A trimmed down version of the code looks like this: typedef boost::interprocess::managed_mapped_file::segment_manager SegmentManager_t; typedef boost::interprocess::allocator<void, SegmentManager_t> VoidAllocator_t; typedef std::pair<const uint,double> MapValue_t; typedef boost::interprocess::allocator<MapValue_t , SegmentManager_t> MapValueAllocator_t; typedef boost::interprocess::map<uint,double,std::less<uint>,MapValueAllocator_t> Map_t; typedef boost::interprocess::allocator<Map_t,SegmentManager_t> MapAllocator_t; typedef boost::interprocess::vector<Map_t,MapAllocator_t> VectorofMaps_t; boost::interprocess::managed_mapped_file m_mfile=managed_mapped_file(open_or_create, TEMPFILEPATH, TEMPFILEPATHSIZE); VoidAllocator_t alloc_inst (m_mfile.get_segment_manager()); VectorofMaps_t* m_pS=m_mfile.construct<VectorofMaps_t>(anonymous_instance)(numsparserows,Map_t(std::less<uint>(),alloc_inst),alloc_inst); I've managed to obtain a stack trace which pinpoints the problem at the use of the function lower_bound: Map_t::iterator mapiter=(*m_pS)[row].lower_bound(col); I realize that such random segfaults could be the result of a hardware problem (memory corruption, cpu overheating, hard drive storing the memory mapped file (ssd)) but stress testing these components has not revealed any problems. I am therefore hoping that somebody would be able to get some more information from the stack trace provided below. Any help or advice on how to identify the problem would be greatly appreciated. Steven #0 0x0000000000720244 in std::less<unsigned int>::operator() (this=0x7fffffffc390, __x=@0x3ff07fcf9f552438, __y=@0x7fffffffc5c0) at /usr/lib/gcc/x86_64-redhat-linux/4.5.1/../../../../include/c++/4.5.1/bits/stl_function.h:230 #1 0x0000000000721fc7 in boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > >::operator()<std::pair<unsigned int const, double>, unsigned int> (this=0x7fffffffc390, key1=..., key2=@0x7fffffffc5c0) at /home/smaenhout/c++/boost/include/boost/interprocess/containers/container/detail/tree.hpp:78 #2 0x0000000000721b4f in boost::container::containers_detail::rbtree<unsigned int, std::pair<unsigned int const, double>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> >, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family, boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, 0ul>, boost::interprocess::iset_index> > >::key_node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > > >::operator()<boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void> >, unsigned int> (this=0x7fffffffc390, key1=..., key2=@0x7fffffffc5c0) at /home/smaenhout/c++/boost/include/boost/interprocess/containers/container/detail/tree.hpp:337 #3 0x0000000000721747 in boost::intrusive::detail::key_nodeptr_comp<boost::container::containers_detail::rbtree<unsigned int, std::pair<unsigned int const, double>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> >, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family>, boost::interprocess::iset_index> > >::key_node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > > >, boost::intrusive::rbtree_impl<boost::intrusive::setopt<boost::intrusive::detail::base_hook_traits<boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void, long, unsigned long, 0u> >, boost::intrusive::rbtree_node_traits<boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, true>, (boost::intrusive::link_mode_type)0, boost::intrusive::default_tag, 3>, boost::container::containers_detail::node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > >, boost::container::containers_detail:: rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void, long, unsigned long, 0u> > >, unsigned long, true> > >::operator()<boost::interprocess::offset_ptr<boost::intrusive::compact_rbtree_node<boost::interprocess::offset_ptr<void> >, long, unsigned long, 0u>, unsigned int> (this=0x7fffffffc390, key1=..., key2=@0x7fffffffc5c0) at /home/smaenhout/c++/boost/include/boost/intrusive/detail/utilities.hpp:236 #4 0x00000000007213cc in boost::intrusive::detail::tree_algorithms<boost::intrusive::rbtree_node_traits<boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, true> >::lower_bound<unsigned int, boost::intrusive::detail::key_nodeptr_comp<boost::container::containers_detail::rbtree<unsigned int, std::pair<unsigned int const, double>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> >, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family>, boost::interprocess::iset_index> > >::key_node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > > >, boost::intrusive::rbtree_impl<boost::intrusive::setopt<boost::intrusive::detail::base_hook_traits<boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void> >, boost::intrusive::rbtree_node_traits<boost::interprocess::offset_ptr<void>, true>, (boost::intrusive::link_mode_type)0, boost::intrusive::default_tag, 3>, boost::container::containers_detail::node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > >, boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void> > >, unsigned long, true> > > > (header=..., key=@0x7fffffffc5c0, comp=...) at /home/smaenhout/c++/boost/include/boost/intrusive/detail/tree_algorithms.hpp:839 #5 0x0000000000720e32 in boost::intrusive::rbtree_algorithms<boost::intrusive::rbtree_node_traits<boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, true> >::lower_bound<unsigned int, boost::intrusive::detail::key_nodeptr_comp<boost::container::containers_detail::rbtree<unsigned int, std::pair<unsigned int const, double>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> >, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family>, boost::interprocess::iset_index> > >::key_node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > > >, boost::intrusive::rbtree_impl<boost::intrusive::setopt<boost::intrusive::detail::base_hook_traits<boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void> >, boost::intrusive::rbtree_node_traits<boost::interprocess::offset_ptr<void>, true>, (boost::intrusive::link_mode_type)0, boost::intrusive::default_tag, 3>, boost::container::containers_detail::node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > >, boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void> > >, unsigned long, true> > > > (header=..., key=@0x7fffffffc5c0, comp=...) at /home/smaenhout/c++/boost/include/boost/intrusive/rbtree_algorithms.hpp:470 #6 0x00000000007207f1 in boost::intrusive::rbtree_impl<boost::intrusive::setopt<boost::intrusive::detail::base_hook_traits<boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void, long, unsigned long, 0u> >, boost::intrusive::rbtree_node_traits<boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, true>, (boost::intrusive::link_mode_type)0, boost::intrusive::default_tag, 3>, boost::container::containers_detail::node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > >, boost::container::containers_detail::rbtree_node<std::pair<unsigned int const, double>, boost::interprocess::offset_ptr<void, long, unsigned long, 0u> > >, unsigned long, true> >::lower_bound<unsigned int, boost::container::containers_detail::rbtree<unsigned int, std::pair<unsigned int const, double>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> >, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family>, boost::interprocess::iset_index> > >::key_node_compare<boost::container::containers_detail::value_compare_impl<unsigned int, std::pair<unsigned int const, double>, std::less<unsigned int>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> > > > > (this=0x7fc8f21bef08, key=@0x7fffffffc5c0, comp=...) at /home/smaenhout/c++/boost/include/boost/intrusive/rbtree.hpp:1064 #7 0x00000000007202ec in boost::container::containers_detail::rbtree<unsigned int, std::pair<unsigned int const, double>, boost::container::containers_detail::select1st<std::pair<unsigned int const, double> >, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family, boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, 0ul>, boost::interprocess::iset_index> > >::lower_bound (this=0x7fc8f21bef00, k=@0x7fffffffc5c0) at /home/smaenhout/c++/boost/include/boost/interprocess/containers/container/detail/tree.hpp:853 #8 0x000000000071fea8 in boost::container::map<unsigned int, double, std::less<unsigned int>, boost::interprocess::allocator<std::pair<unsigned int const, double>, boost::interprocess::segment_manager<char, boost::interprocess::rbtree_best_fit<boost::interprocess::mutex_family, boost::interprocess::offset_ptr<void, long, unsigned long, 0u>, 0ul>, boost::interprocess::iset_index> > >::lower_bound ( this=0x7fc8f21bef00, x=@0x7fffffffc5c0) at /home/smaenhout/c++/boost/include/boost/interprocess/containers/container/map.hpp:638

1 0

cann't compile Regular Expressions to Split a String code
by Eric Lin 11 Jul '11

11 Jul '11

Dear Boost programers: I copied a piece simple Using Regular Expressions to Split a String code from book(c++ cookbook) chapter 4 section 24, page 196-197, Example code 4.33 --------------------------------------------------------------------- // Example 4-33. Using Boost's regular expressions #include <iostream> #include <string> #include <boost/regex.hpp> int main() { std::string s= "who,lives:in-a,pineapple under the sea?"; boost::regex re(",|:|-|\\s+"); // Create the reg exp boost::sregex_token_iterator // Create an iterator using a p(s.begin(), s.end(), re, -1); // sequence and that reg exp boost::sregex_token_iterator end; // Crate an end_of_reg_exp // marker while (p != end) std::cout << *p++ << '\n'; } ------------------------ source code http://examples.oreilly.com/9780596007614/ > --------------------------------------------- > g++ 4-33.cpp > /tmp/ccx4JXEA.o: In function `boost::basic_regex<char, > boost::regex_traits<char, boost::cpp_regex_traits<char> > >::assign(char > const*, char const*, unsigned int)': > 4-33.cpp:(.text._ZN5boost11basic_regexIcNS_12regex_traitsIcNS_16cpp_regex_traitsIcEEEEE6assignEPKcS7_j[boost::basic_regex<char, boost::regex_traits<char, boost::cpp_regex_traits<char> > >::assign(char const*, char const*, unsigned int)]+0x22): undefined reference to `boost::basic_regex<char, boost::regex_traits<char, boost::cpp_regex_traits<char> > >::do_assign(char const*, char const*, unsigned int)' > /tmp/ccx4JXEA.o: In function `bool > boost::regex_search<__gnu_cxx::__normal_iterator<char const*, > std::basic_string<char, std::char_traits<char>, std::allocator<char> > > >, std::allocator<boost::sub_match<__gnu_cxx::__normal_iterator<char > const*, std::basic_string<char, std::char_traits<char>, > std::allocator<char> > > > >, char, boost::regex_traits<char, > boost::cpp_regex_traits<char> > >(__gnu_cxx::__normal_iterator<char > const*, std::basic_string<char, std::char_traits<char>, > std::allocator<char> > >, __gnu_cxx::__normal_iterator<char const*, > std::basic_string<char, std::char_traits<char>, std::allocator<char> > > >, boost::match_results<__gnu_cxx::__normal_iterator<char const*, > std::basic_string<char, std::char_traits<char>, std::allocator<char> > > >, std::allocator<boost::sub_match<__gnu_cxx::__normal_iterator<char > const*, std::basic_string<char, std::char_traits<char>, > std::allocator<char> > > > > >&, boost::basic_regex<char, > boost::regex_traits<char, boost::cpp_regex_traits<char> > > const&, > boost::regex_constants::_match_flags, __gnu_cxx::__normal_iterator<char > const*, std::basic_string<char, std::char_traits<char>, > std::allocator<char> > >)': > 4-33.cpp:(.text._ZN5boost12regex_searchIN9__gnu_cxx17__normal_iteratorIPKcSsEESaINS_9sub_matchIS5_EEEcNS_12regex_traitsIcNS_16cpp_regex_traitsIcEEEEEEbT_SD_RNS_13match_resultsISD_T0_EERKNS_11basic_regexIT1_T2_EENS_15regex_constants12_match_flagsESD_[bool boost::regex_search<__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<boost::sub_match<__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > > > >, char, boost::regex_traits<char, boost::cpp_regex_traits<char> > >(__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, __gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, boost::match_results<__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<boost::sub_match<__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > > > > >&, boost::basic_regex<char, boost::regex_traits<char, boost::cpp_regex_traits<char> > > const&, boost::regex_constants::_match_flags, __gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >)]+0x6c): undefined reference to `boost::re_detail::perl_matcher<__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > >, std::allocator<boost::sub_match<__gnu_cxx::__normal_iterator<char const*, std::basic_string<char, std::char_traits<char>, std::allocator<char> > > > >, boost::regex_traits<char, boost::cpp_regex_traits<char> > >::find()' > /tmp/ccx4JXEA.o: In function > `boost::re_detail::perl_matcher<__gnu_cxx::__normal_iterator<char > const*, std::basic_string<char, std::char_traits<char>, > std::allocator<char> > >, > std::allocator<boost::sub_match<__gnu_cxx::__normal_iterator<char > const*, std::basic_string<char, std::char_traits<char>, > std::allocator<char> > > > >, boost::regex_traits<char, > boost::cpp_regex_traits<char> > > >::perl_matcher(__gnu_cxx::__normal_iterator<char const*, > std::basic_string<char, std::char_t > ------------------------------------------ Thanks your help a lot in advance, Eric

3 2

Time classes and zoneinfo (tz/Olsen) database
by Dom Driver 10 Jul '11

10 Jul '11

Hi List, I'm currently working on a project with a requirement for up-to-date worldwide timezone information, including accurate daylight saving information. How well do the boost time classes handle the tz database? Can I populate the boost classes with up-to-date info easily? Has anyone done this? Ta! D

1 0

[asio] sending and receiving binary
by Wilde, Donald S 10 Jul '11

10 Jul '11

Hello, all - After starting from scratch again, I've been able to climb into boost::asio and am beginning to get it to work. Please bear with me; I'm still a noob when it comes to reading C++ templates. I started by building the little asynchronous daytime server into my primary application, and used the asynch client to successfully talk to it. All well and good. Now, I've built my real message, which is mixed 7-bit ASCII and binary data (counts, checksums, etc.). In experimenting to make it work, I've started changing my code in the server and client to be more like the echo server. It appears to be accepting the message, but when it tries to respond the async_write() function throws an error: ERROR: 'system:0' has occurred. ... and I see 'connection reset by peer' on the client side. I don't THINK it's because I'm sending binary; this is more likely a glitch in my understanding of boost::asio. I'll back up and look at the daytime and echo examples again and try to see what I've messed up, but I thought I'd put this out there as I've been slogging in mud for a few hours now. :) // ---- server code ---- // server using boost::asio::ip::tcp; TCPConnection::TCPConnection(boost::asio::io_service& aIOService) : _socket(aIOService) { } boost::shared_ptr<TCPConnection> TCPConnection::Create(boost::asio::io_service& aIOService) { return boost::shared_ptr<TCPConnection>(new TCPConnection(aIOService)); } tcp::socket& TCPConnection::Socket() { return _socket; } void TCPConnection::CheckMessageAndRespond() { _message = make_my_daytime_string(); boost::asio::async_write( _socket, boost::asio::buffer(_message), boost::bind(&TCPConnection::HandleWrite, shared_from_this(), boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); } void TCPConnection::HandleWrite( const boost::system::error_code& aError, std::size_t aNumBytes) { std::cerr << "ERROR: '" << aError << "' has occurred." << std::endl; } std::string TCPConnection::make_my_daytime_string() { std::time_t now = std::time(0); return std::ctime(&now); } static const int QUERYIPADDR = 2000; TCPServer::TCPServer(boost::asio::io_service& aIOService) : _acceptor(aIOService, tcp::endpoint(tcp::v4(), QUERYIPADDR)) { StartAccept(); } void TCPServer::StartAccept() { boost::shared_ptr<TCPConnection> newconnection = TCPConnection::Create(_acceptor.io_service()); _acceptor.async_accept( newconnection->Socket(), boost::bind(&TCPServer::HandleAccept, this, newconnection, boost::asio::placeholders::error)); std::cout << "Extender inquiry server ready for business!" << std::endl; } void TCPServer::HandleAccept( boost::shared_ptr<TCPConnection> aNewConnection, const boost::system::error_code& aError) { if (!aError) { aNewConnection->CheckMessageAndRespond(); StartAccept(); } } //---- main equiv (within another class) ---------------------- ExtenderServer::ExtenderServer(TVED::ITVExtenderDeviceHandler* aEDHandler) { try { boost::asio::io_service ioservice; TCPServer Server(ioservice); ioservice.run(); } catch (std::exception& e) { std::cerr << e.what() << std::endl; } } //-------- client (extracted code) ------------------------- string message; message.reserve(1024); ... size_t mlen = message.length(); const char* mptr = 0; mptr = message.data(); // Create new IO network client service boost::asio::io_service io_service; // Attach a Query Resolver to it tcp::resolver resolver(io_service); // We will talk to a Well Known Port (currently 2000) tcp::resolver::query query(tcp::v4(), argv[3], "2000"); tcp::resolver::iterator iterator = resolver.resolve(query); tcp::socket socket(io_service); socket.connect(*iterator); boost::system::error_code error; size_t lwrite = boost::asio::write(socket, boost::asio::buffer(mptr, mlen)); if (error) { throw boost::system::system_error(error); // Some error occurred. } cout << "Wrote " << lwrite << " bytes" << endl; char buf[1024]; size_t len; while (1) { char buf[1024]; len = socket.read_some(boost::asio::buffer(buf), error); if (error == boost::asio::error::eof) { cout << "eof" << endl; break; } else if (error) { throw boost::system::system_error(error); // Some other error. } } string response; stringstream sbuf (response, stringstream::in | stringstream::out | stringstream::binary); sbuf.write(buf, len); cout << endl << "Message string server returns: " << endl; print_message(&response); } catch (std::exception& e) { std::cerr << "ERR from faker: " << e.what() << std::endl; } // ---------------------------------run data ----------------------- // example data // as sent by client "faker" program Message string client sends: ASCII: I N T C :: :: :: / :: :: :: :: :: :: :: :: 0 0 : 1 3 : 2 0 : f 9 : 2 a : 8 9 | 1 9 2 . 1 6 8 . 0 . 1 0 | 3 0 0 0 F N :: H Binary: 49 4E 54 43 00 00 00 2F 00 00 00 00 00 00 00 00 30 30 3A 31 33 3A 32 30 3A 66 39 3A 32 61 3A 38 39 7C 31 39 32 2E 31 36 38 2E 30 2E 31 30 7C 33 30 30 30 46 4E 8D 48 Wrote 55 bytes ERR from faker: Connection reset by peer TIA for suggestions! :D -- Don Wilde

2 4

[datetime] convert a int32_t to a time
by Sean Farrow 10 Jul '11

10 Jul '11

Hi: I'm working with a piece of code that gives me time as an int32_t I'd like to convert this in to a more intelligible form to store along with the current date. Does boost.datetime allow me to do this? Any help appreciated. Cheers Sean.

2 1

[thread] terminating a thread when a program exits
by Sean Farrow 10 Jul '11

10 Jul '11

Hi: I've got a situation whereby, I've got a number of boost::thread objects being created by classes in my program and run for the duration of the program. What I need to do is when the exit menu item is activated, close down all threads. I was going to use a condition, and have the threads continue until the condition is signalled, and then use notify_all when the exit menu item is activated. Given that I want this condition to be multi-read/exclusive write, what mutex is the best option? Also will I need to use a mutex in the threads I need to terminate. I see the code of the threads being something like: While (Terminate !=false) { //perform actions. }; Normally in this situation I'd use a windows event and the WaitForSingle/multipleObject functions, but as this has to be cross platform I carn't do this. Any help with this appreciated. Cheers Sean.

1 0

connection timeout
by Gianni Ambrosio 09 Jul '11

09 Jul '11

Hi All, I use an async_connect() call in my tcp socket client implementation. It seems there is a timeout of about 15 seconds (in my case) so that after that time connect callback is executed passing an error. Is there a way to get or set that connection timeout? Regards Gianni

2 1

Re: [Boost-users] [Asio] Crash on service delete
by Marat Abrarov 09 Jul '11

09 Jul '11

Hi, Indrek. > // m_socket was associated with m_service > m_socket->cancel(); > m_socket->shutdown( boost::asio::ip::tcp::socket::shutdown_both, ec ); > m_socket->close( ec ); > delete m_socket; > m_socket = NULL; > > // Delete work on the service > delete m_work; > m_work = NULL; > > // Stop the service > m_service->stop(); > > // Join the thread this service was running on > m_thread->interrupt(); > m_thread->join(); > delete m_thread; > m_thread = NULL; > > // Crashes here > delete m_service; > m_service = NULL; > > Here's what VC10 reported: > Access violation > camc.exe!boost::asio::detail::socket_ops::send(unsigned int s, const _WSABUF > * bufs, unsigned int count, int flags, boost::system::error_code & ec) Line > 876 + 0x24 bytes C++ > camc.exe!boost::asio::detail::socket_select_interrupter::interrupt() Line > 127 + 0x18 bytes C++ > camc.exe!boost::asio::detail::select_reactor::shutdown_service() Line 73 C++ > camc.exe!boost::asio::detail::service_registry::~service_registry() Line 42 > + 0xf bytes C++ > camc.exe!boost::asio::detail::service_registry::`scalar deleting > destructor'() + 0x16 bytes C++ > camc.exe!boost::asio::io_service::~io_service() Line 51 + 0x1f bytes C++ > camc.exe!boost::asio::io_service::`scalar deleting destructor'() + 0x16 > bytes C++ May be the source of your problem is located in yours async write completion handler (it is often so - see asio-users mailing list). It seems that your completion handler tries to use destroyed m_socket. Regards, Marat Abrarov.

3 5

algorithm question
by Peter Foelsche 09 Jul '11

09 Jul '11

Dear All, I'm trying to get some objects sorted. Every object has a set of pointers to other objects, which need to come before this object (or are considered smaller than this object). It is kind of a make-tool algorithm. I can imagine the straight-forward way to attack this -- searching. Is there some more elegant way I'm missing? The number of objects not small. I tried to write some recursive functor to be passed to std::sort -- caching the result of previous comparisions -- but I was not successful. My brain is hurting... Thanks Peter struct object { std::set<object*> m_sPredecessors; }; // to be sorted: std::list<object*> sList; std::list<object*> sort(std::list<object*> _sList) { std::set<object*> sSet; std::list<object*> sSorted; while (_sList.size()) for (std::list<object*>::iterator p = _sList.begin(), pNext = p, pEnd = _sList.end(); p != pEnd; p = pNext) { ++pNext; bool bFound = false; for (std::set<object*>::const_iterator p1 = (*p)->m_sPredecessors.begin(), p1End = (*p)->m_sPredecessors.end(); p1 != p1End; ++p1) if (sSet.find(*p1) == sSet.end()) { bFound = true; break; } if (!bFound) { sSorted.push_back(*p); _sList.erase(p); } } return sSorted; }

2 4

Multi Index Container - find() not working with std::string, kind of stuck...
by Steve Hibbert 09 Jul '11

09 Jul '11

Hi, I've hit a snag with the Boost Multi Index Container, and I'd really appreciate some help. I've set up a container and I am using it to store shared pointers to custom objects. The custom objects are just data collections effectively, including std::strings, chars, ints etc. The problem is that when I try to find a string in the MIC, the find function sometimes succeeds, and sometimes returns the same iterator as .end(), indicating a failure to find. Yet, if I iterate through the container testing the strings, the string is always found. I've done something wrong, but I do not know what it is. Here's the container definition... typedef boost::multi_index::multi_index_container < spExchOrder, boost::multi_index::indexed_by < boost::multi_index::ordered_unique // 0 index - shared pointer index < boost::multi_index::identity<spExchOrder> > , boost::multi_index::ordered_unique // 1 index - Exchange ID eg "ORD-WIDGET-Timestamp" < boost::multi_index::const_mem_fun< FC::ExchOrder, std::string, &FC::ExchOrder::ID > > , boost::multi_index::ordered_unique // 2 index - OrigDetails eg "CLIENTA|ORDER00123" < boost::multi_index::const_mem_fun< FC::ExchOrder, std::string, &FC::ExchOrder::origDetails > > > > OrderReg; The spExchOrder typedef is just a std::tr1 shared pointer to an FC::ExchOrder object. This object has member functions that return the ID and origDetails member variable data as std::string type. Both are guaranteed unique. I'm searching the MIC using this kind of code: std::string sExchID = "Passed in Exchange ID"; OrderReg::nth_index<1>::type::iterator i = m_regOrders.get<1>().find( sExchID ); OrderReg::nth_index<1>::type::iterator iEnd = m_regOrders.get<1>().end(); if ( i != iEnd ) { // Found, do what needs to be done } I add shared pointers to the MIC like this: m_regOrders.insert(spOrder); When needed, shared pointers are deleted like this: OrderReg::nth_index<0>::type& indexSP = m_regOrders.get<0>(); iDelCount = indexSP.erase(spOrder); Any help with this would be greatly appreciated. Multi Index Containers have sorted out a number of problems for me, but I can't get past this issue. Thanks in advance, Steve

1 1