Skip to content

Commit f01620f

Browse files
[refactor] Remove +1 from db_index in db_name construction
1 parent 6db5200 commit f01620f

File tree

6 files changed

+14
-14
lines changed

6 files changed

+14
-14
lines changed

src/fdb5/parallax/ParallaxArray.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ uint64_t ParallaxArray::read(void *buffer, uint64_t length, const eckit::Offset
3232
size_t hash = std::hash<std::string>{}(key.c_str());
3333
int db_index = hash % PARALLAX_DB_COUNT;
3434

35-
std::string db_name = "par_db" + std::to_string(db_index + 1);
35+
std::string db_name = "par_db" + std::to_string(db_index);
3636

3737
par_handle db_handle = par_get_db(db_name);
3838
const char *error_msg = NULL;

src/fdb5/parallax/ParallaxCatalogue.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ void ParallaxCatalogue::loadSchema()
5555
size_t hash = std::hash<std::string>{}(key_str.c_str());
5656
int db_index = hash % PARALLAX_DB_COUNT;
5757

58-
std::string db_name = "par_db" + std::to_string(db_index + 1);
58+
std::string db_name = "par_db" + std::to_string(db_index);
5959
par_handle db_handle = par_get_db(db_name);
6060
const char *error_msg = nullptr;
6161

src/fdb5/parallax/ParallaxCatalogueReader.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ bool ParallaxCatalogueReader::selectIndex(const Key &key)
4545
size_t hash = std::hash<std::string>{}(keyStr.c_str());
4646
int db_index = hash % PARALLAX_DB_COUNT;
4747

48-
std::string db_name = "par_db" + std::to_string(db_index + 1);
48+
std::string db_name = "par_db" + std::to_string(db_index);
4949
par_handle db_handle = par_get_db(db_name);
5050

5151
par_get(db_handle, &keyData, &valueData, &error_msg);

src/fdb5/parallax/ParallaxCatalogueWriter.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ ParallaxCatalogueWriter::ParallaxCatalogueWriter(const Key &key, const fdb5::Con
4242
size_t hash = std::hash<std::string>{}(key_str.c_str());
4343
int db_index = hash % PARALLAX_DB_COUNT;
4444

45-
std::string db_name = "par_db" + std::to_string(db_index + 1);
45+
std::string db_name = "par_db" + std::to_string(db_index);
4646
par_handle db_handle = par_get_db(db_name);
4747
const char *error_msg = NULL;
4848

@@ -93,7 +93,7 @@ bool ParallaxCatalogueWriter::selectIndex(const Key &key)
9393
size_t hash = std::hash<std::string>{}(keyStr.c_str());
9494
int db_index = hash % PARALLAX_DB_COUNT;
9595

96-
std::string db_name = "par_db" + std::to_string(db_index + 1);
96+
std::string db_name = "par_db" + std::to_string(db_index);
9797
par_handle db_handle = par_get_db(db_name);
9898
const char *error_msg = nullptr;
9999

@@ -115,7 +115,7 @@ bool ParallaxCatalogueWriter::selectIndex(const Key &key)
115115
size_t hash = std::hash<std::string>{}(keyStr.c_str());
116116
int db_index = hash % PARALLAX_DB_COUNT;
117117

118-
std::string db_name = "par_db" + std::to_string(db_index + 1);
118+
std::string db_name = "par_db" + std::to_string(db_index);
119119
db_handle = par_get_db(db_name);
120120

121121
par_put(db_handle, &kv, &error_msg);
@@ -214,7 +214,7 @@ void ParallaxCatalogueWriter::archive(const Key &key, std::unique_ptr<FieldLocat
214214
hash = std::hash<std::string>{}(indexKeyWithAxes.c_str());
215215
db_index = hash % PARALLAX_DB_COUNT;
216216

217-
db_name = "par_db" + std::to_string(db_index + 1);
217+
db_name = "par_db" + std::to_string(db_index);
218218
db_handle = par_get_db(db_name);
219219

220220
par_put(db_handle, &kv, &error_message);
@@ -246,7 +246,7 @@ void ParallaxCatalogueWriter::archive(const Key &key, std::unique_ptr<FieldLocat
246246
hash = std::hash<std::string>{}(axisKey.c_str());
247247
db_index = hash % PARALLAX_DB_COUNT;
248248

249-
db_name = "par_db" + std::to_string(db_index + 1);
249+
db_name = "par_db" + std::to_string(db_index);
250250
db_handle = par_get_db(db_name);
251251

252252
par_get(db_handle, &existing_key, &existing_value, &error_message2);
@@ -278,7 +278,7 @@ void ParallaxCatalogueWriter::archive(const Key &key, std::unique_ptr<FieldLocat
278278
size_t hash = std::hash<std::string>{}(axisKey.c_str());
279279
int db_index = hash % PARALLAX_DB_COUNT;
280280

281-
std::string db_name = "par_db" + std::to_string(db_index + 1);
281+
std::string db_name = "par_db" + std::to_string(db_index);
282282
db_handle = par_get_db(db_name);
283283
par_put(db_handle, &kv2, &error_message2);
284284
if (error_message2) {

src/fdb5/parallax/ParallaxIndex.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ void ParallaxIndex::updateAxes()
5050
hash = std::hash<std::string>{}(keyStr.c_str());
5151
db_index = hash % PARALLAX_DB_COUNT;
5252

53-
db_name = "par_db" + std::to_string(db_index + 1);
53+
db_name = "par_db" + std::to_string(db_index);
5454
db_handle = par_get_db(db_name);
5555
par_get(db_handle, &axes_key, &axes_value, &error_msg);
5656

@@ -76,7 +76,7 @@ void ParallaxIndex::updateAxes()
7676
hash = std::hash<std::string>{}(axisKeyStr.c_str());
7777
db_index = hash % PARALLAX_DB_COUNT;
7878

79-
db_name = "par_db" + std::to_string(db_index + 1);
79+
db_name = "par_db" + std::to_string(db_index);
8080
db_handle = par_get_db(db_name);
8181

8282
par_get(db_handle, &axis_key, &axis_value, &error_msg);
@@ -112,7 +112,7 @@ bool ParallaxIndex::get(const Key &key, const Key &remapKey, Field &field) const
112112
size_t hash = std::hash<std::string>{}(query.c_str());
113113
int db_index = hash % PARALLAX_DB_COUNT;
114114

115-
std::string db_name = "par_db" + std::to_string(db_index + 1);
115+
std::string db_name = "par_db" + std::to_string(db_index);
116116
par_handle db_handle = par_get_db(db_name);
117117
const char *error_msg = nullptr;
118118

@@ -169,7 +169,7 @@ void ParallaxIndex::add(const Key &key, const Field &field)
169169
size_t hash = std::hash<std::string>{}(keyStr);
170170
int db_index = hash % PARALLAX_DB_COUNT;
171171

172-
std::string db_name = "par_db" + std::to_string(db_index + 1);
172+
std::string db_name = "par_db" + std::to_string(db_index);
173173
par_handle db_handle = par_get_db(db_name);
174174
const char *error_msg = nullptr;
175175

src/fdb5/parallax/ParallaxStore.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ std::unique_ptr<FieldLocation> ParallaxStore::archive(const Key &key, const void
3232
size_t hash = std::hash<std::string>{}(internalKey);
3333
int db_index = hash % PARALLAX_DB_COUNT;
3434

35-
std::string db_name = "par_db" + std::to_string(db_index + 1);
35+
std::string db_name = "par_db" + std::to_string(db_index);
3636
par_handle db_handle = par_get_db(db_name);
3737

3838
const char *error_msg = nullptr;

0 commit comments

Comments
 (0)