Subversion Repositories w11

// $Id: RlinkConnect.cpp 632 2015-01-11 12:30:03Z mueller $

//

// Copyright 2011-2015 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

// 2015-01-06   631   2.1    full rlink v4 implementation

// 2014-12-10   611   2.0    re-organize for rlink v4

// 2014-08-26   587   1.5    start accept rlink v4 protocol (partially...)

// 2014-08-15   583   1.4    rb_mreq addr now 16 bit

// 2014-07-27   575   1.3.3  ExecPart(): increase packet tout from 5 to 15 sec

// 2013-04-21   509   1.3.2  add SndAttn() method

// 2013-03-01   493   1.3.1  add Server(Active..|SignalAttn)() methods

// 2013-02-23   492   1.3    use scoped_ptr for Port; Close allways allowed

//                           use RlinkContext, add Context(), Exec(..., cntx)

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

// 2013-02-03   481   1.1.2  use Rexception

// 2013-01-13   474   1.1.1  add PollAttn() method

// 2011-04-25   380   1.1    use boost::(mutex&lock), implement Lockable IF

// 2011-04-22   379   1.0.1  add Lock(), Unlock(), lock connect in Exec()

// 2011-04-02   375   1.0    Initial version

// 2011-01-15   356   0.1    First draft

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

/*!

  \file

  \version $Id: RlinkConnect.cpp 632 2015-01-11 12:30:03Z mueller $

  \brief   Implemenation of RlinkConnect.

*/

#include <iostream>

#include "boost/thread/locks.hpp"

#include "RlinkPortFactory.hpp"

#include "librtools/RosFill.hpp"

#include "librtools/RosPrintf.hpp"

#include "librtools/RosPrintBvi.hpp"

#include "librtools/Rtools.hpp"

#include "librtools/Rexception.hpp"

#include "librtools/RlogMsg.hpp"

#include "RlinkServer.hpp"

#include "RlinkConnect.hpp"

using namespace std;

/*!

  \class Retro::RlinkConnect

  \brief FIXME_docs

*/

// all method definitions in namespace Retro

namespace Retro {

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

// constants definitions

const uint16_t RlinkConnect::kRbaddr_RLCNTL;

const uint16_t RlinkConnect::kRbaddr_RLSTAT;

const uint16_t RlinkConnect::kRbaddr_RLID1;

const uint16_t RlinkConnect::kRbaddr_RLID0;

const uint16_t RlinkConnect::kRLCNTL_M_AnEna;

const uint16_t RlinkConnect::kRLCNTL_M_AtoEna;

const uint16_t RlinkConnect::kRLCNTL_M_AtoVal;

const uint16_t RlinkConnect::kRLSTAT_V_LCmd;

const uint16_t RlinkConnect::kRLSTAT_B_LCmd;

const uint16_t RlinkConnect::kRLSTAT_M_BAbo;

const uint16_t RlinkConnect::kRLSTAT_M_RBSize;

const uint16_t RlinkConnect::kSBCNTL_V_RLMON;

const uint16_t RlinkConnect::kSBCNTL_V_RLBMON;

const uint16_t RlinkConnect::kSBCNTL_V_RBMON;

const uint16_t RlinkConnect::kRbufBlkDelta;

const uint16_t RlinkConnect::kRbufPrudentDelta;

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

//! Default constructor

RlinkConnect::RlinkConnect()

  : fpPort(),

    fpServ(nullptr),

    fSndPkt(),

    fRcvPkt(),

    fContext(),

    fAddrMap(),

    fStats(),

    fLogBaseAddr(16),

    fLogBaseData(16),

    fLogBaseStat(16),

    fPrintLevel(0),

    fDumpLevel(0),

    fTraceLevel(0),

    fspLog(new RlogFile(&cout)),

    fConnectMutex(),

    fAttnNotiPatt(0),

    fTsLastAttnNoti(-1),

    fSysId(0xffffffff),

