xnu-3789.60.24.tar.gz

[apple/xnu.git] / bsd / net / classq / classq.h

diff --git a/bsd/net/classq/classq.h b/bsd/net/classq/classq.h
index b9705acb70a486563632308a0f846487bd5bef86..750ce545248b8074a84467677e91bfcd6868989a 100644 (file)
--- a/bsd/net/classq/classq.h
+++ b/bsd/net/classq/classq.h
@@ -1,5 +1,5 @@
 /*
 /*

- * Copyright (c) 2007-2012 Apple Inc. All rights reserved.
+ * Copyright (c) 2007-2016 Apple Inc. All rights reserved.

  *
  * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
  *
  *
  * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
  *


@@ -94,6 +94,9 @@ typedef enum classq_state {
 
 #define        DEFAULT_QLIMIT  128 /* default */
 
 
 #define        DEFAULT_QLIMIT  128 /* default */
 

+#define        CLASSQ_DEQUEUE_MAX_PKT_LIMIT    2048
+#define        CLASSQ_DEQUEUE_MAX_BYTE_LIMIT   (1024 * 1024)
+

 /*
  * generic packet counter
  */
 /*
  * generic packet counter
  */


@@ -113,8 +116,8 @@ struct pktcntr {
 typedef struct _class_queue_ {
        MBUFQ_HEAD(mq_head) mbufq;      /* Packet queue */
        u_int32_t       qlen;   /* Queue length (in number of packets) */
 typedef struct _class_queue_ {
        MBUFQ_HEAD(mq_head) mbufq;      /* Packet queue */
        u_int32_t       qlen;   /* Queue length (in number of packets) */

-       u_int32_t       qsize;  /* Approx. queue size (in number of bytes) */

        u_int32_t       qlim;   /* Queue limit (in number of packets*) */
        u_int32_t       qlim;   /* Queue limit (in number of packets*) */

+       u_int64_t       qsize;  /* Approx. queue size (in number of bytes) */

        classq_type_t   qtype;  /* Queue type */
        classq_state_t  qstate; /* Queue state */
 } class_queue_t;
        classq_type_t   qtype;  /* Queue type */
        classq_state_t  qstate; /* Queue state */
 } class_queue_t;


@@ -159,10 +162,12 @@ extern void _addq(class_queue_t *, struct mbuf *);
 extern void _addq_multi(class_queue_t *, struct mbuf *, struct mbuf *,
     u_int32_t, u_int32_t);
 extern struct mbuf *_getq(class_queue_t *);
 extern void _addq_multi(class_queue_t *, struct mbuf *, struct mbuf *,
     u_int32_t, u_int32_t);
 extern struct mbuf *_getq(class_queue_t *);

-extern struct mbuf *_getq_all(class_queue_t *);
+extern struct mbuf *_getq_all(class_queue_t *, struct mbuf **,
+    u_int32_t *, u_int64_t *);

 extern struct mbuf *_getq_tail(class_queue_t *);
 extern struct mbuf *_getq_random(class_queue_t *);
 extern struct mbuf *_getq_flow(class_queue_t *, u_int32_t);
 extern struct mbuf *_getq_tail(class_queue_t *);
 extern struct mbuf *_getq_random(class_queue_t *);
 extern struct mbuf *_getq_flow(class_queue_t *, u_int32_t);

+extern struct mbuf *_getq_scidx_lt(class_queue_t *, u_int32_t);

 extern void _removeq(class_queue_t *, struct mbuf *);
 extern void _flushq(class_queue_t *);
 extern void _flushq_flow(class_queue_t *, u_int32_t, u_int32_t *, u_int32_t *);
 extern void _removeq(class_queue_t *, struct mbuf *);
 extern void _flushq(class_queue_t *);
 extern void _flushq_flow(class_queue_t *, u_int32_t, u_int32_t *, u_int32_t *);