A client server app with 2 processes, multithread, sneding data over network to eachother

				
//**************************************
// Name: A client server app with 2 processes, multithread, sneding data over network to eachother
// Description:Nice sample: multithreading Visual C++ application. 2 threads: sender and receiver. The multi-threaded app sends from one process to another over the network.
// By: Tako Griffith
//
//This code is copyrighted and has// limited warranties.Please see http://www.Planet-Source-Code.com/vb/scripts/ShowCode.asp?txtCodeId=7948&lngWId=3//for details.//**************************************

// ********************************************************************
// TCP/IP client/server communication sample
//Client/Server communication: 1 thread sends data, 1 thread receives data
//Requires freeware ASocket.dll to run the sample.
//Download it from http://www.vahland.com/asocket/asocket.dll
//and register it (REGSVR32 asocket.dll) on your machine.
//
// IMPORTANT: 
//Online manual: http://www.vahland.com/asocket/manual.htm
// ********************************************************************
#define _MT
#define _WIN32_DCOM
#include <comdef.h>
#include <atlbase.h>
#include <windows.h>
#include <process.h>
#include <stdio.h>
#include "..\include\ASocketConstants.h"
#include "..\include\ASocket_i.c"
#include "..\include\ASocket.h"
////////////////////////////////////////////////
#define	SAMPLETCPPORT	1500 
CRITICAL_SECTION		g_cs;
BOOL					g_bFinished = FALSE;
////////////////////////////////////////////////
void Print( LPSTR lpszMessage )
{
 EnterCriticalSection( &g_cs );
 printf( "%s\n", lpszMessage );
 LeaveCriticalSection( &g_cs );
}
////////////////////////////////////////////////
void SetFinished( BOOL bFinished )
{
 EnterCriticalSection( &g_cs );
 g_bFinished = bFinished;
 LeaveCriticalSection( &g_cs );
}
////////////////////////////////////////////////
BOOL IsFinished()
{
 BOOL	bIsFinished;
 EnterCriticalSection( &g_cs );
 bIsFinished = g_bFinished;
 LeaveCriticalSection( &g_cs );
 return bIsFinished;
}
////////////////////////////////////////////////
void ClientThread( void* pParams )
{
 HRESULThr;
 ISocket*pSocket = NULL;
 _bstr_tbstrHost = "127.0.0.1"; 
 _bstr_tbstrMesg[ 8 ];
 CHAR szMessage[ 1023 + 1 ];
 LONG lResult;
 inti;
 CoInitializeEx( NULL, COINIT_APARTMENTTHREADED );	// _WIN32_DCOM must be defined
 hr = CoCreateInstance(CLSID_Socket, NULL, CLSCTX_INPROC_SERVER, IID_ISocket, (void**) &pSocket);
 if( ! SUCCEEDED( hr ) )
 {
SetFinished( TRUE );
goto _EndClientThread;
 }
 pSocket->put_Protocol( asPROTOCOL_RAW );
 pSocket->Connect( bstrHost, SAMPLETCPPORT );
 pSocket->get_LastError( &lResult );
 sprintf( szMessage, "CLIENT - Connect: result = %d", lResult );
 Print( szMessage );
 if( lResult != asERR_SUCCESS ) 
 {
SetFinished( TRUE );
goto _EndClientThread;
 }
 bstrMesg[ 0 ] = "This is just a message";
 bstrMesg[ 1 ] = "And another message";
 bstrMesg[ 2 ] = "Quit";
 bstrMesg[ 3 ] = "";
 for( i = 0; i < 3; i++ )
 {
sprintf( szMessage, "CLIENT - Send : %s", ( char * ) bstrMesg[ i ] );
Print( szMessage );
pSocket->SendString( bstrMesg[ i ], 0 );
pSocket->Sleep( 3000 );
 }
_EndClientThread:
 if( pSocket != NULL )
 {
pSocket->Disconnect();	// Can be called at any time, even if socket is not open
pSocket->Release();
pSocket = NULL;
 }
}
////////////////////////////////////////////////
void ServerThread( void* pParams )
{
 HRESULThr;
 ISocket*pSocket = NULL;
 _bstr_tbstrHost = "127,0,0,1", bstrMesg = "", bstrReceived = "";
 BSTR bstrTemp;
 CHAR szMessage[ 1023 + 1 ];
 LONG lConnectionState, lResult;
 BOOL bHasData;
 CoInitializeEx( NULL, COINIT_APARTMENTTHREADED );	// _WIN32_DCOM must be defined
 hr = CoCreateInstance(CLSID_Socket, NULL, CLSCTX_INPROC_SERVER, IID_ISocket, (void**) &pSocket);
 if( ! SUCCEEDED( hr ) )
 {
Print( "CoCreateInstance failed" );
goto _EndServerThread;
 }
 pSocket->put_Protocol( asPROTOCOL_RAW );
 // Try to listen for a connection on port on this machine
 pSocket->StartListening( SAMPLETCPPORT );
 pSocket->get_LastError( &lResult );
 sprintf( szMessage, "SERVER - StartListening: result = %d", lResult ); 
 Print( szMessage );
 if( lResult != asERR_SUCCESS )
goto _EndServerThread;
 // Wait for a connection on port 1500 on this machine now...
 Print( "SERVER - Waiting for a connection..." );
 while( TRUE )
 {
 pSocket->get_ConnectionState( &lConnectionState );		
 if( lConnectionState != asCONN_LISTENING )
break;
 pSocket->Sleep( 1000 );
 }
 if( lConnectionState != asCONN_CONNECTED )
 {
Print( "SERVER - No Connection" );
goto _EndServerThread;
 }
 // YES, connection established.
 Print( "SERVER - Connection established" );
 while( TRUE )
 {
pSocket->get_ConnectionState( &lConnectionState );		
if( lConnectionState != asCONN_CONNECTED )
 break;
if( stricmp( ( char * ) bstrReceived, "Quit" ) == 0 )
 break;
pSocket->HasData( &bHasData );
if( bHasData )
{
 pSocket->ReceiveString( &bstrTemp );
 bstrReceived = bstrTemp;
 sprintf( szMessage, "SERVER - Received : %s", ( char * ) bstrReceived );
 Print( szMessage );
 pSocket->Sleep( 100 );
}
 }
_EndServerThread:
 if( pSocket != NULL )
 {
pSocket->Disconnect();	// Can be called at any time, even if socket is not open
Print( "SERVER - Socket closed" );
pSocket->Release();
pSocket = NULL;
 }
 SetFinished( TRUE );
}
////////////////////////////////////////////////
int main( void )
{ 
 InitializeCriticalSection( &g_cs );
 _beginthread( ServerThread, 0, NULL );
 Sleep( 3000 );
 _beginthread( ClientThread, 0, NULL );
 while( ! IsFinished() )
 {;
 }
 Print( "MAIN - READY!" );
 Sleep( 5000 );
 return 0;
}