#include <qxrddetectorpilatus.h>

Inheritance diagram for QxrdDetectorPilatus:

Collaboration diagram for QxrdDetectorPilatus:

[legend]

Public Slots
void	startDetector ()

void	stopDetector ()

void	beginAcquisition (double exposure)

void	endAcquisition ()

void	shutdownAcquisition ()

void	beginFrame ()

void	remoteConnect (QString sshCmd)

void	remoteCommand (QString cmd)

void	remoteCopy (QString file)

void	remoteDelete (QString file)

void	remoteTransfer (QString file)

void	executeCommand (QString cmd)

Public Slots inherited from QxrdDetector
bool	isEnabled ()

bool	checkDetectorEnabled ()

virtual void	startDetector ()

virtual void	stopDetector ()

virtual void	onExposureTimeChanged ()

virtual void	beginAcquisition (double exposure)

virtual void	endAcquisition ()

virtual void	shutdownAcquisition ()

void	openControlWindow ()

QxrdDetectorProcessorPtr	processor ()

void	startOrStop (bool enabled)

virtual void	beginFrame ()

virtual QcepImageDataBasePtr	acquireFrameIfAvailable ()

virtual QcepImageDataBasePtr	acquireFrame ()

int	roiCount ()

QxrdROICoordinatesPtr	roi (int i)

QcepDoubleVector	scalerCounts ()

double	scalerCounts (int chan)

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

virtual QString	settingsScript ()

QString	scriptValueLiteral (QVariant v)

Public Member Functions
	QxrdDetectorPilatus (QcepSettingsSaverWPtr saver, QxrdExperimentWPtr expt, QxrdAcquisitionWPtr acq, int detNum, QcepObject *parent)

virtual	~QxrdDetectorPilatus ()

void	pushPropertiesToProxy (QxrdDetectorProxyPtr proxy)

void	pullPropertiesfromProxy (QxrdDetectorProxyPtr proxy)

Public Member Functions inherited from QxrdDetector
	QxrdDetector (QcepSettingsSaverWPtr saver, QxrdExperimentWPtr expt, QxrdAcquisitionWPtr acq, int detType, int detNum, QcepObject *parent)

void	initialize ()

virtual	~QxrdDetector ()

QxrdExperimentWPtr	experiment ()

QxrdAcquisitionWPtr	acquisition ()

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

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

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

void	readSettings (QSettings *settings, QString section)

void	writeSettings (QSettings *settings, QString section)

void	enqueueAcquiredFrame (QcepImageDataBasePtr img)

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

virtual	~QcepObject ()

QString	get_Name () const

void	set_Name (QString name)

Static Public Member Functions
static void	pushDefaultsToProxy (QxrdDetectorProxyPtr proxy)

Static Public Member Functions inherited from QxrdDetector
static QScriptValue	toScriptValue (QScriptEngine *engine, const QxrdDetectorPtr &det)

static void	fromScriptValue (const QScriptValue &obj, QxrdDetectorPtr &det)

static void	pushDefaultsToProxy (QxrdDetectorProxyPtr proxy, int detType)

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

static int	deletedObjects ()

static QSet< QcepObject * >	allocatedObjectsSet ()

static QString	addSlashes (QString str)

Properties
QString	pilatusHost

int	pilatusPort

QString	pilatusUser

QString	pilatusSSH

QString	pilatusSCP

QString	pilatusDataDirectory

bool	readFilesLocally

bool	deleteFilesAfterReading

int	exposureMode

double	enableFrequency

QString	pilatusExtension

Properties inherited from QxrdDetector
int	detectorNumber

int	detectorType

QString	detectorTypeName

bool	enabled

QString	detectorName

int	nCols

int	nRows

int	hBinning

int	vBinning

QString	extension

Properties inherited from QcepObject
QString	name

Private Types
enum	{ NoExternalTrigger, ExternalTrigger, ExternalEnable }

