src/network/tc/hhf.c

   1 /* SPDX-License-Identifier: LGPL-2.1-or-later
   2  * Copyright © 2020 VMware, Inc. */
   3
   4 #include <linux/pkt_sched.h>
   5
   6 #include "alloc-util.h"
   7 #include "conf-parser.h"
   8 #include "hhf.h"
   9 #include "netlink-util.h"
  10 #include "parse-util.h"
  11 #include "string-util.h"
  12 #include "util.h"
  13
  14 static int heavy_hitter_filter_fill_message(Link *link, QDisc *qdisc, sd_netlink_message *req) {
  15         HeavyHitterFilter *hhf;
  16         int r;
  17
  18         assert(link);
  19         assert(qdisc);
  20         assert(req);
  21
  22         hhf = HHF(qdisc);
  23
  24         r = sd_netlink_message_open_container_union(req, TCA_OPTIONS, "hhf");
  25         if (r < 0)
  26                 return log_link_error_errno(link, r, "Could not open container TCA_OPTIONS: %m");
  27
  28         if (hhf->packet_limit > 0) {
  29                 r = sd_netlink_message_append_u32(req, TCA_HHF_BACKLOG_LIMIT, hhf->packet_limit);
  30                 if (r < 0)
  31                         return log_link_error_errno(link, r, "Could not append TCA_HHF_BACKLOG_LIMIT attribute: %m");
  32         }
  33
  34        r = sd_netlink_message_close_container(req);
  35         if (r < 0)
  36                 return log_link_error_errno(link, r, "Could not close container TCA_OPTIONS: %m");
  37
  38         return 0;
  39 }
  40
  41 int config_parse_heavy_hitter_filter_packet_limit(
  42                 const char *unit,
  43                 const char *filename,
  44                 unsigned line,
  45                 const char *section,
  46                 unsigned section_line,
  47                 const char *lvalue,
  48                 int ltype,
  49                 const char *rvalue,
  50                 void *data,
  51                 void *userdata) {
  52
  53         _cleanup_(qdisc_free_or_set_invalidp) QDisc *qdisc = NULL;
  54         HeavyHitterFilter *hhf;
  55         Network *network = data;
  56         int r;
  57
  58         assert(filename);
  59         assert(lvalue);
  60         assert(rvalue);
  61         assert(data);
  62
  63         r = qdisc_new_static(QDISC_KIND_HHF, network, filename, section_line, &qdisc);
  64         if (r == -ENOMEM)
  65                 return log_oom();
  66         if (r < 0) {
  67                 log_syntax(unit, LOG_WARNING, filename, line, r,
  68                            "More than one kind of queueing discipline, ignoring assignment: %m");
  69                 return 0;
  70         }
  71
  72         hhf = HHF(qdisc);
  73
  74         if (isempty(rvalue)) {
  75                 hhf->packet_limit = 0;
  76
  77                 qdisc = NULL;
  78                 return 0;
  79         }
  80
  81         r = safe_atou32(rvalue, &hhf->packet_limit);
  82         if (r < 0) {
  83                 log_syntax(unit, LOG_WARNING, filename, line, r,
  84                            "Failed to parse '%s=', ignoring assignment: %s",
  85                            lvalue, rvalue);
  86                 return 0;
  87         }
  88
  89         qdisc = NULL;
  90
  91         return 0;
  92 }
  93
  94 const QDiscVTable hhf_vtable = {
  95         .object_size = sizeof(HeavyHitterFilter),
  96         .tca_kind = "hhf",
  97         .fill_message = heavy_hitter_filter_fill_message,
  98 };