| 462 | } |
| 463 | |
| 464 | void Statestore::Topic::ClearAllEntries() { |
| 465 | lock_guard<shared_mutex> write_lock(lock_); |
| 466 | entries_.clear(); |
| 467 | topic_update_log_.clear(); |
| 468 | int64_t key_size_metric_val = key_size_metric_->GetValue(); |
| 469 | key_size_metric_->SetValue(std::max(static_cast<int64_t>(0), |
| 470 | key_size_metric_val - total_key_size_bytes_)); |
| 471 | int64_t value_size_metric_val = value_size_metric_->GetValue(); |
| 472 | value_size_metric_->SetValue(std::max(static_cast<int64_t>(0), |
| 473 | value_size_metric_val - total_value_size_bytes_)); |
| 474 | int64_t topic_size_metric_val = topic_size_metric_->GetValue(); |
| 475 | topic_size_metric_->SetValue(std::max(static_cast<int64_t>(0), |
| 476 | topic_size_metric_val - (total_value_size_bytes_ + total_key_size_bytes_))); |
| 477 | total_value_size_bytes_ = 0; |
| 478 | total_key_size_bytes_ = 0; |
| 479 | } |
| 480 | |
| 481 | void Statestore::Topic::BuildDelta(const SubscriberId& subscriber_id, |
| 482 | TopicEntry::Version last_processed_version, |
no test coverage detected