Rw11VirtTape.cpp

Go to the documentation of this file.

// $Id: Rw11VirtTape.cpp 1186 2019-07-12 17:49:59Z mueller $
// SPDX-License-Identifier: GPL-3.0-or-later
// Copyright 2015-2019 by Walter F.J. Mueller <W.F.J.Mueller@gsi.de>
// 
// Revision History: 
// Date         Rev Version  Comment
// 2019-07-08  1180   1.2.2  remove dtor
// 2018-12-19  1090   1.2.1  use RosPrintf(bool)
// 2018-12-02  1076   1.2    use unique_ptr for New()
// 2017-04-07   868   1.1.1  Dump(): add detail arg
// 2017-04-02   864   1.1    move fWProt,WProt() to Rw11Virt base
// 2015-06-04   686   1.0    Initial version
// 2015-05-17   683   0.1    First draft
// ---------------------------------------------------------------------------
 
#include <memory>
 
#include "librtools/RosFill.hpp"
#include "librtools/RosPrintf.hpp"
#include "librtools/RparseUrl.hpp"
#include "librtools/Rexception.hpp"
#include "Rw11VirtTapeTap.hpp"
 
#include "Rw11VirtTape.hpp"
 
using namespace std;
 
// all method definitions in namespace Retro
namespace Retro {
 
//------------------------------------------+-----------------------------------
 
Rw11VirtTape::Rw11VirtTape(Rw11Unit* punit)
  : Rw11Virt(punit),
    fCapacity(0),
    fBot(false),
    fEot(false),
    fEom(true),
    fPosFile(-1),
    fPosRecord(-1)
{
  fStats.Define(kStatNVTReadRec,  "NVTReadRec",  "ReadRecord() calls");
  fStats.Define(kStatNVTReadByt,  "NVTReadByt",  "bytes read");
  fStats.Define(kStatNVTReadEof,  "NVTReadEof",  "eof read");
  fStats.Define(kStatNVTReadEom,  "NVTReadEom",  "eom read");
  fStats.Define(kStatNVTReadPErr, "NVTReadPErr", "parity error read");
  fStats.Define(kStatNVTReadLErr, "NVTReadLErr", "length error read");
  fStats.Define(kStatNVTWriteRec, "NVTWriteRec", "WriteRecord() calls");
  fStats.Define(kStatNVTWriteByt, "NVTWriteByt", "bytes written");
  fStats.Define(kStatNVTWriteEof, "NVTWriteEof", "WriteEof() calls");
  fStats.Define(kStatNVTSpaForw,  "NVTSpaForw",  "SpaceForw() calls");
  fStats.Define(kStatNVTSpaBack,  "NVTSpaBack",  "SpaceBack() calls");
  fStats.Define(kStatNVTRewind,   "NVTRewind",   "Rewind() calls");
}
 
//------------------------------------------+-----------------------------------
 
std::unique_ptr<Rw11VirtTape> Rw11VirtTape::New(const std::string& url,
                                                Rw11Unit* punit, RerrMsg& emsg)
{
  string scheme = RparseUrl::FindScheme(url, "tap");
  unique_ptr<Rw11VirtTape> up;
  
  if (scheme == "tap") {                   // scheme -> tap:
    up.reset(new Rw11VirtTapeTap(punit));
    if (!up->Open(url, emsg)) up.reset();
 
  } else {                                  // scheme -> no match
    emsg.Init("Rw11VirtTape::New", string("Scheme '") + scheme +
              "' is not supported");
  }
 
  return up;
}
 
//------------------------------------------+-----------------------------------
 
void Rw11VirtTape::SetPosFile(int posfile)
{
  if (posfile < 0) posfile = 0;
 
  RerrMsg emsg;
  int     opcode;
  size_t  ndone;
  bool    rc = Rewind(opcode, emsg);
 
  while (rc && posfile != fPosFile) {
    rc = SpaceForw(1000000000, ndone, opcode, emsg);
    if (rc && opcode == kOpCodeEom) return;
  }
 
  if (!rc) throw Rexception("Rw11VirtTape::SetPosFile", emsg.Text());
 
  return;
}
 
//------------------------------------------+-----------------------------------
 
void Rw11VirtTape::SetPosRecord(int posrec)
{
  if (posrec < 0) posrec = 0;
 
  RerrMsg emsg;
  int     opcode;
  size_t  ndone;
 
  // space back to begin of current file (works even when fPosRecord is -1!)
  bool rc = SpaceBack(1000000000, ndone, opcode, emsg);
  // if eof was spaced over backwards, space forward over eof
  if (rc && opcode == kOpCodeEof) rc = SpaceForw(1, ndone, opcode, emsg);
  // now space forward to find record
  if (rc && posrec != 0) {
    rc = SpaceForw(posrec, ndone, opcode, emsg);
    // if eof was spaced over, space backward over eof to stay in file
    // the number of records spaced is used to setup fPosRecord
    if (rc && opcode == kOpCodeEof) {
      size_t ndoneeof;
      rc = SpaceBack(1, ndoneeof, opcode, emsg);
      if (rc) fPosRecord = ndone;
    }
  }
 
  if (!rc) throw Rexception("Rw11VirtTape::SetPosFile", emsg.Text());
 
  return;
}
 
//------------------------------------------+-----------------------------------
 
void Rw11VirtTape::Dump(std::ostream& os, int ind, const char* text,
                        int detail) const
{
  RosFill bl(ind);
  os << bl << (text?text:"--") << "Rw11VirtTape @ " << this << endl;
 
  os << bl << "  fCapacity:       " << fCapacity << endl;
  os << bl << "  fBot:            " << RosPrintf(fBot) << endl;
  os << bl << "  fEot:            " << RosPrintf(fEot) << endl;
  os << bl << "  fEom:            " << RosPrintf(fEom) << endl;
  os << bl << "  fPosFile:        " << fPosFile << endl;
  os << bl << "  fPosRecord:      " << fPosRecord << endl;
  Rw11Virt::Dump(os, ind, " ^", detail);
  return;
}
 
 
} // end namespace Retro