#include <IIOThreadedQ.H>
|
| | IIOThreadedQ () |
| |
| virtual | ~IIOThreadedQ () |
| |
| int | setSampleCountChannelCount (uint N, uint ch) |
| |
| | IIO () |
| |
| virtual | ~IIO () |
| |
| int | findDevicesByChipName (std::string chipName) |
| |
| uint | getDeviceCnt () |
| |
| uint | getChCnt () |
| |
| void | printInfo () |
| |
| int | open (void) |
| |
| int | close (void) |
| |
| int | getChFrameSize (void) |
| |
| int | getDevFrameSize (void) |
| |
| template<typename TYPE > |
| int | getReadArray (uint N, Eigen::Array< TYPE, Eigen::Dynamic, Eigen::Dynamic > &array) |
| |
| template<typename TYPE > |
| int | getReadArraySampleCount (Eigen::Array< TYPE, Eigen::Dynamic, Eigen::Dynamic > &array) |
| |
| template<typename TYPE > |
| int | read (uint N, const Eigen::Array< TYPE, Eigen::Dynamic, Eigen::Dynamic > &array) |
| |
| int | enable (bool enable) |
| |
| int | getChannelBufferCnt () |
| |
| int | setChannelBufferCnt (int chBufCnt) |
| |
| virtual int | run (int priority=0) |
| |
| | Thread (void) |
| |
| virtual | ~Thread (void) |
| |
| void * | stop (void) |
| |
| int | run (void *(*start_routine)(void *), void *data, int priority=0) |
| |
| int | setPriority (pthread_attr_t *attributes, int priority) |
| |
| int | getPriority () |
| |
| void * | meetThread (void) |
| |
| void | exit (void *retVal) |
| |
| bool | running () |
| |
| | Cond () |
| | Constructor. More...
|
| |
| virtual | ~Cond () |
| | Destructor. More...
|
| |
| void | wait () |
| |
| void | signal () |
| |
| void | boroadcast () |
| |
| | Mutex () |
| |
| virtual | ~Mutex () |
| |
| int | lock () |
| |
| int | tryLock () |
| |
| int | unLock () |
| |
| | BlockBuffer (int count) |
| |
| | BlockBuffer (void) |
| | Constructor - creates BLOCK_BUFFER_DEFAULT_COUNT buffers. More...
|
| |
| Eigen::Array< unsigned short, Eigen::Dynamic, Eigen::Dynamic > * | getEmptyBuffer (void) |
| |
| Eigen::Array< unsigned short, Eigen::Dynamic, Eigen::Dynamic > * | getFullBuffer (void) |
| |
| void | putFullBuffer (Eigen::Array< unsigned short, Eigen::Dynamic, Eigen::Dynamic > *fb) |
| |
| void | putEmptyBuffer (Eigen::Array< unsigned short, Eigen::Dynamic, Eigen::Dynamic > *eb) |
| |
| int | getBufferCount () |
| |
| void | resizeBuffers (int rows, int cols) |
| |
| void | resize (int count) |
| |
|
| pthread_mutex_t | mut |
| | The POSIX mutex semaphore. More...
|
| |
- Examples:
- IIOQueueTest.C.
Definition at line 25 of file IIOThreadedQ.H.
◆ IIOThreadedQ()
| IIOThreadedQ::IIOThreadedQ |
( |
| ) |
|
|
inline |
◆ ~IIOThreadedQ()
| virtual IIOThreadedQ::~IIOThreadedQ |
( |
| ) |
|
|
inlinevirtual |
◆ resizeBuffers()
| int IIOThreadedQ::resizeBuffers |
( |
int |
N, |
|
|
int |
ch |
|
) |
| |
|
inlineprivate |
Resize the internal buffers for reading. The end result will be buffers which capture N samples per channel, where the total number of channels is the number requested + the remainder non-requested channels on the last device. i.e. the total number of channels will be ceil(ch / number of channels per device) * number of channels per device. For example, if ch=3 but there are 2 channels per device, we will get ceil(3/2)*2 = 4.
- Parameters
-
| N | the number of samples to read. |
| ch | the number of channels to read. |
- Returns
- NO_ERROR or the suitable error. The arrays are returned correctly sized for reading N samples.
Definition at line 96 of file IIOThreadedQ.H.
◆ setSampleCountChannelCount()
| int IIOThreadedQ::setSampleCountChannelCount |
( |
uint |
N, |
|
|
uint |
ch |
|
) |
| |
|
inline |
◆ threadMain()
| void* IIOThreadedQ::threadMain |
( |
void |
| ) |
|
|
inlineprivatevirtual |
All reading is done in a threaded environment. This ensures that you can process data whilst new data is being read in.
Implements ThreadedMethod.
Definition at line 30 of file IIOThreadedQ.H.
◆ newbufReady
| bool IIOThreadedQ::newbufReady |
◆ sampleRate
| float IIOThreadedQ::sampleRate |
The documentation for this class was generated from the following file: