diff options
-rw-r--r-- | fbench/src/fbench/fbench.cpp | 4 | ||||
-rw-r--r-- | fbench/src/util/filereader.cpp | 2 | ||||
-rw-r--r-- | fbench/src/util/filereader.h | 4 |
3 files changed, 5 insertions, 5 deletions
diff --git a/fbench/src/fbench/fbench.cpp b/fbench/src/fbench/fbench.cpp index f473eb608d5..32d18e1a330 100644 --- a/fbench/src/fbench/fbench.cpp +++ b/fbench/src/fbench/fbench.cpp @@ -400,12 +400,12 @@ FBench::Main(int argc, char *argv[]) FileReader r; r.Open(queryFilePattern); uint64_t clientOffset = std::max(i*perClient, _queryfileOffset.back() ); - uint64_t newline = r.FindNewline(clientOffset) + 1; + uint64_t newline = r.FindNextLine(clientOffset); _queryfileOffset.push_back(newline); } // Add pos to end of file - _queryfileOffset.push_back( totalSize+1 ); + _queryfileOffset.push_back(totalSize); // Print offset of clients diff --git a/fbench/src/util/filereader.cpp b/fbench/src/util/filereader.cpp index b4c1c18a7d3..e59e9966899 100644 --- a/fbench/src/util/filereader.cpp +++ b/fbench/src/util/filereader.cpp @@ -70,7 +70,7 @@ FileReader::GetFileSize() } uint64_t -FileReader::FindNewline(int64_t pos) +FileReader::FindNextLine(int64_t pos) { char buf[100]; SetFilePos(pos); diff --git a/fbench/src/util/filereader.h b/fbench/src/util/filereader.h index a0ec794836a..7fd1943d65d 100644 --- a/fbench/src/util/filereader.h +++ b/fbench/src/util/filereader.h @@ -101,9 +101,9 @@ public: uint64_t GetFilePos() const { return _lastReadPos + _bufpos; } /** - * @returns offset of next newline from pos + * @return offset to start of next line from pos **/ - uint64_t FindNewline(int64_t pos); + uint64_t FindNextLine(int64_t pos); /** * Read the next line of text from the the currently open file into |