/* */ #ifndef _D_SOCKET_H_ #define _D_SOCKET_H_ #include #include "SocketCore.h" #include "common.h" using namespace std; class Socket { private: // socket endpoint descriptor SocketCore* core; public: Socket(); Socket(const Socket& s); ~Socket(); Socket& operator=(const Socket& s); int getSockfd() const { return core->sockfd; } /** * Connects to the server named host and the destination port is port. * This method make socket non-blocking mode. * To make the socket blocking mode, call setNonBlockingMode() after * the connection is established. */ void establishConnection(string host, int port); void setNonBlockingMode(); // Closes the connection which this socket object has void closeConnection(); // examines whether the socket of this Socket object is available for writing. // returns true if the socket is available for writing, otherwise returns false. bool isWritable(int timeout); // examines whether the socket of this Socket object is available for reading. // returns true if the socket is available for reading, otherwise returns false. bool isReadable(int timeout); // writes characters into the socket. data is a pointer pointing the first // byte of the data and len is the length of the data. void writeData(const char* data, int len, int timeout = 5); // Reads up to len bytes from this socket. // data is a pointer pointing the first // byte of the data, which must be allocated before this method is called. // len is the size of the allocated memory. When this method returns // successfully, len is replaced by the size of the read data. void readData(char* data, int& len, int timeout = 5); // Reads up to len bytes from this socket, but bytes are not removed from // this socket. void peekData(char* data, int& len, int timeout = 5); #ifdef HAVE_LIBSSL // for SSL void initiateSecureConnection(); #endif // HAVE_LIBSSL }; #endif // _D_SOCKET_H_