OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/browser/chromeos/file_system_provider/request_manager.h" | 5 #include "chrome/browser/chromeos/file_system_provider/request_manager.h" |
6 | 6 |
7 #include "base/files/file.h" | 7 #include "base/files/file.h" |
8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
9 | 9 |
10 namespace chromeos { | 10 namespace chromeos { |
11 namespace file_system_provider { | 11 namespace file_system_provider { |
12 | |
13 namespace { | 12 namespace { |
14 | 13 |
15 // Timeout in seconds, before a request is considered as stale and hence | 14 // Timeout in seconds, before a request is considered as stale and hence |
16 // aborted. | 15 // aborted. |
17 const int kDefaultTimeout = 10; | 16 const int kDefaultTimeout = 10; |
18 | 17 |
19 } // namespace | 18 } // namespace |
20 | 19 |
| 20 std::string RequestTypeToString(RequestType type) { |
| 21 switch (type) { |
| 22 case REQUEST_UNMOUNT: |
| 23 return "REQUEST_UNMOUNT"; |
| 24 case GET_METADATA: |
| 25 return "GET_METADATA"; |
| 26 case READ_DIRECTORY: |
| 27 return "READ_DIRECTORY"; |
| 28 case OPEN_FILE: |
| 29 return "OPEN_FILE"; |
| 30 case CLOSE_FILE: |
| 31 return "CLOSE_FILE"; |
| 32 case READ_FILE: |
| 33 return "READ_FILE"; |
| 34 case TESTING: |
| 35 return "TESTING"; |
| 36 } |
| 37 NOTREACHED(); |
| 38 return ""; |
| 39 } |
| 40 |
21 RequestManager::RequestManager() | 41 RequestManager::RequestManager() |
22 : next_id_(1), | 42 : next_id_(1), |
23 timeout_(base::TimeDelta::FromSeconds(kDefaultTimeout)), | 43 timeout_(base::TimeDelta::FromSeconds(kDefaultTimeout)), |
24 weak_ptr_factory_(this) {} | 44 weak_ptr_factory_(this) {} |
25 | 45 |
26 RequestManager::~RequestManager() { | 46 RequestManager::~RequestManager() { |
27 // Abort all of the active requests. | 47 // Abort all of the active requests. |
28 RequestMap::iterator it = requests_.begin(); | 48 RequestMap::iterator it = requests_.begin(); |
29 while (it != requests_.end()) { | 49 while (it != requests_.end()) { |
30 const int request_id = it->first; | 50 const int request_id = it->first; |
(...skipping 108 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
139 return; | 159 return; |
140 | 160 |
141 delete request_it->second; | 161 delete request_it->second; |
142 requests_.erase(request_it); | 162 requests_.erase(request_it); |
143 | 163 |
144 FOR_EACH_OBSERVER(Observer, observers_, OnRequestDestroyed(request_id)); | 164 FOR_EACH_OBSERVER(Observer, observers_, OnRequestDestroyed(request_id)); |
145 } | 165 } |
146 | 166 |
147 } // namespace file_system_provider | 167 } // namespace file_system_provider |
148 } // namespace chromeos | 168 } // namespace chromeos |
OLD | NEW |