summaryrefslogtreecommitdiffstats
path: root/include/query/wss.h
diff options
context:
space:
mode:
authorDouglas Rumbaugh <dbr4@psu.edu>2025-09-25 14:42:44 -0400
committerDouglas Rumbaugh <dbr4@psu.edu>2025-09-25 14:42:44 -0400
commitcf5f3bbb0cb58430ed68ad3ebfcefc009e553d71 (patch)
tree4c17bc3169ee195c236cea9c9efda0aef7488e3c /include/query/wss.h
parent826c1fff5accbaa6b415acc176a5acbeb5f691b6 (diff)
downloaddynamic-extension-cf5f3bbb0cb58430ed68ad3ebfcefc009e553d71.tar.gz
Code reformatting
Diffstat (limited to 'include/query/wss.h')
-rw-r--r--include/query/wss.h14
1 files changed, 7 insertions, 7 deletions
diff --git a/include/query/wss.h b/include/query/wss.h
index d4e75f3..311de78 100644
--- a/include/query/wss.h
+++ b/include/query/wss.h
@@ -139,7 +139,8 @@ public:
for (size_t i = 0; i < query->sample_size; i++) {
size_t idx = shard->get_weighted_sample(query->global_parms.rng);
- if (!shard->get_record_at(idx)->is_deleted() && !shard->get_record_at(idx)->is_tombstone()) {
+ if (!shard->get_record_at(idx)->is_deleted() &&
+ !shard->get_record_at(idx)->is_tombstone()) {
result.emplace_back(shard->get_record_at(idx)->rec);
}
}
@@ -147,8 +148,7 @@ public:
return result;
}
- static LocalResultType
- local_query_buffer(LocalQueryBuffer *query) {
+ static LocalResultType local_query_buffer(LocalQueryBuffer *query) {
LocalResultType result;
for (size_t i = 0; i < query->sample_size; i++) {
@@ -156,7 +156,8 @@ public:
auto rec = query->buffer->get(idx);
auto test = gsl_rng_uniform(query->global_parms.rng) * query->max_weight;
- if (test <= rec->rec.weight && !rec->is_deleted() && !rec->is_tombstone()) {
+ if (test <= rec->rec.weight && !rec->is_deleted() &&
+ !rec->is_tombstone()) {
result.emplace_back(rec->rec);
}
}
@@ -164,9 +165,8 @@ public:
return result;
}
- static void
- combine(std::vector<LocalResultType> const &local_results,
- Parameters *parms, ResultType &output) {
+ static void combine(std::vector<LocalResultType> const &local_results,
+ Parameters *parms, ResultType &output) {
for (size_t i = 0; i < local_results.size(); i++) {
for (size_t j = 0; j < local_results[i].size(); j++) {
output.emplace_back(local_results[i][j]);