#include <qxrddetectorpilatusremote.h>

Inheritance diagram for QxrdDetectorPilatusRemote:

Collaboration diagram for QxrdDetectorPilatusRemote:

Public Slots
void	connectToRemote (QString sshCmd)

void	executeRemote (QString cmd)

void	onReadyRead ()

Public Slots inherited from QcepObject
virtual void	printLine (QString line)

virtual void	printMessage (QString msg, QDateTime dt=QDateTime::currentDateTime()) const

virtual void	criticalMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

virtual void	statusMessage (QString msg, QDateTime ts=QDateTime::currentDateTime()) const

virtual QString	settingsScript ()

QString	scriptValueLiteral (QVariant v)

Public Member Functions
	QxrdDetectorPilatusRemote (QcepObject *owner)

Public Member Functions inherited from QcepObject
	QcepObject (QString name, QcepObject *parent)

virtual	~QcepObject ()

virtual void	writeSettings (QSettings *set, QString section)

virtual void	readSettings (QSettings *set, QString section)

QString	get_Name () const

void	set_Name (QString name)

Private Member Functions
void	interpretLine (QString line)

Private Attributes
QProcess	m_Process

QByteArray	m_Buffer

int	m_FileTransferSize

QByteArray	m_TransferredFile

Additional Inherited Members
Static Public Member Functions inherited from QcepObject
static int	allocatedObjects ()

static int	deletedObjects ()

static QSet< QcepObject * >	allocatedObjectsSet ()

static QString	addSlashes (QString str)

Properties inherited from QcepObject
QString	name

Detailed Description

Definition at line 8 of file qxrddetectorpilatusremote.h.

Constructor & Destructor Documentation

QxrdDetectorPilatusRemote::QxrdDetectorPilatusRemote ( QcepObject * owner )

Definition at line 5 of file qxrddetectorpilatusremote.cpp.

References m_Process, onReadyRead(), and QcepObject::printMessage().

   : QcepObject("pilatusRemote", owner),
     m_FileTransferSize(0)
 {
   printMessage("Constructed Pilatus Remote Object");
 
   connect(&m_Process, &QProcess::readyRead, this, &QxrdDetectorPilatusRemote::onReadyRead);
 }

Here is the call graph for this function:

Member Function Documentation

void QxrdDetectorPilatusRemote::connectToRemote ( QString sshCmd )

slot

Definition at line 14 of file qxrddetectorpilatusremote.cpp.

References m_Process, and QcepObject::printMessage().

 {
   printMessage(tr("Connect to %1").arg(sshCmd));
 
   m_Process.setProcessChannelMode(QProcess::MergedChannels);
   m_Process.start(sshCmd);
 }

Here is the call graph for this function:

void QxrdDetectorPilatusRemote::executeRemote ( QString cmd )

slot

Definition at line 22 of file qxrddetectorpilatusremote.cpp.

References m_Process, and QcepObject::printMessage().

 {
   printMessage(tr("Exceute %1").arg(cmd));
 
   m_Process.write(qPrintable(cmd+"\n"));
 }

Here is the call graph for this function:

void QxrdDetectorPilatusRemote::interpretLine ( QString line )

private

Definition at line 71 of file qxrddetectorpilatusremote.cpp.

References m_FileTransferSize, and QcepObject::printMessage().

Referenced by onReadyRead().

 {
   printMessage(tr("QxrdDetectorPilatusRemote::interpretLine(\"%1\")").arg(line));
 
   if (line.startsWith("transfer:")) {
     QStringList fields = line.split(QRegExp("\\s+"));
 
     printMessage(tr("transfer: %1 args").arg(fields.count()));
 
     foreach(QString f, fields) {
       printMessage(tr("Arg:%1").arg(f));
     }
 
     m_FileTransferSize = fields.value(4).toInt();
 
     printMessage(tr("Transfer %1 bytes").arg(m_FileTransferSize));
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatusRemote::onReadyRead ( )

slot

Definition at line 29 of file qxrddetectorpilatusremote.cpp.

References DEBUG_PILATUS, interpretLine(), m_Buffer, m_FileTransferSize, m_Process, m_TransferredFile, QcepObject::printMessage(), and qcepDebug().

Referenced by QxrdDetectorPilatusRemote().

 {
   printMessage(tr("Remote On ready read (%1 bytes available)").arg(m_Process.bytesAvailable()));
 
   m_Buffer.append(m_Process.readAll());
 
   while (1) {
     if (m_FileTransferSize > 0) { // Doing a file transfer
       if (m_Buffer.count() >= m_FileTransferSize) {
         m_TransferredFile = m_Buffer.left(m_FileTransferSize);
 
         QByteArray hash = QCryptographicHash::hash(m_TransferredFile, QCryptographicHash::Md5);
 
         printMessage(tr("%1 byte file transferred, md5sum %2")
                      .arg(m_FileTransferSize)
                      .arg(QString(hash.toHex())));
 
         m_Buffer.remove(0, m_FileTransferSize);
 
         m_FileTransferSize = 0;
       } else {
         return;
       }
     } else {
       int ind = m_Buffer.indexOf('\n');
 
       if (ind >= 0) {
         QString line = m_Buffer.left(ind); // Don't include newline
         m_Buffer.remove(0, ind+1);
 
         if (qcepDebug(DEBUG_PILATUS)) {
           printMessage(tr("(%1) : \"%2\"").arg(line.count()).arg(QString(line)));
         }
 
         interpretLine(line);
       } else { // No new lines when expected
         return;
       }
     }
   }
 }