#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: