Skip to content

Commit 13b5c1c

Browse files
committed
Remove set_subarray_unsafe
1 parent a9aaf88 commit 13b5c1c

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
@@ -1517,11 +1517,6 @@ const Subarray* Query::subarray() const {
15171517
return &subarray_;
15181518
}
15191519

1520-
Status Query::set_subarray_unsafe(const Subarray& subarray) {
1521-
subarray_ = subarray;
1522-
return Status::Ok();
1523-
}
1524-
15251520
void Query::set_subarray(const tiledb::sm::Subarray& subarray) {
15261521
// Perform checks related to the query type.
15271522
switch (type_) {
@@ -1572,10 +1567,6 @@ Status Query::set_subarray_unsafe(const NDRange& subarray) {
15721567
return Status::Ok();
15731568
}
15741569

1575-
void Query::set_subarray_unsafe(const void* subarray) {
1576-
subarray_.set_subarray_unsafe(subarray);
1577-
}
1578-
15791570
Status Query::submit() {
15801571
// Do not resubmit completed reads.
15811572
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
@@ -1157,7 +1157,7 @@ Status reader_from_capnp(
11571157
auto subarray_reader = reader_reader.getSubarray();
11581158
Subarray subarray = subarray_from_capnp(
11591159
subarray_reader, array, layout, query->stats(), dummy_logger);
1160-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
1160+
query->set_subarray(subarray);
11611161

11621162
// Read state
11631163
if (reader_reader.hasReadState())
@@ -1198,7 +1198,7 @@ Status index_reader_from_capnp(
11981198
auto subarray_reader = reader_reader.getSubarray();
11991199
Subarray subarray = subarray_from_capnp(
12001200
subarray_reader, array, layout, query->stats(), dummy_logger);
1201-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
1201+
query->set_subarray(subarray);
12021202

12031203
// Read state
12041204
if (reader_reader.hasReadState())
@@ -1240,7 +1240,7 @@ Status dense_reader_from_capnp(
12401240
auto subarray_reader = reader_reader.getSubarray();
12411241
Subarray subarray = subarray_from_capnp(
12421242
subarray_reader, array, layout, query->stats(), dummy_logger);
1243-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
1243+
query->set_subarray(subarray);
12441244

12451245
// Read state
12461246
if (reader_reader.hasReadState())
@@ -2266,7 +2266,7 @@ Status query_from_capnp(
22662266
RETURN_NOT_OK(
22672267
utils::deserialize_subarray(subarray_reader, schema, &subarray));
22682268
try {
2269-
query->set_subarray_unsafe(subarray);
2269+
query->set_subarray(subarray);
22702270
} catch (...) {
22712271
tdb_free(subarray);
22722272
throw;
@@ -2279,7 +2279,7 @@ Status query_from_capnp(
22792279
auto subarray_reader = writer_reader.getSubarrayRanges();
22802280
Subarray subarray = subarray_from_capnp(
22812281
subarray_reader, array, layout, query->stats(), dummy_logger);
2282-
RETURN_NOT_OK(query->set_subarray_unsafe(subarray));
2282+
query->set_subarray(subarray);
22832283
}
22842284
}
22852285
} else {
@@ -3229,7 +3229,7 @@ void ordered_dim_label_reader_from_capnp(
32293229
auto subarray_reader = reader_reader.getSubarray();
32303230
Subarray subarray = subarray_from_capnp(
32313231
subarray_reader, array, layout, query->stats(), dummy_logger);
3232-
throw_if_not_ok(query->set_subarray_unsafe(subarray));
3232+
query->set_subarray(subarray);
32333233

32343234
// OrderedDimLabelReader requires an initialized subarray for construction.
32353235
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)