Attachment #1950 for bug #1835

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




  address = InetSocketAddress (m_src, 0);
  return 0;
}
int
Ipv4RawSocketImpl::GetPeerName (Address &address) const
{
  NS_LOG_FUNCTION (this << address);

  if (m_dst == Ipv4Address::GetAny ())
    {
      m_err = ERROR_NOTCONN;;
      return -1;
    }

  address = InetSocketAddress (m_dst, 0);

  return 0;
}
int 
Ipv4RawSocketImpl::Close (void)
{

(-)a/src/internet/model/ipv4-raw-socket-impl.h (-1 / +2 lines)

Lines 53-58	Link Here

  virtual int Bind ();

  virtual int Bind ();

  virtual int Bind6 ();

  virtual int Bind6 ();

  virtual int GetSockName (Address &address) const;

  virtual int GetSockName (Address &address) const;

  virtual int GetPeerName (Address &address) const;

  virtual int Close (void);

  virtual int Close (void);

  virtual int ShutdownSend (void);

  virtual int ShutdownSend (void);

  virtual int ShutdownRecv (void);

  virtual int ShutdownRecv (void);

Lines 98-104	Link Here

    uint16_t fromProtocol;   /**< Protocol used */

    uint16_t fromProtocol;   /**< Protocol used */

};

100

};

100

101

  enum Socket::SocketErrno m_err;   //!< Last error number.

102

  mutable enum Socket::SocketErrno m_err; //!< Last error number.

102

  Ptr<Node> m_node;                 //!< Node

103

  Ptr<Node> m_node;                 //!< Node

103

  Ipv4Address m_src;                //!< Source address.

104

  Ipv4Address m_src;                //!< Source address.

104

  Ipv4Address m_dst;                //!< Destination address.

105

  Ipv4Address m_dst;                //!< Destination address.




  return 0;
}

int
Ipv6RawSocketImpl::GetPeerName (Address& address) const
{
  NS_LOG_FUNCTION (this << address);

  if (m_dst.IsAny ())
    {
      m_err = ERROR_NOTCONN;;
      return -1;
    }

  address = Inet6SocketAddress (m_dst, 0);

  return 0;
}

int Ipv6RawSocketImpl::Close ()
{
  NS_LOG_FUNCTION_NOARGS ();

(-)a/src/internet/model/ipv6-raw-socket-impl.h (-1 / +2 lines)

Lines 95-100	Link Here

  virtual int Bind6 ();

  virtual int Bind6 ();

  virtual int GetSockName (Address& address) const;

  virtual int GetSockName (Address& address) const;

  virtual int GetPeerName (Address& address) const;

  virtual int Close ();

100

  virtual int Close ();

100

  virtual int ShutdownSend ();

101

  virtual int ShutdownSend ();

Lines 183-189	Link Here

183

/**

184

/**

184

   * \brief Last error number.

185

   * \brief Last error number.

185

*/

186

*/

186

  enum Socket::SocketErrno m_err;

187

  mutable enum Socket::SocketErrno m_err;

187

188

/**

189

/**

189

   * \brief Node.

190

   * \brief Node.




  return 0;
}

int
TcpSocketBase::GetPeerName (Address &address) const
{
  NS_LOG_FUNCTION (this << address);

  if (!m_connected)
    {
      m_errno = ERROR_NOTCONN;;
      return -1;
    }

  if (m_endPoint)
    {
      address = InetSocketAddress (m_endPoint->GetPeerAddress (),
                                   m_endPoint->GetPeerPort ());
    }
  else if (m_endPoint6)
    {
      address = Inet6SocketAddress (m_endPoint6->GetPeerAddress (),
                                    m_endPoint6->GetPeerPort ());
    }
  else
    {
      NS_ASSERT_MSG (false, "unexpected address type");
    }

  return 0;
}

/* Inherit from Socket class: Bind this socket to the specified NetDevice */
void
TcpSocketBase::BindToNetDevice (Ptr<NetDevice> netdevice)

(-)a/src/internet/model/tcp-socket-base.h (-1 / +2 lines)

Lines 120-125	Link Here

120

  virtual uint32_t GetTxAvailable (void) const; // Available Tx buffer size

120

  virtual uint32_t GetTxAvailable (void) const; // Available Tx buffer size

121

  virtual uint32_t GetRxAvailable (void) const; // Available-to-read data size, i.e. value of m_rxAvailable

121

  virtual uint32_t GetRxAvailable (void) const; // Available-to-read data size, i.e. value of m_rxAvailable

122

  virtual int GetSockName (Address &address) const; // Return local addr:port in address

122

  virtual int GetSockName (Address &address) const; // Return local addr:port in address

123

  virtual int GetPeerName (Address &address) const;

123

  virtual void BindToNetDevice (Ptr<NetDevice> netdevice); // NetDevice with my m_endPoint

124

  virtual void BindToNetDevice (Ptr<NetDevice> netdevice); // NetDevice with my m_endPoint

124

125

protected:

126

protected:

Lines 647-653	Link Here

647

648

  // State-related attributes

649

  // State-related attributes

649

  TracedValue<TcpStates_t> m_state;         //!< TCP state

650

  TracedValue<TcpStates_t> m_state;         //!< TCP state

650

  enum SocketErrno         m_errno;         //!< Socket error code

651

  mutable enum SocketErrno m_errno;         //!< Socket error code

651

  bool                     m_closeNotified; //!< Told app to close socket

652

  bool                     m_closeNotified; //!< Told app to close socket

652

  bool                     m_closeOnEmpty;  //!< Close socket upon tx buffer emptied

653

  bool                     m_closeOnEmpty;  //!< Close socket upon tx buffer emptied

653

  bool                     m_shutdownSend;  //!< Send no longer allowed

654

  bool                     m_shutdownSend;  //!< Send no longer allowed




  return 0;
}

