Skip to content

File unload_object_file.h

FileList > cubrid > src > executables > unload_object_file.h

Go to the source code of this file

  • #include <thread>

Classes

Type Name
struct _unloaddb_thread_param
struct _waiting_info
struct text_buffer_block
struct text_output

Public Types

Type Name
typedef struct _waiting_info S_WAITING_INFO
typedef struct text_buffer_block TEXT_BUFFER_BLK
typedef struct text_output TEXT_OUTPUT
typedef struct _unloaddb_thread_param UNLD_THR_PARAM

Public Attributes

Type Name
volatile bool error_occurred
int g_fd_handle
int g_io_buffer_size
bool g_multi_thread_mode
int g_sampling_records
UNLD_THR_PARAM * g_thr_param

Public Functions

Type Name
void desc_value_print (print_output & output_ctx, DB_VALUE * value)
int desc_value_special_fprint (TEXT_OUTPUT * tout, DB_VALUE * value)
int flushing_write_blk_queue ()
bool init_queue_n_list_for_object_file (int q_size, int blk_size)
void print_message_with_time (FILE * fp, const char * msg)
int text_print (TEXT_OUTPUT * tout, const char * buf, int buflen, char const * fmt, ...)
int text_print_request_flush (TEXT_OUTPUT * tout, bool force)
void timespec_accumulate (struct timespec * ts_sum, struct timespec * ts_start)
void timespec_addup (struct timespec * ts_sum, struct timespec * ts_add)
void timespec_diff (struct timespec * start, struct timespec * end, struct timespec * diff)

Macros

Type Name
define CHECK_EXIT_ERROR (e) /* multi line expression */
define CHECK_PRINT_ERROR (print_fnc) /* multi line expression */
define INVALID_FILE_NO (-1)
define NANO_PREC_VAL (1000000000L)
define PRINT_MESSAGE_WITH_TIME (fp, msg) [**print\_message\_with\_time**](unload__object__file_8c.md#function-print_message_with_time)((fp), (msg))
define SUPPORT_MULTIPLE_UNLOADDB
define TIMER_BEGIN (flag, pwi) [**if**](dynamic__load_8c.md#function-if)(([**flag**](classflag.md))) [**clock\_gettime**](broker__monitor_8c.md#function-timeout) ([**CLOCK\_MONOTONIC**](broker__monitor_8c.md#function-timeout) /\* [**CLOCK\_REALTIME**](broker__monitor_8c.md#function-timeout) \*/, &(([**pwi**](broker__monitor_8c.md#function-timeout))-&gt;ts\_beging))
define TIMER_CLEAR (pwi) [**memset**](broker__monitor_8c.md#function-timeout)(([**pwi**](broker__monitor_8c.md#function-timeout)), 0x00, [**sizeof**](broker__monitor_8c.md#function-timeout)([**S\_WAITING\_INFO**](unload__object__file_8h.md#typedef-s_waiting_info)))
define TIMER_END (flag, pwi) /* multi line expression */
define YIELD_THREAD () [**std::this\_thread::yield**](broker__monitor_8c.md#function-timeout) ()

Public Types Documentation

typedef S_WAITING_INFO

typedef struct _waiting_info S_WAITING_INFO;

typedef TEXT_BUFFER_BLK

typedef struct text_buffer_block TEXT_BUFFER_BLK;

typedef TEXT_OUTPUT

typedef struct text_output TEXT_OUTPUT;

typedef UNLD_THR_PARAM

typedef struct _unloaddb_thread_param UNLD_THR_PARAM;

Public Attributes Documentation

variable error_occurred

volatile bool error_occurred;

variable g_fd_handle

int g_fd_handle;

variable g_io_buffer_size

int g_io_buffer_size;

variable g_multi_thread_mode

bool g_multi_thread_mode;

variable g_sampling_records

int g_sampling_records;

variable g_thr_param

UNLD_THR_PARAM* g_thr_param;

Public Functions Documentation

function desc_value_print

void desc_value_print (
    print_output & output_ctx,
    DB_VALUE * value
) 

function desc_value_special_fprint

int desc_value_special_fprint (
    TEXT_OUTPUT * tout,
    DB_VALUE * value
) 

function flushing_write_blk_queue

int flushing_write_blk_queue () 

function init_queue_n_list_for_object_file

bool init_queue_n_list_for_object_file (
    int q_size,
    int blk_size
) 

function print_message_with_time

void print_message_with_time (
    FILE * fp,
    const  char * msg
) 

function text_print

int text_print (
    TEXT_OUTPUT * tout,
    const  char * buf,
    int buflen,
    char  const * fmt,
    ...
) 

function text_print_request_flush

int text_print_request_flush (
    TEXT_OUTPUT * tout,
    bool force
) 

function timespec_accumulate

void timespec_accumulate (
    struct  timespec * ts_sum,
    struct  timespec * ts_start
) 

function timespec_addup

void timespec_addup (
    struct  timespec * ts_sum,
    struct  timespec * ts_add
) 

function timespec_diff

void timespec_diff (
    struct  timespec * start,
    struct  timespec * end,
    struct  timespec * diff
) 

Macro Definition Documentation

define CHECK_EXIT_ERROR

#define CHECK_EXIT_ERROR (
    e
) `/* multi line expression */`

define CHECK_PRINT_ERROR

#define CHECK_PRINT_ERROR (
    print_fnc
) `/* multi line expression */`

define INVALID_FILE_NO

#define INVALID_FILE_NO `(-1)`

define NANO_PREC_VAL

#define NANO_PREC_VAL `(1000000000L)`

define PRINT_MESSAGE_WITH_TIME

#define PRINT_MESSAGE_WITH_TIME (
    fp,
    msg
) `print_message_with_time ((fp), (msg))`

define SUPPORT_MULTIPLE_UNLOADDB

#define SUPPORT_MULTIPLE_UNLOADDB 

define TIMER_BEGIN

#define TIMER_BEGIN (
    flag,
    pwi
) `if (( flag )) clock_gettime ( CLOCK_MONOTONIC /* CLOCK_REALTIME */, &(( pwi )->ts_beging))`

define TIMER_CLEAR

#define TIMER_CLEAR (
    pwi
) `memset (( pwi ), 0x00, sizeof ( S_WAITING_INFO ))`

define TIMER_END

#define TIMER_END (
    flag,
    pwi
) `/* multi line expression */`

define YIELD_THREAD

#define YIELD_THREAD (

) `std::this_thread::yield ()`


The documentation for this class was generated from the following file cubrid/src/executables/unload_object_file.h