Add missed qdisc arg to tx injector

svpcom · Sep 19, 2024 · 697e4f5 · 697e4f5
1 parent c4c865b
commit 697e4f5
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/wfb_ng/cluster.py b/wfb_ng/cluster.py
@@ -47,6 +47,7 @@ def update_node(node, profile, service_name, link_id, tx_port_base, wlans, srv_c
                  stream_tx = srv_cfg.stream_tx,
                  stream_rx = srv_cfg.stream_rx,
                  tx_port_base = tx_port_base,
+                 fwmark = srv_cfg.fwmark if srv_cfg.use_qdisc else None,
                  rx_fwd = (server_address, srv_cfg.udp_port_auto))
 
         if node not in cluster_nodes:
@@ -131,7 +132,7 @@ def get_allocator(node):
 wfb_rx -f -c {{ attrs['rx_fwd'][0] }} -u {{ attrs['rx_fwd'][1] }} -p {{ attrs['stream_rx'] }} -i {{ attrs['link_id'] }} -R {{ settings.common.tx_rcv_buf_size }} {{ attrs['wlans']|join(' ') }} &
 {% endif %}
 {% if attrs['stream_tx'] != None %}
-wfb_tx -I {{ attrs['tx_port_base'] }} -R {{ settings.common.tx_rcv_buf_size }} {{ attrs['wlans']|join(' ') }} &
+wfb_tx -I {{ attrs['tx_port_base'] }} -R {{ settings.common.tx_rcv_buf_size }} {{ '-Q -P %d' % (attrs['fwmark'],) if attrs['fwmark'] != None else '' }} {{ attrs['wlans']|join(' ') }} &
 {% endif %}
 {% endfor %}