2 * Copyright (c) 2005 The DragonFly Project. All rights reserved.
4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in
12 * the documentation and/or other materials provided with the
14 * 3. Neither the name of The DragonFly Project nor the names of its
15 * contributors may be used to endorse or promote products derived
16 * from this software without specific, prior written permission.
18 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
19 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
20 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
21 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
22 * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
23 * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
24 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
25 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
26 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
27 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
28 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 * $DragonFly: src/sys/net/ifq_var.h,v 1.6 2005/11/28 17:13:45 dillon Exp $
34 * NOTE ON MPSAFE access. Routines which manipulate the packet queue must
35 * be called within a critical section to interlock subsystems based on
36 * the MP lock, and must be holding the interface serializer to interlock
37 * MPSAFE subsystems. Once all subsystems are made MPSAFE, the critical
38 * section will no longer be required.
41 #ifndef _NET_IFQ_VAR_H
42 #define _NET_IFQ_VAR_H
44 #include <sys/thread2.h>
48 ifq_is_enabled(struct ifaltq *_ifq)
50 return(_ifq->altq_flags & ALTQF_ENABLED);
54 ifq_is_attached(struct ifaltq *_ifq)
56 return(_ifq->altq_disc != NULL);
60 ifq_is_enabled(struct ifaltq *_ifq)
66 ifq_is_attached(struct ifaltq *_ifq)
73 * WARNING: Should only be called in an MPSAFE manner.
76 ifq_is_ready(struct ifaltq *_ifq)
78 return(_ifq->altq_flags & ALTQF_READY);
82 * WARNING: Should only be called in an MPSAFE manner.
85 ifq_set_ready(struct ifaltq *_ifq)
87 _ifq->altq_flags |= ALTQF_READY;
91 * WARNING: Should only be called in an MPSAFE manner.
94 ifq_enqueue(struct ifaltq *_ifq, struct mbuf *_m, struct altq_pktattr *_pa)
96 return((*_ifq->altq_enqueue)(_ifq, _m, _pa));
100 * WARNING: Should only be called in an MPSAFE manner.
102 static __inline struct mbuf *
103 ifq_dequeue(struct ifaltq *_ifq, struct mbuf *_mpolled)
106 if (_ifq->altq_tbr != NULL)
107 return(tbr_dequeue(_ifq, _mpolled, ALTDQ_REMOVE));
109 return((*_ifq->altq_dequeue)(_ifq, _mpolled, ALTDQ_REMOVE));
113 * WARNING: Should only be called in an MPSAFE manner.
115 static __inline struct mbuf *
116 ifq_poll(struct ifaltq *_ifq)
119 if (_ifq->altq_tbr != NULL)
120 return(tbr_dequeue(_ifq, NULL, ALTDQ_POLL));
122 return((*_ifq->altq_dequeue)(_ifq, NULL, ALTDQ_POLL));
126 * WARNING: Should only be called in an MPSAFE manner.
129 ifq_purge(struct ifaltq *_ifq)
131 (*_ifq->altq_request)(_ifq, ALTRQ_PURGE, NULL);
135 * WARNING: Should only be called in an MPSAFE manner.
138 ifq_classify(struct ifaltq *_ifq, struct mbuf *_m, uint8_t _af,
139 struct altq_pktattr *_pa)
141 if (!ifq_is_enabled(_ifq))
144 _pa->pattr_hdr = mtod(_m, caddr_t);
145 if (_ifq->altq_flags & ALTQF_CLASSIFY)
146 (*_ifq->altq_classify)(_ifq, _m, _pa);
150 * Hand a packet to an interface.
152 * For subsystems protected by the MP lock, access to the queue is protected
153 * by a critical section.
155 * For MPSAFE subsystems and drivers, access to the queue is protected by
156 * the ifnet serializer.
159 ifq_handoff(struct ifnet *_ifp, struct mbuf *_m, struct altq_pktattr *_pa)
163 ASSERT_SERIALIZED(_ifp->if_serializer);
164 _error = ifq_enqueue(&_ifp->if_snd, _m, _pa);
166 _ifp->if_obytes += _m->m_pkthdr.len;
167 if (_m->m_flags & M_MCAST)
169 if ((_ifp->if_flags & IFF_OACTIVE) == 0)
170 (*_ifp->if_start)(_ifp);
176 ifq_is_empty(struct ifaltq *_ifq)
178 return(_ifq->ifq_len == 0);
182 ifq_set_maxlen(struct ifaltq *_ifq, int _len)
184 _ifq->ifq_maxlen = _len;
187 void ifq_set_classic(struct ifaltq *);