areaDetector
3-13
EPICS areaDetector framework
|
Class from which actual plugin drivers are derived; derived from asynNDArrayDriver. More...
#include <NDPluginDriver.h>
Public Member Functions | |
NDPluginDriver (const char *portName, int queueSize, int blockingCallbacks, const char *NDArrayPort, int NDArrayAddr, int maxAddr, int maxBuffers, size_t maxMemory, int interfaceMask, int interruptMask, int asynFlags, int autoConnect, int priority, int stackSize, int maxThreads, bool compressionAware=false) | |
Constructor for NDPluginDriver; most parameters are simply passed to asynNDArrayDriver::asynNDArrayDriver. More... | |
~NDPluginDriver () | |
virtual asynStatus | writeInt32 (asynUser *pasynUser, epicsInt32 value) |
Called when asyn clients call pasynInt32->write(). More... | |
virtual asynStatus | writeFloat64 (asynUser *pasynUser, epicsFloat64 value) |
Called when asyn clients call pasynFloat64->write(). More... | |
virtual asynStatus | writeOctet (asynUser *pasynUser, const char *value, size_t maxChars, size_t *nActual) |
Called when asyn clients call pasynOctet->write(). More... | |
virtual asynStatus | readInt32Array (asynUser *pasynUser, epicsInt32 *value, size_t nElements, size_t *nIn) |
Called when asyn clients call pasynInt32Array->read(). More... | |
virtual void | driverCallback (asynUser *pasynUser, void *genericPointer) |
Method that is called from the driver with a new NDArray. More... | |
virtual void | run (void) |
Starts the thread that receives NDArrays from the epicsMessageQueue. More... | |
virtual asynStatus | start (void) |
Starts the plugin threads. More... | |
void | sortingTask () |
Method runs as a separate thread, periodically doing NDArray callbacks to downstream plugins. More... | |
Public Member Functions inherited from asynNDArrayDriver | |
asynNDArrayDriver (const char *portName, int maxAddr, int maxBuffers, size_t maxMemory, int interfaceMask, int interruptMask, int asynFlags, int autoConnect, int priority, int stackSize) | |
This is the constructor for the asynNDArrayDriver class. More... | |
virtual | ~asynNDArrayDriver () |
virtual asynStatus | readGenericPointer (asynUser *pasynUser, void *genericPointer) |
This method copies an NDArray object from the asynNDArrayDriver to an NDArray pointer passed in by the caller. More... | |
virtual asynStatus | writeGenericPointer (asynUser *pasynUser, void *genericPointer) |
This method currently does nothing, but it should be implemented in this base class. More... | |
virtual asynStatus | setIntegerParam (int index, int value) |
Sets the value for an integer in the parameter library. More... | |
virtual asynStatus | setIntegerParam (int list, int index, int value) |
Sets the value for an integer in the parameter library. More... | |
virtual void | report (FILE *fp, int details) |
Report status of the driver. More... | |
virtual asynStatus | createFilePath (const char *path, int pathDepth) |
Function to create a directory path for a file. More... | |
virtual asynStatus | checkPath () |
Checks whether the directory specified NDFilePath parameter exists. More... | |
virtual bool | checkPath (std::string &filePath) |
Checks whether the directory specified exists. More... | |
virtual asynStatus | createFileName (int maxChars, char *fullFileName) |
Build a file name from component parts. More... | |
virtual asynStatus | createFileName (int maxChars, char *filePath, char *fileName) |
Build a file name from component parts. More... | |
virtual asynStatus | readNDAttributesFile () |
Create this driver's NDAttributeList (pAttributeList) by reading an XML file This clears any existing attributes from this drivers' NDAttributeList and then creates a new list based on the XML file. More... | |
virtual asynStatus | getAttributes (NDAttributeList *pAttributeList) |
Get the current values of attributes from this driver and appends them to an output attribute list. More... | |
virtual void | updateTimeStamps (NDArray *pArray) |
asynStatus | incrementQueuedArrayCount () |
asynStatus | decrementQueuedArrayCount () |
int | getQueuedArrayCount () |
void | updateQueuedArrayCount () |
Protected Member Functions | |
virtual void | processCallbacks (NDArray *pArray)=0 |
virtual void | beginProcessCallbacks (NDArray *pArray) |
Method that is normally called at the beginning of the processCallbacks method in derived classes. More... | |
virtual asynStatus | endProcessCallbacks (NDArray *pArray, bool copyArray=false, bool readAttributes=true) |
Method that is normally called at the end of the processCallbacks()) method in derived classes. More... | |
virtual asynStatus | connectToArrayPort (void) |
Connect this plugin to an NDArray port driver; disconnect from any existing driver first, register for callbacks if enabled. More... | |
virtual asynStatus | setArrayInterrupt (int connect) |
Register or unregister to receive asynGenericPointer (NDArray) callbacks from the driver. More... | |
bool | throttled (NDArray *pArray) |
Additional Inherited Members | |
Public Attributes inherited from asynNDArrayDriver | |
class NDArrayPool * | pNDArrayPool |
An NDArrayPool pointer that is initialized to pNDArrayPoolPvt_ in the constructor. More... | |
Class from which actual plugin drivers are derived; derived from asynNDArrayDriver.
NDPluginDriver::NDPluginDriver | ( | const char * | portName, |
int | queueSize, | ||
int | blockingCallbacks, | ||
const char * | NDArrayPort, | ||
int | NDArrayAddr, | ||
int | maxAddr, | ||
int | maxBuffers, | ||
size_t | maxMemory, | ||
int | interfaceMask, | ||
int | interruptMask, | ||
int | asynFlags, | ||
int | autoConnect, | ||
int | priority, | ||
int | stackSize, | ||
int | maxThreads, | ||
bool | compressionAware = false |
||
) |
Constructor for NDPluginDriver; most parameters are simply passed to asynNDArrayDriver::asynNDArrayDriver.
After calling the base class constructor this method creates a thread to execute the NDArray callbacks, and sets reasonable default values for all of the parameters defined in NDPluginDriver.h.
[in] | portName | The name of the asyn port driver to be created. |
[in] | queueSize | The number of NDArrays that the input queue for this plugin can hold when NDPluginDriverBlockingCallbacks=0. Larger queues can decrease the number of dropped arrays, at the expense of more NDArray buffers being allocated from the underlying driver's NDArrayPool. |
[in] | blockingCallbacks | Initial setting for the NDPluginDriverBlockingCallbacks flag. 0=callbacks are queued and executed by the callback thread; 1 callbacks execute in the thread of the driver doing the callbacks. |
[in] | NDArrayPort | Name of asyn port driver for initial source of NDArray callbacks. |
[in] | NDArrayAddr | asyn port driver address for initial source of NDArray callbacks. |
[in] | maxAddr | The maximum number of asyn addr addresses this driver supports. 1 is minimum. |
[in] | maxBuffers | The maximum number of NDArray buffers that the NDArrayPool for this driver is allowed to allocate. Set this to 0 to allow an unlimited number of buffers. |
[in] | maxMemory | The maximum amount of memory that the NDArrayPool for this driver is allowed to allocate. Set this to 0 to allow an unlimited amount of memory. |
[in] | interfaceMask | Bit mask defining the asyn interfaces that this driver supports. |
[in] | interruptMask | Bit mask definining the asyn interfaces that can generate interrupts (callbacks) |
[in] | asynFlags | Flags when creating the asyn port driver; includes ASYN_CANBLOCK and ASYN_MULTIDEVICE. |
[in] | autoConnect | The autoConnect flag for the asyn port driver. |
[in] | priority | The thread priority for the asyn port driver thread if ASYN_CANBLOCK is set in asynFlags. This value should also be used for any other threads this object creates. |
[in] | stackSize | The stack size for the asyn port driver thread if ASYN_CANBLOCK is set in asynFlags. This value should also be used for any other threads this object creates. |
[in] | maxThreads | The maximum number of threads this plugin is allowed to use. |
[in] | compressionAware | true if the plugin can handle compressed input arrays, false if not. |
NDPluginDriver::~NDPluginDriver | ( | ) |
|
protectedvirtual |
Method that is normally called at the beginning of the processCallbacks method in derived classes.
[in] | pArray | The NDArray from the callback. |
This method takes care of some bookkeeping for callbacks, updating parameters from data in the class and in the NDArray. It does asynInt32Array callbacks for the dimensions array if the dimensions of the NDArray data have changed.
|
protectedvirtual |
Connect this plugin to an NDArray port driver; disconnect from any existing driver first, register for callbacks if enabled.
Reimplemented in NDPluginGather.
|
virtual |
Method that is called from the driver with a new NDArray.
It calls the processCallbacks function, which typically is implemented in the derived class. It can either do the callbacks directly (if NDPluginDriverBlockingCallbacks=1) or by queueing the arrays to be processed by a background task (if NDPluginDriverBlockingCallbacks=0). In the latter case arrays can be dropped if the queue is full. This method should really be private, but it must be called from a C-linkage callback function, so it must be public.
[in] | pasynUser | The pasynUser from the asyn client. |
[in] | genericPointer | The pointer to the NDArray |
|
protectedvirtual |
Method that is normally called at the end of the processCallbacks()) method in derived classes.
[in] | pArray | The NDArray from the callback. |
[in] | copyArray | This flag should be true if pArray is the original array passed to processCallbacks(). It must be false if the derived class if pArray is a new NDArray that processCallbacks() created |
[in] | readAttributes | This flag must be true if the derived class has not yet called readAttributes() for pArray. |
This method does NDArray callbacks to downstream plugins if NDArrayCallbacks is true and SortMode is Unsorted. If SortMode is sorted it inserts the NDArray into the std::multilist for callbacks in SortThread(). It keeps track of DisorderedArrays and DroppedOutputArrays. It caches the most recent NDArray in pArrays[0].
|
protectedpure virtual |
Implemented in ffmpegStream, NDPluginEdge, pcoEdgePlugin, NDPluginMask, ADnEDPixelROI, NDPosPlugin, NDPluginTransform, NDPluginTimeSeries, NDPluginStdArrays, NDPluginStats, NDPluginScatter, NDPluginROIStat, NDPluginROI, NDPluginPva, NDPluginProcess, NDPluginOverlay, NDPluginGather, NDPluginFile, NDPluginFFT, NDPluginColorConvert, NDPluginCodec, NDPluginCircularBuff, NDPluginBadPixel, NDPluginAttrPlot, and NDPluginAttribute.
|
virtual |
Called when asyn clients call pasynInt32Array->read().
Returns the value of the array dimensions for the last NDArray.
[in] | pasynUser | pasynUser structure that encodes the reason and address. |
[in] | value | Pointer to the array to read. |
[in] | nElements | Number of elements to read. |
[out] | nIn | Number of elements actually read. |
Reimplemented in NDPluginStdArrays.
|
virtual |
Starts the thread that receives NDArrays from the epicsMessageQueue.
|
protectedvirtual |
Register or unregister to receive asynGenericPointer (NDArray) callbacks from the driver.
Note: this function must be called with the lock released, otherwise a deadlock can occur in the call to cancelInterruptUser.
[in] | enableCallbacks | 1 to enable callbacks, 0 to disable callbacks |
Reimplemented in NDPluginGather.
void NDPluginDriver::sortingTask | ( | ) |
Method runs as a separate thread, periodically doing NDArray callbacks to downstream plugins.
This thread is used when SortMode=1. This method should really be private, but it must be called from a C-linkage callback function, so it must be public.
|
virtual |
Starts the plugin threads.
This method must be called after the derived class object is fully constructed.
|
protected |
|
virtual |
Called when asyn clients call pasynFloat64->write().
This function performs actions for NDPluginDriverMaxByteRate. For all parameters it sets the value in the parameter library and calls any registered callbacks..
[in] | pasynUser | pasynUser structure that encodes the reason and address. |
[in] | value | Value to write. |
Reimplemented in ffmpegFile, NDPluginTimeSeries, and NDPluginStats.
|
virtual |
Called when asyn clients call pasynInt32->write().
This function performs actions for some parameters, including NDPluginDriverEnableCallbacks and NDPluginDriverArrayAddr. For all parameters it sets the value in the parameter library and calls any registered callbacks..
[in] | pasynUser | pasynUser structure that encodes the reason and address. |
[in] | value | Value to write. |
Reimplemented from asynNDArrayDriver.
Reimplemented in NDPosPlugin, NDPluginTimeSeries, NDPluginStats, NDPluginROIStat, NDPluginROI, NDPluginProcess, NDPluginOverlay, NDPluginFile, NDPluginCodec, NDPluginCircularBuff, NDPluginAttrPlot, NDPluginAttribute, and NDFileHDF5.
|
virtual |
Called when asyn clients call pasynOctet->write().
This function performs actions for some parameters, including NDPluginDriverArrayPort. For all parameters it sets the value in the parameter library and calls any registered callbacks..
[in] | pasynUser | pasynUser structure that encodes the reason and address. |
[in] | value | Address of the string to write. |
[in] | nChars | Number of characters to write. |
[out] | nActual | Number of characters actually written. |
Reimplemented from asynNDArrayDriver.
Reimplemented in NDPosPlugin, NDPluginCircularBuff, NDPluginBadPixel, NDFileNexus, and NDFileHDF5.
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |