Attachment #2104 for bug #2119

View | Details | Raw Unified | Return to bug 2119
Collapse All | Expand All




FdNetDevice::FdNetDevice ()
  : m_node (0),
    m_ifIndex (0),
    // Defaults to Ethernet v2 MTU
    m_mtu (1500),
    m_fd (-1),
    m_fdReader (0),
    m_isBroadcast (true),
    m_isMulticast (false),
    m_pendingReadCount (0),
    m_startEvent (),
    m_stopEvent ()
{

FdNetDevice::~FdNetDevice ()
{
  NS_LOG_FUNCTION (this);

  {
    CriticalSection cs (m_pendingReadMutex);

    while (!m_pendingQueue.empty ())
      {
        std::pair<uint8_t *, ssize_t> next = m_pendingQueue.front ();
        m_pendingQueue.pop ();

        free (next.first);
      }
  }
}

void


  m_fdReader = Create<FdNetDeviceFdReader> ();
  // 22 bytes covers 14 bytes Ethernet header with possible 8 bytes LLC/SNAP
  m_fdReader->SetBufferSize (m_mtu + 22);
  m_fdReader->Start (m_fd, MakeCallback (&FdNetDevice::ReceiveCallback, this));

  NotifyLinkUp ();


  {
    CriticalSection cs (m_pendingReadMutex);
    if (m_pendingQueue.size () >= m_maxPendingReads)
      {
        NS_LOG_WARN ("Packet dropped");
        skip = true;
      }
    else
      {
        m_pendingQueue.push (std::make_pair (buf, len));
      }
  }

  if (skip)
    {
      struct timespec time = {
        0, 100000000L
      };                                        // 100 ms
      nanosleep (&time, NULL);
    }
  else
    {
      Simulator::ScheduleWithContext (m_nodeId, Time (0), MakeEvent (&FdNetDevice::ForwardUp, this));
    }
}

/**

}

void
FdNetDevice::ForwardUp (void)
{

  uint8_t *buf = 0; 
  ssize_t len = 0;

  {
    CriticalSection cs (m_pendingReadMutex);
    std::pair<uint8_t *, ssize_t> next = m_pendingQueue.front ();
    m_pendingQueue.pop ();

    buf = next.first;
    len = next.second;
  }

  NS_LOG_FUNCTION (this << buf << len);

  if (m_pendingReadCount > 0)
    {
      {
        CriticalSection cs (m_pendingReadMutex);
        --m_pendingReadCount;
      }
    }

  // We need to remove the PI header and ignore it
  if (m_encapMode == DIXPI)
    {




#include "ns3/unix-fd-reader.h"
#include "ns3/system-mutex.h"

#include <utility>
#include <queue>

namespace ns3 {



private:
  FdReader::Data DoRead (void);

  uint32_t m_bufferSize; //!< size of the read buffer
};


  /**
   * Forward the frame to the appropriate callback for processing
   */
  void ForwardUp (void);

  /**
   * Start Sending a Packet Down the Wire.

  /**
   * Number of packets that were received and scheduled for read but not yeat read.
   */
  std::queue< std::pair<uint8_t *, ssize_t> > m_pendingQueue;

  /**
   * Maximum number of packets that can be received and scheduled for read but not yeat read.
   */
  uint32_t m_maxPendingReads;

   
  /**
   * Mutex to increase pending read counter.
   */

Return to bug 2119