2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
///////////////////////
|
|
|
|
|
// Name: eda_dde.cpp //
|
|
|
|
|
///////////////////////
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
|
|
|
|
// For compilers that support precompilation, includes "wx/wx.h".
|
|
|
|
|
#include <wx/wxprec.h>
|
|
|
|
|
|
|
|
|
|
#ifdef __BORLANDC__
|
2007-08-14 19:24:48 +00:00
|
|
|
|
#pragma hdrstop
|
2007-06-05 12:10:51 +00:00
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
// for all others, include the necessary headers
|
|
|
|
|
#ifndef WX_PRECOMP
|
|
|
|
|
#include <wx/wx.h>
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
#include "fctsys.h"
|
|
|
|
|
#include "eda_dde.h"
|
|
|
|
|
#include "wxstruct.h"
|
|
|
|
|
#include "id.h"
|
|
|
|
|
|
|
|
|
|
#include "common.h"
|
|
|
|
|
#include "macros.h"
|
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
wxString HOSTNAME( wxT( "localhost" ) );
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
|
|
|
|
/* variables locales */
|
|
|
|
|
|
|
|
|
|
// buffers for read and write data in socket connections
|
|
|
|
|
#define IPC_BUF_SIZE 4096
|
2007-08-14 19:24:48 +00:00
|
|
|
|
char client_ipc_buffer[IPC_BUF_SIZE];
|
|
|
|
|
char server_ipc_buffer[IPC_BUF_SIZE];
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
wxServer* server;
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
void (*RemoteFct)(const char* cmd);
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
char buffcar[1024];
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
void SetupServerFunction( void (*remotefct)(const char* remotecmd) )
|
2007-06-05 12:10:51 +00:00
|
|
|
|
{
|
2007-08-14 19:24:48 +00:00
|
|
|
|
RemoteFct = remotefct;
|
2007-06-05 12:10:51 +00:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
/*****************************/
|
|
|
|
|
/* Routines liees au SERVEUR */
|
|
|
|
|
/*****************************/
|
|
|
|
|
|
2007-06-05 12:10:51 +00:00
|
|
|
|
/* Fonction d'initialisation d'un serveur socket
|
2007-08-14 19:24:48 +00:00
|
|
|
|
*/
|
|
|
|
|
WinEDA_Server* CreateServer( wxWindow* window, int service )
|
2007-06-05 12:10:51 +00:00
|
|
|
|
{
|
2007-08-14 19:24:48 +00:00
|
|
|
|
wxIPV4address addr;
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
// Create a new server
|
|
|
|
|
addr.Service( service );
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
server = new wxServer( addr );
|
|
|
|
|
if( server )
|
|
|
|
|
{
|
|
|
|
|
server->SetNotify( wxSOCKET_CONNECTION_FLAG );
|
|
|
|
|
server->SetEventHandler( *window, ID_EDA_SOCKET_EVENT_SERV );
|
|
|
|
|
server->Notify( TRUE );
|
|
|
|
|
}
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
return server;
|
2007-06-05 12:10:51 +00:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/********************************************************/
|
2007-08-14 19:24:48 +00:00
|
|
|
|
void WinEDA_DrawFrame::OnSockRequest( wxSocketEvent& evt )
|
2007-06-05 12:10:51 +00:00
|
|
|
|
/********************************************************/
|
2007-08-14 19:24:48 +00:00
|
|
|
|
|
2007-06-05 12:10:51 +00:00
|
|
|
|
/* Fonction appelee a chaque demande d'un client
|
2007-08-14 19:24:48 +00:00
|
|
|
|
*/
|
2007-06-05 12:10:51 +00:00
|
|
|
|
{
|
2007-08-14 19:24:48 +00:00
|
|
|
|
size_t len;
|
|
|
|
|
wxSocketBase* sock = evt.GetSocket();
|
|
|
|
|
|
|
|
|
|
switch( evt.GetSocketEvent() )
|
|
|
|
|
{
|
|
|
|
|
case wxSOCKET_INPUT:
|
|
|
|
|
sock->Read( server_ipc_buffer, 1 );
|
|
|
|
|
if( sock->LastCount() == 0 )
|
|
|
|
|
break; // No data: Occurs on open connection
|
|
|
|
|
|
|
|
|
|
sock->Read( server_ipc_buffer + 1, IPC_BUF_SIZE - 2 );
|
|
|
|
|
len = 1 + sock->LastCount();
|
|
|
|
|
server_ipc_buffer[len] = 0;
|
|
|
|
|
if( RemoteFct )
|
|
|
|
|
RemoteFct( server_ipc_buffer );
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
case wxSOCKET_LOST:
|
|
|
|
|
return;
|
|
|
|
|
break;
|
|
|
|
|
|
|
|
|
|
default:
|
|
|
|
|
wxPrintf( wxT( "WinEDA_DrawFrame::OnSockRequest() error: Invalid event !" ) );
|
|
|
|
|
break;
|
|
|
|
|
}
|
2007-06-05 12:10:51 +00:00
|
|
|
|
}
|
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
|
2007-06-05 12:10:51 +00:00
|
|
|
|
/**************************************************************/
|
2007-08-14 19:24:48 +00:00
|
|
|
|
void WinEDA_DrawFrame::OnSockRequestServer( wxSocketEvent& evt )
|
2007-06-05 12:10:51 +00:00
|
|
|
|
/**************************************************************/
|
2007-08-14 19:24:48 +00:00
|
|
|
|
|
2007-06-05 12:10:51 +00:00
|
|
|
|
/* fonction appel<65>e lors d'une demande de connexion d'un client
|
2007-08-14 19:24:48 +00:00
|
|
|
|
*/
|
2007-06-05 12:10:51 +00:00
|
|
|
|
{
|
2007-08-14 19:24:48 +00:00
|
|
|
|
wxSocketBase* sock2;
|
|
|
|
|
wxSocketServer* server = (wxSocketServer*) evt.GetSocket();
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
|
|
|
|
sock2 = server->Accept();
|
2007-08-14 19:24:48 +00:00
|
|
|
|
if( sock2 == NULL )
|
|
|
|
|
return;
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
sock2->Notify( TRUE );
|
|
|
|
|
sock2->SetEventHandler( *this, ID_EDA_SOCKET_EVENT );
|
|
|
|
|
sock2->SetNotify( wxSOCKET_INPUT_FLAG | wxSOCKET_LOST_FLAG );
|
2007-06-05 12:10:51 +00:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
/****************************/
|
|
|
|
|
/* Routines liees au CLIENT */
|
|
|
|
|
/*****************************/
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
/**************************************************/
|
|
|
|
|
bool SendCommand( int service, const char* cmdline )
|
|
|
|
|
/**************************************************/
|
2007-06-05 12:10:51 +00:00
|
|
|
|
|
2007-08-14 19:24:48 +00:00
|
|
|
|
/* Used by a client to sent (by a socket connection) a data to a server.
|
|
|
|
|
* - Open a Socket Client connection
|
|
|
|
|
* - Send the buffer cmdline
|
|
|
|
|
* - Close the socket connection
|
|
|
|
|
*
|
|
|
|
|
* service is the service number for the TC/IP connection
|
|
|
|
|
*/
|
2007-06-05 12:10:51 +00:00
|
|
|
|
{
|
2007-08-14 19:24:48 +00:00
|
|
|
|
wxSocketClient* sock_client;
|
|
|
|
|
bool success = FALSE;
|
|
|
|
|
wxIPV4address addr;
|
|
|
|
|
|
|
|
|
|
// Create a connexion
|
|
|
|
|
addr.Hostname( HOSTNAME );
|
|
|
|
|
addr.Service( service );
|
|
|
|
|
|
|
|
|
|
// Mini-tutorial for Connect() :-) (JP CHARRAS Note: see wxWidgets: sockets/client.cpp sample)
|
|
|
|
|
// ---------------------------
|
|
|
|
|
//
|
|
|
|
|
// There are two ways to use Connect(): blocking and non-blocking,
|
|
|
|
|
// depending on the value passed as the 'wait' (2nd) parameter.
|
|
|
|
|
//
|
|
|
|
|
// Connect(addr, true) will wait until the connection completes,
|
|
|
|
|
// returning true on success and false on failure. This call blocks
|
|
|
|
|
// the GUI (this might be changed in future releases to honour the
|
|
|
|
|
// wxSOCKET_BLOCK flag).
|
|
|
|
|
//
|
|
|
|
|
// Connect(addr, false) will issue a nonblocking connection request
|
|
|
|
|
// and return immediately. If the return value is true, then the
|
|
|
|
|
// connection has been already successfully established. If it is
|
|
|
|
|
// false, you must wait for the request to complete, either with
|
|
|
|
|
// WaitOnConnect() or by watching wxSOCKET_CONNECTION / LOST
|
|
|
|
|
// events (please read the documentation).
|
|
|
|
|
//
|
|
|
|
|
// WaitOnConnect() itself never blocks the GUI (this might change
|
|
|
|
|
// in the future to honour the wxSOCKET_BLOCK flag). This call will
|
|
|
|
|
// return false on timeout, or true if the connection request
|
|
|
|
|
// completes, which in turn might mean:
|
|
|
|
|
//
|
|
|
|
|
// a) That the connection was successfully established
|
|
|
|
|
// b) That the connection request failed (for example, because
|
|
|
|
|
// it was refused by the peer.
|
|
|
|
|
//
|
|
|
|
|
// Use IsConnected() to distinguish between these two.
|
|
|
|
|
//
|
|
|
|
|
// So, in a brief, you should do one of the following things:
|
|
|
|
|
//
|
|
|
|
|
// For blocking Connect:
|
|
|
|
|
//
|
|
|
|
|
// bool success = client->Connect(addr, true);
|
|
|
|
|
//
|
|
|
|
|
// For nonblocking Connect:
|
|
|
|
|
//
|
|
|
|
|
// client->Connect(addr, false);
|
|
|
|
|
//
|
|
|
|
|
// bool waitmore = true;
|
|
|
|
|
// while (! client->WaitOnConnect(seconds, millis) && waitmore )
|
|
|
|
|
// {
|
|
|
|
|
// // possibly give some feedback to the user,
|
|
|
|
|
// // update waitmore if needed.
|
|
|
|
|
// }
|
|
|
|
|
// bool success = client->IsConnected();
|
|
|
|
|
//
|
|
|
|
|
// And that's all :-)
|
|
|
|
|
|
|
|
|
|
sock_client = new wxSocketClient();
|
|
|
|
|
sock_client->SetTimeout( 2 ); // Time out in Seconds
|
|
|
|
|
sock_client->Connect( addr, FALSE );
|
|
|
|
|
sock_client->WaitOnConnect( 0, 100 );
|
|
|
|
|
|
|
|
|
|
if( sock_client->Ok() && sock_client->IsConnected() )
|
|
|
|
|
{
|
|
|
|
|
success = TRUE;
|
|
|
|
|
sock_client->SetFlags( wxSOCKET_NOWAIT /*wxSOCKET_WAITALL*/ );
|
|
|
|
|
sock_client->Write( cmdline, strlen( cmdline ) );
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
sock_client->Close();
|
|
|
|
|
sock_client->Destroy();
|
|
|
|
|
return success;
|
2007-06-05 12:10:51 +00:00
|
|
|
|
}
|