// // datagram_receive_timeout.cpp // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~ // // Copyright (c) 2003-2010 Christopher M. Kohlhoff (chris at kohlhoff dot com) // // 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) // #include <boost/asio.hpp> #include <boost/bind.hpp> #include <boost/date_time/posix_time/posix_time_types.hpp> #include <iostream> using namespace boost::asio; using boost::asio::ip::udp; class datagram_handler { public: datagram_handler(io_service& ios) : io_service_(ios), timer_(ios), socket_(ios, udp::endpoint(udp::v4(), 32124)) { socket_.async_receive_from( boost::asio::buffer(data_, max_length), sender_endpoint_, boost::bind(&datagram_handler::handle_receive_from, this, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); timer_.expires_from_now(boost::posix_time::seconds(5)); timer_.async_wait(boost::bind(&datagram_handler::close, this)); } void handle_receive_from(const boost::system::error_code& err, size_t /*length*/) { if (err) { std::cout << "Receive error: " << err.message() << "\n"; } else { std::cout << "Successful receive\n"; } } void close() { socket_.close(); } private: io_service& io_service_; deadline_timer timer_; udp::socket socket_; udp::endpoint sender_endpoint_; enum { max_length = 512 }; char data_[max_length]; }; int main() { try { io_service ios; datagram_handler dh(ios); ios.run(); } catch (std::exception& e) { std::cerr << "Exception: " << e.what() << "\n"; } return 0; }