Lines Matching refs:msg
133 struct nlmsg msg; member
524 struct nlmsg *msg; in tap_flow_create_eth() local
539 msg = &flow->msg; in tap_flow_create_eth()
541 tap_nlattr_add(&msg->nh, TCA_FLOWER_KEY_ETH_DST, in tap_flow_create_eth()
544 tap_nlattr_add(&msg->nh, in tap_flow_create_eth()
549 tap_nlattr_add(&msg->nh, TCA_FLOWER_KEY_ETH_SRC, in tap_flow_create_eth()
552 tap_nlattr_add(&msg->nh, in tap_flow_create_eth()
578 struct nlmsg *msg; in tap_flow_create_vlan() local
598 msg = &flow->msg; in tap_flow_create_vlan()
599 msg->t.tcm_info = TC_H_MAKE(msg->t.tcm_info, htons(ETH_P_8021Q)); in tap_flow_create_vlan()
610 tap_nlattr_add8(&msg->nh, in tap_flow_create_vlan()
613 tap_nlattr_add16(&msg->nh, in tap_flow_create_vlan()
638 struct nlmsg *msg; in tap_flow_create_ipv4() local
651 msg = &flow->msg; in tap_flow_create_ipv4()
657 tap_nlattr_add32(&msg->nh, TCA_FLOWER_KEY_IPV4_DST, in tap_flow_create_ipv4()
659 tap_nlattr_add32(&msg->nh, TCA_FLOWER_KEY_IPV4_DST_MASK, in tap_flow_create_ipv4()
663 tap_nlattr_add32(&msg->nh, TCA_FLOWER_KEY_IPV4_SRC, in tap_flow_create_ipv4()
665 tap_nlattr_add32(&msg->nh, TCA_FLOWER_KEY_IPV4_SRC_MASK, in tap_flow_create_ipv4()
669 tap_nlattr_add8(&msg->nh, TCA_FLOWER_KEY_IP_PROTO, in tap_flow_create_ipv4()
694 struct nlmsg *msg; in tap_flow_create_ipv6() local
707 msg = &flow->msg; in tap_flow_create_ipv6()
713 tap_nlattr_add(&msg->nh, TCA_FLOWER_KEY_IPV6_DST, in tap_flow_create_ipv6()
715 tap_nlattr_add(&msg->nh, TCA_FLOWER_KEY_IPV6_DST_MASK, in tap_flow_create_ipv6()
719 tap_nlattr_add(&msg->nh, TCA_FLOWER_KEY_IPV6_SRC, in tap_flow_create_ipv6()
721 tap_nlattr_add(&msg->nh, TCA_FLOWER_KEY_IPV6_SRC_MASK, in tap_flow_create_ipv6()
725 tap_nlattr_add8(&msg->nh, in tap_flow_create_ipv6()
749 struct nlmsg *msg; in tap_flow_create_udp() local
763 msg = &flow->msg; in tap_flow_create_udp()
764 tap_nlattr_add8(&msg->nh, TCA_FLOWER_KEY_IP_PROTO, IPPROTO_UDP); in tap_flow_create_udp()
768 tap_nlattr_add16(&msg->nh, TCA_FLOWER_KEY_UDP_DST, in tap_flow_create_udp()
771 tap_nlattr_add16(&msg->nh, TCA_FLOWER_KEY_UDP_SRC, in tap_flow_create_udp()
795 struct nlmsg *msg; in tap_flow_create_tcp() local
809 msg = &flow->msg; in tap_flow_create_tcp()
810 tap_nlattr_add8(&msg->nh, TCA_FLOWER_KEY_IP_PROTO, IPPROTO_TCP); in tap_flow_create_tcp()
814 tap_nlattr_add16(&msg->nh, TCA_FLOWER_KEY_TCP_DST, in tap_flow_create_tcp()
817 tap_nlattr_add16(&msg->nh, TCA_FLOWER_KEY_TCP_SRC, in tap_flow_create_tcp()
921 struct nlmsg *msg = &flow->msg; in add_action() local
923 if (tap_nlattr_nested_start(msg, (*act_index)++) < 0) in add_action()
926 tap_nlattr_add(&msg->nh, TCA_ACT_KIND, in add_action()
928 if (tap_nlattr_nested_start(msg, TCA_ACT_OPTIONS) < 0) in add_action()
931 tap_nlattr_add(&msg->nh, TCA_GACT_PARMS, sizeof(adata->gact), in add_action()
938 tap_nlattr_add(&msg->nh, TCA_MIRRED_PARMS, in add_action()
942 tap_nlattr_add(&msg->nh, TCA_SKBEDIT_PARMS, in add_action()
945 tap_nlattr_add16(&msg->nh, TCA_SKBEDIT_QUEUE_MAPPING, in add_action()
948 tap_nlattr_add32(&msg->nh, TCA_ACT_BPF_FD, adata->bpf.bpf_fd); in add_action()
949 tap_nlattr_add(&msg->nh, TCA_ACT_BPF_NAME, in add_action()
952 tap_nlattr_add(&msg->nh, TCA_ACT_BPF_PARMS, in add_action()
958 tap_nlattr_nested_finish(msg); /* nested TCA_ACT_OPTIONS */ in add_action()
959 tap_nlattr_nested_finish(msg); /* nested act_index */ in add_action()
985 struct nlmsg *msg = &flow->msg; in add_actions() local
989 if (tap_nlattr_nested_start(msg, classifier_action) < 0) in add_actions()
994 tap_nlattr_nested_finish(msg); /* nested TCA_FLOWER_ACT */ in add_actions()
1065 flow->msg.t.tcm_info = TC_H_MAKE(prio << 16, in priv_flow_process()
1066 flow->msg.t.tcm_info); in priv_flow_process()
1077 flow->msg.t.tcm_parent = TC_H_MAKE(TC_H_INGRESS, 0); in priv_flow_process()
1080 flow->msg.t.tcm_parent = in priv_flow_process()
1084 tap_nlattr_add(&flow->msg.nh, TCA_KIND, sizeof("flower"), "flower"); in priv_flow_process()
1085 if (tap_nlattr_nested_start(&flow->msg, TCA_OPTIONS) < 0) in priv_flow_process()
1121 tap_nlattr_add16(&flow->msg.nh, TCA_FLOWER_KEY_ETH_TYPE, in priv_flow_process()
1123 tap_nlattr_add16(&flow->msg.nh, in priv_flow_process()
1128 tap_nlattr_add16(&flow->msg.nh, TCA_FLOWER_KEY_ETH_TYPE, in priv_flow_process()
1252 tap_nlattr_nested_finish(&flow->msg); /* nested TCA_OPTIONS */ in priv_flow_process()
1318 flow->msg.t.tcm_handle = handle; in tap_flow_set_handle()
1369 struct nlmsg *msg = NULL; in tap_flow_create() local
1395 msg = &flow->msg; in tap_flow_create()
1396 tc_init_msg(msg, pmd->if_index, RTM_NEWTFILTER, in tap_flow_create()
1398 msg->t.tcm_info = TC_H_MAKE(0, htons(ETH_P_ALL)); in tap_flow_create()
1402 err = tap_nl_send(pmd->nlsk_fd, &msg->nh); in tap_flow_create()
1432 msg = &remote_flow->msg; in tap_flow_create()
1435 msg, pmd->remote_if_index, RTM_NEWTFILTER, in tap_flow_create()
1437 msg->t.tcm_info = TC_H_MAKE(0, htons(ETH_P_ALL)); in tap_flow_create()
1446 err = tap_nl_send(pmd->nlsk_fd, &msg->nh); in tap_flow_create()
1495 flow->msg.nh.nlmsg_flags = NLM_F_REQUEST | NLM_F_ACK; in tap_flow_destroy_pmd()
1496 flow->msg.nh.nlmsg_type = RTM_DELTFILTER; in tap_flow_destroy_pmd()
1498 ret = tap_nl_send(pmd->nlsk_fd, &flow->msg.nh); in tap_flow_destroy_pmd()
1519 remote_flow->msg.nh.nlmsg_flags = NLM_F_REQUEST | NLM_F_ACK; in tap_flow_destroy_pmd()
1520 remote_flow->msg.nh.nlmsg_type = RTM_DELTFILTER; in tap_flow_destroy_pmd()
1522 ret = tap_nl_send(pmd->nlsk_fd, &remote_flow->msg.nh); in tap_flow_destroy_pmd()
1604 if (remote_flow->msg.t.tcm_ifindex == pmd->if_index) in tap_flow_isolate()
1687 struct nlmsg *msg = NULL; in tap_flow_implicit_create() local
1705 msg = &remote_flow->msg; in tap_flow_implicit_create()
1724 tc_init_msg(msg, if_index, RTM_NEWTFILTER, flags); in tap_flow_implicit_create()
1725 msg->t.tcm_info = TC_H_MAKE(0, htons(ETH_P_ALL)); in tap_flow_implicit_create()
1736 remote_flow->msg.t.tcm_handle = ISOLATE_HANDLE; in tap_flow_implicit_create()
1738 remote_flow->msg.t.tcm_handle = REMOTE_PROMISCUOUS_HANDLE; in tap_flow_implicit_create()
1746 err = tap_nl_send(pmd->nlsk_fd, &msg->nh); in tap_flow_implicit_create()
1789 cur_prio = (remote_flow->msg.t.tcm_info >> 16) & PRIORITY_MASK; in tap_flow_implicit_destroy()
1842 struct nlmsg *msg = NULL; in rss_enable() local
1908 msg = &rss_flow->msg; in rss_enable()
1909 tc_init_msg(msg, pmd->if_index, RTM_NEWTFILTER, NLM_F_REQUEST | in rss_enable()
1911 msg->t.tcm_info = TC_H_MAKE(0, htons(ETH_P_ALL)); in rss_enable()
1915 msg->t.tcm_info = TC_H_MAKE(prio << 16, msg->t.tcm_info); in rss_enable()
1916 msg->t.tcm_parent = TC_H_MAKE(MULTIQ_MAJOR_HANDLE, 0); in rss_enable()
1918 tap_nlattr_add(&msg->nh, TCA_KIND, sizeof("bpf"), "bpf"); in rss_enable()
1919 if (tap_nlattr_nested_start(msg, TCA_OPTIONS) < 0) in rss_enable()
1921 tap_nlattr_add32(&msg->nh, TCA_BPF_FD, pmd->bpf_fd[i]); in rss_enable()
1924 tap_nlattr_add(&msg->nh, TCA_BPF_NAME, strlen(annotation) + 1, in rss_enable()
1940 tap_nlattr_nested_finish(msg); /* nested TCA_OPTIONS */ in rss_enable()
1943 if (tap_nl_send(pmd->nlsk_fd, &msg->nh) < 0) in rss_enable()