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

通讯编程

开发平台:

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 Daedalus Research
  17.  * Group at the University of California Berkeley.
  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.  * Contributed by the Daedalus Research Group, UC Berkeley 
  35.  * (http://daedalus.cs.berkeley.edu)
  36.  *
  37.  * Multi-state error model patches contributed by Jianping Pan 
  38.  * (jpan@bbcr.uwaterloo.ca).
  39.  *
  40.  * @(#) $Header: /cvsroot/nsnam/ns-2/queue/fec.cc,v 1.1 2001/03/07 18:30:02 jahn Exp $ (UCB)
  41.  */
  42. #ifndef lint
  43. static const char rcsid[] =
  44.     "@(#) $Header: /cvsroot/nsnam/ns-2/queue/fec.cc,v 1.1 2001/03/07 18:30:02 jahn Exp $ (UCB)";
  45. #endif
  46. #include "config.h"
  47. #include <stdio.h>
  48. #include <ctype.h>
  49. #include "packet.h"
  50. #include "flags.h"
  51. #include "mcast_ctrl.h"
  52. #include "fec.h"
  53. #include "srm-headers.h" // to get the hdr_srm structure
  54. #include "classifier.h"
  55. static class FECModelClass : public TclClass {
  56. public:
  57. FECModelClass() : TclClass("FECModel") {}
  58. TclObject* create(int, const char*const*) {
  59. return (new FECModel);
  60. }
  61. } class_fecmodel;
  62. FECModel::FECModel() : firstTime_(1), FECstrength_(1) 
  63. {
  64. }
  65. int FECModel::command(int argc, const char*const* argv)
  66. {
  67. Tcl& tcl = Tcl::instance();
  68. if (argc == 3) {
  69. if (strcmp(argv[1], "FECstrength") == 0) {
  70. FECstrength_ = atoi(argv[2]);
  71. return (TCL_OK);
  72. }
  73. } else if (argc == 2) {
  74. if (strcmp(argv[1], "FECstrength") == 0) {
  75. tcl.resultf("%d", FECstrength_);
  76. return (TCL_OK);
  77. }
  78. return BiConnector::command(argc, argv);
  79. }
  80. int fix_ = 0;
  81. void FECModel::recv(Packet* p, Handler* h)
  82. {
  83. hdr_cmn* ch = hdr_cmn::access(p);
  84. if(ch->direction() == hdr_cmn::DOWN) {
  85. addfec(p);
  86. downtarget_->recv(p, h);
  87. return;
  88. } else {
  89. if(ch->errbitcnt() > FECstrength_) {
  90. Packet::free(p);
  91. return;
  92. } else if (ch->errbitcnt() && (ch->errbitcnt() <= FECstrength_)) {
  93. ch->errbitcnt() = 0;
  94. ch->error() = 0;
  95. printf("FEC: %d fixedn", fix_++);
  96. }
  97. subfec(p);
  98. uptarget_->recv(p, h);
  99. }
  100. }
  101. void FECModel::addfec(Packet* p)
  102. {
  103. int bit = hdr_cmn::access(p)->size() * 8;
  104. FECbyte_ = (int)(log(bit) / log(2));
  105. FECbyte_ *= FECstrength_;
  106. FECbyte_ = (FECbyte_ + 7) / 8;
  107. // firstTime_ = 0;
  108.         // printf("FEC Down = %d n", hdr_cmn::access(p)->size());
  109. hdr_cmn::access(p)->size() += FECbyte_;
  110. hdr_cmn::access(p)->fecsize() = FECbyte_;
  111. }
  112. void FECModel::subfec(Packet* p)
  113. {
  114. FECbyte_ = hdr_cmn::access(p)->fecsize();
  115. hdr_cmn::access(p)->size() -= FECbyte_;
  116.         // printf("FEC Up = %d n", hdr_cmn::access(p)->size());
  117. }