diff options
Diffstat (limited to 'storage/tokudb/PerconaFT/ft/logger/logfilemgr.cc')
| -rw-r--r-- | storage/tokudb/PerconaFT/ft/logger/logfilemgr.cc | 205 |
1 files changed, 205 insertions, 0 deletions
diff --git a/storage/tokudb/PerconaFT/ft/logger/logfilemgr.cc b/storage/tokudb/PerconaFT/ft/logger/logfilemgr.cc new file mode 100644 index 00000000..e9028f49 --- /dev/null +++ b/storage/tokudb/PerconaFT/ft/logger/logfilemgr.cc @@ -0,0 +1,205 @@ +/* -*- mode: C++; c-basic-offset: 4; indent-tabs-mode: nil -*- */ +// vim: ft=cpp:expandtab:ts=8:sw=4:softtabstop=4: +#ident "$Id$" +/*====== +This file is part of PerconaFT. + + +Copyright (c) 2006, 2015, Percona and/or its affiliates. All rights reserved. + + PerconaFT is free software: you can redistribute it and/or modify + it under the terms of the GNU General Public License, version 2, + as published by the Free Software Foundation. + + PerconaFT is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with PerconaFT. If not, see <http://www.gnu.org/licenses/>. + +---------------------------------------- + + PerconaFT is free software: you can redistribute it and/or modify + it under the terms of the GNU Affero General Public License, version 3, + as published by the Free Software Foundation. + + PerconaFT is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU Affero General Public License for more details. + + You should have received a copy of the GNU Affero General Public License + along with PerconaFT. If not, see <http://www.gnu.org/licenses/>. +======= */ + +#ident "Copyright (c) 2006, 2015, Percona and/or its affiliates. All rights reserved." + +#include <my_global.h> +#include "logger/log-internal.h" +#include "logger/logcursor.h" +#include "logger/logfilemgr.h" + +// for now, implement with singlely-linked-list +// first = oldest (delete from beginning) +// last = newest (add to end) + +struct lfm_entry { + TOKULOGFILEINFO lf_info; + struct lfm_entry *next; +}; + +struct toku_logfilemgr { + struct lfm_entry *first; + struct lfm_entry *last; + int n_entries; +}; + +int toku_logfilemgr_create(TOKULOGFILEMGR *lfm) { + // malloc a logfilemgr + TOKULOGFILEMGR XMALLOC(mgr); + mgr->first = NULL; + mgr->last = NULL; + mgr->n_entries = 0; + *lfm = mgr; + return 0; +} + +int toku_logfilemgr_destroy(TOKULOGFILEMGR *lfm) { + int r=0; + if ( *lfm != NULL ) { // be tolerant of being passed a NULL + TOKULOGFILEMGR mgr = *lfm; + while ( mgr->n_entries > 0 ) { + toku_logfilemgr_delete_oldest_logfile_info(mgr); + } + toku_free(*lfm); + *lfm = NULL; + } + return r; +} + +int toku_logfilemgr_init(TOKULOGFILEMGR lfm, const char *log_dir, TXNID *last_xid_if_clean_shutdown) { + invariant_notnull(lfm); + invariant_notnull(last_xid_if_clean_shutdown); + + int r; + int n_logfiles; + char **logfiles; + r = toku_logger_find_logfiles(log_dir, &logfiles, &n_logfiles); + if (r!=0) + return r; + + TOKULOGCURSOR cursor; + struct log_entry *entry; + TOKULOGFILEINFO lf_info; + long long index = -1; + char *basename; + LSN tmp_lsn = {0}; + TXNID last_xid = TXNID_NONE; + for(int i=0;i<n_logfiles;i++){ + XMALLOC(lf_info); + // find the index + // basename is the filename of the i-th logfile + basename = strrchr(logfiles[i], '/') + 1; + int version; + r = sscanf(basename, "log%lld.tokulog%d", &index, &version); + assert(r==2); // found index and version + assert(version>=TOKU_LOG_MIN_SUPPORTED_VERSION); + assert(version<=TOKU_LOG_VERSION); + lf_info->index = index; + lf_info->version = version; + // find last LSN in logfile + r = toku_logcursor_create_for_file(&cursor, log_dir, basename); + if (r!=0) { + return r; + } + r = toku_logcursor_last(cursor, &entry); // set "entry" to last log entry in logfile + if (r == 0) { + lf_info->maxlsn = toku_log_entry_get_lsn(entry); + + invariant(lf_info->maxlsn.lsn >= tmp_lsn.lsn); + tmp_lsn = lf_info->maxlsn; + if (entry->cmd == LT_shutdown) { + last_xid = entry->u.shutdown.last_xid; + } else { + last_xid = TXNID_NONE; + } + } + else { + lf_info->maxlsn = tmp_lsn; // handle empty logfile (no LSN in file) case + } + + // add to logfilemgr + toku_logfilemgr_add_logfile_info(lfm, lf_info); + toku_logcursor_destroy(&cursor); + } + toku_logger_free_logfiles(logfiles, n_logfiles); + *last_xid_if_clean_shutdown = last_xid; + return 0; +} + +int toku_logfilemgr_num_logfiles(TOKULOGFILEMGR lfm) { + assert(lfm); + return lfm->n_entries; +} + +int toku_logfilemgr_add_logfile_info(TOKULOGFILEMGR lfm, TOKULOGFILEINFO lf_info) { + assert(lfm); + struct lfm_entry *XMALLOC(entry); + entry->lf_info = lf_info; + entry->next = NULL; + if ( lfm->n_entries != 0 ) + lfm->last->next = entry; + lfm->last = entry; + lfm->n_entries++; + if (lfm->n_entries == 1 ) { + lfm->first = lfm->last; + } + return 0; +} + +TOKULOGFILEINFO toku_logfilemgr_get_oldest_logfile_info(TOKULOGFILEMGR lfm) { + assert(lfm); + return lfm->first->lf_info; +} + +void toku_logfilemgr_delete_oldest_logfile_info(TOKULOGFILEMGR lfm) { + assert(lfm); + if ( lfm->n_entries > 0 ) { + struct lfm_entry *entry = lfm->first; + toku_free(entry->lf_info); + lfm->first = entry->next; + toku_free(entry); + lfm->n_entries--; + if ( lfm->n_entries == 0 ) { + lfm->last = lfm->first = NULL; + } + } +} + +LSN toku_logfilemgr_get_last_lsn(TOKULOGFILEMGR lfm) { + assert(lfm); + if ( lfm->n_entries == 0 ) { + LSN lsn; + lsn.lsn = 0; + return lsn; + } + return lfm->last->lf_info->maxlsn; +} + +void toku_logfilemgr_update_last_lsn(TOKULOGFILEMGR lfm, LSN lsn) { + assert(lfm); + assert(lfm->last!=NULL); + lfm->last->lf_info->maxlsn = lsn; +} + +void toku_logfilemgr_print(TOKULOGFILEMGR lfm) { + assert(lfm); + printf("toku_logfilemgr_print [%p] : %d entries \n", lfm, lfm->n_entries); + struct lfm_entry *entry = lfm->first; + for (int i=0;i<lfm->n_entries;i++) { + printf(" entry %d : index = %" PRId64 ", maxlsn = %" PRIu64 "\n", i, entry->lf_info->index, entry->lf_info->maxlsn.lsn); + entry = entry->next; + } +} |