greg/stasis-aries-wal
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed truncation bug (truncation is more aggressive now), and added more debugging info.

Browse source
This commit is contained in:
Sears Russell 2006-06-12 20:55:49 +00:00
parent 5f307ab820
commit 7bb0ce0d17
2 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/lladd/logger/logWriter.c
View file

@ -463,6 +463,7 @@ int truncateLog(lsn_t LSN) {
if(global_offset + sizeof(lsn_t) >= LSN) { if(global_offset + sizeof(lsn_t) >= LSN) {
/* Another thread beat us to it...the log is already truncated /* Another thread beat us to it...the log is already truncated
past the point requested, so just return. */ past the point requested, so just return. */
printf("Skipping truncate. global_offset = %ld, requested LSN = %ld\n", global_offset, LSN);
pthread_mutex_unlock(&truncateLog_mutex); pthread_mutex_unlock(&truncateLog_mutex);
return 0; return 0;
} }
@ -530,6 +531,9 @@ int truncateLog(lsn_t LSN) {
perror("Error replacing old log file with new log file"); perror("Error replacing old log file with new log file");
return LLADD_IO_ERROR; return LLADD_IO_ERROR;
} else {
printf("Truncation complete.\n");
fflush(stdout);
} }
int logFD = open (LOG_FILE, O_CREAT | O_WRONLY | O_APPEND | O_SYNC, S_IRWXU | S_IRWXG | S_IRWXO); int logFD = open (LOG_FILE, O_CREAT | O_WRONLY | O_APPEND | O_SYNC, S_IRWXU | S_IRWXG | S_IRWXO);

9
src/lladd/truncation.c
View file

@ -171,12 +171,13 @@ int truncateNow() {
printf("Truncating to rec_lsn = %ld\n", rec_lsn); printf("Truncating to rec_lsn = %ld\n", rec_lsn);
fflush(stdout); fflush(stdout);
if(rec_lsn != flushed) { // What was this check for?!?
//if(rec_lsn != flushed) {
LogTruncate(rec_lsn); LogTruncate(rec_lsn);
return 1; return 1;
} else { // } else {
return 0; // return 0;
} // }
} else { } else {
return 0; return 0;
} }