KjPerlServer.cpp

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2007 by Jan Koci   *
 *   honza.koci@email.cz   *
 *   http://kengine.sourceforge.net/tutorial/
 *                                                                         *
 *   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.             *
 ***************************************************************************/

#include "KjPerlServer.h"

KjPerlServer::KjPerlServer()
{
        cout << "KjPerlServer::KjPerlServer()" << endl;
        m_pServer = NULL;
        m_strReadMsg = "";
        m_strWriteMsg = "";
}

KjPerlServer::~KjPerlServer()
{
        cout << "KjPerlServer::~KjPerlServer()" << endl;
}

bool KjPerlServer::CanRead(const int _iClientId)
{
        if(m_pServer)
        {
                KjClientConn *pClient = m_pServer->GetClient(_iClientId);
                if(pClient)
                {
                        if(pClient->GetConn())
                        {
                                if(pClient->GetConn()->GetIsValid() == true)
                                {
                                        if(pClient->GetCanRead())
                                        {
                                                return true;
                                        }
                                }
                        }
                }
        }
        return false;
}

const char *KjPerlServer::Read(const int _iClientId)
{
        if(m_pServer)
        {
                KjClientConn *pClient = m_pServer->GetClient(_iClientId);
                if(pClient)
                {
                        if(pClient->GetConn())
                        {
                                if(pClient->GetConn()->GetIsValid() == true)
                                {
                                        m_strReadMsg = pClient->ReadMsg();
                                        return m_strReadMsg.c_str();
                                }
                        }
                }
        }
        m_strReadMsg = "Error: Client is disconnected !!!";
        return m_strReadMsg.c_str();
}

void KjPerlServer::Write(const int _iClientId, const char* _strMsg)
{
        if(m_pServer)
        {
                KjClientConn *pClient = m_pServer->GetClient(_iClientId);
                if(pClient)
                {
                        if(pClient->GetConn())
                        {
                                if(pClient->GetConn()->GetIsValid() == true)
                                {
                                        m_strWriteMsg = _strMsg;
                                        pClient->WriteMsg(m_strWriteMsg);
                                        return;
                                }
                        }
                }
        }
        cout << "Client id " << _iClientId << " is disconnected !!!" << endl;;
}

int KjPerlServer::GetNumClients()
{
        return m_pServer->GetNumClients();
}

void KjPerlServer::Connect(char* _strConn, const char* _strCertFile,const char* _strKeyFile)
{
        cout << "KjPerlServer::Connect()" << endl;
        m_pServer = new KjServerThread(_strConn, _strCertFile, _strKeyFile);
}

int KjPerlServer::Start()
{
        cout << "int KjPerlServer::Start()" << endl;
        cout << "this = " <<  this << endl;
        cout << "m_pServer = " <<  m_pServer << endl;
        if(m_pServer)
        {
                if(!m_pServer->Start())
                {
                        if(m_pServer)
                        {
                                delete m_pServer;
                                m_pServer = NULL;
                        }
                }
        }
        return 0;
}

---