    fRbufSize(2048)

{

  for (size_t i=0; i<8; i++) fSeqNumber[i] = 0;

  // Statistic setup

  fStats.Define(kStatNExec,     "NExec",     "Exec() calls");

  fStats.Define(kStatNExecPart, "NExecPart", "ExecPart() calls");

  fStats.Define(kStatNCmd,      "NCmd",      "commands executed");

  fStats.Define(kStatNRreg,     "NRreg",     "rreg commands");

  fStats.Define(kStatNRblk,     "NRblk",     "rblk commands");

  fStats.Define(kStatNWreg,     "NWreg",     "wreg commands");

  fStats.Define(kStatNWblk,     "NWblk",     "wblk commands");

  fStats.Define(kStatNLabo,     "NLabo",     "labo commands");

  fStats.Define(kStatNAttn,     "NAttn",     "attn commands");

  fStats.Define(kStatNInit,     "NInit",     "init commands");

  fStats.Define(kStatNRblkWord, "NRblkWord", "words rcvd with rblk");

  fStats.Define(kStatNWblkWord, "NWblkWord", "words send with wblk");

  fStats.Define(kStatNExpData,  "NExpData",  "Expect() for data defined");

  fStats.Define(kStatNExpDone,  "NExpDone",  "Expect() for done defined");

  fStats.Define(kStatNExpStat,  "NExpStat",  "Expect() for stat defined");

  fStats.Define(kStatNChkData,  "NChkData",  "expect data failed");

  fStats.Define(kStatNChkDone,  "NChkData",  "expect done failed");

  fStats.Define(kStatNChkStat,  "NChkStat",  "expect stat failed");

  fStats.Define(kStatNSndOob,   "NSndOob",   "SndOob() calls");

  fStats.Define(kStatNErrMiss,  "NErrMiss",  "decode: missing data");

  fStats.Define(kStatNErrCmd,   "NErrCmd",   "decode: command mismatch");

  fStats.Define(kStatNErrLen,   "NErrLen",   "decode: length mismatch");

  fStats.Define(kStatNErrCrc,   "NErrCrc",   "decode: crc mismatch");

}

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

//! Destructor

RlinkConnect::~RlinkConnect()

{

  Close();

}

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

//! FIXME_docs

bool RlinkConnect::Open(const std::string& name, RerrMsg& emsg)

{

  Close();

  fpPort.reset(RlinkPortFactory::Open(name, emsg));

  if (!fpPort) return false;

  fpPort->SetLogFile(fspLog);

  fpPort->SetTraceLevel(fTraceLevel);

  RlinkCommandList clist;

  clist.AddRreg(kRbaddr_RLSTAT);

  clist.AddRreg(kRbaddr_RLID1);

  clist.AddRreg(kRbaddr_RLID0);

  if (!Exec(clist, emsg)) {

    Close();

    return false;

  }

  uint16_t rlstat = clist[0].Data();

  uint16_t rlid1  = clist[1].Data();

  uint16_t rlid0  = clist[2].Data();

  fRbufSize = size_t(1) << (10 + (rlstat & kRLSTAT_M_RBSize));

  fSysId    = uint32_t(rlid1)<<16 | uint32_t(rlid0);

  return true;

}

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

//! FIXME_docs

void RlinkConnect::Close()

{

  if (!fpPort) return;

  if (fpServ) fpServ->Stop();               // stop server in case still running

  if (fpPort->Url().FindOpt("keep")) {

    RerrMsg emsg;

    fSndPkt.SndKeep(fpPort.get(), emsg);

  }

  fpPort.reset();

  return;

}

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

//! Indicates whether server is active.

/*!

  \returns \c true if server active.

 */

bool RlinkConnect::ServerActive() const

{

  return fpServ && fpServ->IsActive();

}

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

//! Indicates whether server is active and caller is inside server thread.

/*!

  \returns \c true if server active and method is called from server thread.

 */

bool RlinkConnect::ServerActiveInside() const

{

  return fpServ && fpServ->IsActiveInside();

}

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

//! Indicates whether server is active and caller is outside server thread.

/*!

  \returns \c true if server active and method is called from a thread

           other than the server thread.

 */

bool RlinkConnect::ServerActiveOutside() const

{

  return fpServ && fpServ->IsActiveOutside();

}

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

//! FIXME_docs

void RlinkConnect::lock()

{

  fConnectMutex.lock();

  return;

}

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

//! FIXME_docs

bool RlinkConnect::try_lock()

{

  return fConnectMutex.try_lock();

}

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

//! FIXME_docs

void RlinkConnect::unlock()

{

  fConnectMutex.unlock();

  return;

}

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

//! FIXME_docs

bool RlinkConnect::Exec(RlinkCommandList& clist, RlinkContext& cntx,

                        RerrMsg& emsg)

{

  if (clist.Size() == 0)

    throw Rexception("RlinkConnect::Exec()", "Bad state: clist empty");

  if (! IsOpen())

    throw Rexception("RlinkConnect::Exec()", "Bad state: port not open");

  boost::lock_guard<RlinkConnect> lock(*this);

  fStats.Inc(kStatNExec);

  clist.ClearLaboIndex();

  size_t size = clist.Size();

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

    RlinkCommand& cmd = clist[i];

   if (!cmd.TestFlagAny(RlinkCommand::kFlagInit))

     throw Rexception("RlinkConnect::Exec()",

                      "BugCheck: command not initialized");

    if (cmd.Command() > RlinkCommand::kCmdInit)

      throw Rexception("RlinkConnect::Exec()",

                       "BugCheck: invalid command code");

    // trap attn command when server running and outside server thread

    if (cmd.Command() == RlinkCommand::kCmdAttn && ServerActiveOutside())

      throw Rexception("RlinkConnect::Exec()",

                       "attn command not allowed outside active server");

    cmd.ClearFlagBit(RlinkCommand::kFlagSend   |

                     RlinkCommand::kFlagDone   |

                     RlinkCommand::kFlagLabo   |

                     RlinkCommand::kFlagPktBeg |

                     RlinkCommand::kFlagPktEnd |

                     RlinkCommand::kFlagErrNak |

                     RlinkCommand::kFlagErrDec);

  }

  // old split volative logic. Currently dormant

  // may be later used for rtbuf size prot

#ifdef NEVER

  while (ibeg < size) {

    size_t iend = ibeg;

    for (size_t i=ibeg; i<size; i++) {

      iend = i;

      if (clist[i].TestFlagAll(RlinkCommand::kFlagVol)) {

        fStats.Inc(kStatNSplitVol);

        break;

      }

    }

    bool rc = ExecPart(clist, ibeg, iend, emsg, cntx);

    if (!rc) return rc;

    ibeg = iend+1;

  }

#endif

  bool rc = ExecPart(clist, 0, size-1, emsg, cntx);

  if (!rc) return rc;

  bool checkseen = false;

  bool errorseen = false;

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

    RlinkCommand& cmd = clist[i];

    bool checkfound = cmd.TestFlagAny(RlinkCommand::kFlagChkStat |

                                      RlinkCommand::kFlagChkData |

                                      RlinkCommand::kFlagChkDone);

    bool errorfound = cmd.TestFlagAny(RlinkCommand::kFlagErrNak |

                                      RlinkCommand::kFlagErrDec);

    checkseen |= checkfound;

    errorseen |= errorfound;

    if (checkfound | errorfound) cntx.IncErrorCount();

  }

  size_t loglevel = 3;

  if (checkseen) loglevel = 2;

  if (errorseen) loglevel = 1;

  if (loglevel <= fPrintLevel) {

    RlogMsg lmsg(*fspLog);

    clist.Print(lmsg(), cntx, &AddrMap(), fLogBaseAddr, fLogBaseData,

                fLogBaseStat);

  }

  if (loglevel <= fDumpLevel) {

    RlogMsg lmsg(*fspLog);

    clist.Dump(lmsg(), 0);

  }

  return true;

}

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

//! FIXME_docs

void RlinkConnect::Exec(RlinkCommandList& clist, RlinkContext& cntx)

{

  RerrMsg emsg;

  bool rc = Exec(clist, cntx, emsg);

  if (!rc) {

    RlogMsg lmsg(*fspLog, 'F');

    lmsg << emsg << endl;

    lmsg << "Dump of failed clist:" << endl;

    clist.Dump(lmsg(), 0);

  }

  if (!rc)

    throw Rexception("RlinkConnect::Exec", "Exec() failed: ", emsg);

  return;

}

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

//! Wait for an attention notify.

/*!

  First checks whether there are received and not yet harvested notifies.

  In that case the cummulative pattern of these pending notifies is returned

  in \a apat, and a 0. return value.

  If a positive \a timeout is specified the method waits this long for a

  valid and non-zero attention notify.

  \param      timeout  maximal time to wait for input in sec. Must be >= 0.

                       A zero \a timeout can be used to only harvest pending

                       notifies without waiting for new ones.

  \param[out] apat     cummulative attention pattern

  \param[out] emsg     contains error description (mainly from port layer)

  \returns wait time, or a negative value indicating an error:

    - =0.  if there was already a received and not yet harvested notify

    - >0   the wait time till the nofity was received

    - -1.  indicates timeout (\a apat will be 0)

    - -2.  indicates port IO error (\a emsg will contain information)

  \throws Rexception if called outside of an active server

  \pre ServerActiveOutside() must be \c false.

 */

double RlinkConnect::WaitAttn(double timeout, uint16_t& apat, RerrMsg& emsg)

{

  if (ServerActiveOutside())

    throw Rexception("RlinkConnect::WaitAttn()",

                     "not allowed outside active server");

  apat = 0;

  boost::lock_guard<RlinkConnect> lock(*this);

  // harvest pending notifiers

  if (fAttnNotiPatt != 0) {

    apat = fAttnNotiPatt;

    fAttnNotiPatt = 0;

    return 0.;

  }

  // quit if poll only (zero timeout) 

  if (timeout == 0.) return -1.;

  // wait for new notifier

  double tnow = Rtools::TimeOfDayAsDouble();

  double tend = tnow + timeout;

  double tbeg = tnow;

  while (tnow < tend) {

    int irc = fRcvPkt.ReadData(fpPort.get(), tend-tnow, emsg);

    if (irc == RlinkPort::kTout) return -1.;

    if (irc == RlinkPort::kErr)  return -2.;

    tnow = Rtools::TimeOfDayAsDouble();

    while (fRcvPkt.ProcessData()) {

      int irc = fRcvPkt.PacketState();

      if (irc == RlinkPacketBufRcv::kPktPend) break;

      if (irc == RlinkPacketBufRcv::kPktAttn) {

        ProcessAttnNotify();

        if (fAttnNotiPatt != 0) {

          apat = fAttnNotiPatt;

          fAttnNotiPatt = 0;

          return tnow - tbeg;

        }

      } else {

        RlogMsg lmsg(*fspLog, 'E');

        lmsg << "WaitAttn: dropped spurious packet";

        fRcvPkt.AcceptPacket();

      }

    } // while (fRcvPkt.ProcessData())

  } // while (tnow < tend)

  return -1;

}

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

//! FIXME_docs

bool RlinkConnect::SndOob(uint16_t addr, uint16_t data, RerrMsg& emsg)

{

  boost::lock_guard<RlinkConnect> lock(*this);

  fStats.Inc(kStatNSndOob);

  return fSndPkt.SndOob(fpPort.get(), addr, data, emsg);

}

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

//! FIXME_docs

bool RlinkConnect::SndAttn(RerrMsg& emsg)

{

  boost::lock_guard<RlinkConnect> lock(*this);

  return fSndPkt.SndAttn(fpPort.get(), emsg);

}

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

//! FIXME_docs

void RlinkConnect::SetLogBaseAddr(uint32_t base)

{

  if (base!=2 && base!=8 && base!=16)

    throw Rexception("RlinkConnect::SetLogBaseAddr()",

                     "Bad args: base != 2,8,16");

  fLogBaseAddr = base;

  return;

}

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

//! FIXME_docs

void RlinkConnect::SetLogBaseData(uint32_t base)

{

  if (base!=2 && base!=8 && base!=16)

    throw Rexception("RlinkConnect::SetLogBaseData()",

                     "Bad args: base != 2,8,16");

  fLogBaseData = base;

  return;

}

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

//! FIXME_docs

void RlinkConnect::SetLogBaseStat(uint32_t base)

{

  if (base!=2 && base!=8 && base!=16)

    throw Rexception("RlinkConnect::SetLogBaseStat()",

                     "Bad args: base != 2,8,16");

  fLogBaseStat = base;

  return;

}

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

//! FIXME_docs

void RlinkConnect::SetPrintLevel(uint32_t lvl)

{

  fPrintLevel = lvl;

  return;

}

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

//! FIXME_docs

void RlinkConnect::SetDumpLevel(uint32_t lvl)

{

  fDumpLevel = lvl;

  return;

}

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

//! FIXME_docs

void RlinkConnect::SetTraceLevel(uint32_t lvl)

