| 237 | } |
| 238 | |
| 239 | CommandResponse Queue::CommandGetStatus( |
| 240 | const bess::pb::QueueCommandGetStatusArg &) { |
| 241 | bess::pb::QueueCommandGetStatusResponse resp; |
| 242 | resp.set_count(llring_count(queue_)); |
| 243 | resp.set_size(size_); |
| 244 | resp.set_enqueued(stats_.enqueued); |
| 245 | resp.set_dequeued(stats_.dequeued); |
| 246 | resp.set_dropped(stats_.dropped); |
| 247 | return CommandSuccess(resp); |
| 248 | } |
| 249 | |
| 250 | void Queue::AdjustWaterLevels() { |
| 251 | high_water_ = static_cast<uint64_t>(size_ * kHighWaterRatio); |
nothing calls this directly
no test coverage detected