Private Member Functions
void	beginExposure (double exposure)

void	interpretReply (QString reply)

void	expose ()

void	imagePath (QString path)

void	sendCommand (QString cmd)

void	readyRead ()

void	loadAndPush (QString f)

Private Attributes
QTcpSocket	m_PilatusSocket

QString	m_PilatusReply

QByteArray	m_Buffer

QString	m_CurrentFile

double	m_ExposureTime

int	m_ExposuresPerFrame

int	m_ExposureFrameCount

QxrdDetectorPilatusRemotePtr	m_Remote

Additional Inherited Members
Public Types inherited from QxrdDetector
enum	{ FileIndexScaler, FilePhaseScaler, ExtraScalers }

Protected Attributes inherited from QxrdDetector
QcepSettingsSaverWPtr	m_Saver

QxrdExperimentWPtr	m_Experiment

QxrdAcquisitionWPtr	m_Acquisition

QxrdDetectorProcessorPtr	m_Processor

QxrdDetectorControlWindowPtr	m_DetectorControlWindow

Detailed Description

Definition at line 9 of file qxrddetectorpilatus.h.

Member Enumeration Documentation

anonymous enum

private

Enumerator
NoExternalTrigger
ExternalTrigger
ExternalEnable

Definition at line 41 of file qxrddetectorpilatus.h.

        {
     NoExternalTrigger,
     ExternalTrigger,
     ExternalEnable
   };

Constructor & Destructor Documentation

QxrdDetectorPilatus::QxrdDetectorPilatus	(	QcepSettingsSaverWPtr	saver,
		QxrdExperimentWPtr	expt,
		QxrdAcquisitionWPtr	acq,
		int	detNum,
		QcepObject *	parent
	)

explicit

Definition at line 15 of file qxrddetectorpilatus.cpp.

References DEBUG_CONSTRUCTORS, and qcepDebug().

                                                                        :
   QxrdDetector(saver, expt, acq, QxrdDetectorThread::PilatusDetector, detNum, parent),
   m_PilatusSocket(),
   m_ExposureTime(-1),
   m_ExposuresPerFrame(-1),
   m_ExposureFrameCount(-1),
   m_Remote(new QxrdDetectorPilatusRemote(this)),
   m_PilatusHost            (saver, this, "pilatusHost",          "s11id-pilatus", "Host Address of Computer running Camserver"),
   m_PilatusPort            (saver, this, "pilatusPort",          41234,         "Camserver Port Number"),
   m_PilatusUser            (saver, this, "pilatusUser",          "det",         "Camserver User Name"),
   m_PilatusSSH             (saver, this, "pilatusSSH",           "ssh",         "ssh command path"),
   m_PilatusSCP             (saver, this, "pilatusSCP",           "scp",         "scp command path"),
   m_PilatusDataDirectory   (saver, this, "pilatusDataDirectory", "/home/det/shareddata/test/",    "Data directory on Camserver computer"),
   m_ReadFilesLocally       (saver, this, "readFilesLocally",     true, "Attempt to read acquired files into QXRD for further processing"),
   m_DeleteFilesAfterReading(saver, this, "deleteFilesAfterReading", false, "Delete files from Camserver computer after reading"),
   m_ExposureMode           (saver, this, "exposureMode",         0, "Pilatus Exposure Mode = (0:No Trigger, 1:ExtTrigger, 2:ExtEnable"),
   m_EnableFrequency        (saver, this, "enableFrequency",      1000, "Frequency of ext enable signal"),
   m_PilatusExtension       (saver, this, "pilatusExtension",     "cbf",         "File format to be used by camserver")
 {
   if (qcepDebug(DEBUG_CONSTRUCTORS)) {
     printf("QxrdDetectorPilatus::QxrdDetectorPilatus(%p)\n", this);
   }
 }

Here is the call graph for this function:

QxrdDetectorPilatus::~QxrdDetectorPilatus ( )

virtual

