File unload_object_file.c¶

FileList > cubrid > src > executables > unload_object_file.c

#include <inttypes.h>
#include "config.h"
#include <stdio.h>
#include <fcntl.h>
#include <assert.h>
#include <unistd.h>
#include <ctype.h>
#include <sys/stat.h>
#include <math.h>
#include "utility.h"
#include "misc_string.h"
#include "memory_alloc.h"
#include "dbtype.h"
#include "object_representation.h"
#include "work_space.h"
#include "class_object.h"
#include "object_primitive.h"
#include "set_object.h"
#include "db.h"
#include "schema_manager.h"
#include "server_interface.h"
#include "load_object.h"
#include "unload_object_file.h"
#include "db_value_printer.hpp"
#include "network_interface_cl.h"
#include "printer.hpp"
#include "message_catalog.h"
#include "string_opfunc.h"
#include "porting.h"

Classes¶

Type	Name
class	text_buffer_mgr
class	write_block_queue

Public Attributes¶

Type	Name
volatile bool	error_occurred = `[false](broker__monitor_8c.md#function-timeout)`
int	g_fd_handle = `(-1)`
int	g_io_buffer_size = `4096`
bool	g_multi_thread_mode = `[false](broker__monitor_8c.md#function-timeout)`
int	g_sampling_records = `-1`
UNLD_THR_PARAM *	g_thr_param = `[NULL](freelistheap_8h.md#define-null)`
S_WAITING_INFO	wi_write_file

Public Static Attributes¶

Type	Name
class text_buffer_mgr	c_text_buf_mgr
class write_block_queue	c_write_blk_queue

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)
bool	need_append_dot (const char * val)
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)

Public Static Functions¶

Type	Name
int	bfmt_print (int bfmt, const DB_VALUE * the_db_bit, char * string, int max_size)
int	flush_quoted_str (TEXT_OUTPUT * tout, const char * st, int tlen)
int	fprint_special_set (TEXT_OUTPUT * tout, DB_SET * set)
int	fprint_special_strings (TEXT_OUTPUT * tout, DB_VALUE * value)
int	get_text_output_mem (TEXT_OUTPUT * tout, int alloc_sz)
int	print_quoted_str (TEXT_OUTPUT * tout, const char * str, int len, int max_token_len)
void	print_set (print_output & output_ctx, DB_SET * set)
int	write_object_file (TEXT_BUFFER_BLK * head)

Macros¶

Type	Name
define	BITS_IN_BYTE `8`
define	BITS_IN_HEX `4`
define	BYTE_COUNT (bit_cnt) `((([bit\_cnt](broker__monitor_8c.md#function-timeout))+[BITS\_IN\_BYTE](cnv_8c.md#define-bits_in_byte)-1)/[BITS\_IN\_BYTE](cnv_8c.md#define-bits_in_byte))`
define	BYTE_COUNT_HEX (bit_cnt) `((([bit\_cnt](broker__monitor_8c.md#function-timeout))+[BITS\_IN\_HEX](cnv_8c.md#define-bits_in_hex)-1)/[BITS\_IN\_HEX](cnv_8c.md#define-bits_in_hex))`
define	DBL_MAX_DIGITS `(([int](broker__monitor_8c.md#function-timeout))[ceil](broker__monitor_8c.md#function-timeout)([DBL\_MAX\_EXP](broker__monitor_8c.md#function-timeout) \* [log10](broker__monitor_8c.md#function-timeout)([FLT\_RADIX](broker__monitor_8c.md#function-timeout))))`
define	HEX_IN_BYTE `2`
define	INTERNAL_BUFFER_SIZE `(400) /\* [bigger](broker__monitor_8c.md#function-timeout) [than](broker__monitor_8c.md#function-timeout) [DBL\_MAX\_DIGITS](unload__object__file_8c.md#define-dbl_max_digits) \*/`
define	MAX_DISPLAY_COLUMN `70`
define	__STDC_FORMAT_MACROS

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;

variable wi_write_file¶

S_WAITING_INFO wi_write_file;

Public Static Attributes Documentation¶

variable c_text_buf_mgr¶

class text_buffer_mgr c_text_buf_mgr;

variable c_write_blk_queue¶

class write_block_queue c_write_blk_queue;

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 need_append_dot¶

inline bool need_append_dot (
    const  char * val
)

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
)

Public Static Functions Documentation¶

function bfmt_print¶

static int bfmt_print (
    int bfmt,
    const  DB_VALUE * the_db_bit,
    char * string,
    int max_size
)

function flush_quoted_str¶

static int flush_quoted_str (
    TEXT_OUTPUT * tout,
    const  char * st,
    int tlen
)

function fprint_special_set¶

static int fprint_special_set (
    TEXT_OUTPUT * tout,
    DB_SET * set
)

function fprint_special_strings¶

static int fprint_special_strings (
    TEXT_OUTPUT * tout,
    DB_VALUE * value
)

function get_text_output_mem¶

static int get_text_output_mem (
    TEXT_OUTPUT * tout,
    int alloc_sz
)

function print_quoted_str¶

static int print_quoted_str (
    TEXT_OUTPUT * tout,
    const  char * str,
    int len,
    int max_token_len
)

function print_set¶

static void print_set (
    print_output & output_ctx,
    DB_SET * set
)

function write_object_file¶

static int write_object_file (
    TEXT_BUFFER_BLK * head
)

Macro Definition Documentation¶

define BITS_IN_BYTE¶

#define BITS_IN_BYTE `8`

define BITS_IN_HEX¶

#define BITS_IN_HEX `4`

define BYTE_COUNT¶

#define BYTE_COUNT (
    bit_cnt
) `((( bit_cnt )+ BITS_IN_BYTE -1)/ BITS_IN_BYTE )`

define BYTE_COUNT_HEX¶

#define BYTE_COUNT_HEX (
    bit_cnt
) `((( bit_cnt )+ BITS_IN_HEX -1)/ BITS_IN_HEX )`

define DBL_MAX_DIGITS¶

#define DBL_MAX_DIGITS `(( int ) ceil ( DBL_MAX_EXP * log10 ( FLT_RADIX )))`

define HEX_IN_BYTE¶

#define HEX_IN_BYTE `2`

define INTERNAL_BUFFER_SIZE¶

#define INTERNAL_BUFFER_SIZE `(400) /* bigger  than  DBL_MAX_DIGITS */`

define MAX_DISPLAY_COLUMN¶

#define MAX_DISPLAY_COLUMN `70`

define __STDC_FORMAT_MACROS¶

#define __STDC_FORMAT_MACROS

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