Subversion Repositories w11

// $Id: RtclRlinkServer.cpp 513 2013-05-01 14:02:06Z mueller $
//
// Copyright 2013- by Walter F.J. Mueller <W.F.J.Mueller@gsi.de>
//
// This program is free software; you may redistribute and/or modify it under
// the terms of the GNU General Public License as published by the Free
// Software Foundation, either version 2, or at your option any later version.
//
// This program is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY, without even the implied warranty of MERCHANTABILITY
// or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
// for complete details.
// 
// Revision History: 
// Date         Rev Version  Comment
// 2013-05-01   513   1.0.5  TraceLevel now uint32_t
// 2013-04-26   510   1.0.4  change M_attn, now -info instead of -show
// 2013-04-21   509   1.0.3  add server -resume
// 2013-02-05   483   1.0.2  ClassCmdConfig: use RtclArgs
// 2013-02-05   482   1.0.1  add shared_ptr to RlinkConnect object
// 2013-01-12   474   1.0    Initial version
// ---------------------------------------------------------------------------
 
/*!
  \file
  \version $Id: RtclRlinkServer.cpp 513 2013-05-01 14:02:06Z mueller $
  \brief   Implemenation of class RtclRlinkServer.
 */
 
#include <ctype.h>
 
#include <stdexcept>
#include <iostream>
#include <vector>
#include <string>
#include <memory>
 
#include "boost/bind.hpp"
 
#include "librtools/RosPrintBvi.hpp"
#include "librtcltools/Rtcl.hpp"
#include "librtcltools/RtclOPtr.hpp"
#include "librtcltools/RtclStats.hpp"
#include "librtcltools/RtclContext.hpp"
#include "RtclRlinkConnect.hpp"
 
#include "RtclRlinkServer.hpp"
 
using namespace std;
 
/*!
  \class Retro::RtclRlinkServer
  \brief FIXME_docs
*/
 
