Home
last modified time | relevance | path

Searched refs:req (Results 1 – 25 of 78) sorted by relevance

1234

/systemd-251/src/network/
Dnetworkd-queue.c10 static Request *request_free(Request *req) { in request_free() argument
11 if (!req) in request_free()
16 if (req->manager) in request_free()
17 ordered_set_remove(req->manager->request_queue, req); in request_free()
19 if (req->free_func) in request_free()
20 req->free_func(req->userdata); in request_free()
22 if (req->counter) in request_free()
23 (*req->counter)--; in request_free()
25 link_unref(req->link); /* link may be NULL, but link_unref() can handle it gracefully. */ in request_free()
27 return mfree(req); in request_free()
[all …]
Dnetworkd-setlink.c40 Request *req, in set_link_handler_internal() argument
48 assert(req); in set_link_handler_internal()
55 …error_msg = strjoina("Failed to set ", request_type_to_string(req->type), ignore ? ", ignoring" : … in set_link_handler_internal()
63 log_link_debug(link, "%s set.", request_type_to_string(req->type)); in set_link_handler_internal()
79 static int link_set_addrgen_mode_handler(sd_netlink *rtnl, sd_netlink_message *m, Request *req, Lin… in link_set_addrgen_mode_handler() argument
82 r = set_link_handler_internal(rtnl, m, req, link, /* ignore = */ true, NULL); in link_set_addrgen_mode_handler()
95 static int link_set_bond_handler(sd_netlink *rtnl, sd_netlink_message *m, Request *req, Link *link,… in link_set_bond_handler() argument
96 return set_link_handler_internal(rtnl, m, req, link, /* ignore = */ false, NULL); in link_set_bond_handler()
99 static int link_set_bridge_handler(sd_netlink *rtnl, sd_netlink_message *m, Request *req, Link *lin… in link_set_bridge_handler() argument
100 return set_link_handler_internal(rtnl, m, req, link, /* ignore = */ true, NULL); in link_set_bridge_handler()
[all …]
Dnetworkd-manager.c651 sd_netlink_message *req, in manager_enumerate_internal() argument
659 assert(req); in manager_enumerate_internal()
662 r = sd_netlink_message_request_dump(req, true); in manager_enumerate_internal()
666 r = sd_netlink_call(nl, req, 0, &reply); in manager_enumerate_internal()
682 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL; in manager_enumerate_links()
688 r = sd_rtnl_message_new_link(m->rtnl, &req, RTM_GETLINK, 0); in manager_enumerate_links()
692 return manager_enumerate_internal(m, m->rtnl, req, manager_rtnl_process_link); in manager_enumerate_links()
696 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL; in manager_enumerate_qdisc()
702 r = sd_rtnl_message_new_traffic_control(m->rtnl, &req, RTM_GETQDISC, 0, 0, 0); in manager_enumerate_qdisc()
706 return manager_enumerate_internal(m, m->rtnl, req, manager_rtnl_process_qdisc); in manager_enumerate_qdisc()
[all …]
Dnetworkd-bridge-fdb.c96 static int bridge_fdb_configure_handler(sd_netlink *rtnl, sd_netlink_message *m, Request *req, Link… in bridge_fdb_configure_handler() argument
119 static int bridge_fdb_configure_message(const BridgeFDB *fdb, Link *link, sd_netlink_message *req) { in bridge_fdb_configure_message() argument
125 r = sd_rtnl_message_neigh_set_flags(req, fdb->ntf_flags); in bridge_fdb_configure_message()
130 r = sd_rtnl_message_neigh_set_state(req, NUD_NOARP | NUD_PERMANENT); in bridge_fdb_configure_message()
134 r = sd_netlink_message_append_data(req, NDA_LLADDR, &fdb->mac_addr, sizeof(fdb->mac_addr)); in bridge_fdb_configure_message()
140 r = sd_netlink_message_append_u16(req, NDA_VLAN, fdb->vlan_id); in bridge_fdb_configure_message()
146 r = sd_netlink_message_append_u32(req, NDA_IFINDEX, fdb->outgoing_ifindex); in bridge_fdb_configure_message()
152 … r = netlink_message_append_in_addr_union(req, NDA_DST, fdb->family, &fdb->destination_addr); in bridge_fdb_configure_message()
158 r = sd_netlink_message_append_u32(req, NDA_VNI, fdb->vni); in bridge_fdb_configure_message()
166 static int bridge_fdb_configure(BridgeFDB *fdb, Link *link, Request *req) { in bridge_fdb_configure() argument
[all …]
Dnetworkd-sriov.c9 static int sr_iov_handler(sd_netlink *rtnl, sd_netlink_message *m, Request *req, Link *link, SRIOV … in sr_iov_handler() argument
31 static int sr_iov_configure(SRIOV *sr_iov, Link *link, Request *req) { in sr_iov_configure() argument
40 assert(req); in sr_iov_configure()
52 return request_call_netlink_async(link->manager->rtnl, m, req); in sr_iov_configure()
55 static int sr_iov_process_request(Request *req, Link *link, SRIOV *sr_iov) { in sr_iov_process_request() argument
58 assert(req); in sr_iov_process_request()
65 r = sr_iov_configure(sr_iov, link, req); in sr_iov_process_request()
Dnetworkd-ipv6-proxy-ndp.c32 Request *req, in ipv6_proxy_ndp_address_configure_handler() argument
55 …ic int ipv6_proxy_ndp_address_configure(const struct in6_addr *address, Link *link, Request *req) { in ipv6_proxy_ndp_address_configure() argument
63 assert(req); in ipv6_proxy_ndp_address_configure()
78 return request_call_netlink_async(link->manager->rtnl, m, req); in ipv6_proxy_ndp_address_configure()
81 static int ipv6_proxy_ndp_address_process_request(Request *req, Link *link, struct in6_addr *addres… in ipv6_proxy_ndp_address_process_request() argument
84 assert(req); in ipv6_proxy_ndp_address_process_request()
91 r = ipv6_proxy_ndp_address_configure(address, link, req); in ipv6_proxy_ndp_address_process_request()
Dnetworkd-neighbor.c178 static int neighbor_configure_message(Neighbor *neighbor, Link *link, sd_netlink_message *req) { in neighbor_configure_message() argument
181 r = sd_rtnl_message_neigh_set_state(req, NUD_PERMANENT); in neighbor_configure_message()
185 r = netlink_message_append_hw_addr(req, NDA_LLADDR, &neighbor->ll_addr); in neighbor_configure_message()
189 … r = netlink_message_append_in_addr_union(req, NDA_DST, neighbor->family, &neighbor->in_addr); in neighbor_configure_message()
196 static int neighbor_configure(Neighbor *neighbor, Link *link, Request *req) { in neighbor_configure() argument
205 assert(req); in neighbor_configure()
218 return request_call_netlink_async(link->manager->rtnl, m, req); in neighbor_configure()
221 static int neighbor_process_request(Request *req, Link *link, Neighbor *neighbor) { in neighbor_process_request() argument
224 assert(req); in neighbor_process_request()
231 r = neighbor_configure(neighbor, link, req); in neighbor_process_request()
[all …]
Dnetworkd-queue.h15 typedef int (*request_process_func_t)(Request *req, Link *link, void *userdata);
16 typedef int (*request_netlink_handler_t)(sd_netlink *nl, sd_netlink_message *m, Request *req, Link …
85 Request *request_ref(Request *req);
86 Request *request_unref(Request *req);
89 void request_detach(Manager *manager, Request *req);
137 int request_call_netlink_async(sd_netlink *nl, sd_netlink_message *m, Request *req);
/systemd-251/src/libsystemd-network/
Dsd-dhcp-server.c455 DHCPRequest *req, DHCPPacket *packet, in dhcp_server_send_packet() argument
462 assert(req); in dhcp_server_send_packet()
463 assert(req->max_optlen > 0); in dhcp_server_send_packet()
464 assert(req->message); in dhcp_server_send_packet()
465 assert(optoffset <= req->max_optlen); in dhcp_server_send_packet()
468 r = dhcp_option_append(&packet->dhcp, req->max_optlen, &optoffset, 0, in dhcp_server_send_packet()
474 if (req->agent_info_option) { in dhcp_server_send_packet()
475 size_t opt_full_length = *(req->agent_info_option + 1) + 2; in dhcp_server_send_packet()
477 if (optoffset + opt_full_length < req->max_optlen) { in dhcp_server_send_packet()
478 … memcpy(packet->dhcp.options + optoffset, req->agent_info_option, opt_full_length); in dhcp_server_send_packet()
[all …]
/systemd-251/src/shared/
Dloopback-setup.c46 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL; in start_loopback()
52 r = sd_rtnl_message_new_link(rtnl, &req, RTM_SETLINK, LOOPBACK_IFINDEX); in start_loopback()
56 r = sd_rtnl_message_link_set_flags(req, IFF_UP, IFF_UP); in start_loopback()
60 …r = sd_netlink_call_async(rtnl, NULL, req, generic_handler, NULL, s, LOOPBACK_SETUP_TIMEOUT_USEC, … in start_loopback()
69 _cleanup_(sd_netlink_message_unrefp) sd_netlink_message *req = NULL; in add_ipv4_address()
75 r = sd_rtnl_message_new_addr(rtnl, &req, RTM_NEWADDR, LOOPBACK_IFINDEX, AF_INET); in add_ipv4_address()
79 r = sd_rtnl_message_addr_set_prefixlen(req, 8); in add_ipv4_address()
83 r = sd_rtnl_message_addr_set_flags(req, IFA_F_PERMANENT); in add_ipv4_address()
87 r = sd_rtnl_message_addr_set_scope(req, RT_SCOPE_HOST); in add_ipv4_address()
91 …r = sd_netlink_message_append_in_addr(req, IFA_LOCAL, &(struct in_addr) { .s_addr = htobe32(INADDR… in add_ipv4_address()
[all …]
Dnetif-sriov.c103 int sr_iov_set_netlink_message(SRIOV *sr_iov, sd_netlink_message *req) { in sr_iov_set_netlink_message() argument
107 assert(req); in sr_iov_set_netlink_message()
109 r = sd_netlink_message_open_container(req, IFLA_VFINFO_LIST); in sr_iov_set_netlink_message()
113 r = sd_netlink_message_open_container(req, IFLA_VF_INFO); in sr_iov_set_netlink_message()
123 … r = sd_netlink_message_append_data(req, IFLA_VF_MAC, &ivm, sizeof(struct ifla_vf_mac)); in sr_iov_set_netlink_message()
134 … r = sd_netlink_message_append_data(req, IFLA_VF_SPOOFCHK, &ivs, sizeof(struct ifla_vf_spoofchk)); in sr_iov_set_netlink_message()
145 …r = sd_netlink_message_append_data(req, IFLA_VF_RSS_QUERY_EN, &ivs, sizeof(struct ifla_vf_rss_quer… in sr_iov_set_netlink_message()
156 … r = sd_netlink_message_append_data(req, IFLA_VF_TRUST, &ivt, sizeof(struct ifla_vf_trust)); in sr_iov_set_netlink_message()
167 …r = sd_netlink_message_append_data(req, IFLA_VF_LINK_STATE, &ivl, sizeof(struct ifla_vf_link_state… in sr_iov_set_netlink_message()
180 r = sd_netlink_message_open_container(req, IFLA_VF_VLAN_LIST); in sr_iov_set_netlink_message()
[all …]
/systemd-251/src/network/netdev/
Dbridge.c48 static int netdev_bridge_post_create_message(NetDev *netdev, sd_netlink_message *req) { in netdev_bridge_post_create_message() argument
54 r = sd_netlink_message_open_container(req, IFLA_LINKINFO); in netdev_bridge_post_create_message()
58 …r = sd_netlink_message_open_container_union(req, IFLA_INFO_DATA, netdev_kind_to_string(netdev->kin… in netdev_bridge_post_create_message()
64 … r = sd_netlink_message_append_u32(req, IFLA_BR_FORWARD_DELAY, usec_to_jiffies(b->forward_delay)); in netdev_bridge_post_create_message()
70 … r = sd_netlink_message_append_u32(req, IFLA_BR_HELLO_TIME, usec_to_jiffies(b->hello_time)); in netdev_bridge_post_create_message()
76 … r = sd_netlink_message_append_u32(req, IFLA_BR_MAX_AGE, usec_to_jiffies(b->max_age)); in netdev_bridge_post_create_message()
82 … r = sd_netlink_message_append_u32(req, IFLA_BR_AGEING_TIME, usec_to_jiffies(b->ageing_time)); in netdev_bridge_post_create_message()
88 r = sd_netlink_message_append_u16(req, IFLA_BR_PRIORITY, b->priority); in netdev_bridge_post_create_message()
94 r = sd_netlink_message_append_u16(req, IFLA_BR_GROUP_FWD_MASK, b->group_fwd_mask); in netdev_bridge_post_create_message()
100 r = sd_netlink_message_append_u16(req, IFLA_BR_VLAN_DEFAULT_PVID, b->default_pvid); in netdev_bridge_post_create_message()
[all …]
Dvlan.c12 static int netdev_vlan_fill_message_create(NetDev *netdev, Link *link, sd_netlink_message *req) { in netdev_vlan_fill_message_create() argument
19 assert(req); in netdev_vlan_fill_message_create()
25 r = sd_netlink_message_append_u16(req, IFLA_VLAN_ID, v->id); in netdev_vlan_fill_message_create()
30 r = sd_netlink_message_append_u16(req, IFLA_VLAN_PROTOCOL, htobe16(v->protocol)); in netdev_vlan_fill_message_create()
55 … r = sd_netlink_message_append_data(req, IFLA_VLAN_FLAGS, &flags, sizeof(struct ifla_vlan_flags)); in netdev_vlan_fill_message_create()
62 r = sd_netlink_message_open_container(req, IFLA_VLAN_EGRESS_QOS); in netdev_vlan_fill_message_create()
67 …r = sd_netlink_message_append_data(req, IFLA_VLAN_QOS_MAPPING, m, sizeof(struct ifla_vlan_qos_mapp… in netdev_vlan_fill_message_create()
72 r = sd_netlink_message_close_container(req); in netdev_vlan_fill_message_create()
80 r = sd_netlink_message_open_container(req, IFLA_VLAN_INGRESS_QOS); in netdev_vlan_fill_message_create()
85 …r = sd_netlink_message_append_data(req, IFLA_VLAN_QOS_MAPPING, m, sizeof(struct ifla_vlan_qos_mapp… in netdev_vlan_fill_message_create()
[all …]
Dmacvlan.c15 static int netdev_macvlan_fill_message_create(NetDev *netdev, Link *link, sd_netlink_message *req) { in netdev_macvlan_fill_message_create() argument
34 … r = sd_netlink_message_append_u32(req, IFLA_MACVLAN_MACADDR_MODE, MACVLAN_MACADDR_SET); in netdev_macvlan_fill_message_create()
38 r = sd_netlink_message_open_container(req, IFLA_MACVLAN_MACADDR_DATA); in netdev_macvlan_fill_message_create()
43 … r = sd_netlink_message_append_ether_addr(req, IFLA_MACVLAN_MACADDR, mac_addr); in netdev_macvlan_fill_message_create()
48 r = sd_netlink_message_close_container(req); in netdev_macvlan_fill_message_create()
54 r = sd_netlink_message_append_u32(req, IFLA_MACVLAN_MODE, m->mode); in netdev_macvlan_fill_message_create()
61 r = sd_netlink_message_append_u16(req, IFLA_MACVLAN_FLAGS, MACVLAN_FLAG_NOPROMISC); in netdev_macvlan_fill_message_create()
67 … r = sd_netlink_message_append_u32(req, IFLA_MACVLAN_BC_QUEUE_LEN, m->bc_queue_length); in netdev_macvlan_fill_message_create()
/systemd-251/src/home/
Dhomework-quota.c40 struct dqblk req; in home_update_quota_classic() local
57 r = quotactl_devnum(QCMD_FIXED(Q_GETQUOTA, USRQUOTA), devno, h->uid, &req); in home_update_quota_classic()
65 zero(req); in home_update_quota_classic()
68 … if (FLAGS_SET(req.dqb_valid, QIF_BLIMITS) && h->disk_size / QIF_DQBLKSIZE == req.dqb_bhardlimit) { in home_update_quota_classic()
74 req.dqb_valid = QIF_BLIMITS; in home_update_quota_classic()
75 req.dqb_bsoftlimit = req.dqb_bhardlimit = h->disk_size / QIF_DQBLKSIZE; in home_update_quota_classic()
77 r = quotactl_devnum(QCMD_FIXED(Q_SETQUOTA, USRQUOTA), devno, h->uid, &req); in home_update_quota_classic()
/systemd-251/src/network/tc/
Dfq.c27 static int fair_queueing_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in fair_queueing_fill_message() argument
33 assert(req); in fair_queueing_fill_message()
37 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "fq"); in fair_queueing_fill_message()
42 r = sd_netlink_message_append_u32(req, TCA_FQ_PLIMIT, fq->packet_limit); in fair_queueing_fill_message()
48 r = sd_netlink_message_append_u32(req, TCA_FQ_FLOW_PLIMIT, fq->flow_limit); in fair_queueing_fill_message()
54 r = sd_netlink_message_append_u32(req, TCA_FQ_QUANTUM, fq->quantum); in fair_queueing_fill_message()
60 r = sd_netlink_message_append_u32(req, TCA_FQ_INITIAL_QUANTUM, fq->initial_quantum); in fair_queueing_fill_message()
66 r = sd_netlink_message_append_u32(req, TCA_FQ_RATE_ENABLE, fq->pacing); in fair_queueing_fill_message()
72 r = sd_netlink_message_append_u32(req, TCA_FQ_FLOW_MAX_RATE, fq->max_rate); in fair_queueing_fill_message()
81 r = sd_netlink_message_append_u32(req, TCA_FQ_BUCKETS_LOG, l); in fair_queueing_fill_message()
[all …]
Dfq-codel.c28 …nt fair_queueing_controlled_delay_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in fair_queueing_controlled_delay_fill_message() argument
34 assert(req); in fair_queueing_controlled_delay_fill_message()
38 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "fq_codel"); in fair_queueing_controlled_delay_fill_message()
43 r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_LIMIT, fqcd->packet_limit); in fair_queueing_controlled_delay_fill_message()
49 r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_FLOWS, fqcd->flows); in fair_queueing_controlled_delay_fill_message()
55 r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_QUANTUM, fqcd->quantum); in fair_queueing_controlled_delay_fill_message()
61 r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_INTERVAL, fqcd->interval_usec); in fair_queueing_controlled_delay_fill_message()
67 r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_TARGET, fqcd->target_usec); in fair_queueing_controlled_delay_fill_message()
73 r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_ECN, fqcd->ecn); in fair_queueing_controlled_delay_fill_message()
79 … r = sd_netlink_message_append_u32(req, TCA_FQ_CODEL_CE_THRESHOLD, fqcd->ce_threshold_usec); in fair_queueing_controlled_delay_fill_message()
[all …]
Dets.c16 …t enhanced_transmission_selection_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in enhanced_transmission_selection_fill_message() argument
22 assert(req); in enhanced_transmission_selection_fill_message()
26 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "ets"); in enhanced_transmission_selection_fill_message()
30 r = sd_netlink_message_append_u8(req, TCA_ETS_NBANDS, ets->n_bands); in enhanced_transmission_selection_fill_message()
35 r = sd_netlink_message_append_u8(req, TCA_ETS_NSTRICT, ets->n_strict); in enhanced_transmission_selection_fill_message()
41 r = sd_netlink_message_open_container(req, TCA_ETS_QUANTA); in enhanced_transmission_selection_fill_message()
46 r = sd_netlink_message_append_u32(req, TCA_ETS_QUANTA_BAND, ets->quanta[i]); in enhanced_transmission_selection_fill_message()
51 r = sd_netlink_message_close_container(req); in enhanced_transmission_selection_fill_message()
57 r = sd_netlink_message_open_container(req, TCA_ETS_PRIOMAP); in enhanced_transmission_selection_fill_message()
62 r = sd_netlink_message_append_u8(req, TCA_ETS_PRIOMAP_BAND, ets->prio[i]); in enhanced_transmission_selection_fill_message()
[all …]
Dcodel.c26 static int controlled_delay_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in controlled_delay_fill_message() argument
32 assert(req); in controlled_delay_fill_message()
36 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "codel"); in controlled_delay_fill_message()
41 r = sd_netlink_message_append_u32(req, TCA_CODEL_LIMIT, cd->packet_limit); in controlled_delay_fill_message()
47 r = sd_netlink_message_append_u32(req, TCA_CODEL_INTERVAL, cd->interval_usec); in controlled_delay_fill_message()
53 r = sd_netlink_message_append_u32(req, TCA_CODEL_TARGET, cd->target_usec); in controlled_delay_fill_message()
59 r = sd_netlink_message_append_u32(req, TCA_CODEL_ECN, cd->ecn); in controlled_delay_fill_message()
65 … r = sd_netlink_message_append_u32(req, TCA_CODEL_CE_THRESHOLD, cd->ce_threshold_usec); in controlled_delay_fill_message()
70 r = sd_netlink_message_close_container(req); in controlled_delay_fill_message()
Dcake.c34 static int cake_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in cake_fill_message() argument
40 assert(req); in cake_fill_message()
44 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "cake"); in cake_fill_message()
49 r = sd_netlink_message_append_u64(req, TCA_CAKE_BASE_RATE64, c->bandwidth); in cake_fill_message()
55 r = sd_netlink_message_append_u32(req, TCA_CAKE_AUTORATE, c->autorate); in cake_fill_message()
61 r = sd_netlink_message_append_s32(req, TCA_CAKE_OVERHEAD, c->overhead); in cake_fill_message()
67 r = sd_netlink_message_append_u32(req, TCA_CAKE_MPU, c->mpu); in cake_fill_message()
73 r = sd_netlink_message_append_u32(req, TCA_CAKE_ATM, c->compensation_mode); in cake_fill_message()
80 r = sd_netlink_message_append_u32(req, TCA_CAKE_RAW, 0); in cake_fill_message()
86 r = sd_netlink_message_append_u32(req, TCA_CAKE_FLOW_MODE, c->flow_isolation_mode); in cake_fill_message()
[all …]
Dhtb.c18 static int hierarchy_token_bucket_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in hierarchy_token_bucket_fill_message() argument
24 assert(req); in hierarchy_token_bucket_fill_message()
34 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "htb"); in hierarchy_token_bucket_fill_message()
38 r = sd_netlink_message_append_data(req, TCA_HTB_INIT, &opt, sizeof(opt)); in hierarchy_token_bucket_fill_message()
42 r = sd_netlink_message_close_container(req); in hierarchy_token_bucket_fill_message()
173 …nt hierarchy_token_bucket_class_fill_message(Link *link, TClass *tclass, sd_netlink_message *req) { in hierarchy_token_bucket_class_fill_message() argument
180 assert(req); in hierarchy_token_bucket_class_fill_message()
209 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "htb"); in hierarchy_token_bucket_class_fill_message()
213 r = sd_netlink_message_append_data(req, TCA_HTB_PARMS, &opt, sizeof(opt)); in hierarchy_token_bucket_class_fill_message()
218 r = sd_netlink_message_append_u64(req, TCA_HTB_RATE64, htb->rate); in hierarchy_token_bucket_class_fill_message()
[all …]
Dtbf.c18 static int token_bucket_filter_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in token_bucket_filter_fill_message() argument
25 assert(req); in token_bucket_filter_fill_message()
68 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "tbf"); in token_bucket_filter_fill_message()
72 r = sd_netlink_message_append_data(req, TCA_TBF_PARMS, &opt, sizeof(opt)); in token_bucket_filter_fill_message()
76 r = sd_netlink_message_append_data(req, TCA_TBF_BURST, &tbf->burst, sizeof(tbf->burst)); in token_bucket_filter_fill_message()
81 r = sd_netlink_message_append_u64(req, TCA_TBF_RATE64, tbf->rate); in token_bucket_filter_fill_message()
86 r = sd_netlink_message_append_data(req, TCA_TBF_RTAB, rtab, sizeof(rtab)); in token_bucket_filter_fill_message()
92 r = sd_netlink_message_append_u64(req, TCA_TBF_PRATE64, tbf->peak_rate); in token_bucket_filter_fill_message()
97 r = sd_netlink_message_append_u32(req, TCA_TBF_PBURST, tbf->mtu); in token_bucket_filter_fill_message()
101 r = sd_netlink_message_append_data(req, TCA_TBF_PTAB, ptab, sizeof(ptab)); in token_bucket_filter_fill_message()
[all …]
Dhhf.c14 static int heavy_hitter_filter_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in heavy_hitter_filter_fill_message() argument
20 assert(req); in heavy_hitter_filter_fill_message()
24 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "hhf"); in heavy_hitter_filter_fill_message()
29 r = sd_netlink_message_append_u32(req, TCA_HHF_BACKLOG_LIMIT, hhf->packet_limit); in heavy_hitter_filter_fill_message()
34 r = sd_netlink_message_close_container(req); in heavy_hitter_filter_fill_message()
Dpie.c13 static int pie_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) { in pie_fill_message() argument
19 assert(req); in pie_fill_message()
23 r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "pie"); in pie_fill_message()
28 r = sd_netlink_message_append_u32(req, TCA_PIE_LIMIT, pie->packet_limit); in pie_fill_message()
33 r = sd_netlink_message_close_container(req); in pie_fill_message()
/systemd-251/src/resolve/
Dtest-dnssec-complex.c38 _cleanup_(sd_bus_message_unrefp) sd_bus_message *req = NULL, *reply = NULL; in test_rr_lookup()
51 &req, in test_rr_lookup()
57 … assert_se(sd_bus_message_append(req, "isqqt", 0, name, DNS_CLASS_IN, type, UINT64_C(0)) >= 0); in test_rr_lookup()
59 r = sd_bus_call(bus, req, SD_RESOLVED_QUERY_TIMEOUT_USEC, &error, &reply); in test_rr_lookup()
72 _cleanup_(sd_bus_message_unrefp) sd_bus_message *req = NULL, *reply = NULL; in test_hostname_lookup()
88 &req, in test_hostname_lookup()
94 assert_se(sd_bus_message_append(req, "isit", 0, name, family, UINT64_C(0)) >= 0); in test_hostname_lookup()
96 r = sd_bus_call(bus, req, SD_RESOLVED_QUERY_TIMEOUT_USEC, &error, &reply); in test_hostname_lookup()

1234