Skip to content

Commit d8b9eda

Browse files
committed
Remove set_subarray_unsafe
1 parent 6e95f2b commit d8b9eda

File tree

5 files changed

+6
-54
lines changed

5 files changed

+6
-54
lines changed

tiledb/sm/query/query.cc

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1519,11 +1519,6 @@ const Subarray* Query::subarray() const {
15191519
return &subarray_;
15201520
}
15211521

1522-
Status Query::set_subarray_unsafe(const Subarray& subarray) {
1523-
subarray_ = subarray;
1524-
return Status::Ok();
1525-
}
1526-
15271522
void Query::set_subarray(const tiledb::sm::Subarray& subarray) {
15281523
// Perform checks related to the query type.
15291524
switch (type_) {
@@ -1574,10 +1569,6 @@ Status Query::set_subarray_unsafe(const NDRange& subarray) {
15741569
return Status::Ok();
15751570
}
15761571

1577-
void Query::set_subarray_unsafe(const void* subarray) {
1578-
subarray_.set_subarray_unsafe(subarray);
1579-
}
1580-
15811572
Status Query::submit() {
15821573
// Do not resubmit completed reads.
15831574
if (type_ == QueryType::READ && status_ == QueryStatus::COMPLETED) {

tiledb/sm/query/query.h

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -617,21 +617,9 @@ class Query {
617617
*/
618618
void set_subarray(const tiledb::sm::Subarray& subarray);
619619

620-
/** Sets the query subarray, without performing any checks. */
621-
Status set_subarray_unsafe(const Subarray& subarray);
622-
623620
/** Sets the query subarray, without performing any checks. */
624621
Status set_subarray_unsafe(const NDRange& subarray);
625622

626-
/**
627-
* Sets the query subarray without performing any checks.
628-
*
629-
* Used for deserialize dense writes.
630-
*
631-
* @param subarray The subarray to be set.
632-
*/
633-
void set_subarray_unsafe(const void* subarray);
634-
635623
/** Submits the query to the storage manager. */
636624
Status submit();
637625

tiledb/sm/serialization/query.cc

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1143,7 +1143,7 @@ Status reader_from_capnp(
11431143
auto subarray_reader = reader_reader.getSubarray();
11441144
Subarray subarray = subarray_from_capnp(
11451145
subarray_reader, array, layout, query->stats(), dummy_logger);
1146-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
1146+
query->set_subarray(subarray);
11471147

11481148
// Read state
11491149
if (reader_reader.hasReadState())
@@ -1181,7 +1181,7 @@ Status index_reader_from_capnp(
11811181
auto subarray_reader = reader_reader.getSubarray();
11821182
Subarray subarray = subarray_from_capnp(
11831183
subarray_reader, array, layout, query->stats(), dummy_logger);
1184-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
1184+
query->set_subarray(subarray);
11851185

11861186
// Read state
11871187
if (reader_reader.hasReadState())
@@ -1220,7 +1220,7 @@ Status dense_reader_from_capnp(
12201220
auto subarray_reader = reader_reader.getSubarray();
12211221
Subarray subarray = subarray_from_capnp(
12221222
subarray_reader, array, layout, query->stats(), dummy_logger);
1223-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
1223+
query->set_subarray(subarray);
12241224

12251225
// Read state
12261226
if (reader_reader.hasReadState())
@@ -2233,7 +2233,7 @@ Status query_from_capnp(
22332233
RETURN_NOT_OK(
22342234
utils::deserialize_subarray(subarray_reader, schema, &subarray));
22352235
try {
2236-
query->set_subarray_unsafe(subarray);
2236+
query->set_subarray(subarray);
22372237
} catch (...) {
22382238
tdb_free(subarray);
22392239
throw;
@@ -2246,7 +2246,7 @@ Status query_from_capnp(
22462246
auto subarray_reader = writer_reader.getSubarrayRanges();
22472247
Subarray subarray = subarray_from_capnp(
22482248
subarray_reader, array, layout, query->stats(), dummy_logger);
2249-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
2249+
query->set_subarray(subarray);
22502250
}
22512251
}
22522252
} else {
@@ -3191,7 +3191,7 @@ void ordered_dim_label_reader_from_capnp(
31913191
auto subarray_reader = reader_reader.getSubarray();
31923192
Subarray subarray = subarray_from_capnp(
31933193
subarray_reader, array, layout, query->stats(), dummy_logger);
3194-
throw_if_not_ok(query->set_subarray_unsafe(subarray));
3194+
query->set_subarray(subarray);
31953195

31963196
// OrderedDimLabelReader requires an initialized subarray for construction.
31973197
query->set_dimension_label_ordered_read(

tiledb/sm/subarray/subarray.cc

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -396,22 +396,6 @@ Status Subarray::set_subarray(const void* subarray) {
396396
return Status::Ok();
397397
}
398398

399-
void Subarray::set_subarray_unsafe(const void* subarray) {
400-
add_default_ranges();
401-
if (subarray != nullptr) {
402-
auto dim_num = array_->array_schema_latest().dim_num();
403-
auto s_ptr = (const unsigned char*)subarray;
404-
uint64_t offset = 0;
405-
for (unsigned d = 0; d < dim_num; ++d) {
406-
auto r_size =
407-
2 * array_->array_schema_latest().dimension_ptr(d)->coord_size();
408-
Range range(&s_ptr[offset], r_size);
409-
throw_if_not_ok(this->add_range_unsafe(d, std::move(range)));
410-
offset += r_size;
411-
}
412-
}
413-
}
414-
415399
Status Subarray::add_range(
416400
unsigned dim_idx, const void* start, const void* end, const void* stride) {
417401
if (dim_idx >= this->array_->array_schema_latest().dim_num())

tiledb/sm/subarray/subarray.h

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -398,17 +398,6 @@ class Subarray {
398398
*/
399399
Status set_subarray(const void* subarray);
400400

401-
/**
402-
* Sets the subarray using a pointer to raw range data that stores one range
403-
* per dimension without performing validity checks.
404-
*
405-
* This is only valid for arrays with homogenous dimension data types. This
406-
* function should only be used for deserializing dense write queries.
407-
*
408-
* @param subarray A pointer to the range data to use.
409-
*/
410-
void set_subarray_unsafe(const void* subarray);
411-
412401
/**
413402
* Adds dimension ranges computed from label ranges on the dimension label.
414403
*

0 commit comments

Comments
 (0)