summaryrefslogtreecommitdiff
path: root/sys/altq/altq_wfq.h
blob: 15266e33e834cf7c8e86b248c5783e3a66aa2393 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
/*	$NetBSD: altq_wfq.h,v 1.6 2008/09/11 17:58:59 joerg Exp $	*/
/*	$KAME: altq_wfq.h,v 1.8 2003/07/10 12:07:49 kjc Exp $	*/

/*
 * Copyright (C) 1997-2002
 *	Sony Computer Science Laboratories Inc.  All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY SONY CSL AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL SONY CSL OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */
/*
 *  March 27, 1997.  Written by Hiroshi Kyusojin of Keio University
 *  (kyu@mt.cs.keio.ac.jp).
 */

#ifndef _ALTQ_ALTQ_WFQ_H_
#define	_ALTQ_ALTQ_WFQ_H_

#include <altq/altq.h>

#define	DEFAULT_QSIZE	256
#define	MAX_QSIZE	2048

struct wfq_interface{
	char wfq_ifacename[IFNAMSIZ];
};

struct wfq_getqid{
	struct wfq_interface 	iface;
#ifdef ALTQ3_CLFIER_COMPAT
	struct flowinfo 	flow;
#endif
	u_long			qid;
};

struct wfq_setweight {
	struct wfq_interface	iface;
	int 			qid;
	int 			weight;
};

typedef struct each_queue_stats {
	int bytes;		/* bytes in this queue */
	int weight;		/* weight in percent */
	struct pktcntr xmit_cnt;
	struct pktcntr drop_cnt;
} queue_stats;

struct wfq_getstats {
	struct wfq_interface	iface;
	int			qid;
	queue_stats		stats;
};

struct wfq_conf {
	struct wfq_interface	iface;
	int			hash_policy;	/* hash policy */
	int			nqueues;	/* number of queues */
	int			qlimit;		/* queue size in bytes */
};

#define	WFQ_HASH_DSTADDR	0	/* hash by dst address */
#define	WFQ_HASH_SRCPORT	1	/* hash by src port */
#define	WFQ_HASH_FULL		2	/* hash by all fields */
#define	WFQ_HASH_SRCADDR	3	/* hash by src address */

#define	WFQ_IF_ATTACH		_IOW('Q', 1, struct wfq_interface)
#define	WFQ_IF_DETACH		_IOW('Q', 2, struct wfq_interface)
#define	WFQ_ENABLE		_IOW('Q', 3, struct wfq_interface)
#define	WFQ_DISABLE		_IOW('Q', 4, struct wfq_interface)
#define	WFQ_CONFIG		_IOWR('Q', 6, struct wfq_conf)
#define	WFQ_GET_STATS		_IOWR('Q', 12, struct wfq_getstats)
#define	WFQ_GET_QID		_IOWR('Q', 30, struct wfq_getqid)
#define	WFQ_SET_WEIGHT		_IOWR('Q', 31, struct wfq_setweight)

#ifdef _KERNEL

#define	HWM			(64 * 1024)
#define	WFQ_QUOTA		512	/* quota bytes to send at a time */
#define	WFQ_ADDQUOTA(q)		((q)->quota += WFQ_QUOTA * (q)->weight / 100)
#define	ENABLE			0
#define	DISABLE			1

typedef struct weighted_fair_queue{
	struct weighted_fair_queue *next, *prev;
	struct mbuf *head, *tail;
	int bytes;			/* bytes in this queue */
	int quota;			/* bytes sent in this round */
	int weight;			/* weight in percent */

	struct pktcntr xmit_cnt;
	struct pktcntr drop_cnt;
} wfq;


typedef struct wfqstate {
	struct wfqstate *next;		/* for wfqstate list */
	struct ifaltq *ifq;
	int nums;			/* number of queues */
	int hwm;			/* high water mark */
	int bytes;			/* total bytes in all the queues */
	wfq *rrp;			/* round robin pointer */
	wfq *queue;			/* pointer to queue list */
#ifdef ALTQ3_CLFIER_COMPAT
	u_long (*hash_func)(struct flowinfo *, int);
#endif
	u_int32_t fbmask;		/* filter bitmask */
} wfq_state_t;

#endif /* _KERNEL */

#endif /* _ALTQ_ALTQ_WFQ_H */