log.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	log_info (const char *format,...)
void	log_error (const char *format,...)
void	print_info (const char *format,...)
void	print_error (const char *format,...)
void	log_init ()
void	die (const char *format,...)

---

Function Documentation

void die (  const char *  format,   ... )

{ va_list args; fprintf(stderr,"%s: ", my_progname); va_start(args, format); vfprintf(stderr, format, args); va_end(args); fprintf(stderr, "\n"); exit(1); }

void log_error (  const char *  format,   ... )

{ va_list args; va_start(args, format); log(stderr, format, args); va_end(args); }

void log_info (  const char *  format,   ... )

{ va_list args; va_start(args, format); log(stdout, format, args); va_end(args); }

void log_init (   )

{ byte* buf; log_sys = mem_alloc(sizeof(log_t)); mutex_create(&(log_sys->mutex)); mutex_set_level(&(log_sys->mutex), SYNC_LOG); mutex_enter(&(log_sys->mutex)); /* Start the lsn from one log block from zero: this way every log record has a start lsn != zero, a fact which we will use */ log_sys->lsn = LOG_START_LSN; ut_a(LOG_BUFFER_SIZE >= 16 * OS_FILE_LOG_BLOCK_SIZE); ut_a(LOG_BUFFER_SIZE >= 4 * UNIV_PAGE_SIZE); buf = ut_malloc(LOG_BUFFER_SIZE + OS_FILE_LOG_BLOCK_SIZE); log_sys->buf = ut_align(buf, OS_FILE_LOG_BLOCK_SIZE); log_sys->buf_size = LOG_BUFFER_SIZE; memset(log_sys->buf, '\0', LOG_BUFFER_SIZE); log_sys->max_buf_free = log_sys->buf_size / LOG_BUF_FLUSH_RATIO - LOG_BUF_FLUSH_MARGIN; log_sys->check_flush_or_checkpoint = TRUE; UT_LIST_INIT(log_sys->log_groups); log_sys->n_log_ios = 0; log_sys->n_log_ios_old = log_sys->n_log_ios; log_sys->last_printout_time = time(NULL); /*----------------------------*/ log_sys->buf_next_to_write = 0; log_sys->write_lsn = ut_dulint_zero; log_sys->current_flush_lsn = ut_dulint_zero; log_sys->flushed_to_disk_lsn = ut_dulint_zero; log_sys->written_to_some_lsn = log_sys->lsn; log_sys->written_to_all_lsn = log_sys->lsn; log_sys->n_pending_writes = 0; log_sys->no_flush_event = os_event_create(NULL); os_event_set(log_sys->no_flush_event); log_sys->one_flushed_event = os_event_create(NULL); os_event_set(log_sys->one_flushed_event); /*----------------------------*/ log_sys->adm_checkpoint_interval = ULINT_MAX; log_sys->next_checkpoint_no = ut_dulint_zero; log_sys->last_checkpoint_lsn = log_sys->lsn; log_sys->n_pending_checkpoint_writes = 0; rw_lock_create(&(log_sys->checkpoint_lock)); rw_lock_set_level(&(log_sys->checkpoint_lock), SYNC_NO_ORDER_CHECK); log_sys->checkpoint_buf = ut_align( mem_alloc(2 * OS_FILE_LOG_BLOCK_SIZE), OS_FILE_LOG_BLOCK_SIZE); memset(log_sys->checkpoint_buf, '\0', OS_FILE_LOG_BLOCK_SIZE); /*----------------------------*/ #ifdef UNIV_LOG_ARCHIVE /* Under MySQL, log archiving is always off */ log_sys->archiving_state = LOG_ARCH_OFF; log_sys->archived_lsn = log_sys->lsn; log_sys->next_archived_lsn = ut_dulint_zero; log_sys->n_pending_archive_ios = 0; rw_lock_create(&(log_sys->archive_lock)); rw_lock_set_level(&(log_sys->archive_lock), SYNC_NO_ORDER_CHECK); log_sys->archive_buf = NULL; /* ut_align( ut_malloc(LOG_ARCHIVE_BUF_SIZE + OS_FILE_LOG_BLOCK_SIZE), OS_FILE_LOG_BLOCK_SIZE); */ log_sys->archive_buf_size = 0; /* memset(log_sys->archive_buf, '\0', LOG_ARCHIVE_BUF_SIZE); */ log_sys->archiving_on = os_event_create(NULL); #endif /* UNIV_LOG_ARCHIVE */ /*----------------------------*/ log_block_init(log_sys->buf, log_sys->lsn); log_block_set_first_rec_group(log_sys->buf, LOG_BLOCK_HDR_SIZE); log_sys->buf_free = LOG_BLOCK_HDR_SIZE; log_sys->lsn = ut_dulint_add(LOG_START_LSN, LOG_BLOCK_HDR_SIZE); mutex_exit(&(log_sys->mutex)); #ifdef UNIV_LOG_DEBUG recv_sys_create(); recv_sys_init(FALSE, buf_pool_get_curr_size()); recv_sys->parse_start_lsn = log_sys->lsn; recv_sys->scanned_lsn = log_sys->lsn; recv_sys->scanned_checkpoint_no = 0; recv_sys->recovered_lsn = log_sys->lsn; recv_sys->limit_lsn = ut_dulint_max; #endif }

void print_error (  const char *  format,   ... )

{ va_list args; va_start(args, format); vfprintf(stderr, format, args); va_end(args); }

void print_info (  const char *  format,   ... )

{ va_list args; va_start(args, format); vfprintf(stdout, format, args); va_end(args); }

---