fly/flightgear
1
0
Fork 0
Code Activity

Fixes so that we can read incoming broadcast packets (so we can have multiple

Browse source 
channels driven from one broadcast source.)
This commit is contained in:
curt 2002-07-31 23:24:55 +00:00
parent ff6a2ab520
commit acdd550a2f
1 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/FDM/ExternalNet.cxx
View file

@ -307,14 +307,15 @@ FGExternalNet::FGExternalNet( double dt, string host, int dop, int dip, int cp )
valid = false; valid = false;
} }
// we want to block for incoming data in order to syncronize frame // disable blocking
// rates. data_server.setBlocking( false );
data_server.setBlocking( false /* don't block while testing */ );
// data_server.setBlocking( true /* don't block while testing */ ); // allowed to read from a broadcast addr
data_server.setBroadcast( true );
// if we bind to fdm_host = "" then we accept messages from // if we bind to fdm_host = "" then we accept messages from
// anyone. // anyone.
if ( data_server.bind( fdm_host.c_str(), data_in_port ) == -1 ) { if ( data_server.bind( "", data_in_port ) == -1 ) {
printf("error binding to port %d\n", data_in_port); printf("error binding to port %d\n", data_in_port);
valid = false; valid = false;
} }
@ -361,9 +362,13 @@ void FGExternalNet::init() {
new HTTPClient( fdm_host.c_str(), cmd_port, cmd ); new HTTPClient( fdm_host.c_str(), cmd_port, cmd );
netChannel::loop(0); netChannel::loop(0);
SG_LOG( SG_IO, SG_INFO, "before sending reset command." );
sprintf( cmd, "/reset?value=ground" ); sprintf( cmd, "/reset?value=ground" );
new HTTPClient( fdm_host.c_str(), cmd_port, cmd ); new HTTPClient( fdm_host.c_str(), cmd_port, cmd );
netChannel::loop(0); netChannel::loop(0);
SG_LOG( SG_IO, SG_INFO, "Remote FDM init() finished." );
} }
@ -387,7 +392,7 @@ void FGExternalNet::update( double dt ) {
// Read next set of FDM data (blocking enabled to maintain 'sync') // Read next set of FDM data (blocking enabled to maintain 'sync')
length = sizeof(fdm); length = sizeof(fdm);
while ( (result = data_server.recv( (char *)(& fdm), length, 0)) >= 0 ) { while ( (result = data_server.recv( (char *)(& fdm), length, 0)) >= 0 ) {
SG_LOG( SG_IO, SG_DEBUG, "Success reading data." ); SG_LOG( SG_IO, SG_INFO, "Success reading data." );
net2global( &fdm ); net2global( &fdm );
} }
} }