// Created: 27.06.2005
// RCS-ID: $Id$
// Copyright: (c) 2005 Lukasz Michalski <lmichalski@user.sourceforge.net>
-// Licence: wxWindows license
+// Licence: wxWindows licence
/////////////////////////////////////////////////////////////////////////////
// ============================================================================
//and list of two type worker classes that serve clients
class Server : public wxApp
{
- DECLARE_EVENT_TABLE();
+ DECLARE_EVENT_TABLE()
public:
Server() : m_maxConnections(-1) {}
~Server() {}
long int m_maxConnections;
- long m_port;
+ unsigned short m_port;
wxTimer mTimer;
};
void DoWrite();
void DoRead();
- DECLARE_EVENT_TABLE();
+ DECLARE_EVENT_TABLE()
};
/******************* Implementation ******************/
if ((int)(m_threadWorkersDone+m_eventWorkersDone) == m_maxConnections)
{
- wxLogMessage("%d connection(s) served, exiting",m_maxConnections);
+ wxLogMessage("%ld connection(s) served, exiting",m_maxConnections);
ExitMainLoop();
}
}
if (pParser.Found("m",&m_maxConnections))
{
- wxLogMessage("%d connection(s) to exit",m_maxConnections);
+ wxLogMessage("%ld connection(s) to exit",m_maxConnections);
}
- if (pParser.Found("p",&m_port))
+ long port;
+ if (pParser.Found("p", &port))
{
- wxLogMessage("%d connection(s) to exit",m_maxConnections);
+ if ( port <= 0 || port > USHRT_MAX )
+ {
+ wxLogError("Invalid port number %ld, must be in 0..%u range.",
+ port, USHRT_MAX);
+ return false;
+ }
+
+ m_port = static_cast<unsigned short>(port);
+ wxLogMessage("Will listen on port %u", m_port);
}
if (pParser.Found("t"))
m_listeningSocket->SetEventHandler(*this);
m_listeningSocket->SetNotify(wxSOCKET_CONNECTION_FLAG);
m_listeningSocket->Notify(true);
- if (!m_listeningSocket->Ok())
+ if (!m_listeningSocket->IsOk())
{
wxLogError("Cannot bind listening socket");
return false;
m_eventWorkersFailed = 0;
m_maxEventWorkers = 0;
- wxLogMessage("Server listening at port %d, waiting for connections", m_port);
+ wxLogMessage("Server listening at port %u, waiting for connections", m_port);
return true;
}
{
if (it->GetData() == pEvent.m_sender)
{
- wxLogVerbose("Deleting thread worker (%d left)",
- m_threadWorkers.GetCount());
+ wxLogVerbose("Deleting thread worker (%lu left)",
+ static_cast<unsigned long>( m_threadWorkers.GetCount() ));
it->GetData()->Wait();
delete it->GetData();
m_threadWorkers.DeleteNode(it);
{
if (it2->GetData() == pEvent.m_sender)
{
- wxLogVerbose("Deleting event worker (%d left)",
- m_eventWorkers.GetCount());
+ wxLogVerbose("Deleting event worker (%lu left)",
+ static_cast<unsigned long>( m_eventWorkers.GetCount() ));
delete it2->GetData();
m_eventWorkers.DeleteNode(it2);
if (!pEvent.m_workerFailed)
if (m_size == m_infill)
{
m_signature[0] = m_signature[1] = 0x0;
- delete [] m_inbuf;
- m_inbuf = NULL;
+ wxDELETEA(m_inbuf);
m_infill = 0;
return;
}
{
if (m_written == m_size)
{
- delete [] m_outbuf;
- m_outbuf = NULL;
+ wxDELETEA(m_outbuf);
m_outfill = 0;
LogWorker( "All data written");
return;