Attachment #3085 for bug #2405

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





UanMacCw::UanMacCw ()
  : UanMac (),
  m_phy (0),
  m_pktTx (0),
  m_state (IDLE),
  m_txNotified (false),
  m_cleared (false)

{
  m_rv = CreateObject<UniformRandomVariable> ();

      m_phy = 0;
    }
  m_sendEvent.Cancel ();
  m_txNotified = false;
}

void

    {
    case CCABUSY:
      NS_LOG_DEBUG ("Time " << Simulator::Now ().GetSeconds () << " MAC " << GetAddress () << " Starting enqueue CCABUSY");
      if (m_txNotified == true)
        {
          NS_LOG_DEBUG ("State is TX");
        }

void
UanMacCw::NotifyTxStart (Time duration)
{
  m_txNotified = true;

  NS_LOG_DEBUG ("Time " << Simulator::Now ().GetSeconds () << " Tx Start Notified");
    {
      Simulator::Cancel (m_txEndEvent);
    }

  m_txEndEvent = Simulator::Schedule (duration, &UanMacCw::EndTx, this);
  NS_LOG_DEBUG ("Time " << Simulator::Now ().GetSeconds () << " scheduling TxEndEvent with delay " << duration.GetSeconds ());
  if (m_state == RUNNING)
    {
      NS_ASSERT (0);


}

void
UanMacCw::NotifyTxEnd (void)
{
  EndTx ();

  m_txNotified = false;
}

int64_t
UanMacCw::AssignStreams (int64_t stream)
{





  /**
   * Set the contention window size.
   *
   * \param cw Contention window size.
   */
  virtual void SetCw (uint32_t cw);

  virtual void NotifyCcaStart (void);
  virtual void NotifyCcaEnd (void);
  virtual void NotifyTxStart (Time duration);
  virtual void NotifyTxEnd (void);

  /**
   *  TracedCallback signature for enqueue/dequeue of a packet.

   * \param [in] packet The Packet being received.
   * \param [in] proto The protocol number.
   */
  typedef void (* QueueTracedCallback)(Ptr<const Packet> packet, uint16_t proto);
    (Ptr<const Packet> packet, uint16_t proto);

private:
  /** Enum defining possible Phy states. */
  typedef enum
  {
    IDLE,     //!< Idle state.
    CCABUSY,  //!< Channel busy.
    RUNNING,  //!< Delay timer running.

  uint16_t m_pktTxProt;
  /** Scheduled SendPacket event. */
  EventId m_sendEvent;
  /** Tx has been notified from Phy. */
  bool m_txNotified;
  /** Current state. */
  State m_state;





      if (std::abs (pit->GetAmp ()) > maxAmp)
        {
          maxAmp = std::abs (pit->GetAmp ());
          // Modified in order to subtract delay of first tap (maxTapDelay appears to be used later in code
          // as delay from first reception, not from TX time)
          maxTapDelay = pit->GetDelay ().GetSeconds () - pdp.GetTap (0).GetDelay ().GetSeconds ();
        }
    }


  double effRxPowerDb = rxPowerDb + KpToDb (csp);
  //It appears to be just the first elements of the sum in Parrish paper,
  // "System Design Considerations for Undersea Networks: Link and Multiple Access Protocols", eq. 14
  double isiUpa = DbToKp (rxPowerDb) * pdp.SumTapsFromMaxNc (Seconds (ts + clearingTime), Seconds (ts)); // added DpToKp()
  UanTransducer::ArrivalList::const_iterator it = arrivalList.begin ();
  double intKp = -DbToKp (effRxPowerDb);
  for (; it != arrivalList.end (); it++)

/*************** UanPhyGen definition *****************/
UanPhyGen::UanPhyGen ()
  : UanPhy (),
  m_state (IDLE),
  m_channel (0),
  m_transducer (0),
  m_device (0),
  m_mac (0),
  m_txPwrDb (0),
  m_rxThreshDb (0),
  m_ccaThreshDb (0),
  m_pktRx (0),
  m_pktTx (0),
  m_cleared (false)
{
  m_pg = CreateObject<UniformRandomVariable> ();


      m_state = IDLE;
    }
  UpdatePowerConsumption (IDLE);

  NotifyListenersTxEnd ();
}

void

UanPhyGen::SetSleepMode (bool sleep )
{
  if (sleep )
    {
      m_state = SLEEP;
      if (!m_energyCallback.IsNull ())
        {
          m_energyCallback (SLEEP);
        }
    }
  else if (m_state == SLEEP)
    {
      if (GetInterferenceDb ((Ptr<Packet>) 0) > m_ccaThreshDb)

    }
}

void
UanPhyGen::NotifyListenersTxEnd (void)
{
  ListenerList::const_iterator it = m_listeners.begin ();
  for (; it != m_listeners.end (); it++)
    {
      (*it)->NotifyTxEnd ();
    }
}

uint32_t
UanPhyGen::GetNModes (void)
{

(-)a/src/uan/model/uan-phy-gen.h (-3 / +7 lines)

Lines 215-224	Link Here

215

 * clearing time between symbols transmitted on the same frequency.

215

 * clearing time between symbols transmitted on the same frequency.

216

 * This clearing time combats ISI from channel delay spread and also has

216

 * This clearing time combats ISI from channel delay spread and also has

217

 * a byproduct of possibly reducing interference from other transmitted packets.

217

 * a byproduct of possibly reducing interference from other transmitted packets.

218

219

 * Thanks to Randall Plate for the latest model revision based on the following

219

 * Thanks to Randall Plate for the latest model revision based on the following

220

 * papers:

220

 * papers:

221

 * <ul>

221

 * <ul>

222

 * <li>Parrish, "System Design Considerations for Undersea Networks: Link and Multiple Access Protocols"

222

 * <li>Parrish, "System Design Considerations for Undersea Networks: Link and Multiple Access Protocols"

223

 * <li>Siderius, "Effects of Ocean Thermocline Variability on Noncoherent Underwater Acoustic Communications"

223

 * <li>Siderius, "Effects of Ocean Thermocline Variability on Noncoherent Underwater Acoustic Communications"

224

 * <li>Rao, "Channel Coding Techniques for Wireless Communications", ch 2

224

 * <li>Rao, "Channel Coding Techniques for Wireless Communications", ch 2

Lines 442-447	Link Here

442

   * \param duration Duration of transmission.

442

   * \param duration Duration of transmission.

443

*/

443

*/

444

  void NotifyListenersTxStart (Time duration);

444

  void NotifyListenersTxStart (Time duration);

445

/**

446

   * Call UanListener::NotifyTxEnd on all listeners.

447

*/

448

  void NotifyListenersTxEnd (void);

445

449

446

protected:

450

protected:

447

  virtual void DoDispose ();

451

  virtual void DoDispose ();

(-)a/src/uan/model/uan-phy.h (-16 / +18 lines)

Lines 96-102	Link Here

protected:

protected:

  virtual void DoDispose (void);

  virtual void DoDispose (void);

100

};  // class UanPhyCalcSinr

100

};  // class UanPhyCalcSinr

101

102

/**

102

/**

Lines 147-153	Link Here

147

148

public:

148

public:

149

  /** Default destructor */

149

  /** Default destructor */

150

  virtual ~UanPhyListener () { }

150

  virtual ~UanPhyListener ()

151

152

151

  /** Called when UanPhy begins receiving packet. */

153

  /** Called when UanPhy begins receiving packet. */

152

  virtual void NotifyRxStart (void) = 0;

154

  virtual void NotifyRxStart (void) = 0;

153

  /** Called when UanPhy finishes receiving packet without error. */

155

  /** Called when UanPhy finishes receiving packet without error. */

Lines 164-170	Link Here

164

   * \param duration Duration of transmission.

166

   * \param duration Duration of transmission.

165

*/

167

*/

166

  virtual void NotifyTxStart (Time duration) = 0;

168

  virtual void NotifyTxStart (Time duration) = 0;

167

169

  /** Function called when Phy object finishes transmitting packet */

170

  virtual void NotifyTxEnd (void) = 0;

168

};  // class UanPhyListener

