116 lines
3.1 KiB
C++
116 lines
3.1 KiB
C++
// NeL - MMORPG Framework <http://dev.ryzom.com/projects/nel/>
|
|
// Copyright (C) 2010 Winch Gate Property Limited
|
|
//
|
|
// This program is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU Affero General Public License as
|
|
// published by the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Affero General Public License
|
|
// along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
|
|
/*
|
|
* Layer 4 example, client.
|
|
*
|
|
* This client connects to a front-end server at localhost:37000.
|
|
* It sends pings and expects pongs (ping replies).
|
|
*/
|
|
|
|
|
|
// We're using NeL
|
|
#include "nel/misc/types_nl.h"
|
|
#include "nel/misc/debug.h"
|
|
using namespace NLMISC;
|
|
|
|
// We're using the layer 4
|
|
#include "nel/net/net_manager.h"
|
|
using namespace NLNET;
|
|
|
|
|
|
// Name of the front-end service
|
|
const char SVC [3] = "FS";
|
|
|
|
|
|
/*
|
|
* Callback function called when receiving a "PONG" message
|
|
*
|
|
* Arguments:
|
|
* - msgin: the incoming message
|
|
* - from: the "sockid" of the sender (usually useless for a CCallbackClient)
|
|
* - client: the CCallbackNetBase object (which really is a CCallbackClient object, for a client)
|
|
*
|
|
* Input (expected message): PONG
|
|
* - uint32: ping counter
|
|
*
|
|
* Output (sent message): PING
|
|
* - uint32: new ping counter
|
|
*/
|
|
void cbPong( CMessage& msgin, TSockId from, CCallbackNetBase& client )
|
|
{
|
|
uint32 counter;
|
|
|
|
// Input
|
|
msgin.serial( counter );
|
|
nlinfo( "Received PONG number %u", counter );
|
|
|
|
counter++;
|
|
|
|
// Output
|
|
CMessage msgout ( "PING" );
|
|
msgout.serial( counter );
|
|
CNetManager::send( SVC, msgout );
|
|
nlinfo( "Sent PING number %u", counter );
|
|
}
|
|
|
|
|
|
/*
|
|
* Callback array
|
|
*/
|
|
TCallbackItem CallbackArray[] =
|
|
{
|
|
{ "PONG", cbPong } // when receiving a "PONG" message, call cbPong()
|
|
};
|
|
|
|
|
|
/*
|
|
* main
|
|
*/
|
|
void main( int argc, char **argv )
|
|
{
|
|
try
|
|
{
|
|
// Initialize (we don't call CNetManager::init() because we don't use the naming service)
|
|
|
|
// Connect to the front-end server at localhost:37000
|
|
CNetManager::addClient( SVC, "localhost:37000" );
|
|
CNetManager::addCallbackArray( SVC, CallbackArray, sizeof(CallbackArray)/sizeof(CallbackArray[0]) );
|
|
|
|
// Send a PING message
|
|
uint32 counter = 0;
|
|
CMessage msg( "PING" ); // create the message
|
|
msg.serial( counter ); // serialize the counter into the message
|
|
CNetManager::send( SVC, msg ); // put into the send queue
|
|
nlinfo( "Sent PING number %u", counter );
|
|
|
|
// Main loop
|
|
while ( CNetManager::getNetBase( SVC )->connected() )
|
|
{
|
|
// Perform sends and receives, call callbacks
|
|
CNetManager::update();
|
|
}
|
|
|
|
nlinfo( "Disconnected" );
|
|
|
|
// We don't call CNetManager::release() because we didn't call CNetManager::init()
|
|
}
|
|
catch ( Exception &e )
|
|
{
|
|
nlerror( "Error: %s", e.what() );
|
|
}
|
|
}
|