{ "cells": [ { "cell_type": "code", "execution_count": null, "id": "bfe01ceb-2f27-41b3-b3ba-50ec65cfddda", "metadata": {}, "outputs": [], "source": [ "from pythonbpf import bpf, map, section, bpfglobal, BPF, trace_fields\n", "from pythonbpf.helper import ktime\n", "from pythonbpf.maps import HashMap\n", "\n", "from ctypes import c_void_p, c_int64" ] }, { "cell_type": "code", "execution_count": null, "id": "ddb115f4-20a7-43bc-bb5b-ccbfd6031fc2", "metadata": {}, "outputs": [], "source": [ "@bpf\n", "@map\n", "def last() -> HashMap:\n", " return HashMap(key=c_int64, value=c_int64, max_entries=1)\n", "\n", "\n", "@bpf\n", "@section(\"tracepoint/syscalls/sys_enter_sync\")\n", "def do_trace(ctx: c_void_p) -> c_int64:\n", " key = 0\n", " tsp = last.lookup(key)\n", " if tsp:\n", " delta = ktime() - tsp\n", " if delta < 1000000000:\n", " time_ms = delta // 1000000\n", " print(f\"{time_ms}\")\n", " last.delete(key)\n", " else:\n", " last.update(key, ktime())\n", " return 0\n", "\n", "\n", "@bpf\n", "@bpfglobal\n", "def LICENSE() -> str:\n", " return \"GPL\"\n", "\n", "\n", "# Compile and load\n", "b = BPF()\n", "b.load()\n", "b.attach_all()" ] }, { "cell_type": "code", "execution_count": null, "id": "e4f46574-9fd8-46e7-9c7b-27a36d07f200", "metadata": {}, "outputs": [], "source": [ "print(\"Tracing for quick sync's... Ctrl-C to end\")\n", "\n", "# format output\n", "start = 0\n", "while True:\n", " try:\n", " task, pid, cpu, flags, ts, ms = trace_fields()\n", " if start == 0:\n", " start = ts\n", " ts -= start\n", " print(f\"At time {ts} s: Multiple syncs detected, last {ms} ms ago\")\n", " except KeyboardInterrupt:\n", " exit()" ] } ], "metadata": { "kernelspec": { "display_name": "Python 3 (ipykernel)", "language": "python", "name": "python3" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.13.3" } }, "nbformat": 4, "nbformat_minor": 5 }