X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FNetwork%2Fprops.cxx;h=3692a5cfe6ec49fed2c8197df9d5c780b1b61c99;hb=7d3448294bc7486af3f4c1f0ff5c8493b03ffc90;hp=7452f7b5daa1d7b904a7b041f2e298dda54896c8;hpb=4678a4db66dcbae92be1b322edf2cb10bd4537aa;p=flightgear.git diff --git a/src/Network/props.cxx b/src/Network/props.cxx index 7452f7b5d..3692a5cfe 100644 --- a/src/Network/props.cxx +++ b/src/Network/props.cxx @@ -21,13 +21,15 @@ // $Id$ -#include
#include #include #include #include #include +#include + +#include
#include // atoi() atof() @@ -38,6 +40,7 @@ #if !defined(SG_HAVE_NATIVE_SGI_COMPILERS) SG_USING_STD(cout); SG_USING_STD(istrstream); +SG_USING_STD(strstream); #endif FGProps::FGProps() { @@ -49,7 +52,7 @@ FGProps::~FGProps() { // open hailing frequencies bool FGProps::open() { - path = "/"; + reset(); if ( is_enabled() ) { SG_LOG( SG_IO, SG_ALERT, "This shouldn't happen, but the channel " @@ -71,6 +74,14 @@ bool FGProps::open() { } +// prepare for new connection +bool FGProps::reset() { + path = "/"; + mode = PROMPT; + return true; +} + + // return a human readable form of the value "type" static string getValueTypeString( const SGPropertyNode *node ) { string result; @@ -119,21 +130,43 @@ bool FGProps::process_command( const char *cmd ) { string command = tokens[0]; - SGPropertyNode * node = globals->get_props()->getNode(path); + SGPropertyNode * node = globals->get_props()->getNode(path.c_str()); if ( command == "ls" ) { - for (int i = 0; i < (int)node->nChildren(); i++) { - SGPropertyNode * child = node->getChild(i); + SGPropertyNode * dir = node; + if ( tokens.size() > 2 ) { + if ( tokens[1][0] == '/' ) { + dir = globals->get_props()->getNode(tokens[1].c_str()); + } else { + dir = globals->get_props()->getNode((path + "/" + tokens[1]).c_str()); + } + if ( dir == 0 ) { + tokens[1] = "ERR Node \"" + tokens[1] + "\" not found.\n"; + io->writestring( tokens[1].c_str() ); + return true; + } + } + + for (int i = 0; i < (int)dir->nChildren(); i++) { + SGPropertyNode * child = dir->getChild(i); string name = child->getName(); string line = name; + if ( dir->getChild(name.c_str(), 1) ) { + char buf[16]; + sprintf(buf, "[%d]", child->getIndex()); + line += buf; + } if ( child->nChildren() > 0 ) { - line += "/\n"; + line += "/"; } else { - string value = node->getStringValue ( name, "" ); - line += " =\t'" + value + "'\t("; - line += getValueTypeString( node->getNode( name ) ); - line += ")\n"; + if ( mode == PROMPT ) { + string value = dir->getStringValue ( name.c_str(), "" ); + line += " =\t'" + value + "'\t("; + line += getValueTypeString( dir->getNode( name.c_str() ) ); + line += ")"; + } } + line += "\n"; io->writestring( line.c_str() ); } } else if ( command == "dump" ) { @@ -143,12 +176,12 @@ bool FGProps::process_command( const char *cmd ) { io->writestring( buf.str() ); } else { - SGPropertyNode *child = node->getNode(tokens[1]); + SGPropertyNode *child = node->getNode(tokens[1].c_str()); if ( child ) { writeProperties ( buf, child ); io->writestring( buf.str() ); } else { - tokens[1] += " Not Found\n"; + tokens[1] = "ERR Node \"" + tokens[1] + "\" not found.\n"; io->writestring( tokens[1].c_str() ); } } @@ -159,18 +192,18 @@ bool FGProps::process_command( const char *cmd ) { if ( tokens.size() <= 1 ) { // do nothing } else { - SGPropertyNode *child = node->getNode(tokens[1]); + SGPropertyNode *child = node->getNode(tokens[1].c_str()); if ( child ) { node = child; path = node->getPath(); } else { - tokens[1] += " Not Found\n"; + tokens[1] = "ERR Node \"" + tokens[1] + "\" not found.\n"; io->writestring( tokens[1].c_str() ); } } } else if ( command == "pwd" ) { string ttt = node->getPath(); - if ( ttt == "" ) { + if ( ttt.empty() ) { ttt = "/"; } ttt += "\n"; @@ -179,56 +212,72 @@ bool FGProps::process_command( const char *cmd ) { if ( tokens.size() <= 1 ) { // do nothing } else { - string ttt = "debug = '" + tokens[1] + "'\n"; - io->writestring( ttt.c_str() ); - - string value = node->getStringValue ( tokens[1], "" ); - string tmp = tokens[1] + " = '" + value + "' ("; - tmp += getValueTypeString( node->getNode( tokens[1] ) ); - tmp += ")\n"; - + string tmp; + string value = node->getStringValue ( tokens[1].c_str(), "" ); + if ( mode == PROMPT ) { + tmp = tokens[1] + " = '" + value + "' ("; + tmp += getValueTypeString( node->getNode( tokens[1].c_str() ) ); + tmp += ")\n"; + } else { + tmp = value + "\n"; + } io->writestring( tmp.c_str() ); } } else if ( command == "set" ) { if ( tokens.size() <= 2 ) { // do nothing } else { - node->getNode( tokens[1], true )->setStringValue(tokens[2]); - - // now fetch and write out the new value as confirmation - // of the change - string value = node->getStringValue ( tokens[1], "" ); - string tmp = tokens[1] + " = '" + value + "' ("; - tmp += getValueTypeString( node->getNode( tokens[1] ) ); - tmp += ")\n"; - - io->writestring( tmp.c_str() ); + string tmp = tokens[2]; + for ( unsigned int i = 3; i < tokens.size() - 1; i++ ) { + tmp += " " + tokens[i]; + } + node->getNode( tokens[1].c_str(), true )->setStringValue(tmp.c_str()); + + if ( mode == PROMPT ) { + // now fetch and write out the new value as confirmation + // of the change + string value = node->getStringValue ( tokens[1].c_str(), "" ); + string tmp = tokens[1] + " = '" + value + "' ("; + tmp += getValueTypeString( node->getNode( tokens[1].c_str() ) ); + tmp += ")\n"; + + io->writestring( tmp.c_str() ); + } } } else if ( command == "quit" ) { close(); + reset(); + return true; + } else if ( command == "data" ) { + mode = DATA; + } else if ( command == "prompt" ) { + mode = PROMPT; } else { io->writestring( "\n" ); io->writestring( "Valid commands are:\n" ); io->writestring( "\n" ); io->writestring( "help show help message\n" ); - io->writestring( "ls list current directory\n" ); + io->writestring( "ls [] list directory\n" ); io->writestring( "dump dump current state (in xml)\n" ); io->writestring( "cd cd to a directory, '..' to move back\n" ); io->writestring( "pwd display your current path\n" ); io->writestring( "get show the value of a parameter\n" ); io->writestring( "show synonym for get\n" ); io->writestring( "set set to a new \n" ); + io->writestring( "data switch to raw data mode\n" ); + io->writestring( "prompt switch to interactive mode (default)\n" ); io->writestring( "quit terminate connection\n" ); io->writestring( "\n" ); } - string prompt = node->getPath(); - if ( prompt == "" ) { - prompt = "/"; + if ( mode == PROMPT ) { + string prompt = node->getPath(); + if ( prompt.empty() ) { + prompt = "/"; + } + prompt += "> "; + io->writestring( prompt.c_str() ); } - prompt += "> "; - io->writestring( prompt.c_str() ); - return true; } @@ -236,6 +285,7 @@ bool FGProps::process_command( const char *cmd ) { // process work for this port bool FGProps::process() { SGIOChannel *io = get_io_channel(); + char buf[max_cmd_len]; // cout << "processing incoming props command" << endl; @@ -258,8 +308,6 @@ bool FGProps::process() { bool FGProps::close() { SGIOChannel *io = get_io_channel(); - set_enabled( false ); - if ( ! io->close() ) { return false; }