Analogous to the entire engine. More...

Detailed Description

template<typename RW_BLOCK>
struct foedus::xct::McsMockContext< RW_BLOCK >

Analogous to the entire engine.

Note: completely header-only

Definition at line 247 of file xct_mcs_adapter_impl.hpp.

#include <xct_mcs_adapter_impl.hpp>

Collaboration diagram for foedus::xct::McsMockContext< RW_BLOCK >:

[legend]

Public Member Functions
void	init (storage::StorageId dummy_storage_id, uint32_t nodes, uint32_t threads_per_node, uint32_t max_block_count, uint32_t max_lock_count)

RwLockableXctId *	get_rw_lock_address (uint16_t node_id, uint64_t lock_index)

McsWwLock *	get_ww_lock_address (uint16_t node_id, uint64_t lock_index)

Public Attributes
uint32_t	max_block_count_

uint32_t	max_lock_count_

uint32_t	pages_per_node_

std::vector< McsMockNode< RW_BLOCK > >	nodes_

memory::GlobalVolatilePageResolver	page_memory_resolver_
	All locks managed by this objects are placed in these memory regions. More...

Member Function Documentation

template<typename RW_BLOCK>

RwLockableXctId* foedus::xct::McsMockContext< RW_BLOCK >::get_rw_lock_address	(	uint16_t	node_id,
		uint64_t	lock_index
	)

inline

Definition at line 269 of file xct_mcs_adapter_impl.hpp.

References ASSERT_ND, foedus::xct::kMcsMockDataPageLocksPerPage, foedus::xct::McsMockContext< RW_BLOCK >::max_lock_count_, foedus::xct::McsMockContext< RW_BLOCK >::nodes_, foedus::xct::McsMockContext< RW_BLOCK >::pages_per_node_, and foedus::xct::McsMockDataPage::tid_.

                                                                               {
     ASSERT_ND(lock_index < max_lock_count_);
     ASSERT_ND(node_id < nodes_.size());
     const uint64_t page_index = lock_index / kMcsMockDataPageLocksPerPage + 1U;
     const uint64_t lock_in_page_index = lock_index % kMcsMockDataPageLocksPerPage;;
     ASSERT_ND(page_index < pages_per_node_);
     McsMockDataPage* page = nodes_[node_id].pages_ + page_index;
     return page->tid_ + lock_in_page_index;
   }

template<typename RW_BLOCK>

McsWwLock* foedus::xct::McsMockContext< RW_BLOCK >::get_ww_lock_address	(	uint16_t	node_id,
		uint64_t	lock_index
	)

inline

Definition at line 278 of file xct_mcs_adapter_impl.hpp.

References ASSERT_ND, foedus::xct::kMcsMockDataPageLocksPerPage, foedus::xct::McsMockContext< RW_BLOCK >::max_lock_count_, foedus::xct::McsMockContext< RW_BLOCK >::nodes_, foedus::xct::McsMockContext< RW_BLOCK >::pages_per_node_, and foedus::xct::McsMockDataPage::ww_.

                                                                                {
     ASSERT_ND(lock_index < max_lock_count_);
     ASSERT_ND(node_id < nodes_.size());
     const uint64_t page_index = lock_index / kMcsMockDataPageLocksPerPage + 1U;
     const uint64_t lock_in_page_index = lock_index % kMcsMockDataPageLocksPerPage;;
     ASSERT_ND(page_index < pages_per_node_);
     McsMockDataPage* page = nodes_[node_id].pages_ + page_index;
     return page->ww_ + lock_in_page_index;
   }

template<typename RW_BLOCK>

void foedus::xct::McsMockContext< RW_BLOCK >::init	(	storage::StorageId	dummy_storage_id,
		uint32_t	nodes,
		uint32_t	threads_per_node,
		uint32_t	max_block_count,
		uint32_t	max_lock_count
	)

inline

Definition at line 248 of file xct_mcs_adapter_impl.hpp.

References ASSERT_ND, foedus::memory::GlobalVolatilePageResolver::bases_, foedus::memory::GlobalVolatilePageResolver::begin_, foedus::memory::GlobalVolatilePageResolver::end_, foedus::xct::kMcsMockDataPageLocksPerPage, foedus::xct::McsMockContext< RW_BLOCK >::max_block_count_, foedus::xct::McsMockContext< RW_BLOCK >::max_lock_count_, foedus::xct::McsMockContext< RW_BLOCK >::nodes_, foedus::memory::GlobalVolatilePageResolver::numa_node_count_, foedus::xct::McsMockContext< RW_BLOCK >::page_memory_resolver_, and foedus::xct::McsMockContext< RW_BLOCK >::pages_per_node_.

                              {
     max_block_count_ = max_block_count;
     max_lock_count_ = max_lock_count;
     // + 1U for index-0 (which is not used), and +1U for ceiling
     pages_per_node_ = (max_lock_count_ / kMcsMockDataPageLocksPerPage) + 1U + 1U;
     nodes_.resize(nodes);
     page_memory_resolver_.numa_node_count_ = nodes;
     page_memory_resolver_.begin_ = 1U;
     page_memory_resolver_.end_ = pages_per_node_;
     ASSERT_ND(page_memory_resolver_.begin_ < page_memory_resolver_.end_);
     for (uint32_t n = 0; n < nodes; ++n) {
       nodes_[n].init(dummy_storage_id, n, threads_per_node, max_block_count, pages_per_node_);
       page_memory_resolver_.bases_[n] = reinterpret_cast<storage::Page*>(nodes_[n].pages_);
     }
   }