summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Cahill <michael.cahill@wiredtiger.com>2013-11-05 09:47:47 +1100
committerMichael Cahill <michael.cahill@wiredtiger.com>2013-11-05 09:47:47 +1100
commitb73712ffacba582a0ee38eb9fa878f736f38a77b (patch)
tree67b8a358cfa9ea9cfce5361f1fd4a9c90f535ed5 /src
parentaa6c1500b2e3cb5369a646297bfaa3955f26758c (diff)
downloadmongo-b73712ffacba582a0ee38eb9fa878f736f38a77b.tar.gz
Create a Python pass for source code style checking (to eventually replace s_style).
Diffstat (limited to 'src')
-rw-r--r--src/block/block_ext.c12
-rw-r--r--src/block/block_mgr.c2
-rw-r--r--src/btree/bt_handle.c10
-rw-r--r--src/btree/bt_page.c2
-rw-r--r--src/btree/bt_ret.c2
-rw-r--r--src/btree/bt_slvg.c2
-rw-r--r--src/btree/bt_walk.c2
-rw-r--r--src/btree/rec_evict.c4
-rw-r--r--src/btree/rec_write.c12
-rw-r--r--src/btree/row_modify.c2
-rw-r--r--src/config/config.c2
-rw-r--r--src/config/config_check.c4
-rw-r--r--src/conn/conn_cache_pool.c11
-rw-r--r--src/conn/conn_ckpt.c4
-rw-r--r--src/cursor/cur_ds.c6
-rw-r--r--src/cursor/cur_dump.c8
-rw-r--r--src/cursor/cur_index.c4
-rw-r--r--src/cursor/cur_std.c2
-rw-r--r--src/cursor/cur_table.c8
-rw-r--r--src/log/log.c30
-rw-r--r--src/log/log_slot.c2
-rw-r--r--src/lsm/lsm_cursor.c7
-rw-r--r--src/lsm/lsm_tree.c8
-rw-r--r--src/meta/meta_track.c8
-rw-r--r--src/os_posix/os_mtx.c8
-rw-r--r--src/os_posix/os_open.c2
-rw-r--r--src/os_posix/os_strtouq.c3
-rw-r--r--src/schema/schema_create.c32
-rw-r--r--src/schema/schema_drop.c4
-rw-r--r--src/schema/schema_open.c6
-rw-r--r--src/schema/schema_plan.c8
-rw-r--r--src/session/session_dhandle.c10
-rw-r--r--src/support/global.c8
-rw-r--r--src/support/hash_fnv.c3
-rw-r--r--src/support/hex.c4
-rw-r--r--src/support/mutex.c2
-rw-r--r--src/support/pow.c5
-rw-r--r--src/support/scratch.c2
-rw-r--r--src/txn/txn_log.c8
-rw-r--r--src/txn/txn_recover.c14
40 files changed, 218 insertions, 55 deletions
diff --git a/src/block/block_ext.c b/src/block/block_ext.c
index c6f10c1faf3..c4aa8bd02fd 100644
--- a/src/block/block_ext.c
+++ b/src/block/block_ext.c
@@ -907,7 +907,7 @@ __wt_block_extlist_merge(
}
/*
- * __wt_block_insert_ext, __block_merge --
+ * __wt_block_insert_ext --
* Insert an extent into an extent list, merging if possible.
*/
int
@@ -927,6 +927,12 @@ __wt_block_insert_ext(WT_SESSION_IMPL *session,
*/
return (__block_merge(session, block, el, off, size));
}
+
+/*
+ * __block_merge --
+ * Insert an extent into an extent list, merging if possible (internal
+ * version).
+ */
static int
__block_merge(WT_SESSION_IMPL *session,
WT_BLOCK *block, WT_EXTLIST *el, off_t off, off_t size)
@@ -1283,6 +1289,10 @@ __wt_block_extlist_free(WT_SESSION_IMPL *session, WT_EXTLIST *el)
memset(el, 0, sizeof(*el));
}
+/*
+ * __block_extlist_dump --
+ * Dump an extent list as verbose messages.
+ */
static int
__block_extlist_dump(
WT_SESSION_IMPL *session, const char *tag, WT_EXTLIST *el, int show_size)
diff --git a/src/block/block_mgr.c b/src/block/block_mgr.c
index 46bc223f70c..59d748ba430 100644
--- a/src/block/block_mgr.c
+++ b/src/block/block_mgr.c
@@ -22,7 +22,7 @@ __bm_readonly(WT_BM *bm, WT_SESSION_IMPL *session)
}
/*
- * __bm_addr_string
+ * __bm_addr_string --
* Return a printable string representation of an address cookie.
*/
static int
diff --git a/src/btree/bt_handle.c b/src/btree/bt_handle.c
index c1013efb7d6..da5cf95b766 100644
--- a/src/btree/bt_handle.c
+++ b/src/btree/bt_handle.c
@@ -517,7 +517,7 @@ __wt_btree_new_leaf_page(
}
/*
- * __wt_btree_no_eviction --
+ * __wt_btree_evictable --
* Setup or release a cache-resident tree.
*/
void
@@ -703,6 +703,10 @@ __wt_split_page_size(WT_BTREE *btree, uint32_t maxpagesize)
return (split_size);
}
+/*
+ * pse1 --
+ * Page size error message 1.
+ */
static int
pse1(WT_SESSION_IMPL *session, const char *type, uint32_t max, uint32_t ovfl)
{
@@ -712,6 +716,10 @@ pse1(WT_SESSION_IMPL *session, const char *type, uint32_t max, uint32_t ovfl)
type, max, ovfl);
}
+/*
+ * pse2 --
+ * Page size error message 2.
+ */
static int
pse2(WT_SESSION_IMPL *session,
const char *type, uint32_t max, uint32_t ovfl, int pct)
diff --git a/src/btree/bt_page.c b/src/btree/bt_page.c
index ab000f5d664..6b141b20fc1 100644
--- a/src/btree/bt_page.c
+++ b/src/btree/bt_page.c
@@ -16,7 +16,7 @@ static int __inmem_row_leaf_entries(
WT_SESSION_IMPL *, WT_PAGE_HEADER *, uint32_t *);
/*
- * __wt_page_in --
+ * __wt_page_in_func --
* Acquire a hazard pointer to a page; if the page is not in-memory,
* read it from the disk and build an in-memory version.
*/
diff --git a/src/btree/bt_ret.c b/src/btree/bt_ret.c
index 2870a33f49c..a43ff27fa84 100644
--- a/src/btree/bt_ret.c
+++ b/src/btree/bt_ret.c
@@ -8,7 +8,7 @@
#include "wt_internal.h"
/*
- * __wt_key_get --
+ * __wt_row_key_get --
* Get a reference to the current key.
*/
int
diff --git a/src/btree/bt_slvg.c b/src/btree/bt_slvg.c
index 9ab28816046..b6a9354fe31 100644
--- a/src/btree/bt_slvg.c
+++ b/src/btree/bt_slvg.c
@@ -2207,7 +2207,7 @@ __slvg_ovfl_discard(WT_SESSION_IMPL *session, WT_STUFF *ss)
}
/*
- * __slvg_free --
+ * __slvg_cleanup --
* Discard memory allocated to the page and overflow arrays.
*/
static int
diff --git a/src/btree/bt_walk.c b/src/btree/bt_walk.c
index ff363896414..eb3701717a2 100644
--- a/src/btree/bt_walk.c
+++ b/src/btree/bt_walk.c
@@ -8,7 +8,7 @@
#include "wt_internal.h"
/*
- * __tree_walk_delete_rollback --
+ * __wt_tree_walk_delete_rollback --
* Abort pages that were deleted without being instantiated.
*/
void
diff --git a/src/btree/rec_evict.c b/src/btree/rec_evict.c
index cba495f30b5..a6c8d462e19 100644
--- a/src/btree/rec_evict.c
+++ b/src/btree/rec_evict.c
@@ -137,7 +137,7 @@ done: session->excl_next = 0;
}
/*
- * __rec_root_update --
+ * __rec_root_update --
* Update a root page's reference on eviction (clean or dirty).
*/
static void
@@ -147,7 +147,7 @@ __rec_root_update(WT_SESSION_IMPL *session)
}
/*
- * __rec_page_clean_update --
+ * __rec_page_clean_update --
* Update a clean page's reference on eviction.
*/
static void
diff --git a/src/btree/rec_write.c b/src/btree/rec_write.c
index bc213b523a9..6f3eaf6568a 100644
--- a/src/btree/rec_write.c
+++ b/src/btree/rec_write.c
@@ -541,7 +541,7 @@ __rec_write_init(
}
/*
- * __rec_destroy --
+ * __wt_rec_destroy --
* Clean up the reconciliation structure.
*/
void
@@ -2072,8 +2072,12 @@ __wt_rec_row_bulk_insert(WT_CURSOR_BULK *cbulk)
#define WT_FIX_ENTRIES(btree, bytes) (((bytes) * 8) / (btree)->bitcnt)
+/*
+ * __rec_col_fix_bulk_insert_split_check --
+ * Check if a bulk-loaded fixed-length column store page needs to split.
+ */
static inline int
-__rec_col_fix_bulk_insert_split_check(WT_CURSOR_BULK *cbulk)
+__rec_col_fix_bulk_insert_split_check(WT_CURSOR_BULK *cbulk)
{
WT_BTREE *btree;
WT_RECONCILE *r;
@@ -3705,7 +3709,7 @@ __rec_split_discard(WT_SESSION_IMPL *session, WT_PAGE *page)
}
/*
- * __rec_write_wrapup --
+ * __rec_write_wrapup --
* Finish the reconciliation.
*/
static int
@@ -3951,7 +3955,7 @@ err: __wt_scr_free(&tkey);
}
/*
- * __rec_write_wrapup_err --
+ * __rec_write_wrapup_err --
* Finish the reconciliation on error.
*/
static int
diff --git a/src/btree/row_modify.c b/src/btree/row_modify.c
index 91e2f091c33..8e791fe59f2 100644
--- a/src/btree/row_modify.c
+++ b/src/btree/row_modify.c
@@ -283,7 +283,7 @@ __wt_update_obsolete_free(
}
/*
- * __wt_page_obsolete --
+ * __wt_row_leaf_obsolete --
* Discard all obsolete updates on a row-store leaf page.
*/
void
diff --git a/src/config/config.c b/src/config/config.c
index 5bfb1646288..acff9c29e28 100644
--- a/src/config/config.c
+++ b/src/config/config.c
@@ -486,7 +486,7 @@ __config_next(WT_CONFIG *conf, WT_CONFIG_ITEM *key, WT_CONFIG_ITEM *value)
} while (0)
/*
- * __config_process_value
+ * __config_process_value --
* Deal with special config values like true / false.
*/
static int
diff --git a/src/config/config_check.c b/src/config/config_check.c
index 08d65e72d18..d613e3c734e 100644
--- a/src/config/config_check.c
+++ b/src/config/config_check.c
@@ -210,9 +210,9 @@ err: if (entry != NULL) {
}
/*
- * __wt_config_check--
+ * __wt_config_check --
* Check the keys in an application-supplied config string match what is
- * specified in an array of check strings.
+ * specified in an array of check strings.
*/
int
__wt_config_check(WT_SESSION_IMPL *session,
diff --git a/src/conn/conn_cache_pool.c b/src/conn/conn_cache_pool.c
index e7a9398ef7f..974ce1a402a 100644
--- a/src/conn/conn_cache_pool.c
+++ b/src/conn/conn_cache_pool.c
@@ -363,6 +363,10 @@ err: __wt_spin_unlock(NULL, &cp->cache_pool_lock);
return (ret);
}
+/*
+ * __cache_pool_assess --
+ * Assess the usage of the cache pool.
+ */
static int
__cache_pool_assess(uint64_t *phighest)
{
@@ -405,9 +409,10 @@ __cache_pool_assess(uint64_t *phighest)
}
/*
- * Adjust the allocation of cache to each connection. If force is set ignore
- * cache load information, and reduce the allocation for every connection
- * allocated more than their reserved size.
+ * __cache_pool_adjust --
+ * Adjust the allocation of cache to each connection. If force is set
+ * ignore cache load information, and reduce the allocation for every
+ * connection allocated more than their reserved size.
*/
static int
__cache_pool_adjust(uint64_t highest, uint64_t bump_threshold)
diff --git a/src/conn/conn_ckpt.c b/src/conn/conn_ckpt.c
index 511904a4565..0706527caf2 100644
--- a/src/conn/conn_ckpt.c
+++ b/src/conn/conn_ckpt.c
@@ -84,7 +84,7 @@ err: __wt_err(session, ret, "checkpoint server error");
}
/*
- * __wt_checkpoint_create -
+ * __wt_checkpoint_create --
* Start the checkpoint server thread.
*/
int
@@ -120,7 +120,7 @@ __wt_checkpoint_create(WT_CONNECTION_IMPL *conn, const char *cfg[])
}
/*
- * __wt_checkpoint_destroy -
+ * __wt_checkpoint_destroy --
* Destroy the checkpoint server thread.
*/
int
diff --git a/src/cursor/cur_ds.c b/src/cursor/cur_ds.c
index 9e849e664e9..dc8e1618ccb 100644
--- a/src/cursor/cur_ds.c
+++ b/src/cursor/cur_ds.c
@@ -36,7 +36,7 @@ __curds_txn_leave(WT_SESSION_IMPL *session)
}
/*
- * __curds_key_set -
+ * __curds_key_set --
* Set the key for the data-source.
*/
static int
@@ -57,7 +57,7 @@ err: return (ret);
}
/*
- * __curds_value_set -
+ * __curds_value_set --
* Set the value for the data-source.
*/
static int
@@ -77,7 +77,7 @@ err: return (ret);
}
/*
- * __curds_cursor_resolve -
+ * __curds_cursor_resolve --
* Resolve cursor operation.
*/
static int
diff --git a/src/cursor/cur_dump.c b/src/cursor/cur_dump.c
index 7883996f7cb..f89cad2ffd9 100644
--- a/src/cursor/cur_dump.c
+++ b/src/cursor/cur_dump.c
@@ -247,6 +247,10 @@ WT_CURDUMP_PASS(prev)
WT_CURDUMP_PASS(reset)
WT_CURDUMP_PASS(search)
+/*
+ * __curdump_search_near --
+ * WT_CURSOR::search_near for dump cursors.
+ */
static int
__curdump_search_near(WT_CURSOR *cursor, int *exact)
{
@@ -260,6 +264,10 @@ WT_CURDUMP_PASS(insert)
WT_CURDUMP_PASS(update)
WT_CURDUMP_PASS(remove)
+/*
+ * __curdump_close --
+ * WT_CURSOR::close for dump cursors.
+ */
static int
__curdump_close(WT_CURSOR *cursor)
{
diff --git a/src/cursor/cur_index.c b/src/cursor/cur_index.c
index 34987898ccf..b6b597816a2 100644
--- a/src/cursor/cur_index.c
+++ b/src/cursor/cur_index.c
@@ -303,6 +303,10 @@ err: API_END(session);
return (ret);
}
+/*
+ * __curindex_open_colgroups --
+ * Open cursors on the column groups required for an index cursor.
+ */
static int
__curindex_open_colgroups(
WT_SESSION_IMPL *session, WT_CURSOR_INDEX *cindex, const char *cfg_arg[])
diff --git a/src/cursor/cur_std.c b/src/cursor/cur_std.c
index b2575ddebc0..3f85e65b353 100644
--- a/src/cursor/cur_std.c
+++ b/src/cursor/cur_std.c
@@ -19,7 +19,7 @@ __wt_cursor_notsup(WT_CURSOR *cursor)
return (ENOTSUP);
}
-/*
+/*
* __wt_cursor_noop --
* Cursor noop.
*/
diff --git a/src/cursor/cur_table.c b/src/cursor/cur_table.c
index 59015838af7..54b9db2bfd0 100644
--- a/src/cursor/cur_table.c
+++ b/src/cursor/cur_table.c
@@ -602,6 +602,10 @@ err: API_END(session);
return (ret);
}
+/*
+ * __curtable_open_colgroups --
+ * Open cursors on column groups for a table cursor.
+ */
static int
__curtable_open_colgroups(WT_CURSOR_TABLE *ctable, const char *cfg_arg[])
{
@@ -638,6 +642,10 @@ __curtable_open_colgroups(WT_CURSOR_TABLE *ctable, const char *cfg_arg[])
return (0);
}
+/*
+ * __curtable_open_indices --
+ * Open cursors on indices for a table cursor.
+ */
static int
__curtable_open_indices(WT_CURSOR_TABLE *ctable)
{
diff --git a/src/log/log.c b/src/log/log.c
index f6c8dcf9656..de0724112be 100644
--- a/src/log/log.c
+++ b/src/log/log.c
@@ -27,7 +27,7 @@ __wt_log_ckpt(WT_SESSION_IMPL *session, WT_LSN *ckp_lsn)
}
/*
- * __wt_log_getfiles --
+ * __wt_log_get_files --
* Retrieve the list of all existing log files.
*/
int
@@ -45,8 +45,9 @@ __wt_log_get_files(WT_SESSION_IMPL *session, char ***filesp, u_int *countp)
}
/*
- * __wt_log_getfiles --
- * Retrieve the list of all existing log files.
+ * __wt_log_get_active_files --
+ * Retrieve the list of active log files (those that are not candidates
+ * for archiving).
*/
int
__wt_log_get_active_files(
@@ -257,6 +258,10 @@ __wt_log_close(WT_SESSION_IMPL *session)
return (0);
}
+/*
+ * __log_fill --
+ * Copy a thread's log records into the assigned slot.
+ */
static int
__log_fill(WT_SESSION_IMPL *session,
WT_MYSLOT *myslot, int direct, WT_ITEM *record, WT_LSN *lsnp)
@@ -456,6 +461,10 @@ __log_acquire(WT_SESSION_IMPL *session, uint64_t recsize, WT_LOGSLOT *slot)
return (0);
}
+/*
+ * __log_release --
+ * Release a log slot.
+ */
static int
__log_release(WT_SESSION_IMPL *session, WT_LOGSLOT *slot)
{
@@ -668,6 +677,10 @@ err:
return (ret);
}
+/*
+ * __wt_log_scan --
+ * Scan the logs, calling a function on each record found.
+ */
int
__wt_log_scan(WT_SESSION_IMPL *session, WT_LSN *lsnp, uint32_t flags,
int (*func)(WT_SESSION_IMPL *session,
@@ -857,7 +870,8 @@ err: WT_STAT_FAST_CONN_INCR(session, log_scans);
}
/*
- * Write a log record without using the consolidation arrays.
+ * __log_direct_write --
+ * Write a log record without using the consolidation arrays.
*/
static int
__log_direct_write(WT_SESSION_IMPL *session, WT_ITEM *record, WT_LSN *lsnp,
@@ -893,6 +907,10 @@ err: if (locked)
return (ret);
}
+/*
+ * __wt_log_write --
+ * Write a record into the log.
+ */
int
__wt_log_write(WT_SESSION_IMPL *session, WT_ITEM *record, WT_LSN *lsnp,
uint32_t flags)
@@ -1014,6 +1032,10 @@ err:
return (ret);
}
+/*
+ * __wt_log_vprintf --
+ * Write a message into the log.
+ */
int
__wt_log_vprintf(WT_SESSION_IMPL *session, const char *fmt, va_list ap)
{
diff --git a/src/log/log_slot.c b/src/log/log_slot.c
index 108f61f7536..f67e74bbbe0 100644
--- a/src/log/log_slot.c
+++ b/src/log/log_slot.c
@@ -227,7 +227,7 @@ __wt_log_slot_wait(WT_LOGSLOT *slot)
}
/*
- * _wt_log_slot_release --
+ * __wt_log_slot_release --
* Each thread in a consolidated group releases its portion to
* signal it has completed writing its piece of the log.
*/
diff --git a/src/lsm/lsm_cursor.c b/src/lsm/lsm_cursor.c
index 27b6f0d873a..8ddd3d84b94 100644
--- a/src/lsm/lsm_cursor.c
+++ b/src/lsm/lsm_cursor.c
@@ -33,6 +33,10 @@
static int __clsm_open_cursors(WT_CURSOR_LSM *, int, u_int, uint32_t);
static int __clsm_lookup(WT_CURSOR_LSM *);
+/*
+ * __clsm_enter --
+ * Start an operation on an LSM cursor, update if the tree has changed.
+ */
static inline int
__clsm_enter(WT_CURSOR_LSM *clsm, int update)
{
@@ -434,7 +438,8 @@ err: F_CLR(session, WT_SESSION_NO_CACHE_CHECK);
return (ret);
}
-/* __wt_clsm_init_merge --
+/*
+ * __wt_clsm_init_merge --
* Initialize an LSM cursor for a merge.
*/
int
diff --git a/src/lsm/lsm_tree.c b/src/lsm/lsm_tree.c
index f3f08ee4936..acb3f4c315e 100644
--- a/src/lsm/lsm_tree.c
+++ b/src/lsm/lsm_tree.c
@@ -223,7 +223,7 @@ __wt_lsm_tree_setup_chunk(
}
/*
- * __wt_lsm_start_worker --
+ * __lsm_tree_start_worker --
* Start the worker thread for an LSM tree.
*/
static int
@@ -504,8 +504,8 @@ __wt_lsm_tree_get(WT_SESSION_IMPL *session,
}
/*
- * __wt_lsm_tree_get --
- * get an LSM tree structure for the given name.
+ * __wt_lsm_tree_release --
+ * Release an LSM tree structure.
*/
void
__wt_lsm_tree_release(WT_SESSION_IMPL *session, WT_LSM_TREE *lsm_tree)
@@ -515,7 +515,7 @@ __wt_lsm_tree_release(WT_SESSION_IMPL *session, WT_LSM_TREE *lsm_tree)
}
/*
- * __lsm_tree_throttle --
+ * __wt_lsm_tree_throttle --
* Calculate whether LSM updates need to be throttled.
*/
void
diff --git a/src/meta/meta_track.c b/src/meta/meta_track.c
index 82f7ceded01..3992687f559 100644
--- a/src/meta/meta_track.c
+++ b/src/meta/meta_track.c
@@ -89,6 +89,10 @@ __wt_meta_track_on(WT_SESSION_IMPL *session)
return (0);
}
+/*
+ * __meta_track_apply --
+ * Apply the changes in a metadata tracking record.
+ */
static int
__meta_track_apply(WT_SESSION_IMPL *session, WT_META_TRACK *trk, int unroll)
{
@@ -320,8 +324,8 @@ __wt_meta_track_update(WT_SESSION_IMPL *session, const char *key)
}
/*
- * __wt_meta_track_fs_rename --
- * Track a filesystem rename operation.
+ * __wt_meta_track_fileop --
+ * Track a filesystem operation.
*/
int
__wt_meta_track_fileop(
diff --git a/src/os_posix/os_mtx.c b/src/os_posix/os_mtx.c
index bf444db6e36..857cfe6239d 100644
--- a/src/os_posix/os_mtx.c
+++ b/src/os_posix/os_mtx.c
@@ -42,7 +42,7 @@ err: __wt_free(session, cond);
}
/*
- * __wt_cond_wait
+ * __wt_cond_wait --
* Wait on a mutex, optionally timing out.
*/
int
@@ -193,7 +193,7 @@ err: __wt_free(session, rwlock);
}
/*
- * __wt_readlock
+ * __wt_readlock --
* Get a shared lock.
*/
int
@@ -211,7 +211,7 @@ __wt_readlock(WT_SESSION_IMPL *session, WT_RWLOCK *rwlock)
}
/*
- * __wt_try_writelock
+ * __wt_try_writelock --
* Try to get an exclusive lock, or fail immediately if unavailable.
*/
int
@@ -230,7 +230,7 @@ __wt_try_writelock(WT_SESSION_IMPL *session, WT_RWLOCK *rwlock)
}
/*
- * __wt_writelock
+ * __wt_writelock --
* Wait to get an exclusive lock.
*/
int
diff --git a/src/os_posix/os_open.c b/src/os_posix/os_open.c
index dddf9a91485..f6b141c4da2 100644
--- a/src/os_posix/os_open.c
+++ b/src/os_posix/os_open.c
@@ -8,7 +8,7 @@
#include "wt_internal.h"
/*
- * __open_directory_sync:
+ * __open_directory_sync --
* Fsync the directory in which we created the file.
*/
static int
diff --git a/src/os_posix/os_strtouq.c b/src/os_posix/os_strtouq.c
index cb445261ce5..b532918e241 100644
--- a/src/os_posix/os_strtouq.c
+++ b/src/os_posix/os_strtouq.c
@@ -8,7 +8,8 @@
#include "wt_internal.h"
/*
- * Convert a string to an unsigned quad integer.
+ * __wt_strtouq --
+ * Convert a string to an unsigned quad integer.
*/
uint64_t
__wt_strtouq(const char *nptr, char **endptr, int base)
diff --git a/src/schema/schema_create.c b/src/schema/schema_create.c
index bd16fb39cc1..fe1ede05393 100644
--- a/src/schema/schema_create.c
+++ b/src/schema/schema_create.c
@@ -46,6 +46,10 @@ __wt_direct_io_size_check(WT_SESSION_IMPL *session,
return (0);
}
+/*
+ * __create_file --
+ * Create a new 'file:' object.
+ */
static int
__create_file(WT_SESSION_IMPL *session,
const char *uri, int exclusive, const char *config)
@@ -122,6 +126,10 @@ err: __wt_scr_free(&val);
return (ret);
}
+/*
+ * __wt_schema_colgroup_source --
+ * Get the URI of the data source for a column group.
+ */
int
__wt_schema_colgroup_source(WT_SESSION_IMPL *session,
WT_TABLE *table, const char *cgname, const char *config, WT_ITEM *buf)
@@ -154,6 +162,10 @@ __wt_schema_colgroup_source(WT_SESSION_IMPL *session,
return (0);
}
+/*
+ * __create_colgroup --
+ * Create a column group.
+ */
static int
__create_colgroup(WT_SESSION_IMPL *session,
const char *name, int exclusive, const char *config)
@@ -259,6 +271,10 @@ err: __wt_free(session, cgconf);
return (ret);
}
+/*
+ * __wt_schema_index_source --
+ * Get the URI of the data source for an index.
+ */
int
__wt_schema_index_source(WT_SESSION_IMPL *session,
WT_TABLE *table, const char *idxname, const char *config, WT_ITEM *buf)
@@ -287,6 +303,10 @@ __wt_schema_index_source(WT_SESSION_IMPL *session,
return (0);
}
+/*
+ * __create_index --
+ * Create an index.
+ */
static int
__create_index(WT_SESSION_IMPL *session,
const char *name, int exclusive, const char *config)
@@ -417,6 +437,10 @@ err: __wt_free(session, idxconf);
return (ret);
}
+/*
+ * __create_table --
+ * Create a table.
+ */
static int
__create_table(WT_SESSION_IMPL *session,
const char *name, int exclusive, const char *config)
@@ -490,6 +514,10 @@ err: if (table != NULL) {
return (ret);
}
+/*
+ * __create_data_source --
+ * Create a custom data source.
+ */
static int
__create_data_source(WT_SESSION_IMPL *session,
const char *uri, const char *config, WT_DATA_SOURCE *dsrc)
@@ -519,6 +547,10 @@ __create_data_source(WT_SESSION_IMPL *session,
return (dsrc->create(dsrc, &session->iface, uri, (WT_CONFIG_ARG *)cfg));
}
+/*
+ * __wt_schema_create --
+ * Process a WT_SESSION::create operation for all supported types.
+ */
int
__wt_schema_create(
WT_SESSION_IMPL *session, const char *uri, const char *config)
diff --git a/src/schema/schema_drop.c b/src/schema/schema_drop.c
index 91a15f477d6..c4cb864a5de 100644
--- a/src/schema/schema_drop.c
+++ b/src/schema/schema_drop.c
@@ -157,6 +157,10 @@ err: if (force && ret == WT_NOTFOUND)
return (ret);
}
+/*
+ * __wt_schema_drop --
+ * Process a WT_SESSION::drop operation for all supported types.
+ */
int
__wt_schema_drop(WT_SESSION_IMPL *session, const char *uri, const char *cfg[])
{
diff --git a/src/schema/schema_open.c b/src/schema/schema_open.c
index ad5fee55d16..a63e85a7df9 100644
--- a/src/schema/schema_open.c
+++ b/src/schema/schema_open.c
@@ -109,7 +109,7 @@ err: __wt_scr_free(&buf);
}
/*
- * ___open_index --
+ * __open_index --
* Open an index.
*/
static int
@@ -203,8 +203,8 @@ err: __wt_scr_free(&buf);
}
/*
- * __wt_schema_open_indices --
- * Open the indices for a table.
+ * __wt_schema_open_index --
+ * Open one or more indices for a table.
*/
int
__wt_schema_open_index(WT_SESSION_IMPL *session,
diff --git a/src/schema/schema_plan.c b/src/schema/schema_plan.c
index 44b69c0cf9f..aba5fa29715 100644
--- a/src/schema/schema_plan.c
+++ b/src/schema/schema_plan.c
@@ -7,6 +7,10 @@
#include "wt_internal.h"
+/*
+ * __find_next_col --
+ * Find the next column to use for a plan.
+ */
static int
__find_next_col(WT_SESSION_IMPL *session, WT_TABLE *table,
WT_CONFIG_ITEM *colname, u_int *cgnump, u_int *colnump, char *coltype)
@@ -249,6 +253,10 @@ __wt_struct_plan(WT_SESSION_IMPL *session, WT_TABLE *table,
return (0);
}
+/*
+ * __find_column_format --
+ * Find the format of the named column.
+ */
static int
__find_column_format(WT_SESSION_IMPL *session,
WT_TABLE *table, WT_CONFIG_ITEM *colname, int value_only, WT_PACK_VALUE *pv)
diff --git a/src/session/session_dhandle.c b/src/session/session_dhandle.c
index d95a17c66db..d776144d880 100644
--- a/src/session/session_dhandle.c
+++ b/src/session/session_dhandle.c
@@ -211,7 +211,8 @@ retry: WT_RET(__wt_meta_checkpoint_last_name(
}
/*
- * Discard any session dhandles that are not open.
+ * __session_dhandle_sweep --
+ * Discard any session dhandles that are not open.
*/
static int
__session_dhandle_sweep(WT_SESSION_IMPL *session)
@@ -235,9 +236,10 @@ __session_dhandle_sweep(WT_SESSION_IMPL *session)
}
/*
- * Wrapper function to first sweep the session and then get the btree.
- * Sweeping is only called when a session notices it has dead dhandles
- * on its session dhandle list. Must be called with schema lock.
+ * __session_open_btree --
+ * Wrapper function to first sweep the session and then get the btree.
+ * Sweeping is only called when a session notices it has dead dhandles on
+ * its session dhandle list. Must be called with schema lock.
*/
static int
__session_open_btree(WT_SESSION_IMPL *session,
diff --git a/src/support/global.c b/src/support/global.c
index 807675bddf2..b365b9473eb 100644
--- a/src/support/global.c
+++ b/src/support/global.c
@@ -10,6 +10,10 @@
WT_PROCESS __wt_process; /* Per-process structure */
static int __wt_pthread_once_failed; /* If initialization failed */
+/*
+ * __system_is_little_endian --
+ * Check if the system is little endian.
+ */
static int
__system_is_little_endian(void)
{
@@ -28,6 +32,10 @@ __system_is_little_endian(void)
return (EINVAL);
}
+/*
+ * __wt_pthread_once --
+ * Global initialization, run once.
+ */
static void
__wt_pthread_once(void)
{
diff --git a/src/support/hash_fnv.c b/src/support/hash_fnv.c
index 111556b62a6..099dba1ec73 100644
--- a/src/support/hash_fnv.c
+++ b/src/support/hash_fnv.c
@@ -109,7 +109,8 @@
#define FNV1A_64_INIT ((uint64_t)0xcbf29ce484222325ULL)
/*
- * fnv_64a_buf - perform a 64 bit Fowler/Noll/Vo FNV-1a hash on a buffer
+ * fnv_64a_buf --
+ * Perform a 64 bit Fowler/Noll/Vo FNV-1a hash on a buffer
*
* input:
* buf - start of buffer to hash
diff --git a/src/support/hex.c b/src/support/hex.c
index 079260a4eab..3c220ad6ead 100644
--- a/src/support/hex.c
+++ b/src/support/hex.c
@@ -130,6 +130,10 @@ hex2byte(const u_char *from, u_char *to)
return (0);
}
+/*
+ * __hex_fmterr --
+ * Hex format error message.
+ */
static int
__hex_fmterr(WT_SESSION_IMPL *session)
{
diff --git a/src/support/mutex.c b/src/support/mutex.c
index b684fcf0299..8ed8f50322f 100644
--- a/src/support/mutex.c
+++ b/src/support/mutex.c
@@ -66,7 +66,7 @@ __wt_spin_lock_register(WT_SESSION_IMPL *session,
}
/*
- * __wt_statlog_spinlock_dump --
+ * __wt_statlog_dump_spinlock --
* Log the spin-lock statistics.
*/
int
diff --git a/src/support/pow.c b/src/support/pow.c
index 9ba22a53f8d..c01268245bb 100644
--- a/src/support/pow.c
+++ b/src/support/pow.c
@@ -28,6 +28,7 @@
#include "wt_internal.h"
#ifdef __WIREDTIGER_UNUSED__
+
/*
* __wt_nlpo2_round --
* Round up to the next-largest power-of-two for a 32-bit unsigned value.
@@ -63,6 +64,10 @@ __wt_nlpo2_round(uint32_t v)
return (v + 1);
}
+/*
+ * __wt_nlpo2 --
+ * Return the next largest power-of-two.
+ */
uint32_t
__wt_nlpo2(uint32_t v)
{
diff --git a/src/support/scratch.c b/src/support/scratch.c
index db731bf99de..5f4cab931d6 100644
--- a/src/support/scratch.c
+++ b/src/support/scratch.c
@@ -275,7 +275,7 @@ __wt_buf_catfmt(WT_SESSION_IMPL *session, WT_ITEM *buf, const char *fmt, ...)
}
/*
- * __wt_scr_alloc --
+ * __wt_scr_alloc_func --
* Scratch buffer allocation function.
*/
int
diff --git a/src/txn/txn_log.c b/src/txn/txn_log.c
index 179ea1f8837..17edc48645f 100644
--- a/src/txn/txn_log.c
+++ b/src/txn/txn_log.c
@@ -7,6 +7,10 @@
#include "wt_internal.h"
+/*
+ * __txn_op_log --
+ * Log an operation for the current transaction.
+ */
static int
__txn_op_log(WT_SESSION_IMPL *session, WT_ITEM *logrec, WT_TXN_OP *op)
{
@@ -48,6 +52,10 @@ __txn_op_log(WT_SESSION_IMPL *session, WT_ITEM *logrec, WT_TXN_OP *op)
return (0);
}
+/*
+ * __txn_commit_printlog --
+ * Print a commit log record.
+ */
static int
__txn_commit_printlog(
WT_SESSION_IMPL *session, const uint8_t **pp, const uint8_t *end, FILE *out)
diff --git a/src/txn/txn_recover.c b/src/txn/txn_recover.c
index 5e4c6a41915..f48e83b9b84 100644
--- a/src/txn/txn_recover.c
+++ b/src/txn/txn_recover.c
@@ -26,6 +26,10 @@ typedef struct {
int metadata_only;
} WT_RECOVERY;
+/*
+ * __recovery_cursor --
+ * Get a cursor for a recovery operation.
+ */
static int
__recovery_cursor(WT_SESSION_IMPL *session, WT_RECOVERY *r,
WT_LSN *lsnp, u_int id, int duplicate, WT_CURSOR **cp)
@@ -63,6 +67,10 @@ __recovery_cursor(WT_SESSION_IMPL *session, WT_RECOVERY *r,
return (0);
}
+/*
+ * __txn_op_apply --
+ * Apply a transactional operation during recovery.
+ */
static int
__txn_op_apply(
WT_RECOVERY *r, WT_LSN *lsnp, const uint8_t **pp, const uint8_t *end)
@@ -206,6 +214,10 @@ err: if (ret != 0)
return (ret);
}
+/*
+ * __txn_commit_apply --
+ * Apply a commit record during recovery.
+ */
static int
__txn_commit_apply(
WT_RECOVERY *r, WT_LSN *lsnp, const uint8_t **pp, const uint8_t *end)
@@ -257,7 +269,7 @@ __txn_log_recover(
}
/*
- * __recovery_setup_slot --
+ * __recovery_setup_file --
* Set up the recovery slot for a file.
*/
static int