diff options
| -rwxr-xr-x | clover/clovisor/bin/clovisor | bin | 39227600 -> 39227920 bytes | |||
| -rwxr-xr-x | clover/clovisor/build-docker | 8 | ||||
| -rw-r--r-- | clover/clovisor/libclovisor/clovisor_bcc.go | 16 |
3 files changed, 20 insertions, 4 deletions
diff --git a/clover/clovisor/bin/clovisor b/clover/clovisor/bin/clovisor Binary files differindex d35f90e..240e0bc 100755 --- a/clover/clovisor/bin/clovisor +++ b/clover/clovisor/bin/clovisor diff --git a/clover/clovisor/build-docker b/clover/clovisor/build-docker index 4f776ec..99668d7 100755 --- a/clover/clovisor/build-docker +++ b/clover/clovisor/build-docker @@ -14,7 +14,7 @@ if [ -z "$1" ] fi cp bin/clovisor . docker build --build-arg TARGET_KERNEL_VER=$kernel_ver -t clovisor . -docker tag clovisor localhost:5000/clovisor -docker push localhost:5000/clovisor -#docker tag clovisor s3wong/clovisor -#docker push s3wong/clovisor +#docker tag clovisor localhost:5000/clovisor +#docker push localhost:5000/clovisor +docker tag clovisor s3wong/clovisor +docker push s3wong/clovisor diff --git a/clover/clovisor/libclovisor/clovisor_bcc.go b/clover/clovisor/libclovisor/clovisor_bcc.go index e2d9cd8..ab5bc33 100644 --- a/clover/clovisor/libclovisor/clovisor_bcc.go +++ b/clover/clovisor/libclovisor/clovisor_bcc.go @@ -509,6 +509,22 @@ func ClovisorNewPodInit(k8s_client *ClovisorK8s, session_table := bcc.NewTable(bpf_mod.TableId("sessions"), bpf_mod) + // check if qdisc clsact filter for this interface already exists + link, err := netlink.LinkByIndex(ifindex) + if err != nil { + fmt.Println(err) + } else { + qdiscs, err := netlink.QdiscList(link) + if err == nil { + for _, qdisc := range qdiscs { + if qdisc.Type() == "clsact" { + netlink.QdiscDel(qdisc) + break + } + } + } + } + attrs := netlink.QdiscAttrs { LinkIndex: ifindex, Handle: netlink.MakeHandle(0xffff, 0), |