| 83 | } |
| 84 | |
| 85 | inline void table_data::commit(bool show_progress) |
| 86 | { |
| 87 | if (dataset_ == nullptr || !dataset_->has_uncommitted_changes()) { |
| 88 | return; |
| 89 | } |
| 90 | try { |
| 91 | flush(); |
| 92 | impl::commit_dataset(get_dataset(), show_progress); |
| 93 | } catch (const std::exception& e) { |
| 94 | reset_insert_rows(); |
| 95 | clear_delete_rows(); |
| 96 | clear_update_rows(); |
| 97 | elog(ERROR, "Failed to commit dataset: %s", e.what()); |
| 98 | } catch (...) { |
| 99 | reset_insert_rows(); |
| 100 | clear_delete_rows(); |
| 101 | clear_update_rows(); |
| 102 | elog(ERROR, "Failed to commit dataset, unknown exception"); |
| 103 | } |
| 104 | streamers_.reset(); |
| 105 | force_refresh(); |
| 106 | } |
| 107 | |
| 108 | inline void table_data::open_dataset(bool create) |
| 109 | { |
no test coverage detected