OLD | NEW |
| (Empty) |
1 #include "DMReporter.h" | |
2 | |
3 #include "SkDynamicAnnotations.h" | |
4 #include "SkCommonFlags.h" | |
5 #include "OverwriteLine.h" | |
6 #include "ProcStats.h" | |
7 | |
8 namespace DM { | |
9 | |
10 void Reporter::printStatus(SkString name, SkMSec timeMs) const { | |
11 if (FLAGS_quiet) { | |
12 return; | |
13 } | |
14 | |
15 // It's okay if these are a little off---they're just for show---so we can r
ead unprotectedly. | |
16 const int32_t failed = SK_ANNOTATE_UNPROTECTED_READ(fFailed); | |
17 const int32_t pending = SK_ANNOTATE_UNPROTECTED_READ(fPending) - 1; | |
18 | |
19 SkString status; | |
20 status.printf("%s%d tasks left", FLAGS_verbose ? "\n" : kSkOverwriteLine, pe
nding); | |
21 if (failed > 0) { | |
22 status.appendf(", %d failed", failed); | |
23 } | |
24 if (FLAGS_verbose) { | |
25 int max_rss_mb = sk_tools::getMaxResidentSetSizeMB(); | |
26 if (max_rss_mb >= 0) { | |
27 status.appendf("\t%4dM peak", max_rss_mb); | |
28 } | |
29 status.appendf("\t%5dms\t%s", timeMs, name.c_str()); | |
30 } | |
31 SkDebugf("%s", status.c_str()); | |
32 } | |
33 | |
34 void Reporter::fail(SkString msg) { | |
35 sk_atomic_inc(&fFailed); | |
36 | |
37 SkAutoMutexAcquire writer(&fMutex); | |
38 fFailures.push_back(msg); | |
39 } | |
40 | |
41 void Reporter::getFailures(SkTArray<SkString>* failures) const { | |
42 SkAutoMutexAcquire reader(&fMutex); | |
43 *failures = fFailures; | |
44 } | |
45 | |
46 } // namespace DM | |
OLD | NEW |