Byte queue limits

src/point-to-point/model/point-to-point-net-device.cc

 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
 /*
  * Copyright (c) 2007, 2008 University of Washington
  *
  * This program is free software; you can redistribute it and/or modify
  * it under the terms of the GNU General Public License version 2 as
  * published by the Free Software Foundation;
  *
  * This program is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
@@ skipping 323 matching lines @@
         {
           NS_LOG_DEBUG ("The device queue is being started (" << m_queue->GetNPackets () <<
                         " packets and " << m_queue->GetNBytes () << " bytes inside)");
           txq->Start ();
         }
     }
   Ptr<Packet> p = item->GetPacket ();
   m_snifferTrace (p);
   m_promiscSnifferTrace (p);
   TransmitStart (p);
+  if (txq)
+    {
+      // Inform BQL
+      txq->NotifyTransmittedBytes (m_currentPkt->GetSize ());
+    }
 }
 
 bool
 PointToPointNetDevice::Attach (Ptr<PointToPointChannel> ch)
 {
   NS_LOG_FUNCTION (this << &ch);
 
   m_channel = ch;
 
   m_channel->Attach (this);
@@ skipping 230 matching lines @@
   //
   AddHeader (packet, protocolNumber);
 
   m_macTxTrace (packet);
 
   //
   // We should enqueue and dequeue the packet to hit the tracing hooks.
   //
   if (m_queue->Enqueue (Create<QueueItem> (packet)))
     {
+      // Inform BQL
+      if (txq)
+        {
+          txq->NotifyQueuedBytes (packet->GetSize ());
+        }
       //
       // If the channel is ready for transition we send the packet right now
       //·
       if (m_txMachineState == READY)
         {
           packet = m_queue->Dequeue ()->GetPacket ();
           // We have enqueued a packet and dequeued a (possibly different) packet. We
           // need to check if there is still room for another packet only if the queue
           // is in byte mode (the enqueued packet might be larger than the dequeued
           // packet, thus leaving no room for another packet)
           if (txq)
             {
               if (m_queue->GetMode () == Queue::QUEUE_MODE_BYTES &&
                   m_queue->GetNBytes () + m_mtu > m_queue->GetMaxBytes ())
                 {
                   NS_LOG_DEBUG ("The device queue is being stopped (" << m_queue->GetNPackets () <<
                                 " packets and " << m_queue->GetNBytes () << " bytes inside)");
                   txq->Stop ();
                 }
             }
           m_snifferTrace (packet);
           m_promiscSnifferTrace (packet);
-          return TransmitStart (packet);
+          bool ret = TransmitStart (packet);
+          if (txq)
+            {
+              // Inform BQL
+              txq->NotifyTransmittedBytes (m_currentPkt->GetSize ());
+            }
+          return ret;
         }
       // We have enqueued a packet but we have not dequeued any packet. Thus, we
       // need to check whether the queue is able to store another packet. If not,
       // we stop the queue
       if (txq)
         {
           if ((m_queue->GetMode () == Queue::QUEUE_MODE_PACKETS &&
                m_queue->GetNPackets () >= m_queue->GetMaxPackets ()) ||
               (m_queue->GetMode () == Queue::QUEUE_MODE_BYTES &&
                m_queue->GetNBytes () + m_mtu > m_queue->GetMaxBytes ()))
@@ skipping 129 matching lines @@
     {
     case 0x0800: return 0x0021;   //IPv4
     case 0x86DD: return 0x0057;   //IPv6
     default: NS_ASSERT_MSG (false, "PPP Protocol number not defined!");
     }
   return 0;
 }
 
 
 } // namespace ns3