Essentia
2.1-beta6-dev
|
#include <source.h>
Public Member Functions | |
Source (Algorithm *parent=0) | |
Source (const std::string &name) | |
~Source () | |
const void * | buffer () const |
void * | buffer () |
const MultiRateBuffer< TokenType > & | typedBuffer () const |
MultiRateBuffer< TokenType > & | typedBuffer () |
virtual void | setBufferType (BufferUsage::BufferUsageType type) |
virtual BufferInfo | bufferInfo () const |
virtual void | setBufferInfo (const BufferInfo &info) |
int | totalProduced () const |
ReaderID | addReader () |
void | removeReader (ReaderID id) |
std::vector< TokenType > & | tokens () |
TokenType & | firstToken () |
const TokenType & | lastTokenProduced () const |
virtual void * | getTokens () |
virtual void * | getFirstToken () |
void | acquire () |
virtual bool | acquire (int n) |
void | release () |
virtual void | release (int n) |
virtual int | available () const |
virtual void | reset () |
Public Member Functions inherited from SourceBase | |
SourceBase (Algorithm *parent=0, const std::string &name="unnamed") | |
SourceBase (const std::string &name) | |
~SourceBase () | |
const std::vector< SinkBase * > & | sinks () const |
std::vector< SinkBase * > & | sinks () |
bool | isProxied () const |
const std::vector< SinkBase * > & | proxiedSinks () const |
template<typename TokenType > | |
void | push (const TokenType &value) |
Public Member Functions inherited from Connector | |
Connector (Algorithm *parent=0, const std::string &name="Unnamed") | |
Connector (const std::string &name) | |
const Algorithm * | parent () const |
Algorithm * | parent () |
void | setParent (Algorithm *parent) |
std::string | parentName () const |
std::string | fullName () const |
Public Member Functions inherited from TypeProxy | |
TypeProxy () | |
TypeProxy (const std::string &name) | |
virtual | ~TypeProxy () |
const std::string & | name () const |
void | setName (const std::string &name) |
void | checkType (const std::type_info &received, const std::type_info &expected) const |
template<typename Type > | |
void | checkType () const |
void | checkSameTypeAs (const TypeProxy &obj) const |
void | checkVectorSameTypeAs (const TypeProxy &obj) const |
Public Member Functions inherited from StreamConnector | |
StreamConnector () | |
virtual | ~StreamConnector () |
bool | acquire () |
void | release () |
virtual int | acquireSize () const |
virtual int | releaseSize () const |
virtual void | setAcquireSize (int n) |
virtual void | setReleaseSize (int n) |
Protected Attributes | |
MultiRateBuffer< TokenType > * | _buffer |
Protected Attributes inherited from SourceBase | |
std::vector< SinkBase * > | _sinks |
SourceProxyBase * | _sproxy |
Protected Attributes inherited from Connector | |
Algorithm * | _parent |
Protected Attributes inherited from TypeProxy | |
std::string | _name |
Protected Attributes inherited from StreamConnector | |
int | _acquireSize |
int | _releaseSize |
Private Member Functions | |
virtual const std::type_info & | typeInfo () const |
virtual const std::type_info & | vectorTypeInfo () const |
Additional Inherited Members | |
Protected Member Functions inherited from SourceBase | |
virtual void | connect (SinkBase &sink) |
virtual void | disconnect (SinkBase &sink) |
void | attachProxy (SourceProxyBase *sproxy) |
void | detachProxy (SourceProxyBase *sproxy) |
Source | ( | const std::string & | name | ) |
|
inline |
References Source< TokenType >::_buffer.
|
inline |
References StreamConnector::acquire().
|
inlinevirtual |
Acquire (consume) the requested number of tokens.
Implements StreamConnector.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::acquireForWrite().
|
inlinevirtual |
Implements SourceBase.
Reimplemented in AbsoluteSource< TokenType >.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::addReader().
|
inlinevirtual |
Returns how many tokens are available in the stream.
Implements StreamConnector.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::availableForWrite().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::_buffer.
|
inline |
References Source< TokenType >::_buffer.
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::bufferInfo().
|
inline |
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::writeView().
Referenced by Source< TokenType >::getFirstToken().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::firstToken().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::tokens().
|
inline |
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::lastTokenProduced().
Referenced by essentia::streaming::lastTokenProduced().
|
inline |
References StreamConnector::release().
|
inlinevirtual |
Release (produce) the requested number of tokens.
Implements StreamConnector.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::releaseForWrite().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::removeReader().
|
inlinevirtual |
Resets the state of this StreamConnector
Implements StreamConnector.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::reset().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::setBufferInfo().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::setBufferType().
|
inline |
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::writeView().
Referenced by Source< TokenType >::getTokens().
|
inlinevirtual |
Implements SourceBase.
References Source< TokenType >::_buffer, and MultiRateBuffer< T >::totalTokensWritten().
|
inline |
References Source< TokenType >::_buffer.
|
inline |
References Source< TokenType >::_buffer.
|
inlineprivatevirtual |
Implements TypeProxy.
|
inlineprivatevirtual |
Implements TypeProxy.
|
protected |
Referenced by Source< TokenType >::acquire(), Source< TokenType >::addReader(), AbsoluteSource< TokenType >::addReader(), Source< TokenType >::available(), Source< TokenType >::buffer(), Source< TokenType >::bufferInfo(), Source< TokenType >::firstToken(), Source< TokenType >::lastTokenProduced(), Source< TokenType >::release(), Source< TokenType >::removeReader(), Source< TokenType >::reset(), Source< TokenType >::setBufferInfo(), Source< TokenType >::setBufferType(), Source< TokenType >::tokens(), Source< TokenType >::totalProduced(), Source< TokenType >::typedBuffer(), and Source< TokenType >::~Source().