request.cpp

Go to the documentation of this file.

/***************************************************************************
 * lib/io/request.cpp
 *
 * Part of the STXXL. See http://stxxl.sourceforge.net
 *
 * Copyright (C) 2008 Andreas Beckmann <[email protected]>
 * Copyright (C) 2009 Johannes Singler <[email protected]>
 *
 * 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 <ostream>

#include <stxxl/bits/io/request.h>
#include <stxxl/bits/io/file.h>

STXXL_BEGIN_NAMESPACE

request::request(
 const completion_handler& on_compl,
 file* file,
 void* buffer,
 offset_type offset,
 size_type bytes,
 request_type type)
 : m_on_complete(on_compl),
 m_file(file),
 m_buffer(buffer),
 m_offset(offset),
 m_bytes(bytes),
 m_type(type)
{
 STXXL_VERBOSE3_THIS("request::(...), ref_cnt=" << get_reference_count());
 m_file->add_request_ref();
}

request::~request()
{
 STXXL_VERBOSE3_THIS("request::~request(), ref_cnt=" << get_reference_count());
}

void request::check_alignment() const
{
 if (m_offset % STXXL_BLOCK_ALIGN != 0)
 STXXL_ERRMSG("Offset is not aligned: modulo " <<
 STXXL_BLOCK_ALIGN << " = " << m_offset % STXXL_BLOCK_ALIGN);

 if (m_bytes % STXXL_BLOCK_ALIGN != 0)
 STXXL_ERRMSG("Size is not a multiple of " <<
 STXXL_BLOCK_ALIGN << ", = " << m_bytes % STXXL_BLOCK_ALIGN);

 if (unsigned_type(m_buffer) % STXXL_BLOCK_ALIGN != 0)
 STXXL_ERRMSG("Buffer is not aligned: modulo " <<
 STXXL_BLOCK_ALIGN << " = " << unsigned_type(m_buffer) % STXXL_BLOCK_ALIGN <<
 " (" << m_buffer << ")");
}

void request::check_nref_failed(bool after)
{
 STXXL_ERRMSG("WARNING: serious error, reference to the request is lost " <<
 (after ? "after" : "before") << " serve()" <<
 " nref=" << get_reference_count() <<
 " this=" << this <<
 " offset=" << m_offset <<
 " buffer=" << m_buffer <<
 " bytes=" << m_bytes <<
 " type=" << ((m_type == READ) ? "READ" : "WRITE") <<
 " file=" << m_file <<
 " iotype=" << m_file->io_type()
 );
}

const char* request::io_type() const
{
 return m_file->io_type();
}

std::ostream& request::print(std::ostream& out) const
{
 out << "File object address: " << static_cast<void*>(m_file);
 out << " Buffer address: " << static_cast<void*>(m_buffer);
 out << " File offset: " << m_offset;
 out << " Transfer size: " << m_bytes << " bytes";
 out << " Type of transfer: " << ((m_type == READ) ? "READ" : "WRITE");
 return out;
}

STXXL_END_NAMESPACE
// vim: et:ts=4:sw=4