// all method definitions in namespace Retro
namespace Retro {
 
//------------------------------------------+-----------------------------------
//! Default constructor
 
RtclRlinkServer::RtclRlinkServer(Tcl_Interp* interp, const char* name)
  : RtclProxyOwned<RlinkServer>("RlinkServer", interp, name, 
                                new RlinkServer()),
    fspConn()
{
  AddMeth("server",   boost::bind(&RtclRlinkServer::M_server,  this, _1));
  AddMeth("attn",     boost::bind(&RtclRlinkServer::M_attn,    this, _1));
  AddMeth("stats",    boost::bind(&RtclRlinkServer::M_stats,   this, _1));
  AddMeth("print",    boost::bind(&RtclRlinkServer::M_print,   this, _1));
  AddMeth("dump",     boost::bind(&RtclRlinkServer::M_dump,    this, _1));
  AddMeth("$default", boost::bind(&RtclRlinkServer::M_default, this, _1));
}
 
//------------------------------------------+-----------------------------------
//! Destructor
 
RtclRlinkServer::~RtclRlinkServer()
{
  for (alist_it_t it = fAttnHdl.begin(); it != fAttnHdl.end(); it++) {
    delete (*it);
  }
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::ClassCmdConfig(RtclArgs& args)
{
  string parent;
  if (!args.GetArg("parent", parent)) return kERR;
 
  // locate RlinkConnect proxy and object -> setup Server->Connect linkage
  RtclProxyBase* pprox = RtclContext::Find(args.Interp()).FindProxy(
                            "RlinkConnect", parent);
  if (pprox == 0) 
    return args.Quit(string("-E: object '") + parent + 
                     "' not found or not type RlinkConnect");
 
  // make RtclRlinkServer object be co-owner of RlinkConnect object
  fspConn = dynamic_cast<RtclRlinkConnect*>(pprox)->ObjSPtr();
  // set RlinkConnect in RlinkServer (make RlinkServer also co-owner)
  Obj().SetConnect(fspConn);
 
  return kOK;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::M_server(RtclArgs& args)
{
  static RtclNameSet optset("-start|-stop|-resume|-test|-trace");
  string opt;
  if (args.NextOpt(opt, optset)) {
    if        (opt == "-start") {           // server -start
      if (!args.AllDone()) return kERR;
      Obj().Start();
    } else if (opt == "-stop") {            // server -stop
      if (!args.AllDone()) return kERR;
      Obj().Stop();
    } else if (opt == "-resume") {          // server -resume
      if (!args.AllDone()) return kERR;
      Obj().Resume();
    } else if (opt == "-test") {            // server -test
      if (!args.AllDone()) return kERR;
      args.SetResult(Obj().IsActive());
    } else if (opt == "-trace") {           // server -trace ...
      uint32_t level;
      if (!args.GetArg("?level", level)) return kERR;
      if (args.NOptMiss()==0) {             // server -trace level
        Obj().SetTraceLevel(level);
      } else {                              // server -trace
        args.SetResult((int)Obj().TraceLevel());
      }
    }
 
  } else {                                  // server
    if (!args.OptValid()) return kERR;
    if (!args.AllDone()) return kERR;
    args.SetResult(Obj().IsActive());
  }
 
  return kOK;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::M_attn(RtclArgs& args)
{
  static RtclNameSet optset("-add|-remove|-info|-test|-list");
 
  Tcl_Interp* interp = args.Interp();
 
  string opt;
 
  if (args.NextOpt(opt, optset)) {
    if        (opt == "-add") {             // attn -add mask script
      uint16_t mask=0;
      Tcl_Obj* script=0;
      if (!args.GetArg("mask", mask,0xff,1)) return kERR;
      if (!args.GetArg("script", script)) return kERR;
      if (!args.AllDone()) return kERR;
 
      unique_ptr<RtclAttnShuttle> p(new RtclAttnShuttle(mask, script));
      try {
        p->Add(&Obj(), interp);
      } catch (exception& e) {
        return args.Quit(string("-E: handler rejected: ")+e.what());
      }
      fAttnHdl.push_back(p.release());
      return kOK;
 
    } else if (opt == "-remove") {            // attn -remove mask
      uint16_t mask=0;
      if (!args.GetArg("mask", mask)) return kERR;
      if (!args.AllDone()) return kERR;
      for (alist_it_t it = fAttnHdl.end(); it != fAttnHdl.begin(); ) {
        it--;
        if ((*it)->Mask() == mask) {
          fAttnHdl.erase(it);
          delete (*it);
          return kOK;
        }
      }
      return args.Quit(string("-E: no handler defined for '") +
                       args.PeekArgString(-1) + "'");
 
    } else if (opt == "-info") {            // attn -info mask
      uint16_t mask=0;
      if (!args.GetArg("mask", mask)) return kERR;
      if (!args.AllDone()) return kERR;
      RtclOPtr pres(Tcl_NewListObj(0,0));
      for (alist_it_t it = fAttnHdl.begin(); it != fAttnHdl.end(); it++) {
        if ((*it)->Mask() & mask) {
          RtclOPtr pele(Tcl_NewListObj(0,0));
          Tcl_ListObjAppendElement(NULL, pele, Tcl_NewIntObj((*it)->Mask()) );
          Tcl_ListObjAppendElement(NULL, pele, (*it)->Script() );
          Tcl_ListObjAppendElement(NULL, pres, pele);
        }
      }
      args.SetResult(pres);
      return kOK;
 
    } else if (opt == "-test") {            // attn -test mask
      uint16_t mask=0;
      if (!args.GetArg("mask", mask)) return kERR;
      if (!args.AllDone()) return kERR;
      int nhdl = 0;
      for (alist_it_t it = fAttnHdl.begin(); it != fAttnHdl.end(); it++) {
        if ((*it)->Mask() & mask) {
          nhdl += 1;
          int rc = Tcl_EvalObjEx(interp, (*it)->Script(), TCL_EVAL_GLOBAL);
          if (rc != kOK) return rc;
        }
      }
      if (nhdl) return kOK;
      return args.Quit(string("-E: no handler defined for '") +
                       args.PeekArgString(-1) + "'");
 
    } else if (opt == "-list") {            // attn -list
      if (!args.AllDone()) return kERR;
      vector<uint16_t> vres;
      for (alist_it_t it = fAttnHdl.begin(); it != fAttnHdl.end(); it++) {
        vres.push_back((*it)->Mask());
      }
      args.SetResult(Rtcl::NewListIntObj(vres));
    }
 
  } else {                                  // attn
    if (!args.OptValid()) return kERR;
    if (!args.AllDone()) return kERR;
    uint16_t mask=0;
    for (alist_it_t it = fAttnHdl.begin(); it != fAttnHdl.end(); it++) {
      mask |= (*it)->Mask();
    }
    args.SetResult(mask);
  }
 
  return kOK;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::M_stats(RtclArgs& args)
{
  RtclStats::Context cntx;
  if (!RtclStats::GetArgs(args, cntx)) return kERR;
  if (!RtclStats::Collect(args, cntx, Obj().Stats())) return kERR;
  return kOK;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::M_print(RtclArgs& args)
{
  if (!args.AllDone()) return kERR;
 
  ostringstream sos;
  Obj().Print(sos);
  args.SetResult(sos);
  return kOK;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::M_dump(RtclArgs& args)
{
  if (!args.AllDone()) return kERR;
 
  ostringstream sos;
  Obj().Dump(sos, 0);
  args.SetResult(sos);
  return kOK;
}
 
//------------------------------------------+-----------------------------------
//! FIXME_docs
 
int RtclRlinkServer::M_default(RtclArgs& args)
{
  if (!args.AllDone()) return kERR;
  ostringstream sos;
  sos << "no default output defined yet...\n";
  args.AppendResultLines(sos);
  return kOK;
}
 
} // end namespace Retro