kernel/bpf-developer-tutorial
1
0
Fork 0
mirror of https://github.com/eunomia-bpf/bpf-developer-tutorial.git synced 2026-11-01 13:15:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Simplify fsession polling control flow

Browse Source
This commit is contained in:
LinuxDev9002
2026-07-18 14:18:14 -07:00
parent 7e984142d5
commit 3afcab0d7e
1 changed files with 27 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
src/52-fsession-latency/fsession_latency.c
View File

@@ -145,6 +145,31 @@ static int handle_event(void *context, void *data, size_t size)
return 0; return 0;
} }
static int poll_until_deadline(struct ring_buffer *ring, long long deadline)
{
while (!exiting) {
long long now = monotonic_milliseconds();
int consumed;
if (now < 0)
return (int)now;
if (now >= deadline)
break;
consumed = ring_buffer__poll(ring,
deadline - now > 100 ? 100 : deadline - now);
if (consumed == -EINTR)
continue;
if (consumed < 0) {
fprintf(stderr, "ring buffer poll failed: %s\n",
strerror(-consumed));
return consumed;
}
}
return 0;
}
int main(int argc, char **argv) int main(int argc, char **argv)
{ {
struct fsession_latency_bpf *skel = NULL; struct fsession_latency_bpf *skel = NULL;
@@ -206,27 +231,8 @@ int main(int argc, char **argv)
} }
deadline = now + env.duration * 1000LL; deadline = now + env.duration * 1000LL;
while (!exiting) { err = poll_until_deadline(ring, deadline);
now = monotonic_milliseconds(); if (err)
if (now < 0) {
err = now;
break;
}
if (now >= deadline)
break;
err = ring_buffer__poll(ring, deadline - now > 100 ? 100 : deadline - now);
if (err == -EINTR) {
err = 0;
continue;
}
if (err < 0) {
fprintf(stderr, "ring buffer poll failed: %s\n", strerror(-err));
break;
}
err = 0;
}
if (err < 0)
goto cleanup; goto cleanup;
fsession_latency_bpf__detach(skel); fsession_latency_bpf__detach(skel);