Re: [opendds-main] take() function in a datareader always reads one sample

[Jeff S. <sch...@oc...>]

Yes it should, I believe.

Turn up your transport debug level (-TransportDebugLevel 5) , to see what
has been received by that datareader and verify it is greater than one
since the last take()

jeff

On Thu, Dec 4, 2014 at 4:37 AM, Yannis Damigos <yda...@ic...> wrote:

> Hi all,
>
> I have a strange problem using the take() function in a datareader in my
> application.
> take(data, si, DDS::LENGTH_UNLIMITED, DDS::ANY_SAMPLE_STATE,
> DDS::ANY_VIEW_STATE, DDS::ANY_INSTANCE_STATE);
>
> My publisher is sending about 2000 data samples, each one every 100
> miliseconds.
> I set a delay on my datareader of 500 miliseconds on the
> "on_data_available" function in order to ensure that more than one
> samples are in my datareaders cache.
> I set the QoS policies on reader and writer to:
> DDS::RELIABLE_RELIABILITY_QOS, DDS::KEEP_ALL_HISTORY_QOS (all other
> default).
> My reader reads only one sample at a time and not a sequence of samples.
>
> So, I change a little your "Reliability" example in tests/DCPS folder by
> adding the following line in SeqReaderListenerImpl.cpp:
> "std::cout << "Yannis: Data length: " << messages_.length() << std::endl;"
> just before the for loop:
> "for (unsigned int i = 0; i < messages_.length(); ++i) {"
> and run it using the flag 'take' (./run_test.pl take).
>
> I always receive a "messages_" with length one.
> Is this the correct behavior using the take() function? Shouldn't the
> reader receive more than one samples?
>
> Best regards,
> Yannis
>
>
>
> ------------------------------------------------------------------------------
> Download BIRT iHub F-Type - The Free Enterprise-Grade BIRT Server
> from Actuate! Instantly Supercharge Your Business Reports and Dashboards
> with Interactivity, Sharing, Native Excel Exports, App Integration & more
> Get technology previously reserved for billion-dollar corporations, FREE
>
> http://pubads.g.doubleclick.net/gampad/clk?id=164703151&iu=/4140/ostg.clktrk
> _______________________________________________
> opendds-main mailing list
> ope...@li...
> https://lists.sourceforge.net/lists/listinfo/opendds-main
>