unix-stream-socket-fd.h

Go to the documentation of this file.

#ifndef UNIX_STREAM_SOCKET_FD_H
#define UNIX_STREAM_SOCKET_FD_H

#include "unix-socket-fd.h"
#include <list>

namespace ns3 {

class UnixStreamSocketFd : public UnixSocketFd
{
public:
  UnixStreamSocketFd (Ptr<Socket> sock, bool connected = 0);
  virtual ~UnixStreamSocketFd (void);
private:
  enum State
  {
    CREATED,
//    BINDED,
    LISTENING,
//    ACCEPTING,
    CONNECTING,
    CONNECTED,
    REMOTECLOSED,
    CLOSING, // wait for socket close callback
    CLOSED
  };
  virtual int Close (void);
  virtual ssize_t DoRecvmsg (struct msghdr *msg, int flags);
  virtual ssize_t DoSendmsg (const struct msghdr *msg, int flags);
  virtual int Listen (int backlog);
  virtual int Accept (struct sockaddr *my_addr, socklen_t *addrlen);
  virtual int Shutdown (int how);
  virtual bool CanRecv (void) const;
  virtual bool CanSend (void) const;
  virtual bool HangupReceived (void) const;
  virtual int Connect (const struct sockaddr *my_addr, socklen_t addrlen);
  virtual int Getpeername (struct sockaddr *name, socklen_t *namelen);
  virtual int Poll (PollTable* ptable);

  bool ConnectionRequest (Ptr<Socket> sock, const Address & from);
  void ConnectionCreated (Ptr<Socket> sock, const Address & from);

  void ConnectionSuccess (Ptr<Socket> sock);
  void ConnectionError (Ptr<Socket> sock);

  void CloseSuccess (Ptr<Socket> sock);
  void CloseError (Ptr<Socket> sock);

  void SetPeerAddress (Address *a);

  void MainSend (int *r, Ptr<Packet> p);

  std::list<std::pair<Ptr<Socket>,Address> > m_connectionQueue;
  int m_backlog;
  State m_state;
  Address* m_peerAddress;
  bool m_shutWrite;
};

} // namespace ns3

#endif /* UNIX_STREAM_SOCKET_FD_H */