Subversion Repositories w11

// $Id: RtclRlinkConnect.cpp 521 2013-05-20 22:16:45Z mueller $

//

// Copyright 2011-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-02-23   492   1.1.6  use RlogFile.Name(); use Context().ErrorCount()

// 2013-02-22   491   1.1.5  use new RlogFile/RlogMsg interfaces

// 2013-02-02   480   1.1.4  allow empty exec commands

// 2013-01-27   478   1.1.3  use RtclRlinkPort::DoRawio on M_rawio

// 2013-01-06   473   1.1.2  add M_rawio: rawio -write|-read

// 2011-11-28   434   1.1.1  ConfigBase(): use uint32_t for lp64 compatibility

// 2011-04-23   380   1.1    use boost/bind instead of RmethDsc

// 2011-04-17   376   1.0.1  M_wtlam: now correct log levels

// 2011-03-27   374   1.0    Initial version

// 2011-02-11   360   0.1    First draft

// ---------------------------------------------------------------------------

/*!

  \file

  \version $Id: RtclRlinkConnect.cpp 521 2013-05-20 22:16:45Z mueller $

  \brief   Implemenation of class RtclRlinkConnect.

 */

#include <ctype.h>

#include <iostream>

#include "boost/bind.hpp"

#include "librtcltools/Rtcl.hpp"

#include "librtcltools/RtclOPtr.hpp"

#include "librtcltools/RtclNameSet.hpp"

#include "librtcltools/RtclStats.hpp"

#include "librtools/RosPrintf.hpp"

#include "librtools/RlogMsg.hpp"

#include "librlink/RlinkCommandList.hpp"

#include "RtclRlinkPort.hpp"

#include "RtclRlinkConnect.hpp"

using namespace std;

/*!

  \class Retro::RtclRlinkConnect

  \brief FIXME_docs

*/

// all method definitions in namespace Retro

namespace Retro {

//------------------------------------------+-----------------------------------

//! Default constructor

RtclRlinkConnect::RtclRlinkConnect(Tcl_Interp* interp, const char* name)

