kopia lustrzana https://github.com/micropython/micropython-lib
utop: Add initial implementation for ESP32.
Signed-off-by: Daniël van de Giessen <daniel@dvdgiessen.nl>pull/822/head
rodzic
68e0dfce0a
commit
0d60de65b7
|
@ -0,0 +1,12 @@
|
|||
# utop
|
||||
|
||||
Provides a top-like live overview of the running system.
|
||||
|
||||
On the `esp32` port this depends on the `esp32.idf_task_info()` function, which
|
||||
can be enabled by adding the following lines to the board `sdkconfig`:
|
||||
|
||||
```ini
|
||||
CONFIG_FREERTOS_USE_TRACE_FACILITY=y
|
||||
CONFIG_FREERTOS_VTASKLIST_INCLUDE_COREID=y
|
||||
CONFIG_FREERTOS_GENERATE_RUN_TIME_STATS=y
|
||||
```
|
|
@ -0,0 +1,6 @@
|
|||
metadata(
|
||||
version="0.1.0",
|
||||
description="Provides a top-like live overview of the running system.",
|
||||
)
|
||||
|
||||
module("utop.py")
|
|
@ -0,0 +1,85 @@
|
|||
import time
|
||||
|
||||
try:
|
||||
import esp32
|
||||
import _thread
|
||||
except ImportError:
|
||||
esp32 = None
|
||||
|
||||
|
||||
def top(update_interval_ms=1000, timeout_ms=None, thread_names={}):
|
||||
time_start = time.ticks_ms()
|
||||
previous_total_runtime = None
|
||||
previous_task_runtimes = {}
|
||||
previous_line_count = 0
|
||||
esp32_task_state_names = dict(
|
||||
enumerate(("running", "ready", "blocked", "suspended", "deleted", "invalid"))
|
||||
)
|
||||
|
||||
while timeout_ms is None or abs(time.ticks_diff(time.ticks_ms(), time_start)) < timeout_ms:
|
||||
if previous_line_count > 0:
|
||||
print("\x1b[{}A".format(previous_line_count), end="")
|
||||
line_count = 0
|
||||
|
||||
if esp32 is not None:
|
||||
if not hasattr(esp32, "idf_task_info"):
|
||||
print(
|
||||
"INFO: esp32.idf_task_info() is not available, cannot list active tasks.\x1b[K"
|
||||
)
|
||||
line_count += 1
|
||||
else:
|
||||
print(" CPU% CORE PRIORITY STATE STACKWATERMARK NAME\x1b[K")
|
||||
line_count += 1
|
||||
|
||||
total_runtime, tasks = esp32.idf_task_info()
|
||||
current_thread_id = _thread.get_ident()
|
||||
tasks.sort(key=lambda t: t[0])
|
||||
for (
|
||||
task_id,
|
||||
task_name,
|
||||
task_state,
|
||||
task_priority,
|
||||
task_runtime,
|
||||
task_stackhighwatermark,
|
||||
task_coreid,
|
||||
) in tasks:
|
||||
task_runtime_percentage = "-"
|
||||
if (
|
||||
total_runtime != previous_total_runtime
|
||||
and task_id in previous_task_runtimes
|
||||
):
|
||||
task_runtime_percentage = "{:.2f}%".format(
|
||||
100
|
||||
* ((task_runtime - previous_task_runtimes[task_id]) & (2**32 - 1))
|
||||
/ ((total_runtime - previous_total_runtime) & (2**32 - 1))
|
||||
)
|
||||
print(
|
||||
"{:>7} {:>4} {:>8d} {:<9} {:<14d} {}{}\x1b[K".format(
|
||||
task_runtime_percentage,
|
||||
"-" if task_coreid is None else task_coreid,
|
||||
task_priority,
|
||||
esp32_task_state_names.get(task_state, "unknown"),
|
||||
task_stackhighwatermark,
|
||||
thread_names.get(task_id, task_name),
|
||||
" (*)" if task_id == current_thread_id else "",
|
||||
)
|
||||
)
|
||||
line_count += 1
|
||||
|
||||
previous_task_runtimes[task_id] = task_runtime
|
||||
previous_total_runtime = total_runtime
|
||||
else:
|
||||
print("INFO: Platform does not support listing active tasks.\x1b[K")
|
||||
line_count += 1
|
||||
|
||||
if previous_line_count > line_count:
|
||||
for _ in range(previous_line_count - line_count):
|
||||
print("\x1b[K")
|
||||
print("\x1b[{}A".format(previous_line_count - line_count), end="")
|
||||
|
||||
previous_line_count = line_count
|
||||
|
||||
try:
|
||||
time.sleep_ms(update_interval_ms)
|
||||
except KeyboardInterrupt:
|
||||
break
|
Ładowanie…
Reference in New Issue