From 7d75232632d009fa42c24e6491e0901c06c7a8db Mon Sep 17 00:00:00 2001 From: "amit.slavin" Date: Sun, 26 Nov 2023 13:58:48 +0200 Subject: [PATCH] fixed chan bug --- pkg/network/ebpf/c/protocols/http2/decoding-defs.h | 2 +- pkg/network/protocols/http2/protocol.go | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/network/ebpf/c/protocols/http2/decoding-defs.h b/pkg/network/ebpf/c/protocols/http2/decoding-defs.h index 86ee75b870396..954bf1a1a112f 100644 --- a/pkg/network/ebpf/c/protocols/http2/decoding-defs.h +++ b/pkg/network/ebpf/c/protocols/http2/decoding-defs.h @@ -155,7 +155,7 @@ typedef struct { __u64 path_exceeds_frame; __u64 exceeding_max_interesting_frames; __u64 exceeding_max_frames_to_filter; - __u64 path_size_bucket[7]; + __u64 path_size_bucket[6]; } http2_telemetry_t; #endif diff --git a/pkg/network/protocols/http2/protocol.go b/pkg/network/protocols/http2/protocol.go index 8ce5daf8e0bc9..280b1772d8f38 100644 --- a/pkg/network/protocols/http2/protocol.go +++ b/pkg/network/protocols/http2/protocol.go @@ -214,6 +214,7 @@ func (p *protocol) PostStart(mgr *manager.Manager) error { // Setup map cleaner after manager start. ticker := time.NewTicker(10 * time.Second) http2Telemetry := &HTTP2Telemetry{} + p.done = make(chan struct{}) var zero uint32 mp, _, err := mgr.GetMap(telemetryMap)