KjPerlServerThread.pl

Go to the documentation of this file.

#!/usr/bin/perl -w
# file KjPerlServer.pl
# Perl server test using KjSslSocket library
#
# Author: Jan Koci <honza.koci@email.cz> (C) 2007
# http://kjsslsocket.sourceforge.net/
#
# Copyright: See COPYING file that comes with this distribution
#
# 07.05.09 - First version      
#
#

#***************************************************************************
 #   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.             *
 #***************************************************************************/


use KjPerlServer;
use threads;
use threads::shared;

# ----- Object creation -----
my $g_pServer =new KjPerlServer::KjPerlServer();
print "    Created g_pKjServer $g_pServer\n";
my $g_bIsConnected = 0;

sub NewThread
{
        print "In the thread\n";
        #In new thread start server
        $g_pServer->Start();
}

sub ConnectServer
{
        my $strConn = 'localhost:4444';
        my $strCertFile = '/etc/kjssl/test.crt';
        my $strKeyFile = '/etc/kjssl/test.key';
        print("Try connection ssl server \n");
        print("Connection:  $strConn\n");
        print("Cert file:  $strCertFile\n");
        print("Key file:  $strKeyFile\n");
        $g_pServer->Connect($strConn, $strCertFile, $strKeyFile);
        $g_bIsConnected = 1;
}

sub Start
{
        if(!$g_pServer)
        {
                print "Error:: Start -- pServer can`t allocated !!! \n";
                return 0;
    }
        ConnectServer();
        if($g_bIsConnected == 1)
        {
                $thr = threads->new(\&NewThread);
                for (;;) 
                {
                        my $iNumClients = $g_pServer->GetNumClients();
                        # Go through all clients
                        for($i=0; $i<$iNumClients; $i++)
                        {
                                # If can read client
                                if($g_pServer->CanRead($i))
                                {
                                        print "Client id = $i can read ... \n";
                                        # Read client message
                                        my $strReadMsg = $g_pServer->Read($i);
                                        print "strReadMsg = $strReadMsg \n";
                                        print " \n";
                                        # Write client message
                                        my $strWriteMsg = "Client id $i reads next message... $strReadMsg";
                                        $g_pServer->Write($i, $strWriteMsg);
                                }
                        }
                }
        }
        return 0;
}

if(&Start() == 0)
{
        if($g_pServer)
        {
                print "g_pServer now Destroyed\n";
                $g_pServer->DESTROY();
        }
        print "Goodbye\n";
}

---