Tcp long connections metrics

[yp969803]

What type of PR is this?

/kind feature

What this PR does / why we need it:
The pr introduces new feature of tcp_long_conn metrics
Which issue(s) this PR fixes:

Fixes #1211

Special notes for your reviewer:

Does this PR introduce a user-facing change?:
Yes

Tcp long connections metrics

[kmesh-bot]

[APPROVALNOTIFIER] This PR is NOT APPROVED

This pull-request has been approved by:
Once this PR has been reviewed and has the lgtm label, please assign nlgwcy for approval. For more information see the Kubernetes Code Review Process.

The full list of commands accepted by this bot can be found here.

Needs approval from an approver in each of these files:

• OWNERS

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

[yp969803]

@nlgwcy @LemmyHuang @xiangxinyong can you review the pr, have i writen correct ebpf code, i have done the changes which has been told in previous comments in the proposal.

[LiZhenCheng9527]

1. Please present the results of the long connection metrics
2. The original destination address problem is still unhandle. If you plan to optimize later, you can create a sub-issue under the existing lfx issue to track the task.

[LiZhenCheng9527]

I don't think it's necessary to distinguish between metrics for long connections and short connections.
As long as metrics is turned on, we should handle all types of connections.

[LiZhenCheng9527]

BPF_OBJ_NAME_LEN = 16
So I think, this name of map is too long.

[yp969803]

    bpf_map.go:60: bpf init failed: bpf Load failed: load program: permission denied:
        	; int sockops_active_prog(struct bpf_sock_ops *skops)
        	0: (bf) r6 = r1
        	; __u64 sock_cookie = bpf_get_socket_cookie(skops);
        	1: (85) call bpf_get_socket_cookie#46
        	2: (bf) r7 = r0
        	; if (skops->family != AF_INET && skops->family != AF_INET6)
        	3: (61) r1 = *(u32 *)(r6 +20)
        	; if (skops->family != AF_INET && skops->family != AF_INET6)
        	4: (bf) r2 = r1
        	5: (47) r2 |= 8
        	6: (15) if r2 == 0xa goto pc+1

@LiZhenCheng9527 @nlgwcy can you look at the above error during bpf_compaitliblity test, why is this happening, i have also shorten the program length so that number of instruction sets not exceeds

[yp969803]

so the problem arrises in the line of code, with the error

	303: (18) r1 = 0xffff8ff1b4577000     ; R1_w=map_ptr(map=km_orig_dst,ks=8,vs=36)
        	305: (85) call bpf_map_lookup_elem#1
        	R2 type=sock_or_null expected=fp, pkt, pkt_meta, map_key, map_value, mem, ringbuf_mem, buf, trusted_ptr_
        	processed 390 insns (limit 1000000) max_states_per_insn 1 total_states 33 peak_states 33 mark_read 5

when i try to comment these lines and run unit tests, verifier accept it. these lines are written previously in the sockops_prog

     __u64 *current_sk = (__u64 *)skops->sk;
        struct bpf_sock_tuple *dst = bpf_map_lookup_elem(&map_of_orig_dst, current_sk);

in the program

SEC("sockops_active")
int sockops_active_prog(struct bpf_sock_ops *skops)
{
    __u64 sock_cookie = bpf_get_socket_cookie(skops);

    if (skops->family != AF_INET && skops->family != AF_INET6)
        return 0;

    switch (skops->op) {
    case BPF_SOCK_OPS_TCP_CONNECT_CB:
        skops_handle_kmesh_managed_process(skops);
        break;

    case BPF_SOCK_OPS_ACTIVE_ESTABLISHED_CB:
        if (!is_managed_by_kmesh(skops))
            break;
        observe_on_connect_established(skops->sk, sock_cookie, OUTBOUND);
        if (bpf_sock_ops_cb_flags_set(skops, BPF_SOCK_OPS_STATE_CB_FLAG) != 0
            || bpf_sock_ops_cb_flags_set(skops, BPF_SOCK_OPS_RETRANS_CB_FLAG) != 0
            || bpf_sock_ops_cb_flags_set(skops, BPF_SOCK_OPS_RTT_CB_FLAG) != 0) {
            BPF_LOG(ERR, SOCKOPS, "set sockops cb failed!\n");
        }
        __u64 *current_sk = (__u64 *)skops->sk;
        struct bpf_sock_tuple *dst = bpf_map_lookup_elem(&map_of_orig_dst, current_sk);
        if (dst != NULL)
            enable_encoding_metadata(skops);
        break;

    default:
        break;
    }
    return 0;
}

@nlgwcy @LiZhenCheng9527