src/Network/props.cxx

   1 // props.hxx -- FGFS property manager interaction class
   2 //
   3 // Written by Curtis Olson, started September 2000.
   4 //
   5 // Copyright (C) 2000  Curtis L. Olson - curt@flightgear.org
   6 //
   7 // This program is free software; you can redistribute it and/or
   8 // modify it under the terms of the GNU General Public License as
   9 // published by the Free Software Foundation; either version 2 of the
  10 // License, or (at your option) any later version.
  11 //
  12 // This program is distributed in the hope that it will be useful, but
  13 // WITHOUT ANY WARRANTY; without even the implied warranty of
  14 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15 // General Public License for more details.
  16 //
  17 // You should have received a copy of the GNU General Public License
  18 // along with this program; if not, write to the Free Software
  19 // Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  20 //
  21 // $Id$
  22
  23
  24 #include <simgear/compiler.h>
  25 #include <simgear/debug/logstream.hxx>
  26 #include <simgear/io/iochannel.hxx>
  27 #include <simgear/math/sg_types.hxx>
  28
  29 #include <strstream>
  30
  31 #include "props.hxx"
  32
  33 FG_USING_STD(cout);
  34 FG_USING_STD(istrstream);
  35
  36 FGProps::FGProps() {
  37 }
  38
  39 FGProps::~FGProps() {
  40 }
  41
  42
  43 // open hailing frequencies
  44 bool FGProps::open() {
  45     if ( is_enabled() ) {
  46         FG_LOG( FG_IO, FG_ALERT, "This shouldn't happen, but the channel "
  47                 << "is already in use, ignoring" );
  48         return false;
  49     }
  50
  51     SGIOChannel *io = get_io_channel();
  52
  53     if ( ! io->open( get_direction() ) ) {
  54         FG_LOG( FG_IO, FG_ALERT, "Error opening channel communication layer." );
  55         return false;
  56     }
  57
  58     set_enabled( true );
  59
  60     return true;
  61 }
  62
  63
  64 bool FGProps::process_command( const char *cmd ) {
  65     cout << "processing command = " << cmd << endl;
  66     string_list tokens;
  67     tokens.clear();
  68
  69     istrstream in(cmd);
  70
  71     while ( !in.eof() ) {
  72         string token;
  73         in >> token;
  74         tokens.push_back( token );
  75     }
  76
  77     string command = tokens[0];
  78
  79     if ( command == "ls" ) {
  80
  81     }
  82
  83     return true;
  84 }
  85
  86
  87 // process work for this port
  88 bool FGProps::process() {
  89     SGIOChannel *io = get_io_channel();
  90
  91     cout << "processing incoming props command" << endl;
  92
  93     if ( get_direction() == SG_IO_BI ) {
  94         cout << "  (bi directional)" << endl;
  95         while ( io->read( buf, max_cmd_len ) > 0 ) {
  96             FG_LOG( FG_IO, FG_ALERT, "Success reading data." );
  97             process_command( buf );
  98         }
  99     } else {
 100         FG_LOG( FG_IO, FG_ALERT,
 101                 "in or out direction not supported for FGProps." );
 102     }
 103
 104     return true;
 105 }
 106
 107
 108 // close the channel
 109 bool FGProps::close() {
 110     SGIOChannel *io = get_io_channel();
 111
 112     set_enabled( false );
 113
 114     if ( ! io->close() ) {
 115         return false;
 116     }
 117
 118     return true;
 119 }