diff options
author | Tor Egge <Tor.Egge@yahoo-inc.com> | 2016-09-21 14:40:26 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@yahoo-inc.com> | 2016-09-21 14:40:26 +0000 |
commit | 14fe17412479a328e5a8d6fba2bb6ddde3320daa (patch) | |
tree | bbcfbe95fb1051a8f9b6af995cde07ff363ea5cb /searchcorespi | |
parent | 05a874f4b5a50af05943dd1ef3e61311a885f3ec (diff) |
Factor out portions of get_state() to helper functions.
Diffstat (limited to 'searchcorespi')
-rw-r--r-- | searchcorespi/src/vespa/searchcorespi/index/index_manager_explorer.cpp | 37 |
1 files changed, 27 insertions, 10 deletions
diff --git a/searchcorespi/src/vespa/searchcorespi/index/index_manager_explorer.cpp b/searchcorespi/src/vespa/searchcorespi/index/index_manager_explorer.cpp index 448dde9bac2..959f5ccdc59 100644 --- a/searchcorespi/src/vespa/searchcorespi/index/index_manager_explorer.cpp +++ b/searchcorespi/src/vespa/searchcorespi/index/index_manager_explorer.cpp @@ -11,9 +11,34 @@ LOG_SETUP(".searchcorespi.index.index_manager_explorer"); using vespalib::slime::Cursor; using vespalib::slime::Inserter; using search::SearchableStats; +using searchcorespi::index::DiskIndexStats; +using searchcorespi::index::MemoryIndexStats; namespace searchcorespi { +namespace { + +void insertDiskIndex(Cursor &arrayCursor, const DiskIndexStats &diskIndex) +{ + Cursor &diskIndexCursor = arrayCursor.addObject(); + const SearchableStats &sstats = diskIndex.getSearchableStats(); + diskIndexCursor.setLong("serialNum", diskIndex.getSerialNum()); + diskIndexCursor.setString("indexDir", diskIndex.getIndexdir()); + diskIndexCursor.setLong("sizeOnDisk", sstats.sizeOnDisk()); +} + +void insertMemoryIndex(Cursor &arrayCursor, const MemoryIndexStats &memoryIndex) +{ + Cursor &memoryIndexCursor = arrayCursor.addObject(); + const SearchableStats &sstats = memoryIndex.getSearchableStats(); + memoryIndexCursor.setLong("serialNum", memoryIndex.getSerialNum()); + memoryIndexCursor.setLong("docsInMemory", sstats.docsInMemory()); + memoryIndexCursor.setLong("memoryUsage", sstats.memoryUsage()); +} + +} + + IndexManagerExplorer::IndexManagerExplorer(IIndexManager::SP mgr) : _mgr(std::move(mgr)) { @@ -28,19 +53,11 @@ IndexManagerExplorer::get_state(const Inserter &inserter, bool full) const IndexManagerStats stats(*_mgr); Cursor &diskIndexArrayCursor = object.setArray("diskIndexes"); for (const auto &diskIndex : stats.getDiskIndexes()) { - Cursor &diskIndexCursor = diskIndexArrayCursor.addObject(); - const SearchableStats &sstats = diskIndex.getSearchableStats(); - diskIndexCursor.setLong("serialNum", diskIndex.getSerialNum()); - diskIndexCursor.setString("indexDir", diskIndex.getIndexdir()); - diskIndexCursor.setLong("sizeOnDisk", sstats.sizeOnDisk()); + insertDiskIndex(diskIndexArrayCursor, diskIndex); } Cursor &memoryIndexArrayCursor = object.setArray("memoryIndexes"); for (const auto &memoryIndex : stats.getMemoryIndexes()) { - Cursor &memoryIndexCursor = memoryIndexArrayCursor.addObject(); - const SearchableStats &sstats = memoryIndex.getSearchableStats(); - memoryIndexCursor.setLong("serialNum", memoryIndex.getSerialNum()); - memoryIndexCursor.setLong("docsInMemory", sstats.docsInMemory()); - memoryIndexCursor.setLong("memoryUsage", sstats.memoryUsage()); + insertMemoryIndex(memoryIndexArrayCursor, memoryIndex); } } } |