Remove queue limit from listen
This commit is contained in:
@@ -87,7 +87,7 @@ void PacketSink::StartApplication() // Called at time specified by Start
|
||||
{
|
||||
m_socket = Socket::CreateSocket (GetNode(), m_tid);
|
||||
m_socket->Bind (m_local);
|
||||
m_socket->Listen (0);
|
||||
m_socket->Listen ();
|
||||
}
|
||||
|
||||
m_socket->SetRecvCallback (MakeCallback(&PacketSink::HandleRead, this));
|
||||
|
||||
@@ -395,9 +395,9 @@ NscTcpSocketImpl::GetTxAvailable (void) const
|
||||
}
|
||||
|
||||
int
|
||||
NscTcpSocketImpl::Listen (uint32_t q)
|
||||
NscTcpSocketImpl::Listen (void)
|
||||
{
|
||||
NS_LOG_FUNCTION (this << q);
|
||||
NS_LOG_FUNCTION (this);
|
||||
m_nscTcpSocket->listen(m_localPort);
|
||||
m_state = LISTEN;
|
||||
return 0;
|
||||
|
||||
@@ -73,7 +73,7 @@ public:
|
||||
virtual int ShutdownSend (void);
|
||||
virtual int ShutdownRecv (void);
|
||||
virtual int Connect(const Address &address);
|
||||
virtual int Listen(uint32_t queueLimit);
|
||||
virtual int Listen(void);
|
||||
virtual uint32_t GetTxAvailable (void) const;
|
||||
virtual int Send (Ptr<Packet> p, uint32_t flags);
|
||||
virtual int SendTo(Ptr<Packet> p, uint32_t flags, const Address &toAddress);
|
||||
|
||||
@@ -454,9 +454,9 @@ TcpSocketImpl::GetTxAvailable (void) const
|
||||
}
|
||||
|
||||
int
|
||||
TcpSocketImpl::Listen (uint32_t q)
|
||||
TcpSocketImpl::Listen (void)
|
||||
{
|
||||
NS_LOG_FUNCTION (this << q);
|
||||
NS_LOG_FUNCTION (this);
|
||||
Actions_t action = ProcessEvent (APP_LISTEN);
|
||||
ProcessAction (action);
|
||||
return 0;
|
||||
@@ -1915,7 +1915,7 @@ TcpSocketImplTest::SetupDefaultSim ()
|
||||
InetSocketAddress serverremoteaddr (Ipv4Address(ipaddr0), port);
|
||||
|
||||
listeningSock->Bind(serverlocaladdr);
|
||||
listeningSock->Listen (0);
|
||||
listeningSock->Listen ();
|
||||
|
||||
sock1->Connect(serverremoteaddr);
|
||||
}
|
||||
|
||||
@@ -86,7 +86,7 @@ public:
|
||||
virtual int ShutdownSend (void);
|
||||
virtual int ShutdownRecv (void);
|
||||
virtual int Connect(const Address &address);
|
||||
virtual int Listen(uint32_t queueLimit);
|
||||
virtual int Listen(void);
|
||||
virtual uint32_t GetTxAvailable (void) const;
|
||||
virtual int Send (Ptr<Packet> p, uint32_t flags);
|
||||
virtual int SendTo(Ptr<Packet> p, uint32_t flags, const Address &toAddress);
|
||||
|
||||
@@ -216,7 +216,7 @@ UdpSocketImpl::Connect(const Address & address)
|
||||
}
|
||||
|
||||
int
|
||||
UdpSocketImpl::Listen (uint32_t queueLimit)
|
||||
UdpSocketImpl::Listen (void)
|
||||
{
|
||||
m_errno = Socket::ERROR_OPNOTSUPP;
|
||||
return -1;
|
||||
|
||||
@@ -65,7 +65,7 @@ public:
|
||||
virtual int ShutdownSend (void);
|
||||
virtual int ShutdownRecv (void);
|
||||
virtual int Connect(const Address &address);
|
||||
virtual int Listen (uint32_t queueLimit);
|
||||
virtual int Listen (void);
|
||||
virtual uint32_t GetTxAvailable (void) const;
|
||||
virtual int Send (Ptr<Packet> p, uint32_t flags);
|
||||
virtual int SendTo (Ptr<Packet> p, uint32_t flags, const Address &address);
|
||||
|
||||
@@ -222,7 +222,7 @@ PacketSocket::Connect(const Address &ad)
|
||||
return -1;
|
||||
}
|
||||
int
|
||||
PacketSocket::Listen(uint32_t queueLimit)
|
||||
PacketSocket::Listen(void)
|
||||
{
|
||||
m_errno = Socket::ERROR_OPNOTSUPP;
|
||||
return -1;
|
||||
|
||||
@@ -93,7 +93,7 @@ public:
|
||||
virtual int ShutdownSend (void);
|
||||
virtual int ShutdownRecv (void);
|
||||
virtual int Connect(const Address &address);
|
||||
virtual int Listen(uint32_t queueLimit);
|
||||
virtual int Listen(void);
|
||||
virtual uint32_t GetTxAvailable (void) const;
|
||||
virtual int Send (Ptr<Packet> p, uint32_t flags);
|
||||
virtual int SendTo(Ptr<Packet> p, uint32_t flags, const Address &toAddress);
|
||||
|
||||
@@ -100,12 +100,6 @@ Socket::Send (Ptr<Packet> p)
|
||||
return Send (p, 0);
|
||||
}
|
||||
|
||||
|
||||
int Socket::Listen (uint32_t queueLimit)
|
||||
{
|
||||
return 0; //XXX the base class version does nothing
|
||||
}
|
||||
|
||||
int
|
||||
Socket::Send (const uint8_t* buf, uint32_t size, uint32_t flags)
|
||||
{
|
||||
|
||||
@@ -222,7 +222,7 @@ public:
|
||||
* \param queueLimit maximum number of incoming request to queue
|
||||
* \returns 0 on success, -1 on error (in which case errno is set).
|
||||
*/
|
||||
virtual int Listen (uint32_t queueLimit) = 0;
|
||||
virtual int Listen (void) = 0;
|
||||
|
||||
/**
|
||||
* \brief Returns the number of bytes which can be sent in a single call
|
||||
|
||||
Reference in New Issue
Block a user