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_) :
 on_complete(on_compl),
 file_(file__),
 buffer(buffer_),
 offset(offset_),
 bytes(bytes_),
 type(type_)
{
 STXXL_VERBOSE3("[" << static_cast<void*>(this) << "] request::(...), ref_cnt=" << get_reference_count());
 file_->add_request_ref();
}

request::~request()
{
 STXXL_VERBOSE3("[" << static_cast<void*>(this) << "] request::~(), ref_cnt=" << get_reference_count());
}

void request::completed()
{
 on_complete(this);
 notify_waiters();
 file_->delete_request_ref();
 file_ = 0;
}

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

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

 if (unsigned_type(buffer) % BLOCK_ALIGN != 0)
 STXXL_ERRMSG("Buffer is not aligned: modulo " <<
 BLOCK_ALIGN << " = " << unsigned_type(buffer) % BLOCK_ALIGN <<
 " (" << 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=" << offset <<
 " buffer=" << buffer <<
 " bytes=" << bytes <<
 " type=" << ((type == READ) ? "READ" : "WRITE") <<
 " file=" << get_file() <<
 " iotype=" << get_file()->io_type()
 );
}

std::ostream& request::print(std::ostream& out) const
{
 out << "File object address: " << static_cast<void*>(get_file());
 out << " Buffer address: " << static_cast<void*>(get_buffer());
 out << " File offset: " << get_offset();
 out << " Transfer size: " << get_size() << " bytes";
 out << " Type of transfer: " << ((get_type() == READ) ? "READ" : "WRITE");
 return out;
}

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