OLD | NEW |
---|---|
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 | 5 |
6 class _Directory implements Directory { | 6 class _Directory implements Directory { |
7 static final kCreateRequest = 0; | 7 static final kCreateRequest = 0; |
8 static final kDeleteRequest = 1; | 8 static final kDeleteRequest = 1; |
9 static final kExistsRequest = 2; | 9 static final kExistsRequest = 2; |
10 static final kCreateTempRequest = 3; | 10 static final kCreateTempRequest = 3; |
11 static final kListRequest = 4; | 11 static final kListRequest = 4; |
12 | 12 |
13 static final kSuccessResponse = 0; | 13 static final kSuccessResponse = 0; |
14 static final kIllegalArgumentResponse = 1; | 14 static final kIllegalArgumentResponse = 1; |
15 static final kOSErrorResponse = 2; | 15 static final kOSErrorResponse = 2; |
16 | 16 |
17 _Directory(String this._path); | 17 _Directory(String this._path); |
18 _Directory.current() : _path = _current(); | 18 _Directory.current() : _path = _current(); |
19 | 19 |
20 static String _current() native "Directory_Current"; | 20 static String _current() native "Directory_Current"; |
21 static _createTemp(String template) native "Directory_CreateTemp"; | 21 static _createTemp(String template) native "Directory_CreateTemp"; |
22 static int _exists(String path) native "Directory_Exists"; | 22 static int _exists(String path) native "Directory_Exists"; |
23 static _create(String path) native "Directory_Create"; | 23 static _create(String path) native "Directory_Create"; |
24 static _delete(String path, bool recursive) native "Directory_Delete"; | 24 static _delete(String path, bool recursive) native "Directory_Delete"; |
25 static SendPort _newServicePort() native "Directory_NewServicePort"; | 25 static SendPort _newServicePort() native "Directory_NewServicePort"; |
26 | 26 |
27 void exists(void callback(bool exists)) { | 27 Future<bool> exists() { |
28 _ensureDirectoryService(); | 28 _ensureDirectoryService(); |
29 Completer<bool> completer = new Completer<bool>(); | |
29 List request = new List(2); | 30 List request = new List(2); |
30 request[0] = kExistsRequest; | 31 request[0] = kExistsRequest; |
31 request[1] = _path; | 32 request[1] = _path; |
32 _directoryService.call(request).then((response) { | 33 _directoryService.call(request).then((response) { |
33 if (_isErrorResponse(response)) { | 34 if (_isErrorResponse(response)) { |
34 _handleErrorResponse(response, "Exists failed"); | 35 var e = _exceptionFromResponse(response, "Exists failed"); |
36 completer.completeException(e); | |
35 } else { | 37 } else { |
36 callback(response == 1); | 38 completer.complete(response == 1); |
37 } | 39 } |
38 }); | 40 }); |
41 return completer.future; | |
39 } | 42 } |
40 | 43 |
41 bool existsSync() { | 44 bool existsSync() { |
42 if (_path is !String) { | 45 if (_path is !String) { |
43 throw new IllegalArgumentException(); | 46 throw new IllegalArgumentException(); |
44 } | 47 } |
45 var result = _exists(_path); | 48 var result = _exists(_path); |
46 if (result is OSError) { | 49 if (result is OSError) { |
47 throw new DirectoryIOException("Exists failed", _path, result); | 50 throw new DirectoryIOException("Exists failed", _path, result); |
48 } | 51 } |
49 return (result == 1); | 52 return (result == 1); |
50 } | 53 } |
51 | 54 |
52 void create(void callback()) { | 55 Future<Directory> create() { |
53 _ensureDirectoryService(); | 56 _ensureDirectoryService(); |
57 Completer<Directory> completer = new Completer<Directory>(); | |
54 List request = new List(2); | 58 List request = new List(2); |
55 request[0] = kCreateRequest; | 59 request[0] = kCreateRequest; |
56 request[1] = _path; | 60 request[1] = _path; |
57 _directoryService.call(request).then((response) { | 61 _directoryService.call(request).then((response) { |
58 if (_isErrorResponse(response)) { | 62 if (_isErrorResponse(response)) { |
59 _handleErrorResponse(response, "Creation failed"); | 63 var e = _exceptionFromResponse(response, "Creation failed"); |
64 completer.completeException(e); | |
60 } else { | 65 } else { |
61 callback(); | 66 completer.complete(this); |
62 } | 67 } |
63 }); | 68 }); |
69 return completer.future; | |
64 } | 70 } |
65 | 71 |
66 void createSync() { | 72 void createSync() { |
67 if (_path is !String) { | 73 if (_path is !String) { |
68 throw new IllegalArgumentException(); | 74 throw new IllegalArgumentException(); |
69 } | 75 } |
70 var result = _create(_path); | 76 var result = _create(_path); |
71 if (result is OSError) { | 77 if (result is OSError) { |
72 throw new DirectoryIOException("Creation failed", _path, result); | 78 throw new DirectoryIOException("Creation failed", _path, result); |
73 } | 79 } |
74 } | 80 } |
75 | 81 |
76 void createTemp(void callback()) { | 82 Future<Directory> createTemp() { |
77 _ensureDirectoryService(); | 83 _ensureDirectoryService(); |
84 Completer<Directory> completer = new Completer<Directory>(); | |
78 List request = new List(2); | 85 List request = new List(2); |
79 request[0] = kCreateTempRequest; | 86 request[0] = kCreateTempRequest; |
80 request[1] = _path; | 87 request[1] = _path; |
81 _directoryService.call(request).then((response) { | 88 _directoryService.call(request).then((response) { |
82 if (_isErrorResponse(response)) { | 89 if (_isErrorResponse(response)) { |
83 _handleErrorResponse(response, "Creation of temporary directory failed") ; | 90 var e = _exceptionFromResponse(response, |
91 "Creation of temporary directory failed") ; | |
Søren Gjesse
2012/05/10 11:24:45
Long line.
Mads Ager (google)
2012/05/10 12:42:38
Done.
| |
92 completer.completeException(e); | |
84 } else { | 93 } else { |
85 _path = response; | 94 completer.complete(new Directory(response)); |
86 callback(); | |
87 } | 95 } |
88 }); | 96 }); |
97 return completer.future; | |
89 } | 98 } |
90 | 99 |
91 void createTempSync() { | 100 void createTempSync() { |
92 if (_path is !String) { | 101 if (_path is !String) { |
93 throw new IllegalArgumentException(); | 102 throw new IllegalArgumentException(); |
94 } | 103 } |
95 var result = _createTemp(path); | 104 var result = _createTemp(path); |
96 if (result is OSError) { | 105 if (result is OSError) { |
97 throw new DirectoryIOException("Creation of temporary directory failed", | 106 throw new DirectoryIOException("Creation of temporary directory failed", |
98 _path, | 107 _path, |
99 result); | 108 result); |
100 } | 109 } |
101 _path = result; | 110 return new Directory(result); |
102 } | 111 } |
103 | 112 |
104 void _deleteHelper(bool recursive, String errorMsg, void callback()) { | 113 Future<Directory> _deleteHelper(bool recursive, String errorMsg) { |
105 _ensureDirectoryService(); | 114 _ensureDirectoryService(); |
115 Completer<Directory> completer = new Completer<Directory>(); | |
106 List request = new List(3); | 116 List request = new List(3); |
107 request[0] = kDeleteRequest; | 117 request[0] = kDeleteRequest; |
108 request[1] = _path; | 118 request[1] = _path; |
109 request[2] = recursive; | 119 request[2] = recursive; |
110 _directoryService.call(request).then((response) { | 120 _directoryService.call(request).then((response) { |
111 if (_isErrorResponse(response)) { | 121 if (_isErrorResponse(response)) { |
112 _handleErrorResponse(response, errorMsg); | 122 var e = _exceptionFromResponse(response, errorMsg); |
123 completer.completeException(e); | |
113 } else { | 124 } else { |
114 callback(); | 125 completer.complete(this); |
115 } | 126 } |
116 }); | 127 }); |
128 return completer.future; | |
117 } | 129 } |
118 | 130 |
119 void delete(void callback()) { | 131 Future<Directory> delete() { |
120 _deleteHelper(false, "Deletion failed", callback); | 132 return _deleteHelper(false, "Deletion failed"); |
121 } | 133 } |
122 | 134 |
123 void deleteRecursively(void callback()) { | 135 Future<Directory> deleteRecursively() { |
124 _deleteHelper(true, "Deletion failed", callback); | 136 return _deleteHelper(true, "Deletion failed"); |
125 } | 137 } |
126 | 138 |
127 void deleteSync() { | 139 void deleteSync() { |
128 if (_path is !String) { | 140 if (_path is !String) { |
129 throw new IllegalArgumentException(); | 141 throw new IllegalArgumentException(); |
130 } | 142 } |
131 var result = _delete(_path, false); | 143 var result = _delete(_path, false); |
132 if (result is OSError) { | 144 if (result is OSError) { |
133 throw new DirectoryIOException("Deletion failed", _path, result); | 145 throw new DirectoryIOException("Deletion failed", _path, result); |
134 } | 146 } |
135 } | 147 } |
136 | 148 |
137 void deleteRecursivelySync() { | 149 void deleteRecursivelySync() { |
138 if (_path is !String) { | 150 if (_path is !String) { |
139 throw new IllegalArgumentException(); | 151 throw new IllegalArgumentException(); |
140 } | 152 } |
141 var result = _delete(_path, true); | 153 var result = _delete(_path, true); |
142 if (result is OSError) { | 154 if (result is OSError) { |
143 throw new DirectoryIOException("Deletion failed", _path, result); | 155 throw new DirectoryIOException("Deletion failed", _path, result); |
144 } | 156 } |
145 } | 157 } |
146 | 158 |
147 void list([bool recursive = false]) { | 159 DirectoryLister list([bool recursive = false]) { |
160 return new _DirectoryLister(_path, recursive); | |
161 } | |
162 | |
163 String get path() { return _path; } | |
164 | |
165 bool _isErrorResponse(response) { | |
166 return response is List && response[0] != _FileUtils.kSuccessResponse; | |
167 } | |
168 | |
169 Exception _exceptionFromResponse(response, String message) { | |
170 assert(_isErrorResponse(response)); | |
171 switch (response[_FileUtils.kErrorResponseErrorType]) { | |
172 case _FileUtils.kIllegalArgumentResponse: | |
173 return new IllegalArgumentException(); | |
174 case _FileUtils.kOSErrorResponse: | |
175 var err = new OSError(response[_FileUtils.kOSErrorResponseMessage], | |
176 response[_FileUtils.kOSErrorResponseErrorCode]); | |
177 return new DirectoryIOException(message, _path, err); | |
178 default: | |
179 return new Exception("Unknown error"); | |
180 } | |
181 } | |
182 | |
183 void _ensureDirectoryService() { | |
184 if (_directoryService == null) { | |
185 _directoryService = _newServicePort(); | |
186 } | |
187 } | |
188 | |
189 final String _path; | |
190 SendPort _directoryService; | |
191 } | |
192 | |
193 class _DirectoryLister implements DirectoryLister { | |
194 _DirectoryLister(String path, bool recursive) { | |
148 final int kListDirectory = 0; | 195 final int kListDirectory = 0; |
149 final int kListFile = 1; | 196 final int kListFile = 1; |
150 final int kListError = 2; | 197 final int kListError = 2; |
151 final int kListDone = 3; | 198 final int kListDone = 3; |
152 | 199 |
153 final int kResponseType = 0; | 200 final int kResponseType = 0; |
154 final int kResponsePath = 1; | 201 final int kResponsePath = 1; |
155 final int kResponseComplete = 1; | 202 final int kResponseComplete = 1; |
156 final int kResponseError = 2; | 203 final int kResponseError = 2; |
157 | 204 |
158 List request = new List(3); | 205 List request = new List(3); |
159 request[0] = kListRequest; | 206 request[0] = _Directory.kListRequest; |
160 request[1] = _path; | 207 request[1] = path; |
161 request[2] = recursive; | 208 request[2] = recursive; |
162 ReceivePort responsePort = new ReceivePort(); | 209 ReceivePort responsePort = new ReceivePort(); |
163 // Use a separate directory service port for each listing as | 210 // Use a separate directory service port for each listing as |
164 // listing operations on the same directory can run in parallel. | 211 // listing operations on the same directory can run in parallel. |
165 _newServicePort().send(request, responsePort.toSendPort()); | 212 _Directory._newServicePort().send(request, responsePort.toSendPort()); |
166 responsePort.receive((message, replyTo) { | 213 responsePort.receive((message, replyTo) { |
167 if (message is !List || message[kResponseType] is !int) { | 214 if (message is !List || message[kResponseType] is !int) { |
168 responsePort.close(); | 215 responsePort.close(); |
169 _reportError(new DirectoryIOException("Internal error")); | 216 _reportError(new DirectoryIOException("Internal error")); |
170 return; | 217 return; |
171 } | 218 } |
172 switch (message[kResponseType]) { | 219 switch (message[kResponseType]) { |
173 case kListDirectory: | 220 case kListDirectory: |
174 if (_onDir != null) _onDir(message[kResponsePath]); | 221 if (_onDir != null) _onDir(message[kResponsePath]); |
175 break; | 222 break; |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
209 } | 256 } |
210 | 257 |
211 void set onDone(void onDone(bool completed)) { | 258 void set onDone(void onDone(bool completed)) { |
212 _onDone = onDone; | 259 _onDone = onDone; |
213 } | 260 } |
214 | 261 |
215 void set onError(void onError(e)) { | 262 void set onError(void onError(e)) { |
216 _onError = onError; | 263 _onError = onError; |
217 } | 264 } |
218 | 265 |
219 String get path() { return _path; } | |
220 | |
221 void _ensureDirectoryService() { | |
222 if (_directoryService == null) { | |
223 _directoryService = _newServicePort(); | |
224 } | |
225 } | |
226 | |
227 void _reportError(e) { | 266 void _reportError(e) { |
228 if (_onError != null) { | 267 if (_onError != null) { |
229 _onError(e); | 268 _onError(e); |
230 } else { | 269 } else { |
231 throw e; | 270 throw e; |
232 } | 271 } |
233 } | 272 } |
234 | 273 |
235 bool _isErrorResponse(response) { | |
236 return response is List && response[0] != _FileUtils.kSuccessResponse; | |
237 } | |
238 | |
239 void _handleErrorResponse(response, String message) { | |
240 assert(_isErrorResponse(response)); | |
241 switch (response[_FileUtils.kErrorResponseErrorType]) { | |
242 case _FileUtils.kIllegalArgumentResponse: | |
243 _reportError(new IllegalArgumentException()); | |
244 break; | |
245 case _FileUtils.kOSErrorResponse: | |
246 var err = new OSError(response[_FileUtils.kOSErrorResponseMessage], | |
247 response[_FileUtils.kOSErrorResponseErrorCode]); | |
248 _reportError(new DirectoryIOException(message, _path, err)); | |
249 break; | |
250 default: | |
251 _reportError(new Exception("Unknown error")); | |
252 break; | |
253 } | |
254 } | |
255 | |
256 Function _onDir; | 274 Function _onDir; |
257 Function _onFile; | 275 Function _onFile; |
258 Function _onDone; | 276 Function _onDone; |
259 Function _onError; | 277 Function _onError; |
260 | |
261 String _path; | |
262 SendPort _directoryService; | |
263 } | 278 } |
OLD | NEW |