/***************************************************************************
 *  lib/io/request.cpp
 *
 *  Part of the STXXL. See http://stxxl.sourceforge.net
 *
 *  Copyright (C) 2008 Andreas Beckmann <beckmann@cs.uni-frankfurt.de>
 *  Copyright (C) 2009 Johannes Singler <singler@ira.uka.de>
 *
 *  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