Commit d7ff1a3e authored by Bradley C. Kuszmaul's avatar Bradley C. Kuszmaul Committed by Yoni Fogel

Merge r18221. No substantial changes. Refs #2467. [t:2467].

git-svn-id: file:///svn/toku/tokudb@18651 c7de825b-a66e-492c-adef-691d508d4ae1
parent b5fda103
...@@ -67,8 +67,8 @@ int toku_logger_create (TOKULOGGER *resultp) { ...@@ -67,8 +67,8 @@ int toku_logger_create (TOKULOGGER *resultp) {
r = toku_pthread_cond_init(&result->output_condition, NULL); if (r!=0) goto panic; r = toku_pthread_cond_init(&result->output_condition, NULL); if (r!=0) goto panic;
result->input_lock_ctr = 0; result->input_lock_ctr = 0;
result->output_condition_lock_ctr = 0; result->output_condition_lock_ctr = 0;
result->output_is_available = TRUE;
result->swap_ctr = 0; result->swap_ctr = 0;
result->output_is_available = TRUE;
return 0; return 0;
panic: panic:
...@@ -327,7 +327,6 @@ write_outbuf_to_logfile (TOKULOGGER logger, LSN *fsynced_lsn) ...@@ -327,7 +327,6 @@ write_outbuf_to_logfile (TOKULOGGER logger, LSN *fsynced_lsn)
} }
} }
int int
toku_logger_make_space_in_inbuf (TOKULOGGER logger, int n_bytes_needed) toku_logger_make_space_in_inbuf (TOKULOGGER logger, int n_bytes_needed)
// Entry: Holds the inlock // Entry: Holds the inlock
...@@ -594,6 +593,20 @@ void toku_logger_trim_log_files (TOKULOGGER logger, BOOL trim_log_files) ...@@ -594,6 +593,20 @@ void toku_logger_trim_log_files (TOKULOGGER logger, BOOL trim_log_files)
logger->trim_log_files = trim_log_files; logger->trim_log_files = trim_log_files;
} }
double get_tdiff(void) {
static struct timeval prev={0,0};
if (prev.tv_sec==0) {
gettimeofday(&prev, 0);
return 0.0;
} else {
struct timeval now;
gettimeofday(&now, 0);
double diff = now.tv_sec - prev.tv_sec + 1e-6*(now.tv_usec - prev.tv_usec);
prev = now;
return diff;
}
}
int toku_logger_maybe_fsync (TOKULOGGER logger, LSN lsn, int do_fsync) int toku_logger_maybe_fsync (TOKULOGGER logger, LSN lsn, int do_fsync)
// Effect: If fsync is nonzero, then make sure that the log is flushed and synced at least up to lsn. // Effect: If fsync is nonzero, then make sure that the log is flushed and synced at least up to lsn.
// Entry: Holds input lock. The log entry has already been written to the input buffer. // Entry: Holds input lock. The log entry has already been written to the input buffer.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment