1*387f9dfdSAndroid Build Coastguard Worker#!/usr/bin/python 2*387f9dfdSAndroid Build Coastguard Worker# 3*387f9dfdSAndroid Build Coastguard Worker# sync_timing.py Trace time between syncs. 4*387f9dfdSAndroid Build Coastguard Worker# For Linux, uses BCC, eBPF. Embedded C. 5*387f9dfdSAndroid Build Coastguard Worker# 6*387f9dfdSAndroid Build Coastguard Worker# Written as a basic example of tracing time between events. 7*387f9dfdSAndroid Build Coastguard Worker# 8*387f9dfdSAndroid Build Coastguard Worker# Copyright 2016 Netflix, Inc. 9*387f9dfdSAndroid Build Coastguard Worker# Licensed under the Apache License, Version 2.0 (the "License") 10*387f9dfdSAndroid Build Coastguard Worker 11*387f9dfdSAndroid Build Coastguard Workerfrom __future__ import print_function 12*387f9dfdSAndroid Build Coastguard Workerfrom bcc import BPF 13*387f9dfdSAndroid Build Coastguard Workerfrom bcc.utils import printb 14*387f9dfdSAndroid Build Coastguard Worker 15*387f9dfdSAndroid Build Coastguard Worker# load BPF program 16*387f9dfdSAndroid Build Coastguard Workerb = BPF(text=""" 17*387f9dfdSAndroid Build Coastguard Worker#include <uapi/linux/ptrace.h> 18*387f9dfdSAndroid Build Coastguard Worker 19*387f9dfdSAndroid Build Coastguard WorkerBPF_HASH(last); 20*387f9dfdSAndroid Build Coastguard Worker 21*387f9dfdSAndroid Build Coastguard Workerint do_trace(struct pt_regs *ctx) { 22*387f9dfdSAndroid Build Coastguard Worker u64 ts, *tsp, delta, key = 0; 23*387f9dfdSAndroid Build Coastguard Worker 24*387f9dfdSAndroid Build Coastguard Worker // attempt to read stored timestamp 25*387f9dfdSAndroid Build Coastguard Worker tsp = last.lookup(&key); 26*387f9dfdSAndroid Build Coastguard Worker if (tsp != NULL) { 27*387f9dfdSAndroid Build Coastguard Worker delta = bpf_ktime_get_ns() - *tsp; 28*387f9dfdSAndroid Build Coastguard Worker if (delta < 1000000000) { 29*387f9dfdSAndroid Build Coastguard Worker // output if time is less than 1 second 30*387f9dfdSAndroid Build Coastguard Worker bpf_trace_printk("%d\\n", delta / 1000000); 31*387f9dfdSAndroid Build Coastguard Worker } 32*387f9dfdSAndroid Build Coastguard Worker last.delete(&key); 33*387f9dfdSAndroid Build Coastguard Worker } 34*387f9dfdSAndroid Build Coastguard Worker 35*387f9dfdSAndroid Build Coastguard Worker // update stored timestamp 36*387f9dfdSAndroid Build Coastguard Worker ts = bpf_ktime_get_ns(); 37*387f9dfdSAndroid Build Coastguard Worker last.update(&key, &ts); 38*387f9dfdSAndroid Build Coastguard Worker return 0; 39*387f9dfdSAndroid Build Coastguard Worker} 40*387f9dfdSAndroid Build Coastguard Worker""") 41*387f9dfdSAndroid Build Coastguard Worker 42*387f9dfdSAndroid Build Coastguard Workerb.attach_kprobe(event=b.get_syscall_fnname("sync"), fn_name="do_trace") 43*387f9dfdSAndroid Build Coastguard Workerprint("Tracing for quick sync's... Ctrl-C to end") 44*387f9dfdSAndroid Build Coastguard Worker 45*387f9dfdSAndroid Build Coastguard Worker# format output 46*387f9dfdSAndroid Build Coastguard Workerstart = 0 47*387f9dfdSAndroid Build Coastguard Workerwhile 1: 48*387f9dfdSAndroid Build Coastguard Worker try: 49*387f9dfdSAndroid Build Coastguard Worker (task, pid, cpu, flags, ts, ms) = b.trace_fields() 50*387f9dfdSAndroid Build Coastguard Worker if start == 0: 51*387f9dfdSAndroid Build Coastguard Worker start = ts 52*387f9dfdSAndroid Build Coastguard Worker ts = ts - start 53*387f9dfdSAndroid Build Coastguard Worker printb(b"At time %.2f s: multiple syncs detected, last %s ms ago" % (ts, ms)) 54*387f9dfdSAndroid Build Coastguard Worker except KeyboardInterrupt: 55*387f9dfdSAndroid Build Coastguard Worker exit() 56