[t:4875], add brt_header.h and move functions there

git-svn-id: file:///svn/toku/tokudb@43425 c7de825b-a66e-492c-adef-691d508d4ae1

newbrt/brt-internal.h

@@ -470,10 +470,6 @@ int toku_keycompare (bytevec key1, ITEMLEN key1len, bytevec key2, ITEMLEN key2le
 
 void toku_verify_or_set_counts(BRTNODE);
 
-void 
-toku_brt_header_init(struct brt_header *h,
-                     BLOCKNUM root_blocknum_on_disk, LSN checkpoint_lsn, TXNID root_xid_that_created, uint32_t target_nodesize, uint32_t target_basementnodesize, enum toku_compression_method compression_method);
-
 int toku_serialize_brt_header_size (struct brt_header *h);
 int toku_serialize_brt_header_to (int fd, struct brt_header *h);
 int toku_serialize_brt_header_to_wbuf (struct wbuf *, struct brt_header *h, int64_t address_translation, int64_t size_translation);
@@ -545,9 +541,6 @@ extern int toku_brtnode_pe_callback (void *brtnode_pv, PAIR_ATTR old_attr, PAIR_
 extern BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs);
 int toku_brtnode_pf_callback(void* brtnode_pv, void* UU(disk_data), void* read_extraargs, int fd, PAIR_ATTR* sizep);
 extern int toku_brtnode_cleaner_callback( void *brtnode_pv, BLOCKNUM blocknum, u_int32_t fullhash, void *extraargs);
-extern int toku_brt_alloc_init_header(BRT t, TOKUTXN txn);
-extern int toku_read_brt_header_and_store_in_cachefile (BRT brt, CACHEFILE cf, LSN max_acceptable_lsn, struct brt_header **header, BOOL* was_open);
-void toku_brtheader_note_brt_open(BRT live);
 extern CACHEKEY* toku_calculate_root_offset_pointer (struct brt_header* h, u_int32_t *root_hash);
 
 static inline CACHETABLE_WRITE_CALLBACK get_write_callbacks_for_node(struct brt_header* h) {
@@ -809,15 +802,6 @@ toku_verify_brtnode (BRT brt,
                      int recurse, int verbose, int keep_going_on_failure)
     __attribute__ ((warn_unused_result));
 
-void toku_brtheader_init_treelock(struct brt_header* h);
-void toku_brtheader_destroy_treelock(struct brt_header* h);
-void toku_brtheader_grab_treelock(struct brt_header* h);
-void toku_brtheader_release_treelock(struct brt_header* h);
-void toku_brtheader_free (struct brt_header *h);
-int toku_brtheader_close (CACHEFILE cachefile, int fd, void *header_v, char **error_string, BOOL oplsn_valid, LSN oplsn) __attribute__((__warn_unused_result__));
-int toku_brtheader_begin_checkpoint (LSN checkpoint_lsn, void *header_v) __attribute__((__warn_unused_result__));
-int toku_brtheader_checkpoint (CACHEFILE cachefile, int fd, void *header_v) __attribute__((__warn_unused_result__));
-int toku_brtheader_end_checkpoint (CACHEFILE cachefile, int fd, void *header_v) __attribute__((__warn_unused_result__));
 int toku_db_badformat(void) __attribute__((__warn_unused_result__));
 
 int toku_brt_remove_on_commit(TOKUTXN child, DBT* iname_dbt_p) __attribute__((__warn_unused_result__));
@@ -969,7 +953,4 @@ void toku_reset_root_xid_that_created(struct brt_header* h, TXNID new_root_xid_t
 // This redefines which xid created the dictionary.
 void toku_flusher_thread_set_callback(void (*callback_f)(int, void*), void* extra);
 
-void toku_brt_header_note_hot_begin(BRT brt);
-void toku_brt_header_note_hot_complete(BRT brt, BOOL success, MSN msn_at_start_of_hot);
-
 #endif

newbrt/brt.h

@@ -114,9 +114,6 @@ toku_brt_open_with_dict_id(
     DICTIONARY_ID use_dictionary_id
     )  __attribute__ ((warn_unused_result));
 
-int 
-toku_create_new_brtheader(BRT t, CACHEFILE cf, TOKUTXN txn);
-
 int toku_brt_remove_subdb(BRT brt, const char *dbname, u_int32_t flags)  __attribute__ ((warn_unused_result));
 
 int toku_brt_lookup (BRT brt, DBT *k, BRT_GET_CALLBACK_FUNCTION getf, void *getf_v)  __attribute__ ((warn_unused_result));
@@ -167,7 +164,6 @@ int toku_brt_send_commit_any(BRT brt, DBT *key, XIDS xids) __attribute__ ((warn_
 int toku_brt_close (BRT brt, bool oplsn_valid, LSN oplsn)  __attribute__ ((warn_unused_result));
 
 int toku_close_brt_nolsn (BRT, char **error_string)  __attribute__ ((warn_unused_result));
-int toku_remove_brtheader (struct brt_header* h, char **error_string, BOOL oplsn_valid, LSN oplsn)  __attribute__ ((warn_unused_result));
 
 int toku_brt_set_panic(BRT brt, int panic, char *panic_string)  __attribute__ ((warn_unused_result));
 
@@ -272,18 +268,12 @@ void toku_brt_require_local_checkpoint (BRT brt, TOKUTXN txn);
 // Require that dictionary specified by brt is fully written to disk before
 // transaction txn is committed.
 
-
-void toku_brt_header_suppress_rollbacks(struct brt_header *h, TOKUTXN txn);
-//Effect: suppresses rollback logs
-
 void toku_brt_suppress_recovery_logs (BRT brt, TOKUTXN txn);
 // Effect: suppresses recovery logs
 // Requires: this is a (target) redirected brt
 //           implies: txnid_that_created_or_locked_when_empty matches txn 
 //           implies: toku_txn_note_brt(brt, txn) has been called
 
-int toku_brt_header_needed(struct brt_header* h);
-
 int toku_brt_get_fragmentation(BRT brt, TOKU_DB_FRAGMENTATION report) __attribute__ ((warn_unused_result));
 int toku_brt_header_set_panic(struct brt_header *h, int panic, char *panic_string) __attribute__ ((warn_unused_result));
 

newbrt/brt_header.h

+/* -*- mode: C; c-basic-offset: 4 -*- */
+#ifndef BRTHEADER_H
+#define BRTHEADER_H
+#ident "$Id: brt_header.h 43422 2012-05-12 17:51:02Z zardosht $"
+#ident "Copyright (c) 2007-2010 Tokutek Inc.  All rights reserved."
+#ident "The technology is licensed by the Massachusetts Institute of Technology, Rutgers State University of New Jersey, and the Research Foundation of State University of New York at Stony Brook under United States of America Serial No. 11/760379 and to the patents and/or patent applications resulting from it."
+
+#include "brttypes.h"
+#include "ybt.h"
+#include <db.h>
+#include "cachetable.h"
+#include "log.h"
+#include "brt-search.h"
+#include "compress.h"
+
+void toku_brt_header_suppress_rollbacks(struct brt_header *h, TOKUTXN txn);
+//Effect: suppresses rollback logs
+
+void toku_brtheader_init_treelock(struct brt_header* h);
+void toku_brtheader_destroy_treelock(struct brt_header* h);
+void toku_brtheader_grab_treelock(struct brt_header* h);
+void toku_brtheader_release_treelock(struct brt_header* h);
+
+int toku_brtheader_close (CACHEFILE cachefile, int fd, void *header_v, char **error_string, BOOL oplsn_valid, LSN oplsn) __attribute__((__warn_unused_result__));
+int toku_brtheader_begin_checkpoint (LSN checkpoint_lsn, void *header_v) __attribute__((__warn_unused_result__));
+int toku_brtheader_checkpoint (CACHEFILE cachefile, int fd, void *header_v) __attribute__((__warn_unused_result__));
+int toku_brtheader_end_checkpoint (CACHEFILE cachefile, int fd, void *header_v) __attribute__((__warn_unused_result__));
+
+int toku_create_new_brtheader(BRT t, CACHEFILE cf, TOKUTXN txn);
+void toku_brtheader_free (struct brt_header *h);
+
+int toku_brt_alloc_init_header(BRT t, TOKUTXN txn);
+int toku_read_brt_header_and_store_in_cachefile (BRT brt, CACHEFILE cf, LSN max_acceptable_lsn, struct brt_header **header, BOOL* was_open);
+void toku_brtheader_note_brt_open(BRT live);
+
+int toku_brt_header_needed(struct brt_header* h);
+int toku_remove_brtheader (struct brt_header* h, char **error_string, BOOL oplsn_valid, LSN oplsn)  __attribute__ ((warn_unused_result));
+
+void toku_brt_header_note_hot_begin(BRT brt);
+void toku_brt_header_note_hot_complete(BRT brt, BOOL success, MSN msn_at_start_of_hot);
+
+void 
+toku_brt_header_init(
+    struct brt_header *h,
+    BLOCKNUM root_blocknum_on_disk, 
+    LSN checkpoint_lsn, 
+    TXNID root_xid_that_created, 
+    uint32_t target_nodesize, 
+    uint32_t target_basementnodesize, 
+    enum toku_compression_method compression_method
+    );
+
+#endif

newbrt/includes.h

@@ -36,6 +36,7 @@
 
 #include "block_allocator.h"
 #include "brt.h"
+#include "brt_header.h"
 #include "brt-internal.h"
 #include "cachetable.h"
 #include "rwlock.h"