summaryrefslogtreecommitdiff
path: root/forstio/async/async.tmpl.h
diff options
context:
space:
mode:
Diffstat (limited to 'forstio/async/async.tmpl.h')
-rw-r--r--forstio/async/async.tmpl.h28
1 files changed, 14 insertions, 14 deletions
diff --git a/forstio/async/async.tmpl.h b/forstio/async/async.tmpl.h
index 77a24da..d081fa9 100644
--- a/forstio/async/async.tmpl.h
+++ b/forstio/async/async.tmpl.h
@@ -151,7 +151,7 @@ own<conveyor_node> conveyor<T>::from_conveyor(conveyor<T> conveyor) {
template <typename T> error_or<fix_void<T>> conveyor<T>::take() {
SAW_ASSERT(node_) {
return error_or<fix_void<T>>{
- critical_error("conveyor in invalid state")};
+ make_error<err::invalid_state>("conveyor in invalid state")};
}
conveyor_storage *storage = node_->next_storage();
if (storage) {
@@ -161,11 +161,11 @@ template <typename T> error_or<fix_void<T>> conveyor<T>::take() {
return result;
} else {
return error_or<fix_void<T>>{
- recoverable_error("conveyor buffer has no elements")};
+ make_error<err::buffer_exhausted>("conveyor buffer has no elements")};
}
} else {
return error_or<fix_void<T>>{
- critical_error("conveyor node has no child storage")};
+ make_error<err::invalid_state>("conveyor node has no child storage")};
}
}
@@ -187,7 +187,7 @@ template <typename T> void queue_buffer_conveyor_node<T>::fire() {
if (child_mixin_.child) {
if (!storage_.empty()) {
if (storage_.front().is_error()) {
- if (storage_.front().error().is_critical()) {
+ if (storage_.front().get_error().is_critical()) {
child_mixin_.child = nullptr;
}
}
@@ -237,7 +237,7 @@ template <typename T> void queue_buffer_conveyor_node<T>::child_has_fired() {
child_mixin_.child->get_result(eov);
if (eov.is_error()) {
- if (eov.error().is_critical()) {
+ if (eov.get_error().is_critical()) {
}
}
@@ -327,7 +327,7 @@ template <typename T>
error_or<own<conveyor_node>>
merge_conveyor_node<T>::swap_child(own<conveyor_node> &&swapee_) noexcept {
(void)swapee_;
- return critical_error(
+ return make_error<err::invalid_state>(
"merge_conveyor_node<T>::appendage should block calls to this class");
}
@@ -359,7 +359,7 @@ void merge_conveyor_node<T>::get_result(error_or_value &eov) noexcept {
}
}
- err_or_val = critical_error("No value in Merge appendages");
+ err_or_val = make_error<err::invalid_state>("No value in Merge appendages");
}
template <typename T> void merge_conveyor_node<T>::fire() {
@@ -414,7 +414,7 @@ merge_conveyor_node<T>::appendage::swap_child(own<conveyor_node> &&swapee_) {
child = std::move(swapee_);
// This case should never happen
- SAW_ASSERT(old_child) { return critical_error("No child exists"); }
+ SAW_ASSERT(old_child) { return make_error<err::invalid_state>("No child exists"); }
return old_child;
}
@@ -425,7 +425,7 @@ void merge_conveyor_node<T>::appendage::get_result(error_or_value &eov) {
SAW_ASSERT(queued() > 0) {
err_or_val =
- critical_error("No element queued in Merge appendage Node");
+ make_error<err::invalid_state>("No element queued in Merge appendage Node");
return;
}
@@ -461,7 +461,7 @@ void merge_conveyor_node<T>::appendage::get_appendage_result(
SAW_ASSERT(queued() > 0) {
err_or_val =
- critical_error("No element queued in Merge appendage Node");
+ make_error<err::invalid_state>("No element queued in Merge appendage Node");
return;
}
@@ -573,7 +573,7 @@ template <typename T> size_t adapt_conveyor_feeder<T>::space() const {
template <typename T>
error adapt_conveyor_feeder<T>::swap(conveyor<T> &&conv) noexcept {
- SAW_ASSERT(feedee_) { return critical_error("No feedee connected"); }
+ SAW_ASSERT(feedee_) { return make_error<err::invalid_state>("No feedee connected"); }
auto node = conveyor<T>::from_conveyor(std::move(conv));
@@ -602,7 +602,7 @@ adapt_conveyor_node<T>::swap_child(own<conveyor_node> &&swapee) noexcept {
return myself_err;
}
- auto &myself = myself_err.value();
+ auto &myself = myself_err.get_value();
assert(myself.get() == this);
@@ -649,7 +649,7 @@ void adapt_conveyor_node<T>::get_result(error_or_value &err_or_val) {
err_or_val.as<T>() = std::move(storage_.front());
storage_.pop();
} else {
- err_or_val.as<T>() = critical_error(
+ err_or_val.as<T>() = make_error<err::invalid_state>(
"Signal for retrieval of storage sent even though no "
"data is present");
}
@@ -754,7 +754,7 @@ void one_time_conveyor_node<T>::get_result(error_or_value &err_or_val) {
err_or_val.as<T>() = std::move(storage_.value());
storage_ = std::nullopt;
} else {
- err_or_val.as<T>() = critical_error(
+ err_or_val.as<T>() = make_error<err::invalid_state>(
"Signal for retrieval of storage sent even though no "
"data is present");
}