Method AdmitRequest

tensorflow/core/platform/cloud/gcs_throttle.cc:27–35

      env_time_(env_time) {}

bool GcsThrottle::AdmitRequest() {
  mutex_lock l(mu_);
  UpdateState();
  if (available_tokens_ < config_.tokens_per_request) {
    return false || !config_.enabled;
  }
  available_tokens_ -= config_.tokens_per_request;
  return true;
}

void GcsThrottle::RecordResponse(size_t num_bytes) {
  mutex_lock l(mu_);