- Boost-users - lists.boost.org

IEC/SI Binary Prefix Formatter
by Rodrigo Madera 02 Mar '09

02 Mar '09

Hello guys, I'm wondering if in the Boost universe we already have something to format numbers according to IEC's "new" prefixes (such as MiB and GiB) or SI prefixes (such as MB and GB). What I'm looking for is something like: formatter << boost::iec_prefix << 5*1024*1024; // Will output "5 GiB" formatter << boost::si_prefix << 5*1024*1024; // Will output "5GB" Do you have anything like this? Thank you for your support, Rodrigo Madera

2 2

[asio] SSL enabled http server3 example is blocking
by Jean-Pierre Bergamin 02 Mar '09

02 Mar '09

Dear boost-users I changed the http server3 example (many thready run io_service::run()) to use SSL connections. I now face the problem that the async_accept handler is only called when no other connections are alive and not immediately by another thread as with the original non-ssl example. My modified request_handler simply sleeps for 10 seconds. Now when a request arrives while another one is being processed (sleeping), it is only handled after the other one finished. By setting a breakpoint in server::handle_accept() I can see that this handler for the second request is only called after the first connection has been destroyed/closed. This happens on Windows XP. Do you may have an idea why the accept handler is not called immediately or where the blocking could happen? I may help if you could test this on another platform then XP. To test this, apply the attached patch to the directory boost_1_38_0/libs/asio/example/http/server3 and copy the *.pem files from the asio ssl example to the working directory of the server3 example. Regards James PS: I already posted this question to the asio-users list without gettinga reply. I'm trying my luck now here on the boost list. diff -ru server3.orig/connection.cpp server3/connection.cpp --- server3.orig/connection.cpp 2008-03-12 10:12:08.000000000 +0100 +++ server3/connection.cpp 2009-02-17 15:52:12.867198900 +0100 @@ -17,20 +17,20 @@ namespace server3 { connection::connection(boost::asio::io_service& io_service, + boost::asio::ssl::context &context, request_handler& handler) : strand_(io_service), - socket_(io_service), + socket_(io_service, context), request_handler_(handler) { } -boost::asio::ip::tcp::socket& connection::socket() +connection::socket_type::lowest_layer_type& connection::socket() { - return socket_; + return socket_.lowest_layer(); } -void connection::start() -{ +void connection::handle_handshake(const boost::system::error_code& e) { socket_.async_read_some(boost::asio::buffer(buffer_), strand_.wrap( boost::bind(&connection::handle_read, shared_from_this(), @@ -38,6 +38,14 @@ boost::asio::placeholders::bytes_transferred))); } +void connection::start() +{ + socket_.async_handshake(boost::asio::ssl::stream_base::server, + boost::bind(&connection::handle_handshake, shared_from_this(), + boost::asio::placeholders::error) + ); +} + void connection::handle_read(const boost::system::error_code& e, std::size_t bytes_transferred) { @@ -85,7 +93,7 @@ { // Initiate graceful connection closure. boost::system::error_code ignored_ec; - socket_.shutdown(boost::asio::ip::tcp::socket::shutdown_both, ignored_ec); + socket_.shutdown(ignored_ec); } // No new asynchronous operations are started. This means that all shared_ptr diff -ru server3.orig/connection.hpp server3/connection.hpp --- server3.orig/connection.hpp 2008-03-12 10:12:08.000000000 +0100 +++ server3/connection.hpp 2009-02-26 08:51:42.187500000 +0100 @@ -12,6 +12,7 @@ #define HTTP_SERVER3_CONNECTION_HPP #include <boost/asio.hpp> +#include <boost/asio/ssl.hpp> #include <boost/array.hpp> #include <boost/noncopyable.hpp> #include <boost/shared_ptr.hpp> @@ -30,17 +31,20 @@ private boost::noncopyable { public: + typedef boost::asio::ssl::stream<boost::asio::ip::tcp::socket> socket_type; /// Construct a connection with the given io_service. explicit connection(boost::asio::io_service& io_service, + boost::asio::ssl::context &context, request_handler& handler); /// Get the socket associated with the connection. - boost::asio::ip::tcp::socket& socket(); + socket_type::lowest_layer_type& socket(); /// Start the first asynchronous operation for the connection. void start(); - + ~connection() {} private: + void handle_handshake(const boost::system::error_code& e); /// Handle completion of a read operation. void handle_read(const boost::system::error_code& e, std::size_t bytes_transferred); @@ -52,7 +56,7 @@ boost::asio::io_service::strand strand_; /// Socket for the connection. - boost::asio::ip::tcp::socket socket_; + socket_type socket_; /// The handler used to process the incoming request. request_handler& request_handler_; diff -ru server3.orig/reply.cpp server3/reply.cpp --- server3.orig/reply.cpp 2008-03-12 10:12:08.000000000 +0100 +++ server3/reply.cpp 2009-02-17 15:52:20.804800500 +0100 @@ -119,7 +119,7 @@ namespace stock_replies { -const char ok[] = ""; +const char ok[] = "ok\r\n"; const char created[] = "<html>" "<head><title>Created</title></head>" diff -ru server3.orig/request_handler.cpp server3/request_handler.cpp --- server3.orig/request_handler.cpp 2008-03-12 10:12:08.000000000 +0100 +++ server3/request_handler.cpp 2009-02-26 08:23:56.250000000 +0100 @@ -8,6 +8,7 @@ // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) // +#include <boost/thread.hpp> #include "request_handler.hpp" #include <fstream> #include <sstream> @@ -27,56 +28,9 @@ void request_handler::handle_request(const request& req, reply& rep) { - // Decode url to path. - std::string request_path; - if (!url_decode(req.uri, request_path)) - { - rep = reply::stock_reply(reply::bad_request); - return; - } - - // Request path must be absolute and not contain "..". - if (request_path.empty() || request_path[0] != '/' - || request_path.find("..") != std::string::npos) - { - rep = reply::stock_reply(reply::bad_request); - return; - } - - // If path ends in slash (i.e. is a directory) then add "index.html". - if (request_path[request_path.size() - 1] == '/') - { - request_path += "index.html"; - } - - // Determine the file extension. - std::size_t last_slash_pos = request_path.find_last_of("/"); - std::size_t last_dot_pos = request_path.find_last_of("."); - std::string extension; - if (last_dot_pos != std::string::npos && last_dot_pos > last_slash_pos) - { - extension = request_path.substr(last_dot_pos + 1); - } - - // Open the file to send back. - std::string full_path = doc_root_ + request_path; - std::ifstream is(full_path.c_str(), std::ios::in | std::ios::binary); - if (!is) - { - rep = reply::stock_reply(reply::not_found); - return; - } - - // Fill out the reply to be sent to the client. - rep.status = reply::ok; - char buf[512]; - while (is.read(buf, sizeof(buf)).gcount() > 0) - rep.content.append(buf, is.gcount()); - rep.headers.resize(2); - rep.headers[0].name = "Content-Length"; - rep.headers[0].value = boost::lexical_cast<std::string>(rep.content.size()); - rep.headers[1].name = "Content-Type"; - rep.headers[1].value = mime_types::extension_to_type(extension); + using namespace boost; + this_thread::sleep(posix_time::seconds(10)); + rep = reply::stock_reply(reply::ok); } bool request_handler::url_decode(const std::string& in, std::string& out) diff -ru server3.orig/server.cpp server3/server.cpp --- server3.orig/server.cpp 2008-03-12 10:12:08.000000000 +0100 +++ server3/server.cpp 2009-02-17 16:24:16.173066900 +0100 @@ -21,9 +21,23 @@ const std::string& doc_root, std::size_t thread_pool_size) : thread_pool_size_(thread_pool_size), acceptor_(io_service_), - new_connection_(new connection(io_service_, request_handler_)), + context_(io_service_, boost::asio::ssl::context::sslv23), + new_connection_(new connection(io_service_, context_, request_handler_)), request_handler_(doc_root) { + + context_.set_options( + boost::asio::ssl::context::default_workarounds + | boost::asio::ssl::context::no_sslv2 + | boost::asio::ssl::context::single_dh_use); + context_.set_password_callback(boost::bind<const char*>(&server::get_password, this)); + + context_.use_certificate_chain_file("server.pem"); + context_.use_private_key_file("server.pem", boost::asio::ssl::context::pem); + context_.use_tmp_dh_file("dh512.pem"); + context_.set_verify_mode(boost::asio::ssl::context::verify_none); + + // Open the acceptor with the option to reuse the address (i.e. SO_REUSEADDR). boost::asio::ip::tcp::resolver resolver(io_service_); boost::asio::ip::tcp::resolver::query query(address, port); @@ -63,7 +77,7 @@ if (!e) { new_connection_->start(); - new_connection_.reset(new connection(io_service_, request_handler_)); + new_connection_.reset(new connection(io_service_, context_, request_handler_)); acceptor_.async_accept(new_connection_->socket(), boost::bind(&server::handle_accept, this, boost::asio::placeholders::error)); diff -ru server3.orig/server.hpp server3/server.hpp --- server3.orig/server.hpp 2008-03-12 10:12:08.000000000 +0100 +++ server3/server.hpp 2009-02-17 16:02:27.187562100 +0100 @@ -39,6 +39,10 @@ void stop(); private: + const char * get_password() const { + return "test"; + } + /// Handle completion of an asynchronous accept operation. void handle_accept(const boost::system::error_code& e); @@ -51,6 +55,8 @@ /// Acceptor used to listen for incoming connections. boost::asio::ip::tcp::acceptor acceptor_; + boost::asio::ssl::context context_; + /// The next connection to be accepted. connection_ptr new_connection_;