  : RtclProxyOwned<RlinkConnect>("RlinkConnect", interp, name,

                                 new RlinkConnect())

{

  AddMeth("open",     boost::bind(&RtclRlinkConnect::M_open,    this, _1));

  AddMeth("close",    boost::bind(&RtclRlinkConnect::M_close,   this, _1));

  AddMeth("exec",     boost::bind(&RtclRlinkConnect::M_exec,    this, _1));

  AddMeth("amap",     boost::bind(&RtclRlinkConnect::M_amap,    this, _1));

  AddMeth("errcnt",   boost::bind(&RtclRlinkConnect::M_errcnt,  this, _1));

  AddMeth("wtlam",    boost::bind(&RtclRlinkConnect::M_wtlam,   this, _1));

  AddMeth("oob",      boost::bind(&RtclRlinkConnect::M_oob,     this, _1));

  AddMeth("rawio",    boost::bind(&RtclRlinkConnect::M_rawio,   this, _1));

  AddMeth("stats",    boost::bind(&RtclRlinkConnect::M_stats,   this, _1));

  AddMeth("log",      boost::bind(&RtclRlinkConnect::M_log,     this, _1));

  AddMeth("print",    boost::bind(&RtclRlinkConnect::M_print,   this, _1));

  AddMeth("dump",     boost::bind(&RtclRlinkConnect::M_dump,    this, _1));

  AddMeth("config",   boost::bind(&RtclRlinkConnect::M_config,  this, _1));

  AddMeth("$default", boost::bind(&RtclRlinkConnect::M_default, this, _1));

  for (size_t i=0; i<8; i++) {

    fCmdnameObj[i] = Tcl_NewStringObj(RlinkCommand::CommandName(i), -1);

  }

}

//------------------------------------------+-----------------------------------

//! Destructor

RtclRlinkConnect::~RtclRlinkConnect()

{}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_open(RtclArgs& args)

{

  string path;

  if (!args.GetArg("?path", path)) return kERR;

  if (!args.AllDone()) return kERR;

  RerrMsg emsg;

  if (args.NOptMiss() == 0) {               // open path

    if (!Obj().Open(path, emsg)) return args.Quit(emsg);

  } else {                                  // open 

    string name = Obj().IsOpen() ? Obj().Port()->Url().Url() : string();

    args.SetResult(name);

  }

  return kOK;

}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_close(RtclArgs& args)

{

  if (!args.AllDone()) return kERR;

  if (!Obj().IsOpen()) return args.Quit("-E: port not open");

  Obj().Close();

  return kOK;

}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_exec(RtclArgs& args)

{

  static RtclNameSet optset("-rreg|-rblk|-wreg|-wblk|-stat|-attn|-init|"

                            "-edata|-estat|-estatdef|"

                            "-volatile|-print|-dump|-rlist");

  Tcl_Interp* interp = args.Interp();

  RlinkCommandList clist;

  string opt;

  uint16_t addr;

  vector<string> vardata;

  vector<string> varstat;

  string varprint;

  string vardump;

  string varlist;

  uint8_t estatdef_val = 0x00;

  uint8_t estatdef_msk = 0xff;

  while (args.NextOpt(opt, optset)) {

    size_t lsize = clist.Size();

    if        (opt == "-rreg") {            // -rreg addr ?varData ?varStat ---

      if (!GetAddr(args, Obj(), addr)) return kERR;

      if (!GetVarName(args, "??varData", lsize, vardata)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddRreg(addr);

    } else if (opt == "-rblk") {            // -rblk addr size ?varData ?varStat

      int32_t bsize;

      if (!GetAddr(args, Obj(), addr)) return kERR;

      if (!args.GetArg("bsize", bsize, 1, 256)) return kERR;

      if (!GetVarName(args, "??varData", lsize, vardata)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddRblk(addr, (size_t) bsize);

    } else if (opt == "-wreg") {            // -wreg addr data ?varStat -------

      uint16_t data;

      if (!GetAddr(args, Obj(), addr)) return kERR;

      if (!args.GetArg("data", data)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddWreg(addr, data);

    } else if (opt == "-wblk") {            // -wblk addr block ?varStat ------

      vector<uint16_t> block;

      if (!GetAddr(args, Obj(), addr)) return kERR;

      if (!args.GetArg("data", block, 1, 256)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddWblk(addr, block);

    } else if (opt == "-stat") {            // -stat varData ?varStat ---------

      if (!GetVarName(args, "??varData", lsize, vardata)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddStat();

    } else if (opt == "-attn") {            // -attn varData ?varStat ---------

      if (!GetVarName(args, "??varData", lsize, vardata)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddAttn();

    } else if (opt == "-init") {            // -init addr data ?varStat -------

      uint16_t data;

      if (!GetAddr(args, Obj(), addr)) return kERR;

      if (!args.GetArg("data", data)) return kERR;

      if (!GetVarName(args, "??varStat", lsize, varstat)) return kERR;

      clist.AddInit(addr, data);

    } else if (opt == "-edata") {           // -edata data ?mask --------------

      if (!ClistNonEmpty(args, clist)) return kERR;

      if (clist[lsize-1].Expect()==0) {

        clist.LastExpect(new RlinkCommandExpect());

      }

      if (clist[lsize-1].Command() == RlinkCommand::kCmdRblk) {

        vector<uint16_t> data;

        vector<uint16_t> mask;

        size_t bsize = clist[lsize-1].BlockSize();

        if (!args.GetArg("data", data, 0, bsize)) return kERR;

        if (!args.GetArg("??mask", mask, 0, bsize)) return kERR;

        clist[lsize-1].Expect()->SetBlock(data, mask);

      } else {

        uint16_t data=0;

        uint16_t mask=0;

        if (!args.GetArg("data", data)) return kERR;

        if (!args.GetArg("??mask", mask)) return kERR;

        clist[lsize-1].Expect()->SetData(data, mask);

      }

    } else if (opt == "-estat") {           // -estat ?stat ?mask -------------

      if (!ClistNonEmpty(args, clist)) return kERR;

      uint8_t stat=0;

      uint8_t mask=0;

      if (!args.GetArg("??stat", stat)) return kERR;

      if (!args.GetArg("??mask", mask)) return kERR;

      if (args.NOptMiss() == 2)  mask = 0xff;

      if (clist[lsize-1].Expect()==0) {

        clist.LastExpect(new RlinkCommandExpect());

      }

      clist[lsize-1].Expect()->SetStatus(stat, mask);

    } else if (opt == "-estatdef") {        // -estatdef ?stat ?mask -----------

      uint8_t stat=0;

      uint8_t mask=0;

      if (!args.GetArg("??stat", stat)) return kERR;

      if (!args.GetArg("??mask", mask)) return kERR;

      if (args.NOptMiss() == 2)  mask = 0xff;

      estatdef_val = stat;

      estatdef_msk = mask;

    } else if (opt == "-volatile") {        // -volatile ----------------------

      if (!ClistNonEmpty(args, clist)) return kERR;

      clist.LastVolatile();

    } else if (opt == "-print") {           // -print ?varRes -----------------

      varprint = "-";

      if (!args.GetArg("??varRes", varprint)) return kERR;

    } else if (opt == "-dump") {            // -dump ?varRes ------------------

      vardump = "-";

      if (!args.GetArg("??varRes", vardump)) return kERR;

    } else if (opt == "-rlist") {           // -rlist ?varRes -----------------

      varlist = "-";

      if (!args.GetArg("??varRes", varlist)) return kERR;

    }

    if (lsize != clist.Size()) {            // cmd added to clist (ind=lsize!)

      if (estatdef_msk != 0xff) {             // estatdef defined

        if (clist[lsize].Expect()==0) {

          clist.LastExpect(new RlinkCommandExpect());

        }

        clist[lsize].Expect()->SetStatus(estatdef_val, estatdef_msk);

      }

    }

  }

  int nact = 0;

  if (varprint == "-") nact += 1;

  if (vardump  == "-") nact += 1;

  if (varlist  == "-") nact += 1;

  if (nact > 1)

    return args.Quit(

      "-E: more that one of -print,-dump,-list without target variable found");

  if (!args.AllDone()) return kERR;

  if (clist.Size() == 0) return kOK;

  RerrMsg emsg;

  if (!Obj().Exec(clist, emsg)) return args.Quit(emsg);

  for (size_t icmd=0; icmd<clist.Size(); icmd++) {

    RlinkCommand& cmd = clist[icmd];

    if (icmd<vardata.size() && !vardata[icmd].empty()) {

      RtclOPtr pres;

      vector<uint16_t> retstat;

      RtclOPtr pele;

      switch (cmd.Command()) {

        case RlinkCommand::kCmdRreg:

        case RlinkCommand::kCmdAttn:

          pres = Tcl_NewIntObj((int)cmd.Data());

          break;

        case RlinkCommand::kCmdRblk:

          pres = Rtcl::NewListIntObj(cmd.Block());

          break;

        case RlinkCommand::kCmdStat:

          retstat.resize(2);

          retstat[0] = cmd.StatRequest();

          retstat[1] = cmd.Data();

          pres = Rtcl::NewListIntObj(retstat);

          break;

      }

      if(!Rtcl::SetVar(interp, vardata[icmd], pres)) return kERR;

    }

    if (icmd<varstat.size() && !varstat[icmd].empty()) {

      RtclOPtr pres(Tcl_NewIntObj((int)cmd.Status()));

      if (!Rtcl::SetVar(interp, varstat[icmd], pres)) return kERR;

    }

  }

  if (!varprint.empty()) {

    ostringstream sos;

    const RlinkConnect::LogOpts& logopts = Obj().GetLogOpts();

    clist.Print(sos, Obj().Context(), &Obj().AddrMap(), logopts.baseaddr,

                logopts.basedata, logopts.basestat);

    RtclOPtr pobj(Rtcl::NewLinesObj(sos));

    if (!Rtcl::SetVarOrResult(args.Interp(), varprint, pobj)) return kERR;

  }

  if (!vardump.empty()) {

    ostringstream sos;

    clist.Dump(sos, 0);

    RtclOPtr pobj(Rtcl::NewLinesObj(sos));

    if (!Rtcl::SetVarOrResult(args.Interp(), vardump, pobj)) return kERR;

  }

  if (!varlist.empty()) {

    RtclOPtr prlist(Tcl_NewListObj(0, NULL));

    for (size_t icmd=0; icmd<clist.Size(); icmd++) {

      RlinkCommand& cmd(clist[icmd]);

      RtclOPtr pres(Tcl_NewListObj(0, NULL));

      Tcl_ListObjAppendElement(NULL, pres, fCmdnameObj[cmd.Command()]);

      Tcl_ListObjAppendElement(NULL, pres, Tcl_NewIntObj((int)cmd.Request()));

      Tcl_ListObjAppendElement(NULL, pres, Tcl_NewIntObj((int)cmd.Flags()));

      Tcl_ListObjAppendElement(NULL, pres, Tcl_NewIntObj((int)cmd.Status()));

      switch (cmd.Command()) {

        case RlinkCommand::kCmdRreg:

        case RlinkCommand::kCmdAttn:

          Tcl_ListObjAppendElement(NULL, pres, Tcl_NewIntObj((int)cmd.Data()));

          break;

        case RlinkCommand::kCmdRblk:

          Tcl_ListObjAppendElement(NULL, pres,

                                   Rtcl::NewListIntObj(cmd.Block()));

          break;

        case RlinkCommand::kCmdStat:

          Tcl_ListObjAppendElement(NULL, pres,

                                   Tcl_NewIntObj((int)cmd.StatRequest()));

          Tcl_ListObjAppendElement(NULL, pres, Tcl_NewIntObj((int)cmd.Data()));

          break;

      }

      Tcl_ListObjAppendElement(NULL, prlist, pres);

    }

    if (!Rtcl::SetVarOrResult(args.Interp(), varlist, prlist)) return kERR;

  }

  return kOK;

}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_amap(RtclArgs& args)

{

  static RtclNameSet optset("-name|-testname|-testaddr|-insert|-erase|"

                            "-clear|-print");

  const RlinkAddrMap& addrmap = Obj().AddrMap();

  string opt;

  string name;

  uint16_t addr=0;

  if (args.NextOpt(opt, optset)) {

    if        (opt == "-name") {            // amap -name addr

      if (!args.GetArg("addr", addr, 0x00ff)) return kERR;

      if (!args.AllDone()) return kERR;

      string   tstname;

      if(addrmap.Find(addr, tstname)) {

        args.SetResult(tstname);

      } else {

        return args.Quit(string("-E: address '") + args.PeekArgString(-1) +

                         "' not mapped");

      }

    } else if (opt == "-testname") {        // amap -testname name

      if (!args.GetArg("name", name)) return kERR;

      if (!args.AllDone()) return kERR;

      uint16_t tstaddr;

      args.SetResult(int(addrmap.Find(name, tstaddr)));

    } else if (opt == "-testaddr") {        // amap -testaddr addr

      if (!args.GetArg("addr", addr, 0x00ff)) return kERR;

      if (!args.AllDone()) return kERR;

      string   tstname;

      args.SetResult(int(addrmap.Find(addr, tstname)));

    } else if (opt == "-insert") {          // amap -insert name addr

      uint16_t tstaddr;

      string   tstname;

      int      tstint;

      if (!args.GetArg("name", name)) return kERR;

      // enforce that the name is not a valid representation of an int

      if (Tcl_GetIntFromObj(NULL, args[args.NDone()-1], &tstint) == kOK)

        return args.Quit(string("-E: name should not look like an int but '")+

                         name + "' does");

      if (!args.GetArg("addr", addr, 0x00ff)) return kERR;

      if (!args.AllDone()) return kERR;

      if (addrmap.Find(name, tstaddr))

        return args.Quit(string("-E: mapping already defined for '")+name+"'");

      if (addrmap.Find(addr, tstname))

        return args.Quit(string("-E: mapping already defined for address '") +

                         args.PeekArgString(-1) + "'");

      Obj().AddrMapInsert(name, addr);

    } else if (opt == "-erase") {           // amap -erase name

      if (!args.GetArg("name", name)) return kERR;

      if (!args.AllDone()) return kERR;

      if (!Obj().AddrMapErase(name))

        return args.Quit(string("-E: no mapping defined for '") + name + "'");

    } else if (opt == "-clear") {           // amap -clear

      if (!args.AllDone()) return kERR;

      Obj().AddrMapClear();

    } else if (opt == "-print") {           // amap -print

      if (!args.AllDone()) return kERR;

      ostringstream sos;

      addrmap.Print(sos);

      args.AppendResultLines(sos);

    }

  } else {

    if (!args.OptValid()) return kERR;

    if (!args.GetArg("?name", name)) return kERR;

    if (args.NOptMiss()==0) {               // amap name

      uint16_t tstaddr;

      if(addrmap.Find(name, tstaddr)) {

        args.SetResult(int(tstaddr));

      } else {

        return args.Quit(string("-E: no mapping defined for '") + name + "'");

      }

    } else {                                // amap

      RtclOPtr plist(Tcl_NewListObj(0, NULL));

      const RlinkAddrMap::amap_t amap = addrmap.Amap();

      for (RlinkAddrMap::amap_cit_t it=amap.begin(); it!=amap.end(); it++) {

        Tcl_Obj* tpair[2];

        tpair[0] = Tcl_NewIntObj(it->first);

        tpair[1] = Tcl_NewStringObj((it->second).c_str(),(it->second).length());

        Tcl_ListObjAppendElement(NULL, plist, Tcl_NewListObj(2, tpair));

      }

      args.SetResult(plist);

    }

  }

  return kOK;

}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_errcnt(RtclArgs& args)

{

  static RtclNameSet optset("-clear");

  string opt;

  bool fclear = false;

  while (args.NextOpt(opt, optset)) {

    if (opt == "-clear") fclear = true;

  }

  if (!args.AllDone()) return kERR;

  args.SetResult(int(Obj().Context().ErrorCount()));

  if (fclear) Obj().Context().ClearErrorCount();

  return kOK;

}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_wtlam(RtclArgs& args)

{

  double tout;

  if (!args.GetArg("tout", tout, 0.001)) return kERR;

  if (!args.AllDone()) return kERR;

  RerrMsg emsg;

  double twait = Obj().WaitAttn(tout, emsg);

  if (twait == -2.) {

    return args.Quit(emsg);

  } else if (twait == -1.) {

    if (Obj().GetLogOpts().printlevel >= 1) {

      RlogMsg lmsg(Obj().LogFile());

      lmsg << "-- wtlam to=" << RosPrintf(tout, "f", 0,3)

           << " FAIL timeout" << endl;

      Obj().Context().IncErrorCount();

      args.SetResult(tout);

      return kOK;

    }

  }

  if (Obj().GetLogOpts().printlevel >= 3) {

    RlogMsg lmsg(Obj().LogFile());

    lmsg << "-- wtlam to=" << RosPrintf(tout, "f", 0,3)

         << "  T=" << RosPrintf(twait, "f", 0,3)

         << "  OK" << endl;

  }

  args.SetResult(twait);

  return kOK;

}

//------------------------------------------+-----------------------------------

//! FIXME_docs

int RtclRlinkConnect::M_oob(RtclArgs& args)

{

  static RtclNameSet optset("-rlmon|-rbmon|-sbcntl|-sbdata");

  string opt;

  uint16_t addr;

  uint16_t data;

  RerrMsg emsg;

  if (args.NextOpt(opt, optset)) {

    if        (opt == "-rlmon") {           // oob -rlmon (0|1)

      if (!args.GetArg("val", data, 1)) return kERR;

      if (!args.AllDone()) return kERR;

      addr = 15;                              // rlmon on bit 15

      if (!Obj().SndOob(0x00, (addr<<8)+data, emsg)) return args.Quit(emsg);

    } else if (opt == "-rbmon") {           // oob -rbmon (0|1)

      if (!args.GetArg("val", data, 1)) return kERR;

      if (!args.AllDone()) return kERR;

      addr = 14;                              // rbmon on bit 14

      if (!Obj().SndOob(0x00, (addr<<8)+data, emsg)) return args.Quit(emsg);

    } else if (opt == "-sbcntl") {          // oob -sbcntl bit (0|1)

      if (!args.GetArg("bit", addr, 15)) return kERR;

      if (!args.GetArg("val", data,  1)) return kERR;

      if (!args.AllDone()) return kERR;

      if (!Obj().SndOob(0x00, (addr<<8)+data, emsg)) return args.Quit(emsg);

    } else if (opt == "-sbdata") {          // oob -sbdata addr val