From 0983a120d5ef82caa5a68262d6b3c02f6af08e43 Mon Sep 17 00:00:00 2001 From: fcolin Date: Thu, 1 Feb 2007 12:59:29 +0000 Subject: Utilisateur : Fcolin Date : 16/06/00 Heure : 10:14 Créé (vss 1) --- Bus/Ivy/IvyApplication.cxx | 307 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 307 insertions(+) create mode 100644 Bus/Ivy/IvyApplication.cxx (limited to 'Bus/Ivy/IvyApplication.cxx') diff --git a/Bus/Ivy/IvyApplication.cxx b/Bus/Ivy/IvyApplication.cxx new file mode 100644 index 0000000..26d0adf --- /dev/null +++ b/Bus/Ivy/IvyApplication.cxx @@ -0,0 +1,307 @@ +// IvyApplication.cpp : implementation file +// + +#include "stdafx.h" +//#include "libIvy.h" +#include "IvyApplication.h" +#include "Regexp.h" + +//#define DEBUG + +#define ARG_START "\002" +#define ARG_END "\003" + + +///////////////////////////////////////////////////////////////////////////// +// IvyApplication + +IvyApplication::IvyApplication(Ivy * bus) +{ + this->bus = bus; + remoteService = 0; /* unknown or unconnected application */ + appname = "Unknown"; + AppConnectedCallbackCalled = false; +} + +IvyApplication::~IvyApplication() +{ +// bus->RemoveApplication( this ); + for ( int i = 0; i < regexp_in.size(); i++) + delete regexp_in[i]; + regexp_in.clear(); + if ( m_hSocket != INVALID_SOCKET ) + Close(); +} + + +///////////////////////////////////////////////////////////////////////////// +// IvyApplication member functions + + +void IvyApplication::Create(const char* host, UINT & port) +{ + // Exception to catch + CBufferedSocket::Create(); + Connect(host, port); +} + + + +UINT IvyApplication::Create() +{ + string host; + UINT port; + CBufferedSocket::Create(); + // Max Listen Connexion + Listen( SOMAXCONN ); + GetSockName( host, port ); + TRACE(" TCP %s:%d\n", host.c_str(), port ); +#ifdef DEBUG + TRACE( "IvyApplication::Create server socket %d\n", m_hSocket ); +#endif + return port; +} + +void IvyApplication::OnReceive(char * line) +{ + int err,id; + int kind_of_msg = Bye; + Regexp *exp; + + + int argc = 0; + const char *argv[Regexp::NSUBEXP]; + char *arg; + +#ifdef DEBUG + TRACE("Receive %s\n",line); +#endif //DEBUG + + err = sscanf( line ,"%d %d", &kind_of_msg, &id); + arg = strstr( line , ARG_START ); + if ( (err != 2) || (arg == NULL) ) + { + TRACE("Quitting bad format %s\n", line); + SendMsg(Error, Error, "bad format request expected 'type id ...'"); +// bus->RemoveApplication( this ); + Close(); + return; + } + arg++; + switch( kind_of_msg ) + { + case Bye: + +#ifdef DEBUG + TRACE("Quitting %s\n", line); +#endif //DEBUG + +// bus->RemoveApplication( this ); + Close(); + break; + case Error: + +#ifdef DEBUG + TRACE("Receive error %d %s\n", id, arg); +#endif //DEBUG + + break; + case AddRegexp: + +#ifdef DEBUG + TRACE("Regexp id=%d exp='%s'\n", id, arg); +#endif //DEBUG + + if ( !bus->CheckRegexp( arg ) ) + { +#ifdef DEBUG + TRACE("Warning exp='%s' can't match removing from %s\n",arg,appname); +#endif //DEBUG + return; + } + exp = new Regexp( arg ); + if ( !exp->CompiledOK() ) + { + string regerr = exp->GetErrorString(); + string err; + err = "Error can't compile regexp '"+string(arg)+"' error "+regerr; + SendMsg( Error, Error, err.c_str() ); + TRACE("IvyApplication %s\n",err.c_str()); + return; + } + if ( id +1 < regexp_in.size() ) + regexp_in[ id ] = exp ; + else regexp_in.push_back( exp ); + break; + case DelRegexp: + +#ifdef DEBUG + TRACE("Regexp Delete id=%d\n", id); +#endif //DEBUG + if ( id < regexp_in.size() ) + { + exp = regexp_in[ id ]; + delete exp; + regexp_in[ id ] = NULL ; + } + break; + case StartRegexp: + +#ifdef DEBUG + TRACE("Regexp Start id=%d\n", id); +#endif //DEBUG + + appname = arg; + /* remote socket port */ + remoteService = id; + if ( bus->CheckConnected( this ) ) + { + TRACE("Quitting already connected %s\n", appname); + SendMsg( Error, Error, "already connected" ); +// bus->RemoveApplication( this ); + Close(); + } + break; + case EndRegexp: + +#ifdef DEBUG + TRACE("Regexp End id=%d\n", id); +#endif //DEBUG + + bus->CallApplicationConnectedCallback( this ); + AppConnectedCallbackCalled = true; + if ( !bus->ready_message.empty() ) + SendMsg( bus->ready_message.c_str() ); + break; + case Msg: + +#ifdef DEBUG + TRACE("Message id=%d msg='%s'\n", id, arg); +#endif //DEBUG + + arg = strtok( arg, ARG_END); + while ( arg ) + { + argv[argc++] = arg; + arg = strtok( NULL, ARG_END ); + } + bus->CallMessageCallback( this, id, argc, argv ); + break; + case DirectMsg: + +#ifdef DEBUG + TRACE("Direct Message id=%d msg='%s'\n", id, arg); +#endif //DEBUG + + bus->CallDirectMessageCallback( this, id, arg ); + break; + case Die: + +#ifdef DEBUG + TRACE("Die Message id=%d msg='%s'\n", id, arg); +#endif //DEBUG + + if ( bus->CallDieCallback( this, id, arg ) ) + { + PostMessage( NULL, WM_CLOSE, 0, 0); + } + break; + + default: + TRACE("Receive unhandled message %s\n", line); + break; + } +} + + +void IvyApplication::SendMsg(MsgType msg, int id, const char * arg) +{ + char buffer[1024]; + if ( arg ) + sprintf( buffer, "%d %d" ARG_START "%s\n", msg, id, arg ); + else sprintf( buffer, "%d %d" ARG_START "\n", msg, id ); + +#ifdef DEBUG + TRACE("SendMsg %s\n",buffer); +#endif //DEBUG + Send( buffer ); +} + +void IvyApplication::OnAccept(int nErrorCode) +{ + string remotehost; + UINT remoteport; + + // construct a new, empty socket + + IvyApplication *newapp = new IvyApplication(bus); + + // accept connection + + Accept( *newapp ); + newapp->GetPeerName( remotehost, remoteport ); + TRACE("Connexion de %s:%u\n", remotehost.c_str(), remoteport ); + bus->AddApplication( newapp ); +} + +void IvyApplication::OnClose(int nErrorCode) +{ + string remotehost; + UINT remoteport; + GetPeerName( remotehost, remoteport ); + TRACE("Deconnexion de %s:%u\n", remotehost.c_str(), remoteport ); + if ( AppConnectedCallbackCalled ) + bus->CallApplicationDisconnectedCallback( this ); +// bus->RemoveApplication( this ); + for ( int i = 0; i < regexp_in.size(); i++) + delete regexp_in[i]; + regexp_in.clear(); + Close(); +} + +int IvyApplication::SendMsg(const char *message) +{ + int count = 0; + Regexp *exp; + + /* send to already connected */ + for ( int id = 0; id < regexp_in.size(); id++ ) + { + exp = regexp_in[ id ]; + + if ( exp && exp->Match( message ) ) + { + string buffer; + for ( int i = 1; i < exp->SubStrings()+1; i++ ) + { + buffer += (*exp)[i]; + buffer += ARG_END; + } + SendMsg( Msg, id, buffer.c_str() ); + count++; + } + } + return count; +} + +const char *IvyApplication::GetName(void) +{ +return appname.c_str(); +} + + +BOOL IvyApplication::SameApplication(IvyApplication * app) +{ + string host1; + UINT port1; + string host2; + UINT port2; + if ( (remoteService != 0) && (remoteService == app->remoteService) ) + { + GetPeerName( host1, port1 ); + app->GetPeerName( host2, port2 ); + TRACE( "IvyApplication::SameApplication %s:%d %s:%d\n", host1.c_str(),port1, host2.c_str(),port2); + return ( host1 == host2 ); + } + return false; +} -- cgit v1.1