summaryrefslogtreecommitdiff
path: root/src/mongo/db/sorter/sorter.cpp
diff options
context:
space:
mode:
authorSviatlana Zuiko <sviatlana.zuiko@mongodb.com>2022-06-30 19:32:15 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-06-30 22:33:22 +0000
commitff5ce6771bd53616ed644ee794ba69c2fe6d91c3 (patch)
treed5d6b4ff5490b44085446dd5c0289dd2924ab656 /src/mongo/db/sorter/sorter.cpp
parent17f49ab8b16a6f45371771d8c152cfbf4ed186af (diff)
downloadmongo-ff5ce6771bd53616ed644ee794ba69c2fe6d91c3.tar.gz
Revert "SERVER-65481 Bulk shredding and loading for column store indexes"
This reverts commit cb9472afc30d32d1c18691d64899c1aa72cdc43d.
Diffstat (limited to 'src/mongo/db/sorter/sorter.cpp')
-rw-r--r--src/mongo/db/sorter/sorter.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/sorter/sorter.cpp b/src/mongo/db/sorter/sorter.cpp
index ecb9e10118e..c23c2695afd 100644
--- a/src/mongo/db/sorter/sorter.cpp
+++ b/src/mongo/db/sorter/sorter.cpp
@@ -1291,11 +1291,11 @@ void SortedFileWriter<Key, Value>::addAlreadySorted(const Key& key, const Value&
addDataToChecksum(_buffer.buf() + _nextObjPos, _buffer.len() - _nextObjPos, _checksum);
if (_buffer.len() > static_cast<int>(kSortedFileBufferSize))
- writeChunk();
+ spill();
}
template <typename Key, typename Value>
-void SortedFileWriter<Key, Value>::writeChunk() {
+void SortedFileWriter<Key, Value>::spill() {
int32_t size = _buffer.len();
char* outBuffer = _buffer.buf();
@@ -1340,7 +1340,7 @@ void SortedFileWriter<Key, Value>::writeChunk() {
template <typename Key, typename Value>
SortIteratorInterface<Key, Value>* SortedFileWriter<Key, Value>::done() {
- writeChunk();
+ spill();
return new sorter::FileIterator<Key, Value>(
_file, _fileStartOffset, _file->currentOffset(), _settings, _dbName, _checksum);