1 0

[serialization] Archive reload
by Ferllings 02 Mar '09

02 Mar '09

Hello, I have a Class A with string attributes that I serialize in XML format: Class A { public: string _nom; string _prenom; template<class Archive> void serialize(Archive& ar, const unsigned in version){ ar & boost::serialization::make_nvp("Nom", _nom); ar & boost::serialization::make_nvp("Prenom", _prenom); } } The object is correctly saved using this code: A _a; void save() const { ... oTextArchive::xml_oarchive oTextArchive(ofile); oTextArchive << make_nvp("A", _a); ... } But I want to reload the object, the A attributes aren't updated and keep the previous values: void load() { ... iTextArchive::xml_oarchive iTextArchive(ifile); iTextArchive >> make_nvp("A", _a); ... } The only way I found to reload my object is to use an temporary object: void load() { ... A _tmp; iTextArchive::xml_oarchive iTextArchive(ifile); iTextArchive >> make_nvp("A", _tmp); _a = _tmp; ... } Why can't I update the object directly? Thanks for your help.

2 2

[accumulators] Any was to reset an accumulator_set object?
by dhruva 02 Mar '09

02 Mar '09

Hello, I am using boost::accumulator_set to compute mean. After every 100 samples, I need to start afresh. Since I am using accumulator_set as a member variable in a class (I get samples one at a time and need to preserve accumulator_set object across function calls), I need some mechanism to reset it to its initial state. I am not doing anything fancy like using droppable functionality. As a real crude work around, I am keeping 2 objects. The first is not used for any computing and hence its state is same throughout. The computing is done using the second object. After 100 samples, I just copy the first onto the second hoping the state of second object will be same as first which is the initial state. Is there a better way to achieve the above requirement? -dhruva Download prohibited? No problem. CHAT from any browser, without download. Go to http://in.webmessenger.yahoo.com/