Definition at line 43 of file qxrddetectorpilatus.cpp.

References DEBUG_CONSTRUCTORS, and qcepDebug().

 {
 #ifndef QT_NO_DEBUG
   printf("Deleting Pilatus detector\n");
 #endif
 
   if (qcepDebug(DEBUG_CONSTRUCTORS)) {
     printf("QxrdDetectorPilatus::~QxrdDetectorPilatus(%p)\n", this);
   }
 }

Here is the call graph for this function:

Member Function Documentation

void QxrdDetectorPilatus::beginAcquisition ( double exposure )

slot

Definition at line 93 of file qxrddetectorpilatus.cpp.

References QxrdDetector::beginAcquisition(), beginExposure(), DEBUG_PILATUS, imagePath(), QxrdDetector::printMessage(), and qcepDebug().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "beginAcquisition", Qt::BlockingQueuedConnection, Q_ARG(double, exposure));
   } else {
     QxrdDetector::beginAcquisition(exposure);
 
     if (qcepDebug(DEBUG_PILATUS)) {
       printMessage(tr("QxrdDetectorPilatus::beginAcquisition(%1)").arg(exposure));
     }
 
     imagePath(get_PilatusDataDirectory());
 
     beginExposure(exposure);
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::beginExposure ( double exposure )

private

Definition at line 199 of file qxrddetectorpilatus.cpp.

References ExternalEnable, ExternalTrigger, NoExternalTrigger, and sendCommand().

Referenced by beginAcquisition().

 {
   int expMode = get_ExposureMode();
 
   if (expMode == NoExternalTrigger) {
     sendCommand(tr("ExpTime %1").arg(exposure));
     sendCommand("nexpframe 1");
   } else if (expMode == ExternalTrigger) {
     sendCommand("Delay 0");
     sendCommand(tr("ExpPeriod %1").arg(exposure));
     sendCommand(tr("ExpTime %1").arg(exposure));
     sendCommand("nexpframe 1");
   } else if (expMode == ExternalEnable) {
     int nFrames = (int) (get_EnableFrequency()*exposure);
     sendCommand(tr("nexpframe %1").arg(nFrames));
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::beginFrame ( )

slot

Definition at line 242 of file qxrddetectorpilatus.cpp.

References QxrdDetector::beginFrame(), DEBUG_PILATUS, expose(), QxrdDetector::printMessage(), and qcepDebug().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "beginFrame", Qt::BlockingQueuedConnection);
   } else {
     if (qcepDebug(DEBUG_PILATUS)) {
       printMessage("QxrdDetectorPilatus::beginFrame");
     }
 
     QxrdDetector::beginFrame();
 
     expose();
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::endAcquisition ( )

slot

Definition at line 110 of file qxrddetectorpilatus.cpp.

References QxrdDetector::endAcquisition().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "endAcquisition", Qt::BlockingQueuedConnection);
   } else {
     QxrdDetector::endAcquisition();
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::executeCommand ( QString cmd )

slot

Definition at line 128 of file qxrddetectorpilatus.cpp.

References sendCommand().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "executeCommand", Qt::BlockingQueuedConnection, Q_ARG(QString, cmd));
   } else {
     sendCommand(cmd);
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::expose ( )

private

Definition at line 217 of file qxrddetectorpilatus.cpp.

References ExternalEnable, ExternalTrigger, QxrdDetector::m_Acquisition, m_CurrentFile, NoExternalTrigger, and sendCommand().

Referenced by beginFrame().

 {
   QxrdAcquisitionPtr acq(m_Acquisition);
 
   if (acq) {
     m_CurrentFile = acq->currentFileBase(get_DetectorNumber(), get_PilatusExtension());
 
     if (get_ReadFilesLocally()) { // Check to see if file exists...
       if (get_DeleteFilesAfterReading()) {
         // Attempt to delete file before acquisition...
       }
     }
 
     int expMode = get_ExposureMode();
 
     if (expMode == NoExternalTrigger) {
       sendCommand(tr("Exposure \"%1\"").arg(m_CurrentFile));
     } else if (expMode == ExternalTrigger) {
       sendCommand(tr("ExtTrigger \"%1\"").arg(m_CurrentFile));
     } else if (expMode == ExternalEnable) {
       sendCommand(tr("ExtEnable \"%1\"").arg(m_CurrentFile));
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::imagePath ( QString path )

private

Definition at line 192 of file qxrddetectorpilatus.cpp.

References QxrdDetector::checkDetectorEnabled(), and sendCommand().

Referenced by beginAcquisition(), and startDetector().

 {
   if (checkDetectorEnabled()) {
     sendCommand(tr("imgpath \"%1\"").arg(path));
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::interpretReply ( QString reply )

private

Definition at line 257 of file qxrddetectorpilatus.cpp.

References QxrdDetector::criticalMessage(), DEBUG_PILATUS, QxrdDetector::enqueueAcquiredFrame(), loadAndPush(), m_CurrentFile, QxrdDetector::printMessage(), qcepDebug(), remoteCopy(), and remoteDelete().

Referenced by readyRead().

 {
   if (qcepDebug(DEBUG_PILATUS)) {
     printMessage(tr("QxrdDetectorPilatus::interpretReply(\"%1\")").arg(reply));
   }
 
   if (reply.startsWith("1 ERR")) {
     criticalMessage(tr("Error with pilatus detector: %1").arg(reply));
   } else if (reply.startsWith("7 OK")) { // Image has been saved...
     if (get_ReadFilesLocally() == false) {
       enqueueAcquiredFrame(QcepInt16ImageDataPtr());
     } else {
       remoteCopy(m_CurrentFile);
 //      pushFileExpected(m_CurrentFile);
       loadAndPush(m_CurrentFile);
 
       if (get_DeleteFilesAfterReading()) {
         remoteDelete(m_CurrentFile);
       }
     }
   } else if (reply.startsWith("Image format:")) {
     QRegExp matcher("Image format\\: (\\d+)\\(w\\) x (\\d+)\\(h\\) pixels(.*)");
 
     if (matcher.exactMatch(reply)) {
       int width = matcher.cap(1).toInt();
       int height = matcher.cap(2).toInt();
 
       printMessage(tr("Detector dimensions %1 cols x %2 rows").arg(width).arg(height));
 
       set_NRows(height);
       set_NCols(width);
       set_HBinning(1);
       set_VBinning(1);
     } else {
       printMessage(tr("Unmatched: %1, %2").arg(reply).arg(matcher.pattern()));
       printMessage(tr("Matched Length %1").arg(matcher.matchedLength()));
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::loadAndPush ( QString f )

private

Definition at line 442 of file qxrddetectorpilatus.cpp.

References QcepAllocator::AllocateFromReserve, QxrdDetector::enqueueAcquiredFrame(), QxrdDetector::m_Experiment, QcepAllocator::newInt32Image(), and QxrdDetector::printMessage().

Referenced by interpretReply().

 {
   QxrdExperimentPtr  expt(m_Experiment);
 
   if (expt) {
     QxrdDataProcessorPtr proc = expt->dataProcessor();
 
     if (proc) {
       QString dest = proc->filePathInRawOutputDirectory(f);
 
       QcepInt32ImageDataPtr data = QcepAllocator::newInt32Image(QcepAllocator::AllocateFromReserve, 0,0, this);
 
       if (data->readImage(dest)) {
         printMessage(tr("Read %1 successfully").arg(dest));
       }
 
       enqueueAcquiredFrame(data);
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::pullPropertiesfromProxy ( QxrdDetectorProxyPtr proxy )

virtual

Reimplemented from QxrdDetector.

Definition at line 335 of file qxrddetectorpilatus.cpp.

References QxrdDetector::pullPropertiesfromProxy().

 {
   QxrdDetector::pullPropertiesfromProxy(proxy);
 
   if (proxy) {
     set_PilatusHost            (proxy->property("pilatusHost").toString());
     set_PilatusUser            (proxy->property("pilatusUser").toString());
     set_PilatusSSH             (proxy->property("pilatusSSH").toString());
     set_PilatusSCP             (proxy->property("pilatusSCP").toString());
     set_PilatusDataDirectory   (proxy->property("pilatusDataDirectory").toString());
     set_ReadFilesLocally       (proxy->property("readFilesLocally").toBool());
     set_DeleteFilesAfterReading(proxy->property("deleteFilesAfterReading").toBool());
     set_PilatusExtension       (proxy->property("pilatusExtension").toString());
     set_ExposureMode           (proxy->property("exposureMode").toInt());
     set_EnableFrequency        (proxy->property("enableFrequency").toDouble());
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::pushDefaultsToProxy ( QxrdDetectorProxyPtr proxy )

static

Definition at line 297 of file qxrddetectorpilatus.cpp.

References QxrdDetectorProxy::BooleanProperty, QxrdDetectorProxy::DirectoryProperty, QxrdDetectorProxy::DoubleProperty, QxrdDetectorProxy::ExtensionProperty, QxrdDetectorProxy::FilenameProperty, QxrdDetectorProxy::FixedIntegerProperty, QxrdDetectorThread::PilatusDetector, QxrdDetectorProxy::PilatusModeProperty, QxrdDetector::pushDefaultsToProxy(), and QxrdDetectorProxy::StringProperty.

Referenced by QxrdDetectorThread::pushDefaultsToProxy().

 {
   QxrdDetector::pushDefaultsToProxy(proxy, QxrdDetectorThread::PilatusDetector);
 
   if (proxy) {
     proxy->pushProperty(QxrdDetectorProxy::StringProperty, "pilatusHost",          "Camserver Host",    "s11id-pilatus");
     proxy->pushProperty(QxrdDetectorProxy::FixedIntegerProperty,   "pilatusPort",  "Camserver Port",    41234);
     proxy->pushProperty(QxrdDetectorProxy::StringProperty,  "pilatusUser",         "Camserver User",    "det");
     proxy->pushProperty(QxrdDetectorProxy::FilenameProperty,  "pilatusSSH",        "ssh command",       "ssh");
     proxy->pushProperty(QxrdDetectorProxy::FilenameProperty,  "pilatusSCP",        "scp command",       "scp");
     proxy->pushProperty(QxrdDetectorProxy::DirectoryProperty, "pilatusDataDirectory", "Camserver Data Directory", "/home/det/shareddata/test/");
     proxy->pushProperty(QxrdDetectorProxy::BooleanProperty, "readFilesLocally",     "Attempt to read acquired files into QXRD for further processing", true);
     proxy->pushProperty(QxrdDetectorProxy::BooleanProperty, "deleteFilesAfterReading", "Delete files from camserver computer after use", false);
     proxy->pushProperty(QxrdDetectorProxy::ExtensionProperty, "pilatusExtension",   "File format for camserver", "cbf");
     proxy->pushProperty(QxrdDetectorProxy::PilatusModeProperty, "exposureMode",     "Pilatus Exposure Mode", 0);
     proxy->pushProperty(QxrdDetectorProxy::DoubleProperty, "enableFrequency",       "Ext Enable Frequency", 1000);
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::pushPropertiesToProxy ( QxrdDetectorProxyPtr proxy )

virtual

Reimplemented from QxrdDetector.

Definition at line 316 of file qxrddetectorpilatus.cpp.

References QxrdDetectorProxy::BooleanProperty, QxrdDetectorProxy::DirectoryProperty, QxrdDetectorProxy::DoubleProperty, QxrdDetectorProxy::ExtensionProperty, QxrdDetectorProxy::FilenameProperty, QxrdDetectorProxy::FixedIntegerProperty, QxrdDetectorProxy::PilatusModeProperty, QxrdDetector::pushPropertiesToProxy(), and QxrdDetectorProxy::StringProperty.

 {
   QxrdDetector::pushPropertiesToProxy(proxy);
 
   if (proxy) {
     proxy->pushProperty(QxrdDetectorProxy::StringProperty, "pilatusHost",          "Camserver Host",    get_PilatusHost());
     proxy->pushProperty(QxrdDetectorProxy::FixedIntegerProperty,   "pilatusPort",  "Camserver Port",    get_PilatusPort());
     proxy->pushProperty(QxrdDetectorProxy::StringProperty, "pilatusUser",          "Camserver User",    get_PilatusUser());
     proxy->pushProperty(QxrdDetectorProxy::FilenameProperty,  "pilatusSSH",        "ssh command",       get_PilatusSSH());
     proxy->pushProperty(QxrdDetectorProxy::FilenameProperty,  "pilatusSCP",        "scp command",       get_PilatusSCP());
     proxy->pushProperty(QxrdDetectorProxy::DirectoryProperty, "pilatusDataDirectory", "Camserver Data Directory", get_PilatusDataDirectory());
     proxy->pushProperty(QxrdDetectorProxy::BooleanProperty, "readFilesLocally",     "Attempt to read acquired files into QXRD for further processing", get_ReadFilesLocally());
     proxy->pushProperty(QxrdDetectorProxy::BooleanProperty, "deleteFilesAfterReading", "Delete files from camserver computer after use", get_DeleteFilesAfterReading());
     proxy->pushProperty(QxrdDetectorProxy::ExtensionProperty, "pilatusExtension",   "File format for camserver", get_PilatusExtension());
     proxy->pushProperty(QxrdDetectorProxy::PilatusModeProperty, "exposureMode",     "Pilatus Exposure Mode", get_ExposureMode());
     proxy->pushProperty(QxrdDetectorProxy::DoubleProperty, "enableFrequency",       "Ext Enable Frequency", get_EnableFrequency());
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::readyRead ( )

private

Definition at line 137 of file qxrddetectorpilatus.cpp.

References DEBUG_PILATUS, interpretReply(), m_Buffer, m_PilatusSocket, QxrdDetector::printMessage(), and qcepDebug().

Referenced by startDetector().

 {
   if (qcepDebug(DEBUG_PILATUS)) {
     printMessage("QxrdDetectorPilatus::readyRead");
 
     printMessage(tr("%1 bytes available").arg(m_PilatusSocket.bytesAvailable()));
   }
 
   m_Buffer.append(m_PilatusSocket.readAll());
 
   while(1) {
     int ind1 = m_Buffer.indexOf('\n');
     int ind2 = m_Buffer.indexOf(char(24));
 
     int ind = ind1;
 
     if (ind1 >= 0 && ind2 >= 0) {
       if (ind1 < ind2) {
         ind = ind1;
       } else {
         ind = ind2;
       }
     } else if (ind1 >= 0) {
       ind = ind1;
     } else {
       ind = ind2;
     }
 
     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)));
       }
 
       interpretReply(line);
     } else { // No new lines when expected
       return;
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::remoteCommand ( QString cmd )

slot

Definition at line 364 of file qxrddetectorpilatus.cpp.

References m_Remote.

Referenced by remoteTransfer().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "remoteCommand", Q_ARG(QString, cmd));
   } else {
     if (m_Remote) {
       m_Remote->executeRemote(cmd);
     }
   }
 }

Here is the caller graph for this function:

void QxrdDetectorPilatus::remoteConnect ( QString sshCmd )

slot

Definition at line 353 of file qxrddetectorpilatus.cpp.

References m_Remote.

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "remoteConnect", Q_ARG(QString, sshCmd));
   } else {
     if (m_Remote) {
       m_Remote->connectToRemote(sshCmd);
     }
   }
 }

void QxrdDetectorPilatus::remoteCopy ( QString file )

slot

Definition at line 394 of file qxrddetectorpilatus.cpp.

References DEBUG_PILATUS, QxrdDetector::m_Experiment, QxrdDetector::printMessage(), and qcepDebug().

Referenced by interpretReply().

 {
   QxrdExperimentPtr  expt(m_Experiment);
 
   if (expt) {
     QxrdDataProcessorPtr proc = expt->dataProcessor();
 
     if (proc) {
       QString dest = proc->filePathInRawOutputDirectory(file);
 
       QString cmd = tr("%1 -o ForwardX11=No %2@%3:%4/%5 %6")
           .arg(get_PilatusSCP())
           .arg(get_PilatusUser())
           .arg(get_PilatusHost())
           .arg(get_PilatusDataDirectory()).arg(file)
           .arg(dest);
 
       if (qcepDebug(DEBUG_PILATUS)) {
         printMessage(cmd);
       }
 
       int rc = QProcess::execute(cmd);
 
       if (rc) {
         printMessage(tr("rc = %1").arg(rc));
       }
     }
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::remoteDelete ( QString file )

slot

Definition at line 375 of file qxrddetectorpilatus.cpp.

References DEBUG_PILATUS, QxrdDetector::printMessage(), and qcepDebug().

Referenced by interpretReply().

 {
   QString cmd = tr("%1 -o ForwardX11=No %2@%3 rm %4/%5")
       .arg(get_PilatusSSH())
       .arg(get_PilatusUser())
       .arg(get_PilatusHost())
       .arg(get_PilatusDataDirectory()).arg(file);
 
   if (qcepDebug(DEBUG_PILATUS)) {
     printMessage(tr("Deleting: %1").arg(cmd));
   }
 
   int rc = QProcess::execute(cmd);
 
   if (rc) {
     printMessage(tr("rc = %1").arg(rc));
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::remoteTransfer ( QString file )

slot

Definition at line 424 of file qxrddetectorpilatus.cpp.

References QxrdDetector::m_Experiment, and remoteCommand().

 {
   // Transfer contents of a remote file to a local memory buffer:"
 
   QxrdExperimentPtr  expt(m_Experiment);
 
   if (expt) {
     QxrdDataProcessorPtr proc = expt->dataProcessor();
 
     if (proc) {
       QString dest = proc->filePathInRawOutputDirectory(file);
 
       remoteCommand(tr("echo -n transfer: ; ls -la %1").arg(file));
       remoteCommand(tr("cat %1").arg(file));
     }
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::sendCommand ( QString cmd )

private

Definition at line 180 of file qxrddetectorpilatus.cpp.

References DEBUG_PILATUS, m_PilatusSocket, QxrdDetector::printMessage(), qcepDebug(), and THREAD_CHECK.

Referenced by beginExposure(), executeCommand(), expose(), imagePath(), and startDetector().

 {
   THREAD_CHECK;
 
   if (qcepDebug(DEBUG_PILATUS)) {
     printMessage(tr("QxrdDetectorPilatus::sendCommand(\"%1\")").arg(cmd));
   }
 
   m_PilatusSocket.write(qPrintable(cmd+"\n"));
   m_PilatusSocket.waitForBytesWritten();
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void QxrdDetectorPilatus::shutdownAcquisition ( )

slot

Definition at line 119 of file qxrddetectorpilatus.cpp.

References QxrdDetector::shutdownAcquisition().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "shutdownAcquisition", Qt::BlockingQueuedConnection);
   } else {
     QxrdDetector::shutdownAcquisition();
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::startDetector ( )

slot

Definition at line 54 of file qxrddetectorpilatus.cpp.

References DEBUG_PILATUS, imagePath(), m_PilatusSocket, QxrdDetector::printMessage(), qcepDebug(), readyRead(), sendCommand(), and QxrdDetector::startDetector().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "startDetector"/*, Qt::BlockingQueuedConnection*/);
   } else {
     QxrdDetector::startDetector();
 
     printMessage(tr("Starting Pilatus Detector at %1:%2").arg(get_PilatusHost()).arg(get_PilatusPort()));
 
     m_PilatusSocket.connectToHost(get_PilatusHost(), get_PilatusPort());
     m_PilatusSocket.waitForConnected();
 
     if (qcepDebug(DEBUG_PILATUS)) {
       printMessage("Connected to pilatus...");
     }
 
     connect(&m_PilatusSocket, &QTcpSocket::readyRead, this, &QxrdDetectorPilatus::readyRead);
 
     sendCommand("telemetry");
     sendCommand("nimages 1");
     sendCommand("nexpframe 1");
 
     imagePath(get_PilatusDataDirectory());
   }
 }

Here is the call graph for this function:

void QxrdDetectorPilatus::stopDetector ( )

slot

Definition at line 80 of file qxrddetectorpilatus.cpp.

References m_PilatusSocket, QxrdDetector::printMessage(), and QxrdDetector::stopDetector().

 {
   if (QThread::currentThread() != thread()) {
     QMetaObject::invokeMethod(this, "stopDetector");
   } else {
     QxrdDetector::stopDetector();
 
     printMessage(tr("Stopping Pilatus Detector at %1").arg(get_PilatusHost()));
 
     m_PilatusSocket.close();
   }
 }

Here is the call graph for this function:

Member Data Documentation

QByteArray QxrdDetectorPilatus::m_Buffer

private

Definition at line 63 of file qxrddetectorpilatus.h.

Referenced by readyRead().

QString QxrdDetectorPilatus::m_CurrentFile

private

Definition at line 64 of file qxrddetectorpilatus.h.

Referenced by expose(), and interpretReply().

int QxrdDetectorPilatus::m_ExposureFrameCount

private

Definition at line 68 of file qxrddetectorpilatus.h.

int QxrdDetectorPilatus::m_ExposuresPerFrame

private

Definition at line 67 of file qxrddetectorpilatus.h.

double QxrdDetectorPilatus::m_ExposureTime

private

Definition at line 66 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::m_PilatusReply

private

Definition at line 62 of file qxrddetectorpilatus.h.

QTcpSocket QxrdDetectorPilatus::m_PilatusSocket

private

Definition at line 61 of file qxrddetectorpilatus.h.

Referenced by readyRead(), sendCommand(), startDetector(), and stopDetector().

QxrdDetectorPilatusRemotePtr QxrdDetectorPilatus::m_Remote

private

Definition at line 70 of file qxrddetectorpilatus.h.

Referenced by remoteCommand(), and remoteConnect().

Property Documentation

bool QxrdDetectorPilatus::deleteFilesAfterReading

readwrite

Definition at line 94 of file qxrddetectorpilatus.h.

double QxrdDetectorPilatus::enableFrequency

readwrite

Definition at line 100 of file qxrddetectorpilatus.h.

int QxrdDetectorPilatus::exposureMode

readwrite

Definition at line 97 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::pilatusDataDirectory

readwrite

Definition at line 88 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::pilatusExtension

readwrite

Definition at line 103 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::pilatusHost

readwrite

Definition at line 73 of file qxrddetectorpilatus.h.

int QxrdDetectorPilatus::pilatusPort

readwrite

Definition at line 76 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::pilatusSCP

readwrite

Definition at line 85 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::pilatusSSH

readwrite

Definition at line 82 of file qxrddetectorpilatus.h.

QString QxrdDetectorPilatus::pilatusUser

readwrite

Definition at line 79 of file qxrddetectorpilatus.h.

bool QxrdDetectorPilatus::readFilesLocally

readwrite

Definition at line 91 of file qxrddetectorpilatus.h.

The documentation for this class was generated from the following files:

Public Slots

Public Member Functions

Static Public Member Functions

Properties

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation

Property Documentation