aboutsummaryrefslogtreecommitdiff
path: root/dep/src/sockets/SocketHandler.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'dep/src/sockets/SocketHandler.cpp')
-rw-r--r--dep/src/sockets/SocketHandler.cpp48
1 files changed, 0 insertions, 48 deletions
diff --git a/dep/src/sockets/SocketHandler.cpp b/dep/src/sockets/SocketHandler.cpp
index 84d110cfe72..acf71fb2efa 100644
--- a/dep/src/sockets/SocketHandler.cpp
+++ b/dep/src/sockets/SocketHandler.cpp
@@ -50,14 +50,12 @@ Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
namespace SOCKETS_NAMESPACE {
#endif
-
//#ifdef _DEBUG
//#define DEB(x) x; fflush(stderr);
//#else
#define DEB(x)
//#endif
-
SocketHandler::SocketHandler(StdLog *p)
:m_stdlog(p)
,m_mutex(m_mutex)
@@ -90,7 +88,6 @@ SocketHandler::SocketHandler(StdLog *p)
FD_ZERO(&m_efds);
}
-
SocketHandler::SocketHandler(Mutex& mutex,StdLog *p)
:m_stdlog(p)
,m_mutex(mutex)
@@ -124,7 +121,6 @@ SocketHandler::SocketHandler(Mutex& mutex,StdLog *p)
FD_ZERO(&m_efds);
}
-
SocketHandler::~SocketHandler()
{
#ifdef ENABLE_RESOLVER
@@ -182,33 +178,28 @@ DEB( fprintf(stderr, "/Emptying sockets list in SocketHandler destructor,
}
}
-
Mutex& SocketHandler::GetMutex() const
{
return m_mutex;
}
-
#ifdef ENABLE_DETACH
void SocketHandler::SetSlave(bool x)
{
m_slave = x;
}
-
bool SocketHandler::IsSlave()
{
return m_slave;
}
#endif
-
void SocketHandler::RegStdLog(StdLog *log)
{
m_stdlog = log;
}
-
void SocketHandler::LogError(Socket *p,const std::string& user_text,int err,const std::string& sys_err,loglevel_t t)
{
if (m_stdlog)
@@ -217,7 +208,6 @@ void SocketHandler::LogError(Socket *p,const std::string& user_text,int err,cons
}
}
-
void SocketHandler::Add(Socket *p)
{
if (p -> GetSocket() == INVALID_SOCKET)
@@ -238,7 +228,6 @@ void SocketHandler::Add(Socket *p)
m_add[p -> GetSocket()] = p;
}
-
void SocketHandler::Get(SOCKET s,bool& r,bool& w,bool& e)
{
if (s >= 0)
@@ -249,7 +238,6 @@ void SocketHandler::Get(SOCKET s,bool& r,bool& w,bool& e)
}
}
-
void SocketHandler::Set(SOCKET s,bool bRead,bool bWrite,bool bException)
{
DEB( fprintf(stderr, "Set(%d, %s, %s, %s)\n", s, bRead ? "true" : "false", bWrite ? "true" : "false", bException ? "true" : "false");)
@@ -291,7 +279,6 @@ DEB( fprintf(stderr, "Set(%d, %s, %s, %s)\n", s, bRead ? "true" : "false", bW
}
}
-
int SocketHandler::Select(long sec,long usec)
{
struct timeval tv;
@@ -300,7 +287,6 @@ int SocketHandler::Select(long sec,long usec)
return Select(&tv);
}
-
int SocketHandler::Select()
{
if (!m_fds_callonconnect.empty() ||
@@ -317,7 +303,6 @@ int SocketHandler::Select()
return Select(NULL);
}
-
int SocketHandler::Select(struct timeval *tsel)
{
size_t ignore = 0;
@@ -965,7 +950,6 @@ DEB( fprintf(stderr, "Close() before OnDelete\n");)
return n;
}
-
#ifdef ENABLE_RESOLVER
bool SocketHandler::Resolving(Socket *p0)
{
@@ -974,7 +958,6 @@ bool SocketHandler::Resolving(Socket *p0)
}
#endif
-
bool SocketHandler::Valid(Socket *p0)
{
for (socket_m::iterator it = m_sockets.begin(); it != m_sockets.end(); it++)
@@ -986,13 +969,11 @@ bool SocketHandler::Valid(Socket *p0)
return false;
}
-
bool SocketHandler::OkToAccept(Socket *)
{
return true;
}
-
size_t SocketHandler::GetCount()
{
/*
@@ -1003,33 +984,28 @@ printf(" m_delete : %d\n", m_delete.size());
return m_sockets.size() + m_add.size() + m_delete.size();
}
-
#ifdef ENABLE_SOCKS4
void SocketHandler::SetSocks4Host(ipaddr_t a)
{
m_socks4_host = a;
}
-
void SocketHandler::SetSocks4Host(const std::string& host)
{
Utility::u2ip(host, m_socks4_host);
}
-
void SocketHandler::SetSocks4Port(port_t port)
{
m_socks4_port = port;
}
-
void SocketHandler::SetSocks4Userid(const std::string& id)
{
m_socks4_userid = id;
}
#endif
-
#ifdef ENABLE_RESOLVER
int SocketHandler::Resolve(Socket *p,const std::string& host,port_t port)
{
@@ -1049,7 +1025,6 @@ DEB( fprintf(stderr, " *** Resolve '%s:%d' id#%d m_resolve_q size: %d p: %p
return resolv -> GetId();
}
-
#ifdef ENABLE_IPV6
int SocketHandler::Resolve6(Socket *p,const std::string& host,port_t port)
{
@@ -1069,7 +1044,6 @@ int SocketHandler::Resolve6(Socket *p,const std::string& host,port_t port)
}
#endif
-
int SocketHandler::Resolve(Socket *p,ipaddr_t a)
{
// check cache
@@ -1087,7 +1061,6 @@ int SocketHandler::Resolve(Socket *p,ipaddr_t a)
return resolv -> GetId();
}
-
#ifdef ENABLE_IPV6
int SocketHandler::Resolve(Socket *p,in6_addr& a)
{
@@ -1107,7 +1080,6 @@ int SocketHandler::Resolve(Socket *p,in6_addr& a)
}
#endif
-
void SocketHandler::EnableResolver(port_t port)
{
if (!m_resolver)
@@ -1117,60 +1089,51 @@ void SocketHandler::EnableResolver(port_t port)
}
}
-
bool SocketHandler::ResolverReady()
{
return m_resolver ? m_resolver -> Ready() : false;
}
#endif // ENABLE_RESOLVER
-
#ifdef ENABLE_SOCKS4
void SocketHandler::SetSocks4TryDirect(bool x)
{
m_bTryDirect = x;
}
-
ipaddr_t SocketHandler::GetSocks4Host()
{
return m_socks4_host;
}
-
port_t SocketHandler::GetSocks4Port()
{
return m_socks4_port;
}
-
const std::string& SocketHandler::GetSocks4Userid()
{
return m_socks4_userid;
}
-
bool SocketHandler::Socks4TryDirect()
{
return m_bTryDirect;
}
#endif
-
#ifdef ENABLE_RESOLVER
bool SocketHandler::ResolverEnabled()
{
return m_resolver ? true : false;
}
-
port_t SocketHandler::GetResolverPort()
{
return m_resolver_port;
}
#endif // ENABLE_RESOLVER
-
#ifdef ENABLE_POOL
ISocketHandler::PoolSocket *SocketHandler::FindConnection(int type,const std::string& protocol,SocketAddress& ad)
{
@@ -1193,20 +1156,17 @@ ISocketHandler::PoolSocket *SocketHandler::FindConnection(int type,const std::st
return NULL;
}
-
void SocketHandler::EnablePool(bool x)
{
m_b_enable_pool = x;
}
-
bool SocketHandler::PoolEnabled()
{
return m_b_enable_pool;
}
#endif
-
void SocketHandler::Remove(Socket *p)
{
#ifdef ENABLE_RESOLVER
@@ -1247,7 +1207,6 @@ void SocketHandler::Remove(Socket *p)
}
}
-
void SocketHandler::CheckSanity()
{
CheckList(m_fds, "active sockets"); // active sockets
@@ -1261,7 +1220,6 @@ void SocketHandler::CheckSanity()
CheckList(m_fds_close, "checklist close and delete");
}
-
void SocketHandler::CheckList(socket_v& ref,const std::string& listname)
{
for (socket_v::iterator it = ref.begin(); it != ref.end(); it++)
@@ -1288,7 +1246,6 @@ void SocketHandler::CheckList(socket_v& ref,const std::string& listname)
}
}
-
void SocketHandler::AddList(SOCKET s,list_t which_one,bool add)
{
if (s == INVALID_SOCKET)
@@ -1345,7 +1302,6 @@ DEB( fprintf(stderr, "AddList; %5d: %s: %s\n", s, (which_one == LIST_CALLONC
//DEB( fprintf(stderr, "/AddList\n");)
}
-
#ifdef ENABLE_TRIGGERS
int SocketHandler::TriggerID(Socket *src)
{
@@ -1354,7 +1310,6 @@ int SocketHandler::TriggerID(Socket *src)
return id;
}
-
bool SocketHandler::Subscribe(int id, Socket *dst)
{
if (m_trigger_src.find(id) != m_trigger_src.end())
@@ -1372,7 +1327,6 @@ bool SocketHandler::Subscribe(int id, Socket *dst)
return false;
}
-
bool SocketHandler::Unsubscribe(int id, Socket *dst)
{
if (m_trigger_src.find(id) != m_trigger_src.end())
@@ -1390,7 +1344,6 @@ bool SocketHandler::Unsubscribe(int id, Socket *dst)
return false;
}
-
void SocketHandler::Trigger(int id, Socket::TriggerData& data, bool erase)
{
if (m_trigger_src.find(id) != m_trigger_src.end())
@@ -1417,7 +1370,6 @@ void SocketHandler::Trigger(int id, Socket::TriggerData& data, bool erase)
}
#endif // ENABLE_TRIGGERS
-
#ifdef SOCKETS_NAMESPACE
}
#endif