Lines Matching refs:request_id
70 const int request_id = it->first;
72 RejectRequest(request_id,
85 int request_id = next_id_++;
88 if (requests_.find(request_id) != requests_.end())
93 request_id,
99 requests_[request_id] = request;
100 ResetTimer(request_id);
102 FOR_EACH_OBSERVER(Observer, observers_, OnRequestCreated(request_id, type));
108 if (!request->handler->Execute(request_id)) {
109 DestroyRequest(request_id);
113 FOR_EACH_OBSERVER(Observer, observers_, OnRequestExecuted(request_id));
115 return request_id;
118 bool RequestManager::FulfillRequest(int request_id,
122 RequestMap::iterator request_it = requests_.find(request_id);
128 OnRequestFulfilled(request_id, *response.get(), has_more));
130 request_it->second->handler->OnSuccess(request_id, response.Pass(), has_more);
133 DestroyRequest(request_id);
136 notification_manager_->HideUnresponsiveNotification(request_id);
137 ResetTimer(request_id);
143 bool RequestManager::RejectRequest(int request_id,
147 RequestMap::iterator request_it = requests_.find(request_id);
153 OnRequestRejected(request_id, *response.get(), error));
154 request_it->second->handler->OnError(request_id, response.Pass(), error);
155 DestroyRequest(request_id);
190 void RequestManager::OnRequestTimeout(int request_id) {
191 FOR_EACH_OBSERVER(Observer, observers_, OnRequestTimeouted(request_id));
194 RejectRequest(request_id,
201 request_id,
204 request_id));
208 int request_id,
210 RequestMap::iterator request_it = requests_.find(request_id);
215 ResetTimer(request_id);
219 RejectRequest(request_id,
224 void RequestManager::ResetTimer(int request_id) {
225 RequestMap::iterator request_it = requests_.find(request_id);
234 request_id));
237 void RequestManager::DestroyRequest(int request_id) {
238 RequestMap::iterator request_it = requests_.find(request_id);
246 notification_manager_->HideUnresponsiveNotification(request_id);
248 FOR_EACH_OBSERVER(Observer, observers_, OnRequestDestroyed(request_id));
251 "file_system_provider", "RequestManager::Request", request_id);