orders_queue.hpp

Go to the documentation of this file.

 
#pragma once
 
namespace tvm { namespace xchg {
 
 
class orders_queue {
public:
  uint128                  all_amount_; 
  big_queue<OrderInfoXchg> orders_;     
 
  bool empty() const { return orders_.empty(); }
 
  void drop_no_post_orders(process_queue_state& state, bool sell) {
    for (auto it = orders_.begin(); it != orders_.end();) {
      auto next_it = std::next(it);
      auto ord = *it;
      if (!ord.post_order) {
        state.on_no_post_order_done({it.idx_, (*it)}, sell);
        all_amount_ -= ord.amount;
        orders_.erase(it);
      }
      it = next_it;
    }
  }
};
 
class orders_queue_cached {
public:
  explicit orders_queue_cached(orders_queue& q) : q_(q) {}
 
  bool empty() const { return q_.orders_.empty(); }
 
  OrderInfoXchgWithIdx& front_with_idx() {
    if (!head_) {
      head_ = q_.orders_.front_with_idx_opt();
      head_orig_amount_ = head_->second.amount;
    }
    require(!!head_, error_code::iterator_overflow);
    return *head_;
  }
 
  void pop() {
    require(!!head_, error_code::iterator_overflow);
    q_.all_amount_ -= head_orig_amount_;
    q_.orders_.pop();
    head_.reset();
  }
 
  ~orders_queue_cached() {
    if (head_) {
      [[maybe_unused]] auto [idx, ord] = *head_;
      q_.all_amount_ -= (head_orig_amount_ - ord.amount);
      q_.orders_.change_front(ord);
    }
  }
  orders_queue& q_;
  opt<OrderInfoXchgWithIdx> head_;
  uint128 head_orig_amount_;
};
 
}} // namespace tvm::xchg