171

};  // class UanPhyListener

169

172

170

/**

173

/**

Lines 210-222	Link Here

210

   * \param [in] sinr The SINR.

213

   * \param [in] sinr The SINR.

211

   * \param [in] mode The channel mode.

214

   * \param [in] mode The channel mode.

212

*/

215

*/

213

  typedef void (* TracedCallback)

216

  typedef void (* TracedCallback)(Ptr<const Packet> pkt, double sinr, UanTxMode mode);

214

    (Ptr<const Packet> pkt, double sinr, UanTxMode mode);

217

215

218

216

217

/**

219

/**

218

   * Set the DeviceEnergyModel callback for UanPhy device.

220

   * Set the DeviceEnergyModel callback for UanPhy device.

219

221

220

   * \param callback The DeviceEnergyModel change state callback.

222

   * \param callback The DeviceEnergyModel change state callback.

221

*/

223

*/

222

  virtual void SetEnergyModelCallback (DeviceEnergyModel::ChangeStateCallback callback) = 0;

224

  virtual void SetEnergyModelCallback (DeviceEnergyModel::ChangeStateCallback callback) = 0;

Lines 487-500	Link Here

487

*/

489

*/

488

  void NotifyRxDrop (Ptr<const Packet> packet);

490

  void NotifyRxDrop (Ptr<const Packet> packet);

489

491

490

/**

492

/**

491

  * Assign a fixed random variable stream number to the random variables

493

   * Assign a fixed random variable stream number to the random variables

492

  * used by this model.  Return the number of streams (possibly zero) that

494

   * used by this model.  Return the number of streams (possibly zero) that

493

  * have been assigned.

495

   * have been assigned.

494

496

495

  * \param stream First stream index to use.

497

   * \param stream First stream index to use.

496

  * \return The number of stream indices assigned by this model.

498

   * \return The number of stream indices assigned by this model.

497

*/

499

*/

498

  virtual int64_t AssignStreams (int64_t stream) = 0;

500

  virtual int64_t AssignStreams (int64_t stream) = 0;

499

501

500

/**

502

/**

Return to bug 2405