File thread_entry.cpp¶

FileList > cubrid > src > thread > thread_entry.cpp

#include "thread_entry.hpp"
#include "critical_section.h"
#include "critical_section_tracker.hpp"
#include "error_manager.h"
#include "fault_injection.h"
#include "list_file.h"
#include "lock_free.h"
#include "lockfree_transaction_system.hpp"
#include "log_compress.h"
#include "log_system_tran.hpp"
#include "memory_alloc.h"
#include "page_buffer.h"
#include "resource_tracker.hpp"
#include <cstring>
#include <sstream>
#include <pthread.h>
#include "memory_wrapper.hpp"

Namespaces¶

Type	Name
namespace	cubthread

Public Types¶

Type	Name
typedef std::chrono::system_clock	thread_clock_type

Public Functions¶

Type	Name
void	thread_check_suspend_reason_and_wakeup (cubthread::entry * thread_p, thread_resume_suspend_status resume_reason, thread_resume_suspend_status suspend_reason)
const char *	thread_resume_status_to_string (thread_resume_suspend_status resume_status)
const char *	thread_status_to_string (cubthread::entry::status status)
int	thread_suspend_timeout_wakeup_and_unlock_entry (cubthread::entry * thread_p, struct timespec * time_p, thread_resume_suspend_status suspended_reason)
void	thread_suspend_wakeup_and_unlock_entry (cubthread::entry * thread_p, thread_resume_suspend_status suspended_reason)
int	thread_suspend_with_other_mutex (cubthread::entry * thread_p, pthread_mutex_t * mutex_p, int timeout, struct timespec * to, thread_resume_suspend_status suspended_reason)
const char *	thread_type_to_string (thread_type type)
void	thread_wakeup (cubthread::entry * thread_p, thread_resume_suspend_status resume_reason)
void	thread_wakeup_already_had_mutex (cubthread::entry * thread_p, thread_resume_suspend_status resume_reason)

Public Static Functions¶

Type	Name
void	thread_check_suspend_reason_and_wakeup_internal (cubthread::entry * thread_p, thread_resume_suspend_status resume_reason, thread_resume_suspend_status suspend_reason, bool had_mutex)
void	thread_timeval_add_usec (const std::chrono::microseconds & usec, struct timeval & tv)
void	thread_wakeup_internal (cubthread::entry * thread_p, thread_resume_suspend_status resume_reason, bool had_mutex)

Public Types Documentation¶

typedef thread_clock_type¶

using thread_clock_type =  std::chrono::system_clock;

Public Functions Documentation¶

function thread_check_suspend_reason_and_wakeup¶

void thread_check_suspend_reason_and_wakeup (
    cubthread::entry * thread_p,
    thread_resume_suspend_status resume_reason,
    thread_resume_suspend_status suspend_reason
)

function thread_resume_status_to_string¶

const  char * thread_resume_status_to_string (
    thread_resume_suspend_status resume_status
)

function thread_status_to_string¶

const  char * thread_status_to_string (
    cubthread::entry::status status
)

function thread_suspend_timeout_wakeup_and_unlock_entry¶

int thread_suspend_timeout_wakeup_and_unlock_entry (
    cubthread::entry * thread_p,
    struct  timespec * time_p,
    thread_resume_suspend_status suspended_reason
)

function thread_suspend_wakeup_and_unlock_entry¶

void thread_suspend_wakeup_and_unlock_entry (
    cubthread::entry * thread_p,
    thread_resume_suspend_status suspended_reason
)

function thread_suspend_with_other_mutex¶

int thread_suspend_with_other_mutex (
    cubthread::entry * thread_p,
    pthread_mutex_t * mutex_p,
    int timeout,
    struct  timespec * to,
    thread_resume_suspend_status suspended_reason
)

function thread_type_to_string¶

const  char * thread_type_to_string (
    thread_type type
)

function thread_wakeup¶

void thread_wakeup (
    cubthread::entry * thread_p,
    thread_resume_suspend_status resume_reason
)

function thread_wakeup_already_had_mutex¶

void thread_wakeup_already_had_mutex (
    cubthread::entry * thread_p,
    thread_resume_suspend_status resume_reason
)

Public Static Functions Documentation¶

function thread_check_suspend_reason_and_wakeup_internal¶

static void thread_check_suspend_reason_and_wakeup_internal (
    cubthread::entry * thread_p,
    thread_resume_suspend_status resume_reason,
    thread_resume_suspend_status suspend_reason,
    bool had_mutex
)

function thread_timeval_add_usec¶

static void thread_timeval_add_usec (
    const  std::chrono::microseconds & usec,
    struct  timeval & tv
)

function thread_wakeup_internal¶

static void thread_wakeup_internal (
    cubthread::entry * thread_p,
    thread_resume_suspend_status resume_reason,
    bool had_mutex
)

The documentation for this class was generated from the following file cubrid/src/thread/thread_entry.cpp