| // |
| // detail/impl/handler_tracking.ipp |
| // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ |
| // |
| // Copyright (c) 2003-2011 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) |
| // |
| |
| #ifndef BOOST_ASIO_DETAIL_IMPL_HANDLER_TRACKING_IPP |
| #define BOOST_ASIO_DETAIL_IMPL_HANDLER_TRACKING_IPP |
| |
| #if defined(_MSC_VER) && (_MSC_VER >= 1200) |
| # pragma once |
| #endif // defined(_MSC_VER) && (_MSC_VER >= 1200) |
| |
| #include <boost/asio/detail/config.hpp> |
| |
| #if defined(BOOST_ASIO_ENABLE_HANDLER_TRACKING) |
| |
| #include <cstdarg> |
| #include <cstdio> |
| #include <boost/asio/detail/handler_tracking.hpp> |
| |
| #include <boost/asio/detail/push_options.hpp> |
| #include <boost/date_time/posix_time/posix_time_types.hpp> |
| #include <boost/asio/detail/pop_options.hpp> |
| |
| #if !defined(BOOST_WINDOWS) |
| # include <unistd.h> |
| #endif // !defined(BOOST_WINDOWS) |
| |
| #include <boost/asio/detail/push_options.hpp> |
| |
| namespace boost { |
| namespace asio { |
| namespace detail { |
| |
| struct handler_tracking::tracking_state |
| { |
| static_mutex mutex_; |
| boost::uint64_t next_id_; |
| tss_ptr<completion>* current_completion_; |
| }; |
| |
| handler_tracking::tracking_state* handler_tracking::get_state() |
| { |
| static tracking_state state = { BOOST_ASIO_STATIC_MUTEX_INIT, 1, 0 }; |
| return &state; |
| } |
| |
| void handler_tracking::init() |
| { |
| static tracking_state* state = get_state(); |
| |
| state->mutex_.init(); |
| |
| static_mutex::scoped_lock lock(state->mutex_); |
| if (state->current_completion_ == 0) |
| state->current_completion_ = new tss_ptr<completion>; |
| } |
| |
| void handler_tracking::creation(handler_tracking::tracked_handler* h, |
| const char* object_type, void* object, const char* op_name) |
| { |
| static tracking_state* state = get_state(); |
| |
| static_mutex::scoped_lock lock(state->mutex_); |
| h->id_ = state->next_id_++; |
| lock.unlock(); |
| |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| boost::uint64_t current_id = 0; |
| if (completion* current_completion = *state->current_completion_) |
| current_id = current_completion->id_; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|%I64u*%I64u|%.20s@%p.%.50s\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|%llu*%llu|%.20s@%p.%.50s\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| current_id, h->id_, object_type, object, op_name); |
| } |
| |
| handler_tracking::completion::completion(handler_tracking::tracked_handler* h) |
| : id_(h->id_), |
| invoked_(false), |
| next_(*get_state()->current_completion_) |
| { |
| *get_state()->current_completion_ = this; |
| } |
| |
| handler_tracking::completion::~completion() |
| { |
| if (id_) |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|%c%I64u|\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|%c%llu|\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| invoked_ ? '!' : '~', id_); |
| } |
| |
| *get_state()->current_completion_ = next_; |
| } |
| |
| void handler_tracking::completion::invocation_begin() |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|>%I64u|\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|>%llu|\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), id_); |
| |
| invoked_ = true; |
| } |
| |
| void handler_tracking::completion::invocation_begin( |
| const boost::system::error_code& ec) |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|>%I64u|ec=%.20s:%d\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|>%llu|ec=%.20s:%d\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| id_, ec.category().name(), ec.value()); |
| |
| invoked_ = true; |
| } |
| |
| void handler_tracking::completion::invocation_begin( |
| const boost::system::error_code& ec, std::size_t bytes_transferred) |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|>%I64u|ec=%.20s:%d,bytes_transferred=%I64u\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|>%llu|ec=%.20s:%d,bytes_transferred=%llu\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| id_, ec.category().name(), ec.value(), |
| static_cast<boost::uint64_t>(bytes_transferred)); |
| |
| invoked_ = true; |
| } |
| |
| void handler_tracking::completion::invocation_begin( |
| const boost::system::error_code& ec, int signal_number) |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|>%I64u|ec=%.20s:%d,signal_number=%d\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|>%llu|ec=%.20s:%d,signal_number=%d\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| id_, ec.category().name(), ec.value(), signal_number); |
| |
| invoked_ = true; |
| } |
| |
| void handler_tracking::completion::invocation_begin( |
| const boost::system::error_code& ec, const char* arg) |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|>%I64u|ec=%.20s:%d,%.50s\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|>%llu|ec=%.20s:%d,%.50s\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| id_, ec.category().name(), ec.value(), arg); |
| |
| invoked_ = true; |
| } |
| |
| void handler_tracking::completion::invocation_end() |
| { |
| if (id_) |
| { |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|<%I64u|\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|<%llu|\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), id_); |
| |
| id_ = 0; |
| } |
| } |
| |
| void handler_tracking::operation(const char* object_type, |
| void* object, const char* op_name) |
| { |
| static tracking_state* state = get_state(); |
| |
| boost::posix_time::ptime epoch(boost::gregorian::date(1970, 1, 1)); |
| boost::posix_time::time_duration now = |
| boost::posix_time::microsec_clock::universal_time() - epoch; |
| |
| unsigned long long current_id = 0; |
| if (completion* current_completion = *state->current_completion_) |
| current_id = current_completion->id_; |
| |
| write_line( |
| #if defined(BOOST_WINDOWS) |
| "@asio|%I64u.%06I64u|%I64u|%.20s@%p.%.50s\n", |
| #else // defined(BOOST_WINDOWS) |
| "@asio|%llu.%06llu|%llu|%.20s@%p.%.50s\n", |
| #endif // defined(BOOST_WINDOWS) |
| static_cast<boost::uint64_t>(now.total_seconds()), |
| static_cast<boost::uint64_t>(now.total_microseconds() % 1000000), |
| current_id, object_type, object, op_name); |
| } |
| |
| void handler_tracking::write_line(const char* format, ...) |
| { |
| using namespace std; // For sprintf (or equivalent). |
| |
| va_list args; |
| va_start(args, format); |
| |
| char line[256] = ""; |
| #if BOOST_WORKAROUND(BOOST_MSVC, >= 1400) && !defined(UNDER_CE) |
| int length = vsprintf_s(line, sizeof(line), format, args); |
| #else // BOOST_WORKAROUND(BOOST_MSVC, >= 1400) && !defined(UNDER_CE) |
| int length = vsprintf(line, format, args); |
| #endif // BOOST_WORKAROUND(BOOST_MSVC, >= 1400) && !defined(UNDER_CE) |
| |
| va_end(args); |
| |
| #if defined(BOOST_WINDOWS) |
| HANDLE stderr_handle = ::GetStdHandle(STD_ERROR_HANDLE); |
| DWORD bytes_written = 0; |
| ::WriteFile(stderr_handle, line, length, &bytes_written, 0); |
| #else // defined(BOOST_WINDOWS) |
| ::write(STDERR_FILENO, line, length); |
| #endif // defined(BOOST_WINDOWS) |
| } |
| |
| } // namespace detail |
| } // namespace asio |
| } // namespace boost |
| |
| #include <boost/asio/detail/pop_options.hpp> |
| |
| #endif // defined(BOOST_ASIO_ENABLE_HANDLER_TRACKING) |
| |
| #endif // BOOST_ASIO_DETAIL_IMPL_HANDLER_TRACKING_IPP |