| 1068 | } |
| 1069 | |
| 1070 | void AdmissionController::UpdateHostStats(const NetworkAddressPB& host_addr, |
| 1071 | int64_t mem_to_admit, int num_queries_to_admit, int num_slots_to_admit) { |
| 1072 | const string host = NetworkAddressPBToString(host_addr); |
| 1073 | VLOG_ROW << "Update admitted mem reserved for host=" << host |
| 1074 | << " prev=" << PrintBytes(host_stats_[host].mem_admitted) |
| 1075 | << " new=" << PrintBytes(host_stats_[host].mem_admitted + mem_to_admit); |
| 1076 | host_stats_[host].mem_admitted += mem_to_admit; |
| 1077 | DCHECK_GE(host_stats_[host].mem_admitted, 0); |
| 1078 | VLOG_ROW << "Update admitted queries for host=" << host |
| 1079 | << " prev=" << host_stats_[host].num_admitted |
| 1080 | << " new=" << host_stats_[host].num_admitted + num_queries_to_admit; |
| 1081 | host_stats_[host].num_admitted += num_queries_to_admit; |
| 1082 | DCHECK_GE(host_stats_[host].num_admitted, 0); |
| 1083 | VLOG_ROW << "Update slots in use for host=" << host |
| 1084 | << " prev=" << host_stats_[host].slots_in_use |
| 1085 | << " new=" << host_stats_[host].slots_in_use + num_slots_to_admit; |
| 1086 | host_stats_[host].slots_in_use += num_slots_to_admit; |
| 1087 | DCHECK_GE(host_stats_[host].slots_in_use, 0); |
| 1088 | } |
| 1089 | |
| 1090 | // Helper method used by CanAccommodateMaxInitialReservation(). Returns true if the given |
| 1091 | // 'mem_limit' can accommodate 'buffer_reservation'. If not, returns false and the |
nothing calls this directly
no test coverage detected