page.cpp

Go to the documentation of this file.

/*
 * Copyright (c) 2014-2015, Hewlett-Packard Development Company, LP.
 * This program is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License as published by the Free
 * Software Foundation; either version 2 of the License, or (at your option)
 * any later version.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
 * more details. You should have received a copy of the GNU General Public
 * License along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 *
 * HP designates this particular file as subject to the "Classpath" exception
 * as provided by HP in the LICENSE.txt file that accompanied this code.
 */
#include "foedus/storage/page.hpp"

#include <glog/logging.h>

#include <ostream>

#include "foedus/engine.hpp"
#include "foedus/engine_options.hpp"
#include "foedus/memory/page_resolver.hpp"
#include "foedus/thread/thread.hpp"
#include "foedus/xct/xct.hpp"

namespace foedus {
namespace storage {

std::ostream& operator<<(std::ostream& o, const PageVersionStatus& v) {
  o << "<PageVersionStatus><flags>"
    << (v.is_moved() ? "M" : " ")
    << (v.is_retired() ? "R" : " ")
    << "</flags><ver>" << v.get_version_counter() << "</ver>"
    << "</PageVersionStatus>";
  return o;
}

std::ostream& operator<<(std::ostream& o, const PageVersion& v) {
  o << "<PageVersion><locked>"
    << (v.is_locked() ? "L" : " ")
    << (v.is_moved() ? "M" : " ")
    << (v.is_retired() ? "R" : " ")
    << "</locked>" << v.status_
    << "</PageVersion>";
  return o;
}

std::ostream& operator<<(std::ostream& o, const PageHeader& v) {
  o << "<PageHeader>";
  o << std::endl << "<page_id>"
    << "<raw>" << assorted::Hex(v.page_id_, 16) << "</raw>";
  // Also write out interpreted version
  if (v.snapshot_) {
    describe_snapshot_pointer(&o, v.page_id_);
  } else {
    VolatilePagePointer pointer;
    pointer.word = v.page_id_;
    describe_volatile_pointer(&o, pointer);
  }
  o << "</page_id>";
  o << std::endl << "<storage_id_>" << v.storage_id_ << "</storage_id_>";
  o << "<checksum_>" << v.checksum_ << "</checksum_>";
  o << "<page_type_>" << static_cast<int>(v.page_type_) << "</page_type_>";
  o << std::endl << "<snapshot_>" << v.snapshot_ << "</snapshot_>";
  o << "<key_count_>" << v.key_count_ << "</key_count_>";
  o << "<masstree_layer_>" << static_cast<int>(v.masstree_layer_) << "</masstree_layer_>";
  o << "<masstree_in_layer_level_>" << static_cast<int>(v.masstree_in_layer_level_)
    << "</masstree_in_layer_level_>";
  o << "<hotness_>" << static_cast<int>(v.hotness_.value_) << "</hotness_>";
  o << std::endl << "<stat_last_updater_node_>" << static_cast<int>(v.stat_last_updater_node_)
    << "</stat_last_updater_node_>";
  o << v.page_version_;
  o << "</PageHeader>";
  return o;
}

bool PageHeader::contains_hot_records(thread::Thread* context) {
  return hotness_.value_ >= context->get_current_xct().get_hot_threshold_for_this_xct();
}

void assert_within_valid_volatile_page_impl(
  const memory::GlobalVolatilePageResolver& resolver,
  const void* address) {
  const Page* page = to_page(reinterpret_cast<const void*>(address));
  ASSERT_ND(!page->get_header().snapshot_);

  VolatilePagePointer vpp = construct_volatile_page_pointer(page->get_header().page_id_);
  ASSERT_ND(vpp.get_numa_node() < resolver.numa_node_count_);
  ASSERT_ND(vpp.get_offset() >= resolver.begin_);
  ASSERT_ND(vpp.get_offset() < resolver.end_);

  const Page* same_page = resolver.resolve_offset(vpp);
  ASSERT_ND(same_page->get_header().page_id_ == page->get_header().page_id_);
  ASSERT_ND(!same_page->get_header().snapshot_);
  // const uintptr_t int_address = reinterpret_cast<uintptr_t>(address);
  // ASSERT_ND(int_address >= base + vpp.components.offset * kPageSize);
  // ASSERT_ND(int_address < base + (vpp.components.offset + 1U) * kPageSize);
}

}  // namespace storage
}  // namespace foedus