rxmit_queue.h
上传用户:rrhhcc
上传日期:2015-12-11
资源大小:54129k
文件大小:3k
源码类别:

通讯编程

开发平台:

Visual C++

  1. /* -*-  Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
  2. /*
  3.  * Copyright (c) 1997 Regents of the University of California.
  4.  * All rights reserved.
  5.  *
  6.  * Redistribution and use in source and binary forms, with or without
  7.  * modification, are permitted provided that the following conditions
  8.  * are met:
  9.  * 1. Redistributions of source code must retain the above copyright
  10.  *    notice, this list of conditions and the following disclaimer.
  11.  * 2. Redistributions in binary form must reproduce the above copyright
  12.  *    notice, this list of conditions and the following disclaimer in the
  13.  *    documentation and/or other materials provided with the distribution.
  14.  * 3. All advertising materials mentioning features or use of this software
  15.  *    must display the following acknowledgement:
  16.  *      This product includes software developed by the Computer Systems
  17.  *      Engineering Group at Lawrence Berkeley Laboratory.
  18.  * 4. Neither the name of the University nor of the Laboratory may be used
  19.  *    to endorse or promote products derived from this software without
  20.  *    specific prior written permission.
  21.  *
  22.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  23.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  24.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  25.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  26.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  27.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  28.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  29.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  31.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  32.  * SUCH DAMAGE.
  33.  */
  34. /* Ported from CMU/Monarch's code*/
  35. /* -*- c++ -*-
  36.    rexmit_queue.h
  37.    $Id: rxmit_queue.h,v 1.4 2002/05/06 22:23:15 difa Exp $
  38.    */
  39. #ifndef imep_rexmit_queue_h
  40. #define imep_rexmit_queue_h
  41. #include <packet.h>
  42. #include "lib/bsd-list.h"
  43. typedef double Time;
  44. struct rexent {
  45.   double rexmit_at;
  46.   int rexmits_left;
  47.   Packet *p;
  48.   LIST_ENTRY(struct rexent) next;
  49. };
  50. LIST_HEAD(rexent_head, rexent);
  51. class ReXmitQ;
  52. class ReXmitQIter {
  53.   friend class ReXmitQ;
  54.   
  55. public:
  56.   inline Packet * next() {
  57.     if (0 == iter) return 0;
  58.     struct rexent *t = iter;
  59.     iter = iter->next.le_next;
  60.     return t->p;
  61.   }
  62.   
  63. private:
  64.   ReXmitQIter(rexent *r) : iter(r) {};
  65.   struct rexent * iter;
  66. };
  67. class ReXmitQ {
  68. public:
  69.   ReXmitQ();
  70.   
  71.   void insert(Time rxat, Packet *p, int num_rexmits);
  72.   void peekHead(Time *rxat, Packet **pp, int *rexmits_left);
  73.   void removeHead();
  74.   void remove(Packet *p);
  75.   inline ReXmitQIter iter() {
  76.     return ReXmitQIter(head.lh_first); 
  77.   }
  78. private:
  79.   rexent_head head;
  80. };
  81. #endif