Detailed Description

Definition at line 48 of file thread_pimpl.hpp.

#include <thread_pimpl.hpp>

Collaboration diagram for foedus::thread::ThreadControlBlock:

[legend]

Public Member Functions
	ThreadControlBlock ()=delete

	~ThreadControlBlock ()=delete

void	initialize (ThreadId my_thread_id)

void	uninitialize ()

Public Attributes
uint32_t	mcs_block_current_
	How many MCS blocks we allocated in this thread's current xct. More...

uint32_t	mcs_rw_async_mapping_current_
	How many async mappings for extended RW lock we have so far. More...

std::atomic< bool >	mcs_waiting_
	Whether this thread is waiting for some MCS lock. More...

soc::SharedPolling	wakeup_cond_
	The thread sleeps on this conditional when it has no task. More...

ThreadStatus	status_
	Impersonation status of this thread. More...

soc::SharedMutex	task_mutex_
	The following variables are protected by this mutex. More...

ThreadTicket	current_ticket_
	The most recently issued impersonation ticket. More...

proc::ProcName	proc_name_
	Name of the procedure to execute next. More...

uint32_t	input_len_
	Byte size of input given to the procedure. More...

uint32_t	output_len_
	Byte size of output as the result of the procedure. More...

FixedErrorStack	proc_result_
	Error code as the result of the procedure. More...

soc::SharedPolling	task_complete_cond_
	When the current task has been completed, the thread signals this. More...

Epoch	in_commit_epoch_

ThreadId	my_thread_id_
	Used only for sanity check. More...

uint64_t	stat_snapshot_cache_hits_

uint64_t	stat_snapshot_cache_misses_

Constructor & Destructor Documentation

foedus::thread::ThreadControlBlock::ThreadControlBlock ( )

delete

foedus::thread::ThreadControlBlock::~ThreadControlBlock ( )

delete

Member Function Documentation

void foedus::thread::ThreadControlBlock::initialize ( ThreadId my_thread_id )

inline

Definition at line 53 of file thread_pimpl.hpp.

References foedus::FixedErrorStack::clear(), foedus::assorted::FixedString< MAXLEN, CHAR >::clear(), current_ticket_, in_commit_epoch_, foedus::soc::SharedMutex::initialize(), foedus::soc::SharedPolling::initialize(), input_len_, foedus::INVALID_EPOCH, foedus::thread::kNotInitialized, mcs_block_current_, mcs_rw_async_mapping_current_, mcs_waiting_, my_thread_id_, output_len_, proc_name_, proc_result_, stat_snapshot_cache_hits_, stat_snapshot_cache_misses_, status_, task_complete_cond_, task_mutex_, and wakeup_cond_.

Referenced by foedus::thread::ThreadPimpl::initialize_once().

                                          {
     status_ = kNotInitialized;
     mcs_block_current_ = 0;
     mcs_rw_async_mapping_current_ = 0;
     mcs_waiting_.store(false);
     current_ticket_ = 0;
     proc_name_.clear();
     input_len_ = 0;
     output_len_ = 0;
     proc_result_.clear();
     wakeup_cond_.initialize();
     task_mutex_.initialize();
     task_complete_cond_.initialize();
     in_commit_epoch_ = INVALID_EPOCH;
     my_thread_id_ = my_thread_id;
     stat_snapshot_cache_hits_ = 0;
     stat_snapshot_cache_misses_ = 0;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void foedus::thread::ThreadControlBlock::uninitialize ( )

inline

Definition at line 71 of file thread_pimpl.hpp.

References task_mutex_, and foedus::soc::SharedMutex::uninitialize().

Referenced by foedus::thread::ThreadPimpl::uninitialize_once().

                       {
     task_mutex_.uninitialize();
   }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

ThreadTicket foedus::thread::ThreadControlBlock::current_ticket_

The most recently issued impersonation ticket.

A session with this ticket has an exclusive ownership until it changes the status_ to kWaitingForTask.

Definition at line 120 of file thread_pimpl.hpp.

Referenced by foedus::thread::ImpersonateSession::get_result(), initialize(), foedus::thread::ImpersonateSession::is_running(), foedus::thread::ImpersonateSession::release(), and foedus::thread::ThreadRef::try_impersonate().

Epoch foedus::thread::ThreadControlBlock::in_commit_epoch_

See also: foedus::xct::InCommitEpochGuard

Definition at line 140 of file thread_pimpl.hpp.

Referenced by foedus::thread::ThreadRef::get_in_commit_epoch(), foedus::thread::Thread::get_in_commit_epoch_address(), and initialize().

uint32_t foedus::thread::ThreadControlBlock::input_len_

Byte size of input given to the procedure.

Definition at line 126 of file thread_pimpl.hpp.

Referenced by initialize(), and foedus::thread::ThreadRef::try_impersonate().

uint32_t foedus::thread::ThreadControlBlock::mcs_block_current_

How many MCS blocks we allocated in this thread's current xct.

reset to 0 at each transaction begin. This is in shared memory because other SOC might check this value (so far only for sanity check).

Note: So far this is a shared counter between WW and RW locks. We will thus have holes in both of them. Not a big issue, but we might want dedicated counters.

Definition at line 84 of file thread_pimpl.hpp.

Referenced by foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::cancel_new_block(), foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::get_cur_block(), foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::get_other_cur_block(), foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::get_rw_other_block(), foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::get_ww_other_block(), initialize(), foedus::thread::ThreadPimpl::initialize_once(), and foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::issue_new_block().

uint32_t foedus::thread::ThreadControlBlock::mcs_rw_async_mapping_current_

How many async mappings for extended RW lock we have so far.

Definition at line 87 of file thread_pimpl.hpp.

Referenced by foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::add_rw_async_mapping(), foedus::thread::ThreadRef::get_mcs_rw_async_mapping(), initialize(), foedus::thread::ThreadPimpl::initialize_once(), and foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::remove_rw_async_mapping().

std::atomic<bool> foedus::thread::ThreadControlBlock::mcs_waiting_

Whether this thread is waiting for some MCS lock.

While this is true, the thread spins on this local variable. The lock owner updates this when it unlocks. We initially had this flag within each MCS lock node, but we anyway assume one thread can wait for at most one lock. So, we moved it to a flag in control block.

Definition at line 97 of file thread_pimpl.hpp.

Referenced by initialize(), foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::me_waiting(), and foedus::thread::ThreadPimplMcsAdaptor< RW_BLOCK >::other_waiting().

ThreadId foedus::thread::ThreadControlBlock::my_thread_id_

Used only for sanity check.

This thread's ID.

Definition at line 143 of file thread_pimpl.hpp.

Referenced by initialize().

uint32_t foedus::thread::ThreadControlBlock::output_len_

Byte size of output as the result of the procedure.

Definition at line 129 of file thread_pimpl.hpp.

Referenced by foedus::thread::ImpersonateSession::get_output_size(), and initialize().

proc::ProcName foedus::thread::ThreadControlBlock::proc_name_