| OLD | NEW |
|---|
| (Empty) |
| 1 # Copyright 2016 The Chromium Authors. All rights reserved. | |
| 2 # Use of this source code is governed by a BSD-style license that can be | |
| 3 # found in the LICENSE file. | |
| 4 | |
| 5 import logging | |
| 6 | |
| 7 from devil.android import logcat_monitor | |
| 8 from devil.utils import reraiser_thread | |
| 9 from pylib.utils import logdog_helper | |
| 10 | |
| 11 class LogdogLogcatMonitor(logcat_monitor.LogcatMonitor): | |
| 12 """Logcat monitor that writes logcat to a logdog stream. | |
| 13 | |
| 14 The logdog stream client will return a url which contains the logcat. | |
| 15 """ | |
| 16 def __init__(self, adb, stream_name, clear=True, filter_specs=None): | |
| 17 super(LogdogLogcatMonitor, self).__init__(adb, clear, filter_specs) | |
| 18 self._logcat_url = '' | |
| 19 self._logdog_stream = None | |
| 20 self._stream_client = None | |
| 21 self._stream_name = stream_name | |
| 22 | |
| 23 def GetLogcatURL(self): | |
| 24 """Return logcat url. | |
| 25 | |
| 26 The default logcat url is '', if failed to create stream_client. | |
| 27 """ | |
| 28 return self._logcat_url | |
| 29 | |
| 30 def Stop(self): | |
| 31 """Stops the logcat monitor. | |
| 32 | |
| 33 Close the logdog stream as well. | |
| 34 """ | |
| 35 try: | |
| 36 super(LogdogLogcatMonitor, self)._StopRecording() | |
| 37 if self._logdog_stream: | |
| 38 self._logcat_url = logdog_helper.get_viewer_url(self._stream_name) | |
| 39 self._logdog_stream.close() | |
| 40 except Exception as e: # pylint: disable=broad-except | |
| 41 logging.exception('Unknown Error: %s.', e) | |
| 42 | |
| 43 def Start(self): | |
| 44 """Starts the logdog logcat monitor. | |
| 45 | |
| 46 Clears the logcat if |clear| was set in |__init__|. | |
| 47 """ | |
| 48 if self._clear: | |
| 49 self._adb.Logcat(clear=True) | |
| 50 | |
| 51 self._logdog_stream = logdog_helper.open_text(self._stream_name) | |
| 52 self._StartRecording() | |
| 53 | |
| 54 def _StartRecording(self): | |
| 55 """Starts recording logcat to file. | |
| 56 | |
| 57 Write logcat to stream at the same time. | |
| 58 """ | |
| 59 def record_to_stream(): | |
| 60 if self._logdog_stream: | |
| 61 for data in self._adb.Logcat(filter_specs=self._filter_specs, | |
| 62 logcat_format='threadtime', | |
| 63 iter_timeout=0.08): | |
| 64 if self._stop_recording_event.isSet(): | |
| 65 return | |
| 66 if data: | |
| 67 self._logdog_stream.write(data + '\n') | |
| 68 if self._stop_recording_event.isSet(): | |
| 69 return | |
| 70 | |
| 71 self._stop_recording_event.clear() | |
| 72 if not self._record_thread: | |
| 73 self._record_thread = reraiser_thread.ReraiserThread(record_to_stream) | |
| 74 self._record_thread.start() | |
| 75 | |
| 76 def Close(self): | |
| 77 """Override parent's close method.""" | |
| 78 pass | |
| 79 | |
| 80 def __del__(self): | |
| 81 """Override parent's delete method.""" | |
| 82 pass | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 2933993002:
Add local results details pages.