3 2

[lexical_cast] Locales.
by Emre Turkay 02 Mar '09

02 Mar '09

Hi folks, I wonder if there is a downside of adding an optional std::locale argument to lexical_cast? Thanks, Emre Turkay

2 1

[Interprocess] Trying to include unistd.h on Windows?
by Derek Kivi 02 Mar '09

02 Mar '09

We are using the Interprocess library to make use of shared memory within our code. We are experiencing the following problem when building on Windows. Some of our projects are trying to include unistd.h from workaround.hpp. It looks like this happens if BOOST_WINDOWS is not defined. Tracing back through the header files I pieced together that BOOST_WINDOWS is not defined if BOOST_DISABLE_WIN32 is defined (win32.hpp). And BOOST_DISABLE_WIN32 gets defined if _MSC_EXTENSIONS is not defined (visualc.hpp). >From the MSDN documentation, _MSC_EXTENSIONS is not defined if the Visual C++ Language Extensions are turned off, which in fact they are for these projects. Has anyone else seen this and is there a workaround for getting Boost Interprocess to work on Windows in cases where the Visual C++ Language Extensions are turned off? Thanks, Derek -- Derek Kivi Senior Software Developer QuIC Financial Technologies Inc. Office: +1 403 210 8282 Mobile: +1 403 863 5204 derek.kivi(a)quic.com Risk. Managed. www.quic.com Confidentiality Notice: The information transmitted is intended only for the person(s) or entity(ies) to which it is addressed and may contain confidential and/or privileged material. Any review, retransmission, dissemination, or other use of, or taking of any action in reliance upon this information by persons or entities other than the intended recipient is prohibited. If you received this email in error, please contact the sender and delete the email and any related material from any computer. ver. QuIC 0707

2 4

Error while compiling boost thread
by ayansinhas＠gmail.com 02 Mar '09

02 Mar '09

