X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fsocket.h;h=f97588415b1e5df052b1138a1e706f596810fc0b;hb=21c596567e3b6fd794ed6af73d304ce2bc70e58f;hp=caea92444a92cf12719c98cff3fbd6325f6b66ce;hpb=c016a1ae2bc93a48074e4b8cafab70b9d2c9fc20;p=libs%2Fnet.git diff --git a/source/socket.h b/source/socket.h index caea924..f975884 100644 --- a/source/socket.h +++ b/source/socket.h @@ -1,46 +1,53 @@ #ifndef MSP_NET_SOCKET_H_ #define MSP_NET_SOCKET_H_ -#include +#include +#include #include "constants.h" #include "sockaddr.h" -#include "types.h" namespace Msp { namespace Net { -class Socket: public IO::Base -{ -protected: - SocketHandle handle; #ifdef WIN32 - IO::Handle event; +typedef int socklen_t; #endif - bool connected; + + +class bad_socket_state: public std::logic_error +{ +public: + bad_socket_state(const std::string &w): std::logic_error(w) { } + virtual ~bad_socket_state() throw() { } +}; + + +class Socket: public IO::EventObject +{ +protected: + struct Private; + + Private *priv; SockAddr *local_addr; - SockAddr *peer_addr; - Socket(SocketHandle, const SockAddr &); + Socket(const Private &); Socket(Family, int, int); public: ~Socket(); - void set_block(bool); - IO::Handle get_event_handle(); + virtual void set_block(bool); + virtual const IO::Handle &get_event_handle(); - bool is_connected() const { return connected; } + /** Associates the socket with a local address. There must be no existing + users of the address. */ void bind(const SockAddr &); - virtual int connect(const SockAddr &) =0; - void close(); - void set_timeout(const Time::TimeDelta &); + const SockAddr &get_local_address() const; - const SockAddr &get_peer_address() const; + + void set_timeout(const Time::TimeDelta &); protected: - void check_state(bool) const; int set_option(int, int, const void *, socklen_t); int get_option(int, int, void *, socklen_t *) const; - unsigned do_write(const char *, unsigned); - unsigned do_read(char *, unsigned); }; } // namespace Net