aboutsummaryrefslogtreecommitdiffstats
path: root/src/modules/ident/libkviident.cpp
diff options
context:
space:
mode:
authorGravatar Alexey Sokolov2016-04-29 23:57:30 +0100
committerGravatar Alexey Sokolov2016-04-29 23:57:48 +0100
commit690dd7a33ddc90678367d73adf313533536e10f2 (patch)
tree2276fe7c384ebbc222b40a19c536d5c3c5606ce8 /src/modules/ident/libkviident.cpp
parentAdd config for clang-format. (diff)
downloadKVIrc-690dd7a33ddc90678367d73adf313533536e10f2.tar.gz
KVIrc-690dd7a33ddc90678367d73adf313533536e10f2.tar.bz2
KVIrc-690dd7a33ddc90678367d73adf313533536e10f2.zip
Apply clang-format
Diffstat (limited to 'src/modules/ident/libkviident.cpp')
-rw-r--r--src/modules/ident/libkviident.cpp324
1 files changed, 172 insertions, 152 deletions
diff --git a/src/modules/ident/libkviident.cpp b/src/modules/ident/libkviident.cpp
index d79924bf7..8ec10f718 100644
--- a/src/modules/ident/libkviident.cpp
+++ b/src/modules/ident/libkviident.cpp
@@ -37,7 +37,6 @@
#define KVI_IDENT_THREAD_EVENT_EXITING KVI_THREAD_USER_EVENT_BASE + 111
#define KVI_IDENT_THREAD_EVENT_EXITING_ON_REQUEST KVI_THREAD_USER_EVENT_BASE + 112
-
// FIXME: Should have a timeout on the requests!!!
static KviIdentDaemon * g_pIdentDaemon = 0;
@@ -47,9 +46,11 @@ extern KVIRC_API int g_iIdentDaemonRunningUsers;
void startIdentService()
{
-// qDebug("Stargin");
- if(!g_pIdentDaemon)g_pIdentDaemon = new KviIdentDaemon();
- if(!g_pIdentDaemon->isRunning())g_pIdentDaemon->start();
+ // qDebug("Stargin");
+ if(!g_pIdentDaemon)
+ g_pIdentDaemon = new KviIdentDaemon();
+ if(!g_pIdentDaemon->isRunning())
+ g_pIdentDaemon->start();
while(g_pIdentDaemon->isStartingUp())
{
#if defined(COMPILE_ON_WINDOWS) || defined(COMPILE_ON_MINGW)
@@ -58,19 +59,20 @@ void startIdentService()
usleep(100);
#endif
}
-// qDebug("Service started");
+ // qDebug("Service started");
}
void stopIdentService()
{
-// qDebug("Stopping");
- if(g_pIdentDaemon)delete g_pIdentDaemon;
+ // qDebug("Stopping");
+ if(g_pIdentDaemon)
+ delete g_pIdentDaemon;
g_pIdentDaemon = 0;
-// qDebug("Stopped");
+ // qDebug("Stopped");
}
KviIdentSentinel::KviIdentSentinel()
-: QObject(0)
+ : QObject(0)
{
}
@@ -79,13 +81,12 @@ KviIdentSentinel::~KviIdentSentinel()
KviThreadManager::killPendingEvents(this);
}
-bool KviIdentSentinel::event(QEvent *e)
+bool KviIdentSentinel::event(QEvent * e)
{
- if(KVI_OPTION_UINT(KviOption_uintIdentdOutputMode)==KviIdentdOutputMode::Quiet || !g_pActiveWindow)
+ if(KVI_OPTION_UINT(KviOption_uintIdentdOutputMode) == KviIdentdOutputMode::Quiet || !g_pActiveWindow)
return QObject::event(e);
- KviWindow * pTarget = KVI_OPTION_UINT(KviOption_uintIdentdOutputMode)==KviIdentdOutputMode::ToActiveWindow ?
- (KviWindow *)g_pActiveWindow : (KviWindow *)g_pApp->activeConsole();
+ KviWindow * pTarget = KVI_OPTION_UINT(KviOption_uintIdentdOutputMode) == KviIdentdOutputMode::ToActiveWindow ? (KviWindow *)g_pActiveWindow : (KviWindow *)g_pApp->activeConsole();
if(e->type() == KVI_THREAD_EVENT)
{
@@ -99,29 +100,37 @@ bool KviIdentSentinel::event(QEvent *e)
if(d->szAux.hasData())
{
if(_OUTPUT_PARANOIC)
- pTarget->output(KVI_OUT_IDENT,__tr("%s (%s) (%s:%u)"),d->szMessage.ptr(),d->szAux.ptr(),d->szHost.ptr(),d->uPort);
+ pTarget->output(KVI_OUT_IDENT, __tr("%s (%s) (%s:%u)"), d->szMessage.ptr(), d->szAux.ptr(), d->szHost.ptr(), d->uPort);
else
- pTarget->output(KVI_OUT_IDENT,__tr("%s (%s)"),d->szMessage.ptr(),d->szAux.ptr());
- } else {
+ pTarget->output(KVI_OUT_IDENT, __tr("%s (%s)"), d->szMessage.ptr(), d->szAux.ptr());
+ }
+ else
+ {
if(_OUTPUT_PARANOIC)
- pTarget->output(KVI_OUT_IDENT,__tr("%s (%s:%u)"),d->szMessage.ptr(),d->szHost.ptr(),d->uPort);
+ pTarget->output(KVI_OUT_IDENT, __tr("%s (%s:%u)"), d->szMessage.ptr(), d->szHost.ptr(), d->uPort);
else
- pTarget->output(KVI_OUT_IDENT,__tr("%s"),d->szMessage.ptr());
+ pTarget->output(KVI_OUT_IDENT, __tr("%s"), d->szMessage.ptr());
}
- } else {
- pTarget->output(KVI_OUT_IDENT,__tr("[IDENT]: %s"),d->szMessage.ptr());
+ }
+ else
+ {
+ pTarget->output(KVI_OUT_IDENT, __tr("[IDENT]: %s"), d->szMessage.ptr());
}
}
delete d;
- } else if(((KviThreadEvent *)e)->id() == KVI_IDENT_THREAD_EVENT_EXITING)
+ }
+ else if(((KviThreadEvent *)e)->id() == KVI_IDENT_THREAD_EVENT_EXITING)
{
if(_OUTPUT_VERBOSE)
- if(pTarget)pTarget->outputNoFmt(KVI_OUT_IDENT,__tr("Shutting down Ident service (spontaneous action)"));
+ if(pTarget)
+ pTarget->outputNoFmt(KVI_OUT_IDENT, __tr("Shutting down Ident service (spontaneous action)"));
stopIdentService();
- } else if(((KviThreadEvent *)e)->id() == KVI_IDENT_THREAD_EVENT_EXITING_ON_REQUEST)
+ }
+ else if(((KviThreadEvent *)e)->id() == KVI_IDENT_THREAD_EVENT_EXITING_ON_REQUEST)
{
if(_OUTPUT_VERBOSE)
- if(pTarget)pTarget->outputNoFmt(KVI_OUT_IDENT,__tr("Shutting down Ident service (requested action)"));
+ if(pTarget)
+ pTarget->outputNoFmt(KVI_OUT_IDENT, __tr("Shutting down Ident service (requested action)"));
}
return true;
@@ -130,8 +139,7 @@ bool KviIdentSentinel::event(QEvent *e)
return QObject::event(e);
}
-
-KviIdentRequest::KviIdentRequest(kvi_socket_t sock,const char * host,kvi_u32_t uPort)
+KviIdentRequest::KviIdentRequest(kvi_socket_t sock, const char * host, kvi_u32_t uPort)
{
m_sock = sock;
m_szHost = host;
@@ -144,13 +152,13 @@ KviIdentRequest::~KviIdentRequest()
kvi_socket_close(m_sock);
}
-
KviIdentDaemon::KviIdentDaemon()
-: KviSensitiveThread()
+ : KviSensitiveThread()
{
-// qDebug("Thread constructor");
+ // qDebug("Thread constructor");
m_szUser = KVI_OPTION_STRING(KviOption_stringIdentdUser);
- if(m_szUser.isEmpty())m_szUser = "kvirc";
+ if(m_szUser.isEmpty())
+ m_szUser = "kvirc";
m_uPort = KVI_OPTION_UINT(KviOption_uintIdentdPort);
#ifdef COMPILE_IPV6_SUPPORT
m_bEnableIPv6 = KVI_OPTION_BOOL(KviOption_boolIdentdEnableIPv6);
@@ -158,42 +166,43 @@ KviIdentDaemon::KviIdentDaemon()
m_bEnableIPv6 = false;
#endif
m_bIPv6ContainsIPv4 = KVI_OPTION_BOOL(KviOption_boolIdentdIPv6ContainsIPv4);
-// qDebug("Thread constructor done");
+ // qDebug("Thread constructor done");
}
KviIdentDaemon::~KviIdentDaemon()
{
-// qDebug("Thread destructor");
+ // qDebug("Thread destructor");
terminate();
g_iIdentDaemonRunningUsers = 0;
g_pIdentDaemon = 0;
-// qDebug("Destructor gone");
+ // qDebug("Destructor gone");
}
-void KviIdentDaemon::postMessage(const char * message,KviIdentRequest * r,const char * szAux)
+void KviIdentDaemon::postMessage(const char * message, KviIdentRequest * r, const char * szAux)
{
KviThreadDataEvent<KviIdentMessageData> * e = new KviThreadDataEvent<KviIdentMessageData>(KVI_THREAD_EVENT_DATA);
KviIdentMessageData * d = new KviIdentMessageData;
d->szMessage = message;
- if(szAux)d->szAux = szAux;
+ if(szAux)
+ d->szAux = szAux;
if(r)
{
d->szHost = r->m_szHost;
- d->uPort = r->m_uPort;
+ d->uPort = r->m_uPort;
}
e->setData(d);
- postEvent(g_pIdentSentinel,e);
+ postEvent(g_pIdentSentinel, e);
}
void KviIdentDaemon::run()
{
-// qDebug("RUN STARTED");
- m_sock = KVI_INVALID_SOCKET;
+ // qDebug("RUN STARTED");
+ m_sock = KVI_INVALID_SOCKET;
m_sock6 = KVI_INVALID_SOCKET;
bool bEventPosted = false;
@@ -206,109 +215,106 @@ void KviIdentDaemon::run()
#ifdef COMPILE_IPV6_SUPPORT
// If we have enabled ipv6 and we have to use a single socket: this one is IPV6
// otherwise this one is IPV4
- KviSockaddr sa(m_uPort,m_bEnableIPv6 && m_bIPv6ContainsIPv4);
+ KviSockaddr sa(m_uPort, m_bEnableIPv6 && m_bIPv6ContainsIPv4);
#else
- KviSockaddr sa(m_uPort,false);
+ KviSockaddr sa(m_uPort, false);
#endif
KviIdentRequest * r;
#ifdef COMPILE_IPV6_SUPPORT
- m_sock = kvi_socket_create((m_bEnableIPv6 && m_bIPv6ContainsIPv4) ? KVI_SOCKET_PF_INET6 : KVI_SOCKET_PF_INET,KVI_SOCKET_TYPE_STREAM,KVI_SOCKET_PROTO_TCP);
+ m_sock = kvi_socket_create((m_bEnableIPv6 && m_bIPv6ContainsIPv4) ? KVI_SOCKET_PF_INET6 : KVI_SOCKET_PF_INET, KVI_SOCKET_TYPE_STREAM, KVI_SOCKET_PROTO_TCP);
#else
- m_sock = kvi_socket_create(KVI_SOCKET_PF_INET,KVI_SOCKET_TYPE_STREAM,KVI_SOCKET_PROTO_TCP);
+ m_sock = kvi_socket_create(KVI_SOCKET_PF_INET, KVI_SOCKET_TYPE_STREAM, KVI_SOCKET_PROTO_TCP);
#endif
if(m_sock == KVI_INVALID_SOCKET)
{
- postMessage(__tr("Can't start the Ident service : socket() failed"),0);
+ postMessage(__tr("Can't start the Ident service : socket() failed"), 0);
goto exit_thread;
}
if(!kvi_socket_setNonBlocking(m_sock))
{
- postMessage(__tr("Can't start the Ident service : async setting failed"),0);
+ postMessage(__tr("Can't start the Ident service : async setting failed"), 0);
goto exit_thread;
}
if(!sa.socketAddress())
{
- postMessage(__tr("Can't enable the Ident service : can't setup the listen address"),0);
+ postMessage(__tr("Can't enable the Ident service : can't setup the listen address"), 0);
goto exit_thread;
}
- if(!kvi_socket_bind(m_sock,sa.socketAddress(),((int)(sa.addressLength()))))
+ if(!kvi_socket_bind(m_sock, sa.socketAddress(), ((int)(sa.addressLength()))))
{
- postMessage(__tr("Can't start the Ident service : bind() failed"),0);
+ postMessage(__tr("Can't start the Ident service : bind() failed"), 0);
goto exit_thread;
}
- if(!kvi_socket_listen(m_sock,128))
+ if(!kvi_socket_listen(m_sock, 128))
{
- postMessage(__tr("Can't start the Ident service : listen() failed"),0);
+ postMessage(__tr("Can't start the Ident service : listen() failed"), 0);
goto exit_thread;
}
-
#ifdef COMPILE_IPV6_SUPPORT
if(m_bEnableIPv6 && (!m_bIPv6ContainsIPv4))
{
// Need to start the IPV6 socket too
- KviSockaddr sa6(m_uPort,true);
- m_sock6 = kvi_socket_create(KVI_SOCKET_PF_INET6,KVI_SOCKET_TYPE_STREAM,KVI_SOCKET_PROTO_TCP);
+ KviSockaddr sa6(m_uPort, true);
+ m_sock6 = kvi_socket_create(KVI_SOCKET_PF_INET6, KVI_SOCKET_TYPE_STREAM, KVI_SOCKET_PROTO_TCP);
if(m_sock6 == KVI_INVALID_SOCKET)
{
- postMessage(__tr("Can't start the Ident service on IPv6 : socket() failed"),0);
+ postMessage(__tr("Can't start the Ident service on IPv6 : socket() failed"), 0);
goto ipv6_failure;
}
if(!kvi_socket_setNonBlocking(m_sock6))
{
- postMessage(__tr("Can't start the Ident service on IPv6 : async setting failed"),0);
+ postMessage(__tr("Can't start the Ident service on IPv6 : async setting failed"), 0);
kvi_socket_close(m_sock6);
m_sock6 = KVI_INVALID_SOCKET;
goto ipv6_failure;
}
- #if defined(COMPILE_ON_WINDOWS) || defined(COMPILE_ON_MINGW)
- /*
+#if defined(COMPILE_ON_WINDOWS) || defined(COMPILE_ON_MINGW)
+ /*
* under windows, ipv6 hosts behind an ipv4 NAT can use Teredo to be reachable from the outer internet using their
* ipv6 address; the default protection level doesn't permit this, so we need to set this socket option
* see bug ticket #393
*/
- int iPlu = KVI_PROTECTION_LEVEL_UNRESTRICTED;
- if(!kvi_socket_setsockopt(m_sock6,KVI_IPPROTO_IPV6,KVI_IPV6_PROTECTION_LEVEL,(const void*)&iPlu, sizeof(iPlu)))
+ int iPlu = KVI_PROTECTION_LEVEL_UNRESTRICTED;
+ if(!kvi_socket_setsockopt(m_sock6, KVI_IPPROTO_IPV6, KVI_IPV6_PROTECTION_LEVEL, (const void *)&iPlu, sizeof(iPlu)))
{
//this is not a fatal error
- postMessage(__tr("Can't set the IPv6 Ident service protection level to unrestricted: the Ident service won't be exposed to the internet"),0);
+ postMessage(__tr("Can't set the IPv6 Ident service protection level to unrestricted: the Ident service won't be exposed to the internet"), 0);
}
- #endif
+#endif
if(!sa6.socketAddress())
{
- postMessage(__tr("Can't enable the Ident service on IPv6 : can't setup the listen address"),0);
+ postMessage(__tr("Can't enable the Ident service on IPv6 : can't setup the listen address"), 0);
kvi_socket_close(m_sock6);
m_sock6 = KVI_INVALID_SOCKET;
goto ipv6_failure;
}
- if(!kvi_socket_bind(m_sock6,sa6.socketAddress(),((int)(sa6.addressLength()))))
+ if(!kvi_socket_bind(m_sock6, sa6.socketAddress(), ((int)(sa6.addressLength()))))
{
- postMessage(__tr("Can't start the Ident service on IPv6 : bind() failed"),0);
+ postMessage(__tr("Can't start the Ident service on IPv6 : bind() failed"), 0);
kvi_socket_close(m_sock6);
m_sock6 = KVI_INVALID_SOCKET;
goto ipv6_failure;
-
}
- if(!kvi_socket_listen(m_sock6,128))
+ if(!kvi_socket_listen(m_sock6, 128))
{
- postMessage(__tr("Can't start the Ident service on IPv6 : listen() failed"),0);
+ postMessage(__tr("Can't start the Ident service on IPv6 : listen() failed"), 0);
kvi_socket_close(m_sock6);
m_sock6 = KVI_INVALID_SOCKET;
goto ipv6_failure;
}
-
}
#endif
@@ -317,24 +323,27 @@ ipv6_failure:
#ifdef COMPILE_IPV6_SUPPORT
if(m_bEnableIPv6)
{
- if(m_sock6 != KVI_INVALID_SOCKET) {
+ if(m_sock6 != KVI_INVALID_SOCKET)
+ {
if(_OUTPUT_PARANOIC)
- postMessage(__tr("Starting Ident service (IPv4/v6 on separate namespaces)"),0);
- } else {
+ postMessage(__tr("Starting Ident service (IPv4/v6 on separate namespaces)"), 0);
+ }
+ else
+ {
if(_OUTPUT_PARANOIC)
- postMessage(__tr("Starting Ident service (IPv4/v6 in IPv6 namespace)"),0);
+ postMessage(__tr("Starting Ident service (IPv4/v6 in IPv6 namespace)"), 0);
}
-
- } else {
+ }
+ else
+ {
if(_OUTPUT_PARANOIC)
- postMessage(__tr("Starting Ident service (IPv4)"),0);
+ postMessage(__tr("Starting Ident service (IPv4)"), 0);
}
-#else //!COMPILE_IPV6_SUPPORT
+#else //!COMPILE_IPV6_SUPPORT
if(_OUTPUT_PARANOIC)
- postMessage(__tr("Service startup (IPv4)"),0);
+ postMessage(__tr("Service startup (IPv4)"), 0);
#endif //!COMPILE_IPV6_SUPPORT
-
for(;;)
{
if(KviThreadEvent * e = dequeueEvent())
@@ -355,52 +364,55 @@ ipv6_failure:
if(m_sock != KVI_INVALID_SOCKET)
{
- FD_SET(m_sock,&rs);
- if(((unsigned int)m_sock) > ((unsigned int)nmax))nmax = m_sock;
+ FD_SET(m_sock, &rs);
+ if(((unsigned int)m_sock) > ((unsigned int)nmax))
+ nmax = m_sock;
}
#ifdef COMPILE_IPV6_SUPPORT
if(m_sock6 != KVI_INVALID_SOCKET)
{
- FD_SET(m_sock6,&rs);
- if(((unsigned int)m_sock6) > ((unsigned int)nmax))nmax = m_sock6;
+ FD_SET(m_sock6, &rs);
+ if(((unsigned int)m_sock6) > ((unsigned int)nmax))
+ nmax = m_sock6;
}
#endif
- for(r = m_pRequestList->first();r;r = m_pRequestList->next())
+ for(r = m_pRequestList->first(); r; r = m_pRequestList->next())
{
- FD_SET(r->m_sock,&rs);
- if(((unsigned int)r->m_sock) > ((unsigned int)nmax))nmax = r->m_sock;
+ FD_SET(r->m_sock, &rs);
+ if(((unsigned int)r->m_sock) > ((unsigned int)nmax))
+ nmax = r->m_sock;
}
// FIXME: SO_REUSEADDR ?
+ int ret = kvi_socket_select(nmax + 1, &rs, 0, 0, &t);
- int ret = kvi_socket_select(nmax + 1,&rs,0,0,&t);
-
-
- if(ret == 0)msleep(100);
- else {
-
+ if(ret == 0)
+ msleep(100);
+ else
+ {
if(m_sock != KVI_INVALID_SOCKET)
{
- if(FD_ISSET(m_sock,&rs))
+ if(FD_ISSET(m_sock, &rs))
{
#ifdef COMPILE_IPV6_SUPPORT
- KviSockaddr satmp(0,m_bEnableIPv6 && m_bIPv6ContainsIPv4);
+ KviSockaddr satmp(0, m_bEnableIPv6 && m_bIPv6ContainsIPv4);
#else
- KviSockaddr satmp(0,false);
+ KviSockaddr satmp(0, false);
#endif
int salen = (int)satmp.addressLength();
- kvi_socket_t t = kvi_socket_accept(m_sock,satmp.socketAddress(),&salen);
+ kvi_socket_t t = kvi_socket_accept(m_sock, satmp.socketAddress(), &salen);
if(t != KVI_INVALID_SOCKET)
{
QString szHost;
- if(!satmp.getStringAddress(szHost))szHost = "unknown";
- KviIdentRequest * r = new KviIdentRequest(t,szHost.toUtf8().data(),satmp.port());
+ if(!satmp.getStringAddress(szHost))
+ szHost = "unknown";
+ KviIdentRequest * r = new KviIdentRequest(t, szHost.toUtf8().data(), satmp.port());
m_pRequestList->append(r);
- postMessage(__tr("Ident service accepting connection"),r);
+ postMessage(__tr("Ident service accepting connection"), r);
}
}
}
@@ -408,54 +420,59 @@ ipv6_failure:
#ifdef COMPILE_IPV6_SUPPORT
if(m_sock6 != KVI_INVALID_SOCKET)
{
- if(FD_ISSET(m_sock6,&rs))
+ if(FD_ISSET(m_sock6, &rs))
{
- KviSockaddr satmp(0,true);
+ KviSockaddr satmp(0, true);
int salen = (int)satmp.addressLength();
- kvi_socket_t t = kvi_socket_accept(m_sock6,satmp.socketAddress(),&salen);
+ kvi_socket_t t = kvi_socket_accept(m_sock6, satmp.socketAddress(), &salen);
if(t != KVI_INVALID_SOCKET)
{
QString szHost;
- if(!satmp.getStringAddress(szHost))szHost = "unknown";
- KviIdentRequest * r = new KviIdentRequest(t,szHost.toUtf8().data(),satmp.port());
+ if(!satmp.getStringAddress(szHost))
+ szHost = "unknown";
+ KviIdentRequest * r = new KviIdentRequest(t, szHost.toUtf8().data(), satmp.port());
m_pRequestList->append(r);
- postMessage(__tr("Ident service accepting connection"),r);
+ postMessage(__tr("Ident service accepting connection"), r);
}
}
}
#endif
- for(r = m_pRequestList->first();r;r = m_pRequestList->next())
+ for(r = m_pRequestList->first(); r; r = m_pRequestList->next())
{
- if(FD_ISSET(r->m_sock,&rs))
+ if(FD_ISSET(r->m_sock, &rs))
{
char buffer[1025];
- int readed = kvi_socket_recv(r->m_sock,buffer,1024);
+ int readed = kvi_socket_recv(r->m_sock, buffer, 1024);
if(readed > 0)
{
buffer[readed] = '\0';
r->m_szData.append(buffer);
- } else {
+ }
+ else
+ {
// error ?
if(readed < 0)
{
int err = kvi_socket_error();
if(!kvi_socket_recoverableConnectError(err))
{
- postMessage(__tr("Ident service socket error : dropping connection"),r);
+ postMessage(__tr("Ident service socket error : dropping connection"), r);
dying.append(r);
}
- } else {
+ }
+ else
+ {
// connection closed
- postMessage(__tr("Ident service connection closed by remote host"),r);
+ postMessage(__tr("Ident service connection closed by remote host"), r);
dying.append(r);
}
}
}
}
- for(r = m_pRequestList->first();r;r = m_pRequestList->next())
+ for(r = m_pRequestList->first(); r; r = m_pRequestList->next())
{
int idx = r->m_szData.findFirstIdx('\n');
@@ -469,77 +486,79 @@ ipv6_failure:
if(szReq.hasData())
{
- postMessage(__tr("Ident service processing request"),r,szReq.ptr());
+ postMessage(__tr("Ident service processing request"), r, szReq.ptr());
- if(kvi_strEqualCI("VERSION",szReq.ptr()))
+ if(kvi_strEqualCI("VERSION", szReq.ptr()))
{
KviCString reply("Quad-Echelon 7.12-r-244");
- kvi_socket_write(r->m_sock,reply.ptr(),reply.len());
- } else {
- KviCString reply(KviCString::Format,"%s : USERID : UNIX : %s\r\n",szReq.ptr(),m_szUser.ptr());
- kvi_socket_write(r->m_sock,reply.ptr(),reply.len());
+ kvi_socket_write(r->m_sock, reply.ptr(), reply.len());
+ }
+ else
+ {
+ KviCString reply(KviCString::Format, "%s : USERID : UNIX : %s\r\n", szReq.ptr(), m_szUser.ptr());
+ kvi_socket_write(r->m_sock, reply.ptr(), reply.len());
}
dying.append(r);
+ }
+ else
+ {
- } else {
-
- postMessage(__tr("Empty request (EOT ?)"),r,szReq.ptr());
+ postMessage(__tr("Empty request (EOT ?)"), r, szReq.ptr());
dying.append(r);
}
-
- } else {
+ }
+ else
+ {
// qDebug("Data is : (%s)",r->m_szData.ptr());
if(r->m_szData.len() > 1024)
{
// request too long...kill it
dying.append(r);
- postMessage(__tr("Dropping connection (request too long)"),r);
+ postMessage(__tr("Dropping connection (request too long)"), r);
}
}
-
}
}
time_t curTime = time(0);
- for(r = m_pRequestList->first();r;r = m_pRequestList->next())
+ for(r = m_pRequestList->first(); r; r = m_pRequestList->next())
{
if((unsigned int)(curTime - r->m_tStart) > 30)
{
- postMessage(__tr("Timed out while waiting for the request : dropping connection"),r);
+ postMessage(__tr("Timed out while waiting for the request : dropping connection"), r);
dying.append(r);
}
}
- for(KviIdentRequest * ir = dying.first();ir;ir = dying.next())
- m_pRequestList->removeRef(ir);
+ for(KviIdentRequest * ir = dying.first(); ir; ir = dying.next())
+ m_pRequestList->removeRef(ir);
dying.clear();
-
}
exit_on_request:
- postEvent(g_pIdentSentinel,new KviThreadEvent(KVI_IDENT_THREAD_EVENT_EXITING_ON_REQUEST));
+ postEvent(g_pIdentSentinel, new KviThreadEvent(KVI_IDENT_THREAD_EVENT_EXITING_ON_REQUEST));
bEventPosted = true;
exit_thread:
if(!bEventPosted)
- postEvent(g_pIdentSentinel,new KviThreadEvent(KVI_IDENT_THREAD_EVENT_EXITING));
-
+ postEvent(g_pIdentSentinel, new KviThreadEvent(KVI_IDENT_THREAD_EVENT_EXITING));
- if(m_sock != KVI_INVALID_SOCKET)kvi_socket_close(m_sock);
- if(m_sock6 != KVI_INVALID_SOCKET)kvi_socket_close(m_sock6);
+ if(m_sock != KVI_INVALID_SOCKET)
+ kvi_socket_close(m_sock);
+ if(m_sock6 != KVI_INVALID_SOCKET)
+ kvi_socket_close(m_sock6);
delete m_pRequestList;
m_pRequestList = 0;
-// qDebug("RUN EXITING");
+ // qDebug("RUN EXITING");
}
-
/*
@doc: ident.start
@type:
@@ -583,16 +602,18 @@ static bool ident_kvs_cmd_start(KviKvsModuleCommandCall *)
static bool ident_kvs_cmd_stop(KviKvsModuleCommandCall *)
{
- if(g_iIdentDaemonRunningUsers) g_iIdentDaemonRunningUsers--;
- if(!g_iIdentDaemonRunningUsers) stopIdentService();
+ if(g_iIdentDaemonRunningUsers)
+ g_iIdentDaemonRunningUsers--;
+ if(!g_iIdentDaemonRunningUsers)
+ stopIdentService();
return true;
}
-static bool ident_module_init(KviModule *m)
+static bool ident_module_init(KviModule * m)
{
g_pIdentSentinel = new KviIdentSentinel();
- KVSM_REGISTER_SIMPLE_COMMAND(m,"start",ident_kvs_cmd_start);
- KVSM_REGISTER_SIMPLE_COMMAND(m,"stop",ident_kvs_cmd_stop);
+ KVSM_REGISTER_SIMPLE_COMMAND(m, "start", ident_kvs_cmd_start);
+ KVSM_REGISTER_SIMPLE_COMMAND(m, "stop", ident_kvs_cmd_stop);
return true;
}
@@ -611,13 +632,12 @@ static bool ident_module_can_unload(KviModule *)
}
KVIRC_MODULE(
- "Ident", // module name
- "4.0.0", // module version
- "Copyright (C) 2001 Szymon Stefanek (pragma at kvirc dot net)", // author & (C)
- "Ident service",
- ident_module_init,
- ident_module_can_unload,
- 0,
- ident_module_cleanup,
- 0
-)
+ "Ident", // module name
+ "4.0.0", // module version
+ "Copyright (C) 2001 Szymon Stefanek (pragma at kvirc dot net)", // author & (C)
+ "Ident service",
+ ident_module_init,
+ ident_module_can_unload,
+ 0,
+ ident_module_cleanup,
+ 0)