commit f903a1c841977750c18ae80bc3a4cd6f1bc34d03
author Todd Volkert <tvolkert@users.noreply.github.com> Tue Feb 14 09:59:43 2017 -0800
committer GitHub <noreply@github.com> Tue Feb 14 09:59:43 2017 -0800
tree 94dc2093adb051fc34ccb94e7230e4770937be8a
parent 43650e93f4e3bac849f9ccc35fd1b8f71667da4f

Add retry writing to DevFS. (#8142)

This is a workaround to #8141

packages/flutter_tools/lib/src/devfs.dart

diff --git a/packages/flutter_tools/lib/src/devfs.dart b/packages/flutter_tools/lib/src/devfs.dart
index 2cd8c09..8ef1931 100644
--- a/packages/flutter_tools/lib/src/devfs.dart
+++ b/packages/flutter_tools/lib/src/devfs.dart
@@ -222,6 +222,7 @@
   final Uri httpAddress;
 
   static const int kMaxInFlight = 6;
+  static const int kMaxRetries = 3;
 
   int _inFlight = 0;
   Map<String, DevFSContent> _outstanding;
@@ -256,9 +257,12 @@
     }
   }
 
-  Future<Null> _scheduleWrite(String devicePath,
-                              DevFSContent content,
-                              DevFSProgressReporter progressReporter) async {
+  Future<Null> _scheduleWrite(
+    String devicePath,
+    DevFSContent content,
+    DevFSProgressReporter progressReporter, [
+    int retry = 0,
+  ]) async {
     try {
       HttpClientRequest request = await _client.putUrl(httpAddress);
       request.headers.removeAll(HttpHeaders.ACCEPT_ENCODING);
@@ -270,7 +274,13 @@
       HttpClientResponse response = await request.close();
       await response.drain<Null>();
     } catch (e) {
-      printError('Error writing "$devicePath" to DevFS: $e');
+      if (retry < kMaxRetries) {
+        printTrace('Retrying writing "$devicePath" to DevFS due to error: $e');
+        _scheduleWrite(devicePath, content, progressReporter, retry + 1);
+        return;
+      } else {
+        printError('Error writing "$devicePath" to DevFS: $e');
+      }
     }
     if (progressReporter != null) {
       _done++;