Hi All, I am using boost thread for my project. I have used BCP tool to extract only those binaries that is related to boost thread(and the dependencies also).... Now I am trying to compile my code using only that thread binaries.. previously i tried using that binaries by writing a small code.... and it worked properly. I have done the necessary setings changes in VS2008. A snippet of the errors are as follows c:\program files\bthread\boost\shared_ptr.hpp(142) : error C2332: 'class' : missing tag name 1>c:\program files\bthread\boost\shared_ptr.hpp(142) : error C2011: '<unnamed-tag>' : 'enum' type redefinition 1> c:\program files\microsoft sdks\windows\v6.0a\include\shlwapi.h(1550) : see declaration of '<unnamed-tag>' 1>c:\program files\bthread\boost\shared_ptr.hpp(142) : error C2143: syntax error : missing ',' before 'return' 1>c:\program files\bthread\boost\shared_ptr.hpp(146) : error C2332: 'class' : missing tag name 1>c:\program files\bthread\boost\shared_ptr.hpp(146) : error C2011: '<unnamed-tag>' : 'enum' type redefinition 1> c:\program files\microsoft sdks\windows\v6.0a\include\shlwapi.h(1550) : see declaration of '<unnamed-tag>' 1>c:\program files\bthread\boost\shared_ptr.hpp(146) : error C2143: syntax error : missing ',' before 'return' 1>c:\program files\bthread\boost\shared_ptr.hpp(146) : error C2059: syntax error : 'return' 1>c:\program files\bthread\boost\shared_ptr.hpp(147) : error C2143: syntax error : missing ';' before '{' 1>c:\program files\bthread\boost\shared_ptr.hpp(149) : error C2143: syntax error : missing ';' before '}' 1>c:\program files\bthread\boost\shared_ptr.hpp(153) : error C2143: syntax error : missing ';' before '}' 1>c:\program files\bthread\boost\shared_ptr.hpp(164) : error C2649: 'typename' : is not a 'class' 1>c:\program files\bthread\boost\shared_ptr.hpp(529) : error C2649: 'typename' : is not a 'class' I have done a little bit of googling... but i am not getting the right info.... As we can see it is giving syntax error related to .hpp files .... which I haven't change at all.... I will really appreciate if any body can throw some light on it.... Thanks in Advance Ayan.

2 1

serial programs
by Steven Woody 02 Mar '09

02 Mar '09

Hi, I want to write a portable program which need to read/write serial ports. How can boost help this? Thank you. ( I got know basic serial programming in Linux but I have no idea how that it done in Windows ) -- woody then sun rose thinly from the sea and the old man could see the other boats, low on the water and well in toward the shore, spread out across the current.

7 9

Pool ordered_malloc and O(n)
by Georg Sauthoff 02 Mar '09

02 Mar '09

Hi, the boost pool documentation states ordererd_malloc(n) and boost::free(chunk, n) both take O(n). I tested it with a workload of a lot of n=1 and n=2 small allocations. Basically if I just use boost::malloc(2*base_size) even if i just need boost::malloc(base_size) the runtime is 1 min. With ordered_malloc(_)/boost::free(_,_) the runtime explodes (>> 30 minutes) (I terminated the program). Profiling it, one can see, that ordered_malloc dominates the runtime (83 % after a few minutes). Is this a known issue? Is the runtime of ordered_malloc in O(n), i.e. in O(c\cdot n), but the constant factor c is very huge? Best regards Georg Sauthoff

2 2

serial port and boost::iostream
by Christoph Gysin 02 Mar '09

02 Mar '09

I wrote a simple serial device for the boost::iostream library using the serial interface from boost:asio. Feel free to include it as an example if you find it useful. Chris #include <boost/iostreams/stream.hpp> #include <boost/asio/serial_port.hpp> class serial_device { public: typedef char char_type; typedef boost::iostreams::bidirectional_device_tag category; serial_device(boost::asio::serial_port& port) : serial_port(port) {}; std::streamsize read(char* buf, std::streamsize n) { return serial_port.read_some(boost::asio::buffer(buf, n)); } std::streamsize write(const char* buf, std::streamsize n) { return serial_port.write_some(boost::asio::buffer(buf, n)); } private: boost::asio::serial_port& serial_port; }; void example() { // set up serial port boost::asio::io_service io_service; #ifdef WIN32 boost::asio::serial_port serial_port(io_service, "COM1"); #else boost::asio::serial_port serial_port(io_service, "/dev/ttyS0"); #endif typedef boost::asio::serial_port_base spb; serial_port.set_option(spb::baud_rate(9600)); // create iostream serial_device dev(serial_port); boost::iostreams::stream<serial_device> serial(dev); // use serial port with iostream interface serial << "boost::iostreams are fun!" << std::endl; std::string response; serial >> response; } -- echo mailto: NOSPAM !#$.'<*>'|sed 's. ..'|tr "<*> !#:2" org@fr33z3

1 0