Search Site ~Sockets~  C++ Sockets   Tutorial  Classes  License   Java Sockets  ~Examples~  SMTPProxy   PortProxy   ChatServer   Small MUD   ClientServer   HttpGet   DChat   WebServer   UDP   ICMP  ~Contact~ message board  email author

SocketHandler.h Go to the documentation of this file. /* Copyright (C) 2004-2008 Anders Hedstrom This library is made available under the terms of the GNU GPL. If you would like to use this library in a closed-source application, a separate license agreement is available. For information about the closed-source license agreement for the C++ sockets library, please visit http://www.alhem.net/Sockets/license.html and/or email license@alhem.net. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ #ifndef _SOCKETS_SocketHandler_H #define _SOCKETS_SocketHandler_H #include "sockets-config.h" #include <map> #include <list> #include "socket_include.h" #include "ISocketHandler.h" #ifdef SOCKETS_NAMESPACE namespace SOCKETS_NAMESPACE { #endif class Socket; #ifdef ENABLE_RESOLVER class ResolvServer; #endif class IMutex; class SocketHandler : public ISocketHandler { protected: typedef std::map<SOCKET,Socket *> socket_m; public: SocketHandler(StdLog *log = NULL); SocketHandler(IMutex& mutex,StdLog *log = NULL); ~SocketHandler(); IMutex& GetMutex() const; void RegStdLog(StdLog *log); void LogError(Socket *p,const std::string& user_text,int err,const std::string& sys_err,loglevel_t t = LOG_LEVEL_WARNING); void Add(Socket *); void Get(SOCKET s,bool& r,bool& w,bool& e); void Set(SOCKET s,bool bRead,bool bWrite,bool bException = true); int Select(long sec,long usec); int Select(); int Select(struct timeval *tsel); bool Valid(Socket *); size_t GetCount(); bool OkToAccept(Socket *p); void AddList(SOCKET s,list_t which_one,bool add); // Connection pool #ifdef ENABLE_POOL ISocketHandler::PoolSocket *FindConnection(int type,const std::string& protocol,SocketAddress&); void EnablePool(bool x = true); bool PoolEnabled(); #endif // ENABLE_POOL // Socks4 #ifdef ENABLE_SOCKS4 void SetSocks4Host(ipaddr_t); void SetSocks4Host(const std::string& ); void SetSocks4Port(port_t); void SetSocks4Userid(const std::string& ); void SetSocks4TryDirect(bool x = true); ipaddr_t GetSocks4Host(); port_t GetSocks4Port(); const std::string& GetSocks4Userid(); bool Socks4TryDirect(); #endif // ENABLE_SOCKS4 // DNS resolve server #ifdef ENABLE_RESOLVER void EnableResolver(port_t port = 16667); bool ResolverEnabled(); int Resolve(Socket *,const std::string& host,port_t port); #ifdef ENABLE_IPV6 int Resolve6(Socket *,const std::string& host,port_t port); #endif int Resolve(Socket *,ipaddr_t a); #ifdef ENABLE_IPV6 int Resolve(Socket *,in6_addr& a); #endif port_t GetResolverPort(); bool ResolverReady(); bool Resolving(Socket *); #endif // ENABLE_RESOLVER #ifdef ENABLE_TRIGGERS int TriggerID(Socket *src); bool Subscribe(int id, Socket *dst); bool Unsubscribe(int id, Socket *dst); void Trigger(int id, Socket::TriggerData& data, bool erase = true); #endif // ENABLE_TRIGGERS #ifdef ENABLE_DETACH void SetSlave(bool x = true); bool IsSlave(); #endif void CheckSanity(); protected: socket_m m_sockets; socket_m m_add; std::list<Socket *> m_delete; protected: void Remove(Socket *); StdLog *m_stdlog; IMutex& m_mutex; bool m_b_use_mutex; private: void CheckList(socket_v&,const std::string&); SOCKET m_maxsock; fd_set m_rfds; fd_set m_wfds; fd_set m_efds; int m_preverror; int m_errcnt; time_t m_tlast; // state lists socket_v m_fds; socket_v m_fds_erase; socket_v m_fds_callonconnect; #ifdef ENABLE_DETACH socket_v m_fds_detach; #endif socket_v m_fds_timeout; socket_v m_fds_retry; socket_v m_fds_close; #ifdef ENABLE_SOCKS4 ipaddr_t m_socks4_host; port_t m_socks4_port; std::string m_socks4_userid; bool m_bTryDirect; #endif #ifdef ENABLE_RESOLVER int m_resolv_id; ResolvServer *m_resolver; port_t m_resolver_port; std::map<Socket *, bool> m_resolve_q; #endif #ifdef ENABLE_POOL bool m_b_enable_pool; #endif #ifdef ENABLE_TRIGGERS int m_next_trigger_id; std::map<int, Socket *> m_trigger_src; std::map<int, std::map<Socket *, bool> > m_trigger_dst; #endif #ifdef ENABLE_DETACH bool m_slave; #endif }; #ifdef SOCKETS_NAMESPACE } #endif #endif // _SOCKETS_SocketHandler_H

Page, code, and content Copyright (C) 2007 by Anders Hedström

---