Lines Matching refs:boost
68 boost::asio::io_service io_service;
69 boost::asio::deadline_timer timer(io_service);
70 std::map<curl_socket_t, boost::asio::ip::tcp::socket *> socket_map;
88 static void timer_cb(const boost::system::error_code & error, GlobalInfo *g);
100 timer.expires_from_now(boost::posix_time::millisec(timeout_ms)); in multi_timer_cb()
101 timer.async_wait(boost::bind(&timer_cb, _1, g)); in multi_timer_cb()
105 boost::system::error_code error; /*success*/ in multi_timer_cb()
184 int action, const boost::system::error_code & error, in event_cb()
214 boost::asio::ip::tcp::socket *tcp_socket = socket_map.find(s)->second; in event_cb()
217 tcp_socket->async_read_some(boost::asio::null_buffers(), in event_cb()
218 boost::bind(&event_cb, g, s, in event_cb()
222 tcp_socket->async_write_some(boost::asio::null_buffers(), in event_cb()
223 boost::bind(&event_cb, g, s, in event_cb()
231 static void timer_cb(const boost::system::error_code & error, GlobalInfo *g) in timer_cb()
260 std::map<curl_socket_t, boost::asio::ip::tcp::socket *>::iterator it = in setsock()
268 boost::asio::ip::tcp::socket * tcp_socket = it->second; in setsock()
275 tcp_socket->async_read_some(boost::asio::null_buffers(), in setsock()
276 boost::bind(&event_cb, g, s, in setsock()
283 tcp_socket->async_write_some(boost::asio::null_buffers(), in setsock()
284 boost::bind(&event_cb, g, s, in setsock()
291 tcp_socket->async_read_some(boost::asio::null_buffers(), in setsock()
292 boost::bind(&event_cb, g, s, in setsock()
296 tcp_socket->async_write_some(boost::asio::null_buffers(), in setsock()
297 boost::bind(&event_cb, g, s, in setsock()
386 boost::asio::ip::tcp::socket *tcp_socket = in opensocket()
387 new boost::asio::ip::tcp::socket(io_service); in opensocket()
390 boost::system::error_code ec; in opensocket()
391 tcp_socket->open(boost::asio::ip::tcp::v4(), ec); in opensocket()
405 boost::asio::ip::tcp::socket *>(sockfd, tcp_socket)); in opensocket()
417 std::map<curl_socket_t, boost::asio::ip::tcp::socket *>::iterator it = in close_socket()