本文整理汇总了C++中createOutputSRI函数的典型用法代码示例。如果您正苦于以下问题:C++ createOutputSRI函数的具体用法?C++ createOutputSRI怎么用?C++ createOutputSRI使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了createOutputSRI函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。
示例1: createOutputSRI
BULKIO::StreamSRI g723_40_encode_sb_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:g723_40_encode_sb_base.cpp
示例2: createOutputSRI
BULKIO::StreamSRI stream_to_streams_cc_2o_base::createOutputSRI( int32_t oidx, int32_t &in_idx, std::string &ext)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:stream_to_streams_cc_2o_base.cpp
示例3: sid
void stream_to_vector_ii_base::setupIOMappings( )
{
int ninput_streams = 0;
int noutput_streams = 0;
std::vector<std::string>::iterator pname;
std::string sid("");
int inMode=RealMode;
if ( !validGRBlock() ) return;
ninput_streams = gr_sptr->get_max_input_streams();
gr_io_signature_sptr g_isig = gr_sptr->input_signature();
noutput_streams = gr_sptr->get_max_output_streams();
gr_io_signature_sptr g_osig = gr_sptr->output_signature();
LOG_DEBUG( stream_to_vector_ii_base, "GNUHAWK IO MAPPINGS IN/OUT " << ninput_streams << "/" << noutput_streams );
//
// Someone reset the GR Block so we need to clean up old mappings if they exists
// we need to reset the io signatures and check the vlens
//
if ( _istreams.size() > 0 || _ostreams.size() > 0 ) {
LOG_DEBUG( stream_to_vector_ii_base, "RESET INPUT SIGNATURE SIZE:" << _istreams.size() );
IStreamList::iterator istream;
for ( int idx=0 ; istream != _istreams.end(); idx++, istream++ ) {
// re-add existing stream definitons
LOG_DEBUG( stream_to_vector_ii_base, "ADD READ INDEX TO GNU RADIO BLOCK");
if ( ninput_streams == -1 ) gr_sptr->add_read_index();
// setup io signature
istream->associate( gr_sptr );
}
LOG_DEBUG( stream_to_vector_ii_base, "RESET OUTPUT SIGNATURE SIZE:" << _ostreams.size() );
OStreamList::iterator ostream;
for ( int idx=0 ; ostream != _ostreams.end(); idx++, ostream++ ) {
// need to evaluate new settings...???
ostream->associate( gr_sptr );
}
return;
}
//
// Setup mapping of RH port to GNU RADIO Block input streams
// For version 1, we are ignoring the GNU Radio input stream -1 case that allows multiple data
// streams over a single connection. We are mapping a single RH Port to a single GNU Radio stream.
// Stream Identifiers will be pass along as they are received
//
LOG_TRACE( stream_to_vector_ii_base, "setupIOMappings INPUT PORTS: " << inPorts.size() );
pname = inputPortOrder.begin();
for( int i=0; pname != inputPortOrder.end(); pname++ ) {
// grab ports based on their order in the scd.xml file
RH_ProvidesPortMap::iterator p_in = inPorts.find(*pname);
if ( p_in != inPorts.end() ) {
bulkio::InLongPort *port = dynamic_cast< bulkio::InLongPort * >(p_in->second);
int mode = inMode;
sid = "";
// need to add read index to GNU Radio Block for processing streams when max_input == -1
if ( ninput_streams == -1 ) gr_sptr->add_read_index();
// check if we received SRI during setup
BULKIO::StreamSRISequence_var sris = port->activeSRIs();
if ( sris->length() > 0 ) {
BULKIO::StreamSRI sri = sris[sris->length()-1];
mode = sri.mode;
}
std::vector<int> in;
io_mapping.push_back( in );
_istreams.push_back( gr_istream< bulkio::InLongPort > ( port, gr_sptr, i, mode, sid ));
LOG_DEBUG( stream_to_vector_ii_base, "ADDING INPUT MAP IDX:" << i << " SID:" << sid );
// increment port counter
i++;
}
}
//
// Setup mapping of RH port to GNU RADIO Block input streams
// For version 1, we are ignoring the GNU Radio output stream -1 case that allows multiple data
// streams over a single connection. We are mapping a single RH Port to a single GNU Radio stream.
//
LOG_TRACE( stream_to_vector_ii_base, "setupIOMappings OutputPorts: " << outPorts.size() );
pname = outputPortOrder.begin();
for( int i=0; pname != outputPortOrder.end(); pname++ ) {
// grab ports based on their order in the scd.xml file
RH_UsesPortMap::iterator p_out = outPorts.find(*pname);
if ( p_out != outPorts.end() ) {
bulkio::OutLongPort *port = dynamic_cast< bulkio::OutLongPort * >(p_out->second);
int idx = -1;
BULKIO::StreamSRI sri = createOutputSRI( i, idx );
if (idx == -1) idx = i;
if(idx < (int)io_mapping.size()) io_mapping[idx].push_back(i);
int mode = sri.mode;
sid = sri.streamID;
_ostreams.push_back( gr_ostream< bulkio::OutLongPort > ( port, gr_sptr, i, mode, sid ));
//.........这里部分代码省略.........
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:101,代码来源:stream_to_vector_ii_base.cpp
示例4: createOutputSRI
BULKIO::StreamSRI chunks_to_symbols_sf_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:chunks_to_symbols_sf_base.cpp
示例5: createOutputSRI
BULKIO::StreamSRI costas_loop_cc_2o_base::createOutputSRI( int32_t oidx, int32_t &in_idx, std::string &ext)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:costas_loop_cc_2o_base.cpp
示例6: LOG_DEBUG
//.........这里部分代码省略.........
// we need to reset the io signatures and check the vlens
//
if ( _istreams.size() > 0 || _ostreams.size() > 0 ) {
LOG_DEBUG( copy_octet_base, "RESET INPUT SIGNATURE SIZE:" << _istreams.size() );
IStreamList::iterator istream;
for ( int idx=0 ; istream != _istreams.end(); idx++, istream++ ) {
// re-add existing stream definitons
LOG_DEBUG( copy_octet_base, "ADD READ INDEX TO GNU RADIO BLOCK");
if ( ninput_streams == -1 ) gr_sptr->add_read_index();
// setup io signature
istream->associate( gr_sptr );
}
LOG_DEBUG( copy_octet_base, "RESET OUTPUT SIGNATURE SIZE:" << _ostreams.size() );
OStreamList::iterator ostream;
for ( int idx=0 ; ostream != _ostreams.end(); idx++, ostream++ ) {
// need to evaluated new settings...???
ostream->associate( gr_sptr );
}
return;
}
// setup mapping of RH Port to GNU RADIO BLOCK input streams as a 1-1 mapping (basically we ignore streamID when pulling data from port)
// for case ninput == -1 and 1 port we map out streamID to each GNU Radio Block input stream this is done in the notifySRI callback method
if ( ninput_streams != -1 || ( ninput_streams == -1 && inPorts.size() > 1 ) ) {
int nstreams = inPorts.size();
if ( ninput_streams != -1 ) nstreams = std::min( nstreams, ninput_streams);
RH_ProvidesPortMap::iterator p_in = inPorts.begin();
for ( int i=0; i < nstreams && p_in != inPorts.end(); i++, p_in++ ) {
// need to add read index to GNU Radio Block for processing,
if ( ninput_streams == -1 ) gr_sptr->add_read_index();
_istreams.push_back( gr_istream< BULKIO_dataOctet_In_i > ( dynamic_cast< BULKIO_dataOctet_In_i * >(p_in->second), sid, gr_sptr, i));
}
}
else { // ninput_stream is variable == -1 and component ports == 1
//
// need to worry about sync between when service function starts and pushSRI happens,
//
for ( RH_ProvidesPortMap::iterator p_in = inPorts.begin(); p_in != inPorts.end(); p_in++ ) {
BULKIO_dataOctet_In_i *port = dynamic_cast< BULKIO_dataOctet_In_i * >(p_in->second);
BULKIO::StreamSRISequence_var sris = port->activeSRIs();
for ( uint32_t i=0 ; i < sris->length(); i++ ) {
BULKIO::StreamSRI sri = sris[i];
int mode = sri.mode;
sid = sri.streamID;
_istreams.push_back( gr_istream< BULKIO_dataOctet_In_i > ( port, sid, gr_sptr, i, mode ));
}
}
}
if ( noutput_streams != -1 || (noutput_streams == -1 && outPorts.size() > 1 ) ) {
int32_t nstreams = outPorts.size();
if ( noutput_streams != -1 ) {
if ( nstreams != noutput_streams )
LOG_WARN( copy_octet_base, "Number of OUTPUT PORTS is different than number of GNU RADIO STREAMS PORTS/STREAMS " << nstreams << "/" << noutput_streams );
nstreams = std::min( nstreams, noutput_streams);
}
// add number of output streams based min ( gr block output streams, or output ports)
LOG_TRACE( copy_octet_base, "setupIOMappings OutputPorts: " << nstreams );
RH_UsesPortMap::iterator p_out = outPorts.begin();
for ( int i=0; i < nstreams && p_out != outPorts.end(); i++, p_out++ ) {
_ostreams.push_back( gr_ostream < BULKIO_dataOctet_Out_i >( dynamic_cast< BULKIO_dataOctet_Out_i *>(p_out->second), sid, gr_sptr, i ));
}
}
else if ( (noutput_streams == -1 && outPorts.size() == 1) && ( ninput_streams == 0 ) ) {
// RESOLVE: should generate maps based on port connections when output streams is variable and no input stream
RH_UsesPortMap::iterator p_out = outPorts.begin();
uint32_t idx =0;
std::string sid("");
uint32_t nstreams = getNOutputStreams();
for( ; idx < nstreams; idx++ ) {
_ostreams.push_back( gr_ostream < BULKIO_dataOctet_Out_i >( dynamic_cast< BULKIO_dataOctet_Out_i *>(p_out->second), sid, gr_sptr, idx ));
}
}
// for each output stream definition, call createOutputSRI to create initial value for the stream
OStreamList::iterator ostream = _ostreams.begin();
for ( int i=0; ostream != _ostreams.end(); i++, ostream++ ) {
BULKIO::StreamSRI sri = createOutputSRI( i );
ostream->setSRI(sri, i );
ostream->pushSRI();
}
}
开发者ID:VenturaSolutionsInc,项目名称:integration-gnuhawk,代码行数:101,代码来源:copy_octet_base.cpp
示例7: createOutputSRI
BULKIO::StreamSRI argmax_fs_1i_base::createOutputSRI( int32_t oidx, int32_t &in_idx, std::string &ext)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:argmax_fs_1i_base.cpp
示例8: createOutputSRI
BULKIO::StreamSRI vector_to_streams_bb_1o_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:vector_to_streams_bb_1o_base.cpp
示例9: createOutputSRI
BULKIO::StreamSRI stream_to_streams_cc_1o_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:stream_to_streams_cc_1o_base.cpp
示例10: createOutputSRI
BULKIO::StreamSRI short_to_char_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:short_to_char_base.cpp
示例11: createOutputSRI
BULKIO::StreamSRI multiply_const_ii_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:multiply_const_ii_base.cpp
示例12: createOutputSRI
BULKIO::StreamSRI argmax_fs_3i_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:argmax_fs_3i_base.cpp
示例13: createOutputSRI
BULKIO::StreamSRI endian_swap_cc_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:endian_swap_cc_base.cpp
示例14: createOutputSRI
BULKIO::StreamSRI repeat_ii_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:repeat_ii_base.cpp
示例15: createOutputSRI
BULKIO::StreamSRI complex_to_mag_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:complex_to_mag_base.cpp
示例16: createOutputSRI
BULKIO::StreamSRI throttle_cc_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:RedhawkSDR,项目名称:integration-gnuhawk,代码行数:4,代码来源:throttle_cc_base.cpp
示例17: createOutputSRI
BULKIO::StreamSRI divide_cc_2i_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:divide_cc_2i_base.cpp
示例18: createOutputSRI
BULKIO::StreamSRI file_descriptor_source_c_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:file_descriptor_source_c_base.cpp
示例19: createOutputSRI
BULKIO::StreamSRI deinterleave_ff_1o_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:deinterleave_ff_1o_base.cpp
示例20: createOutputSRI
BULKIO::StreamSRI field_sync_mux_base::createOutputSRI( int32_t oidx, int32_t &in_idx)
{
return createOutputSRI( oidx );
}
开发者ID:54AndyN,项目名称:integration-gnuhawk,代码行数:4,代码来源:field_sync_mux_base.cpp
注:本文中的createOutputSRI函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论