Handle errors thrown while doing a DevFS sync via HTTP PUT. (#6434)
This commit is contained in:
@@ -222,15 +222,19 @@ class _DevFSHttpWriter {
|
|||||||
|
|
||||||
Future<Null> _scheduleWrite(DevFSEntry entry,
|
Future<Null> _scheduleWrite(DevFSEntry entry,
|
||||||
DevFSProgressReporter progressReporter) async {
|
DevFSProgressReporter progressReporter) async {
|
||||||
HttpClientRequest request = await _client.putUrl(httpAddress);
|
try {
|
||||||
request.headers.removeAll(HttpHeaders.ACCEPT_ENCODING);
|
HttpClientRequest request = await _client.putUrl(httpAddress);
|
||||||
request.headers.add('dev_fs_name', fsName);
|
request.headers.removeAll(HttpHeaders.ACCEPT_ENCODING);
|
||||||
request.headers.add('dev_fs_path_b64',
|
request.headers.add('dev_fs_name', fsName);
|
||||||
BASE64.encode(UTF8.encode(entry.devicePath)));
|
request.headers.add('dev_fs_path_b64',
|
||||||
Stream<List<int>> contents = entry.contentsAsCompressedStream();
|
BASE64.encode(UTF8.encode(entry.devicePath)));
|
||||||
await request.addStream(contents);
|
Stream<List<int>> contents = entry.contentsAsCompressedStream();
|
||||||
HttpClientResponse response = await request.close();
|
await request.addStream(contents);
|
||||||
await response.drain();
|
HttpClientResponse response = await request.close();
|
||||||
|
await response.drain();
|
||||||
|
} catch (e, stackTrace) {
|
||||||
|
printError('Error writing "${entry.devicePath}" to DevFS: $e\n$stackTrace');
|
||||||
|
}
|
||||||
if (progressReporter != null) {
|
if (progressReporter != null) {
|
||||||
_done++;
|
_done++;
|
||||||
progressReporter(_done, _max);
|
progressReporter(_done, _max);
|
||||||
|
|||||||
Reference in New Issue
Block a user