/* * Copyright 2011, Haiku, Inc. All Rights Reserved. * Distributed under the terms of the MIT License. */ #ifndef _ABSTRACT_SOCKET_H #define _ABSTRACT_SOCKET_H #include #include #include class BAbstractSocket : public BDataIO { public: BAbstractSocket(); BAbstractSocket(const BAbstractSocket& other); virtual ~BAbstractSocket(); status_t InitCheck() const; virtual status_t Bind(const BNetworkAddress& local) = 0; virtual bool IsBound() const; virtual status_t Connect(const BNetworkAddress& peer, bigtime_t timeout = B_INFINITE_TIMEOUT) = 0; virtual bool IsConnected() const; virtual void Disconnect(); virtual status_t SetTimeout(bigtime_t timeout); virtual bigtime_t Timeout() const; virtual const BNetworkAddress& Local() const; virtual const BNetworkAddress& Peer() const; virtual size_t MaxTransmissionSize() const; virtual status_t WaitForReadable(bigtime_t timeout = B_INFINITE_TIMEOUT) const; virtual status_t WaitForWritable(bigtime_t timeout = B_INFINITE_TIMEOUT) const; int Socket() const; protected: status_t Bind(const BNetworkAddress& local, int type); status_t Connect(const BNetworkAddress& peer, int type, bigtime_t timeout = B_INFINITE_TIMEOUT); private: status_t _OpenIfNeeded(int family, int type); status_t _UpdateLocalAddress(); status_t _WaitFor(int flags, bigtime_t timeout) const; protected: status_t fInitStatus; int fSocket; BNetworkAddress fLocal; BNetworkAddress fPeer; bool fIsBound; bool fIsConnected; }; #endif // _ABSTRACT_SOCKET_H