int
UdpSocketImpl::GetPeerName (Address &address) const
{
  NS_LOG_FUNCTION (this << address);

  if (!m_connected)
    {
      m_errno = ERROR_NOTCONN;;
      return -1;
    }

  if (InetSocketAddress::IsMatchingType (m_defaultAddress))
    {
      InetSocketAddress addr =
        InetSocketAddress::ConvertFrom (m_defaultAddress);
      addr.SetPort (m_defaultPort);
      address = addr;
    }
  else if (Inet6SocketAddress::IsMatchingType (m_defaultAddress))
    {
      Inet6SocketAddress addr =
        Inet6SocketAddress::ConvertFrom (m_defaultAddress);
      addr.SetPort (m_defaultPort);
      address = addr;
    }
  else
    {
      NS_ASSERT_MSG (false, "unexpected address type");
    }

  return 0;
}

int 
UdpSocketImpl::MulticastJoinGroup (uint32_t interface, const Address &groupAddress)
{

(-)a/src/internet/model/udp-socket-impl.h (-1 / +2 lines)

Lines 93-98	Link Here

  virtual Ptr<Packet> RecvFrom (uint32_t maxSize, uint32_t flags,

  virtual Ptr<Packet> RecvFrom (uint32_t maxSize, uint32_t flags,

                                Address &fromAddress);

                                Address &fromAddress);

  virtual int GetSockName (Address &address) const;

  virtual int GetSockName (Address &address) const;

  virtual int GetPeerName (Address &address) const;

  virtual int MulticastJoinGroup (uint32_t interfaceIndex, const Address &groupAddress);

  virtual int MulticastJoinGroup (uint32_t interfaceIndex, const Address &groupAddress);

  virtual int MulticastLeaveGroup (uint32_t interfaceIndex, const Address &groupAddress);

  virtual int MulticastLeaveGroup (uint32_t interfaceIndex, const Address &groupAddress);

  virtual void BindToNetDevice (Ptr<NetDevice> netdevice);

  virtual void BindToNetDevice (Ptr<NetDevice> netdevice);

Lines 227-233	Link Here

227

  uint16_t m_defaultPort;   //!< Default port

228

  uint16_t m_defaultPort;   //!< Default port

228

  TracedCallback<Ptr<const Packet> > m_dropTrace; //!< Trace for dropped packets

229

  TracedCallback<Ptr<const Packet> > m_dropTrace; //!< Trace for dropped packets

229

230

  enum SocketErrno         m_errno;           //!< Socket error code

231

  mutable enum SocketErrno m_errno;           //!< Socket error code

231

  bool                     m_shutdownSend;    //!< Send no longer allowed

232

  bool                     m_shutdownSend;    //!< Send no longer allowed

232

  bool                     m_shutdownRecv;    //!< Receive no longer allowed

233

  bool                     m_shutdownRecv;    //!< Receive no longer allowed

233

  bool                     m_connected;       //!< Connection established

234

  bool                     m_connected;       //!< Connection established

(-)a/src/network/model/socket.h (+7 lines)

Lines 561-566	Link Here

561

  virtual int GetSockName (Address &address) const = 0;

561

  virtual int GetSockName (Address &address) const = 0;

562

563

/**

563

/**

564

   * \brief Get peer address of connected socket.

565

   * \param address the address this socket is connected to.

566

   * \returns 0 if success, -1 otherwise

567

*/

568

  virtual int GetPeerName (Address &address) const = 0;

569

570

/**

564

   * \brief Bind a socket to specific device.

571

   * \brief Bind a socket to specific device.

565

572

566

   * This method corresponds to using setsockopt() SO_BINDTODEVICE

573

   * This method corresponds to using setsockopt() SO_BINDTODEVICE




  return 0;
}

int
PacketSocket::GetPeerName (Address &address) const
{
  NS_LOG_FUNCTION (this << address);

  if (m_state != STATE_CONNECTED)
    {
      m_errno = ERROR_NOTCONN;;
      return -1;
    }

  address = m_destAddr;

  return 0;
}

bool
PacketSocket::SetAllowBroadcast (bool allowBroadcast)
{

(-)a/src/network/utils/packet-socket.h (-1 / +2 lines)

Lines 133-138	Link Here

133

  virtual Ptr<Packet> RecvFrom (uint32_t maxSize, uint32_t flags,

133

  virtual Ptr<Packet> RecvFrom (uint32_t maxSize, uint32_t flags,

134

                                Address &fromAddress);

134

                                Address &fromAddress);

135

  virtual int GetSockName (Address &address) const;

135

  virtual int GetSockName (Address &address) const;

136

  virtual int GetPeerName (Address &address) const;

136

  virtual bool SetAllowBroadcast (bool allowBroadcast);

137

  virtual bool SetAllowBroadcast (bool allowBroadcast);

137

  virtual bool GetAllowBroadcast () const;

138

  virtual bool GetAllowBroadcast () const;

138

139

Lines 177-183	Link Here

177

};

178

};

178

179

  Ptr<Node> m_node;         //!< the associated node

180

  Ptr<Node> m_node;         //!< the associated node

180

  enum SocketErrno m_errno; //!< Socket error code

181

  mutable enum SocketErrno m_errno; //!< Socket error code

181

  bool m_shutdownSend;      //!< Send no longer allowed

182

  bool m_shutdownSend;      //!< Send no longer allowed

182

  bool m_shutdownRecv;      //!< Receive no longer allowed

183

  bool m_shutdownRecv;      //!< Receive no longer allowed

183

  enum State m_state;       //!< Socket state

184

  enum State m_state;       //!< Socket state

Return to bug 1835