Skip to content

Commit 6ca3916

Browse files
committed
Fix compile errors.
1 parent 8a64886 commit 6ca3916

File tree

5 files changed

+20
-17
lines changed

5 files changed

+20
-17
lines changed

tiledb/sm/query/writers/unordered_writer.cc

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -165,6 +165,10 @@ std::string UnorderedWriter::name() {
165165
return "UnorderedWriter";
166166
}
167167

168+
ContextResources* UnorderedWriter::resources() {
169+
return &storage_manager_->resources();
170+
}
171+
168172
/* ****************************** */
169173
/* PRIVATE METHODS */
170174
/* ****************************** */

tiledb/sm/query/writers/unordered_writer.h

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,12 +85,10 @@ class UnorderedWriter : public WriterBase {
8585
std::string name();
8686

8787
/** Returns the context resources of the writer. */
88-
ContextResources* resources() {
89-
return &storage_manager_->resources();
90-
}
88+
ContextResources* resources();
9189

9290
/** Set fragment metadata. */
93-
Status set_frag_meta(shared_ptr<FragmentMetadata> frag_meta) {
91+
void set_frag_meta(shared_ptr<FragmentMetadata> frag_meta) {
9492
frag_meta_ = frag_meta;
9593
}
9694

tiledb/sm/serialization/capnp_utils.h

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -173,18 +173,21 @@ std::vector<T> capnp_list_to_vector(
173173
/**
174174
* Converts a capnproto list of lists of primitives to a vector of vectors.
175175
*
176+
* @tparam T The type of items in the capnproto list.
177+
* @tparam TConverted The type of items in the resulting vector.
178+
* Defaults to T.
176179
* @param has_value whether the list actually contains any value.
177180
* @param list The capnproto list.
178181
* @param initial_size The initial size of the returning value.
179182
*/
180-
template <class T>
181-
std::vector<std::vector<T>> capnp_2d_list_to_vector(
183+
template <class T, class TConverted = T>
184+
std::vector<std::vector<TConverted>> capnp_2d_list_to_vector(
182185
bool has_value,
183186
typename ::capnp::List<
184187
typename ::capnp::List<T, ::capnp::Kind::PRIMITIVE>,
185188
::capnp::Kind::LIST>::Reader list,
186189
uint64_t initial_size = 0) {
187-
std::vector<std::vector<T>> result(initial_size);
190+
std::vector<std::vector<TConverted>> result(initial_size);
188191
if (has_value) {
189192
result.reserve(list.size());
190193
for (const auto& t : list) {
@@ -483,7 +486,7 @@ Status copy_capnp_list(
483486
return Status::Ok();
484487
}
485488

486-
void serialize_non_empty_domain_rv(
489+
inline void serialize_non_empty_domain_rv(
487490
capnp::NonEmptyDomainList::Builder& builder,
488491
const NDRange& nonEmptyDomain,
489492
uint32_t dim_num) {
@@ -519,15 +522,15 @@ void serialize_non_empty_domain_rv(
519522
* @param builder Builder to set subarray onto
520523
* @param array Array to get nonEmptyDomain from
521524
*/
522-
void serialize_non_empty_domain(
525+
inline void serialize_non_empty_domain(
523526
capnp::NonEmptyDomainList::Builder& builder, tiledb::sm::Array* array) {
524527
serialize_non_empty_domain_rv(
525528
builder,
526529
array->non_empty_domain(),
527530
array->array_schema_latest().dim_num());
528531
}
529532

530-
NDRange deserialize_non_empty_domain_rv(
533+
inline NDRange deserialize_non_empty_domain_rv(
531534
const capnp::NonEmptyDomainList::Reader& reader) {
532535
NDRange ndRange;
533536
if (reader.hasNonEmptyDomains() && reader.getNonEmptyDomains().size() > 0) {
@@ -560,7 +563,7 @@ NDRange deserialize_non_empty_domain_rv(
560563
* @param builder Builder to get nonEmptyDomain from
561564
* @param array Array to set the nonEmptyDomain on
562565
*/
563-
void deserialize_non_empty_domain(
566+
inline void deserialize_non_empty_domain(
564567
const capnp::NonEmptyDomainList::Reader& reader, tiledb::sm::Array* array) {
565568
array->set_non_empty_domain(deserialize_non_empty_domain_rv(reader));
566569
}

tiledb/sm/serialization/fragment_metadata.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -239,13 +239,13 @@ shared_ptr<FragmentMetadata> fragment_metadata_from_capnp(
239239
utils::capnp_2d_list_to_vector<uint8_t>(
240240
frag_meta_reader.hasTileMinBuffer(),
241241
frag_meta_reader.getTileMinBuffer()),
242-
utils::capnp_2d_list_to_vector<uint8_t>(
242+
utils::capnp_2d_list_to_vector<uint8_t, char>(
243243
frag_meta_reader.hasTileMinVarBuffer(),
244244
frag_meta_reader.getTileMinVarBuffer()),
245245
utils::capnp_2d_list_to_vector<uint8_t>(
246246
frag_meta_reader.hasTileMaxBuffer(),
247247
frag_meta_reader.getTileMaxBuffer()),
248-
utils::capnp_2d_list_to_vector<uint8_t>(
248+
utils::capnp_2d_list_to_vector<uint8_t, char>(
249249
frag_meta_reader.hasTileMaxVarBuffer(),
250250
frag_meta_reader.getTileMaxVarBuffer()),
251251
utils::capnp_2d_list_to_vector<uint8_t>(

tiledb/sm/serialization/query.cc

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3036,10 +3036,8 @@ Status global_write_state_from_capnp(
30363036
write_state->last_hilbert_value_ = state_reader.getLastHilbertValue();
30373037

30383038
if (state_reader.hasFragMeta()) {
3039-
auto frag_meta = write_state->frag_meta_;
3040-
auto frag_meta_reader = state_reader.getFragMeta();
3041-
RETURN_NOT_OK(fragment_metadata_from_capnp(
3042-
query.array_schema_shared(), frag_meta_reader, frag_meta));
3039+
write_state->frag_meta_ = fragment_metadata_from_capnp(
3040+
query.array_schema_shared(), state_reader.getFragMeta());
30433041
}
30443042

30453043
// Deserialize the multipart upload state

0 commit comments

Comments
 (0)