{

  fTraceLevel = lvl;

  if (fpPort) fpPort->SetTraceLevel(lvl);

  return;

}

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

//! FIXME_docs

bool RlinkConnect::LogOpen(const std::string& name, RerrMsg& emsg)

{

  if (!fspLog->Open(name, emsg)) {

    fspLog->UseStream(&cout);

    return false;

  }

  return true;

}

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

//! FIXME_docs

void RlinkConnect::LogUseStream(std::ostream* pstr, const std::string& name)

{

  fspLog->UseStream(pstr, name);

  return;

}

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

//! FIXME_docs

void RlinkConnect::SetLogFileName(const std::string& name)

{

  RerrMsg emsg;

  if (!LogOpen(name, emsg)) {

    throw Rexception("RlinkConnect::SetLogFile",

                     emsg.Text() + "', using stdout");

  }

  return;

}

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

//! FIXME_docs

void RlinkConnect::Print(std::ostream& os) const

{

  os << "RlinkConnect::Print(std::ostream& os)" << endl;

  return;

}

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

//! FIXME_docs

void RlinkConnect::Dump(std::ostream& os, int ind, const char* text) const

{

  RosFill bl(ind);

  os << bl << (text?text:"--") << "RlinkConnect @ " << this << endl;

  if (fpPort) {

    fpPort->Dump(os, ind+2, "fpPort: ");

  } else {

    os << bl << "  fpPort:          " <<  fpPort.get() << endl;

  }

  os << bl << "  fpServ:          " << fpServ << endl;

  os << bl << "  fSeqNumber:      ";

  for (size_t i=0; i<8; i++) os << RosPrintBvi(fSeqNumber[i],16) << " ";

  os << endl;

  fSndPkt.Dump(os, ind+2, "fSndPkt: ");

  fRcvPkt.Dump(os, ind+2, "fRcvPkt: ");

  fContext.Dump(os, ind+2, "fContext: ");

  fAddrMap.Dump(os, ind+2, "fAddrMap: ");

  fStats.Dump(os, ind+2, "fStats: ");

  os << bl << "  fLogBaseAddr:    " << fLogBaseAddr << endl;

  os << bl << "  fLogBaseData:    " << fLogBaseData << endl;

  os << bl << "  fLogBaseStat:    " << fLogBaseStat << endl;

  os << bl << "  fPrintLevel:     " << fPrintLevel << endl;

  os << bl << "  fDumpLevel       " << fDumpLevel << endl;

  os << bl << "  fTraceLevel      " << fTraceLevel << endl;

  fspLog->Dump(os, ind+2, "fspLog: ");

  os << bl << "  fAttnNotiPatt: " << RosPrintBvi(fAttnNotiPatt,16) << endl;

  //FIXME_code: fTsLastAttnNoti not yet in Dump (get formatter...)

  return;

}

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

//! Handle unsolicited data from port.

/*!

  Called by RlinkServer to process unsolicited input data. Will read all

  pending data from input port and process it with ProcessUnsolicitedData().

  \throws Rexception if not called from inside of an active server

  \pre ServerActiveInside() must be \c true.

 */

void RlinkConnect::HandleUnsolicitedData()

{

  if (!ServerActiveInside())

    throw Rexception("RlinkConnect::HandleUnsolicitedData()",

                     "only allowed inside active server");

  boost::lock_guard<RlinkConnect> lock(*this);

  RerrMsg emsg;

  int irc = fRcvPkt.ReadData(fpPort.get(), 0., emsg);

  if (irc == 0) return;

  if (irc < 0) {

    RlogMsg lmsg(*fspLog, 'E');

    lmsg << "HandleUnsolicitedData: IO error: " << emsg;

  }

  ProcessUnsolicitedData();

  return;

}

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

//! FIXME_docs

bool RlinkConnect::ExecPart(RlinkCommandList& clist, size_t ibeg, size_t iend,

                            RerrMsg& emsg, RlinkContext& cntx)

{

  if (ibeg>iend || iend>=clist.Size())

    throw Rexception("RlinkConnect::ExecPart()",

                     "Bad args: ibeg or iend invalid");

  if (!IsOpen())

    throw Rexception("RlinkConnect::ExecPart()","Bad state: port not open");

  fStats.Inc(kStatNExecPart);

  EncodeRequest(clist, ibeg, iend);