1 1.6 joerg /* $NetBSD: altq_wfq.h,v 1.6 2008/09/11 17:58:59 joerg Exp $ */ 2 1.5 peter /* $KAME: altq_wfq.h,v 1.8 2003/07/10 12:07:49 kjc Exp $ */ 3 1.1 thorpej 4 1.1 thorpej /* 5 1.5 peter * Copyright (C) 1997-2002 6 1.1 thorpej * Sony Computer Science Laboratories Inc. All rights reserved. 7 1.1 thorpej * 8 1.1 thorpej * Redistribution and use in source and binary forms, with or without 9 1.1 thorpej * modification, are permitted provided that the following conditions 10 1.1 thorpej * are met: 11 1.1 thorpej * 1. Redistributions of source code must retain the above copyright 12 1.1 thorpej * notice, this list of conditions and the following disclaimer. 13 1.1 thorpej * 2. Redistributions in binary form must reproduce the above copyright 14 1.1 thorpej * notice, this list of conditions and the following disclaimer in the 15 1.1 thorpej * documentation and/or other materials provided with the distribution. 16 1.1 thorpej * 17 1.1 thorpej * THIS SOFTWARE IS PROVIDED BY SONY CSL AND CONTRIBUTORS ``AS IS'' AND 18 1.1 thorpej * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 19 1.1 thorpej * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 20 1.1 thorpej * ARE DISCLAIMED. IN NO EVENT SHALL SONY CSL OR CONTRIBUTORS BE LIABLE 21 1.1 thorpej * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 22 1.1 thorpej * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 23 1.1 thorpej * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 24 1.1 thorpej * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 25 1.1 thorpej * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 26 1.1 thorpej * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 27 1.1 thorpej * SUCH DAMAGE. 28 1.1 thorpej */ 29 1.1 thorpej /* 30 1.1 thorpej * March 27, 1997. Written by Hiroshi Kyusojin of Keio University 31 1.3 perry * (kyu (at) mt.cs.keio.ac.jp). 32 1.1 thorpej */ 33 1.1 thorpej 34 1.1 thorpej #ifndef _ALTQ_ALTQ_WFQ_H_ 35 1.1 thorpej #define _ALTQ_ALTQ_WFQ_H_ 36 1.1 thorpej 37 1.1 thorpej #include <altq/altq.h> 38 1.1 thorpej 39 1.1 thorpej #define DEFAULT_QSIZE 256 40 1.1 thorpej #define MAX_QSIZE 2048 41 1.1 thorpej 42 1.1 thorpej struct wfq_interface{ 43 1.1 thorpej char wfq_ifacename[IFNAMSIZ]; 44 1.1 thorpej }; 45 1.1 thorpej 46 1.1 thorpej struct wfq_getqid{ 47 1.1 thorpej struct wfq_interface iface; 48 1.5 peter #ifdef ALTQ3_CLFIER_COMPAT 49 1.1 thorpej struct flowinfo flow; 50 1.5 peter #endif 51 1.1 thorpej u_long qid; 52 1.1 thorpej }; 53 1.1 thorpej 54 1.1 thorpej struct wfq_setweight { 55 1.1 thorpej struct wfq_interface iface; 56 1.1 thorpej int qid; 57 1.1 thorpej int weight; 58 1.1 thorpej }; 59 1.1 thorpej 60 1.1 thorpej typedef struct each_queue_stats { 61 1.1 thorpej int bytes; /* bytes in this queue */ 62 1.1 thorpej int weight; /* weight in percent */ 63 1.1 thorpej struct pktcntr xmit_cnt; 64 1.1 thorpej struct pktcntr drop_cnt; 65 1.1 thorpej } queue_stats; 66 1.1 thorpej 67 1.1 thorpej struct wfq_getstats { 68 1.1 thorpej struct wfq_interface iface; 69 1.1 thorpej int qid; 70 1.1 thorpej queue_stats stats; 71 1.1 thorpej }; 72 1.1 thorpej 73 1.1 thorpej struct wfq_conf { 74 1.1 thorpej struct wfq_interface iface; 75 1.1 thorpej int hash_policy; /* hash policy */ 76 1.1 thorpej int nqueues; /* number of queues */ 77 1.1 thorpej int qlimit; /* queue size in bytes */ 78 1.1 thorpej }; 79 1.1 thorpej 80 1.1 thorpej #define WFQ_HASH_DSTADDR 0 /* hash by dst address */ 81 1.1 thorpej #define WFQ_HASH_SRCPORT 1 /* hash by src port */ 82 1.1 thorpej #define WFQ_HASH_FULL 2 /* hash by all fields */ 83 1.6 joerg #define WFQ_HASH_SRCADDR 3 /* hash by src address */ 84 1.1 thorpej 85 1.1 thorpej #define WFQ_IF_ATTACH _IOW('Q', 1, struct wfq_interface) 86 1.1 thorpej #define WFQ_IF_DETACH _IOW('Q', 2, struct wfq_interface) 87 1.1 thorpej #define WFQ_ENABLE _IOW('Q', 3, struct wfq_interface) 88 1.1 thorpej #define WFQ_DISABLE _IOW('Q', 4, struct wfq_interface) 89 1.1 thorpej #define WFQ_CONFIG _IOWR('Q', 6, struct wfq_conf) 90 1.1 thorpej #define WFQ_GET_STATS _IOWR('Q', 12, struct wfq_getstats) 91 1.1 thorpej #define WFQ_GET_QID _IOWR('Q', 30, struct wfq_getqid) 92 1.1 thorpej #define WFQ_SET_WEIGHT _IOWR('Q', 31, struct wfq_setweight) 93 1.1 thorpej 94 1.1 thorpej #ifdef _KERNEL 95 1.1 thorpej 96 1.1 thorpej #define HWM (64 * 1024) 97 1.1 thorpej #define WFQ_QUOTA 512 /* quota bytes to send at a time */ 98 1.1 thorpej #define WFQ_ADDQUOTA(q) ((q)->quota += WFQ_QUOTA * (q)->weight / 100) 99 1.1 thorpej #define ENABLE 0 100 1.1 thorpej #define DISABLE 1 101 1.1 thorpej 102 1.1 thorpej typedef struct weighted_fair_queue{ 103 1.1 thorpej struct weighted_fair_queue *next, *prev; 104 1.1 thorpej struct mbuf *head, *tail; 105 1.1 thorpej int bytes; /* bytes in this queue */ 106 1.1 thorpej int quota; /* bytes sent in this round */ 107 1.1 thorpej int weight; /* weight in percent */ 108 1.1 thorpej 109 1.1 thorpej struct pktcntr xmit_cnt; 110 1.1 thorpej struct pktcntr drop_cnt; 111 1.1 thorpej } wfq; 112 1.1 thorpej 113 1.1 thorpej 114 1.1 thorpej typedef struct wfqstate { 115 1.1 thorpej struct wfqstate *next; /* for wfqstate list */ 116 1.1 thorpej struct ifaltq *ifq; 117 1.1 thorpej int nums; /* number of queues */ 118 1.1 thorpej int hwm; /* high water mark */ 119 1.1 thorpej int bytes; /* total bytes in all the queues */ 120 1.1 thorpej wfq *rrp; /* round robin pointer */ 121 1.1 thorpej wfq *queue; /* pointer to queue list */ 122 1.5 peter #ifdef ALTQ3_CLFIER_COMPAT 123 1.1 thorpej u_long (*hash_func)(struct flowinfo *, int); 124 1.5 peter #endif 125 1.1 thorpej u_int32_t fbmask; /* filter bitmask */ 126 1.1 thorpej } wfq_state_t; 127 1.1 thorpej 128 1.1 thorpej #endif /* _KERNEL */ 129 1.1 thorpej 130 1.1 thorpej #endif /* _ALTQ_ALTQ_WFQ_H */ 131