When an RBNB source has more than one RingBuffer, and a sink is monitoring
channels from the multiple RingBuffers in this source, the server will not
reliably deliver the most recent data from every channel.  Conversely,
monitoring a source with multiple channels in one RingBuffer will not have
this problem.

Example:
A source, "Foo", has 3 channels (A, B, C) which are individually flushed,
one right after the other (thus Foo will contain 3 RingBuffers - one for
each channel).  A sink wants to monitor all 3 channels from Foo.  What we
would like to see: on the first fetch, the sink retrieves the most recent
data on channel A; on the second fetch the most recent data on channel B,
and on the third fetch the most recent data on channel C.  Then the process
will repeat, getting an update on A/B/C for each three fetches.  Instead,
what we will see (due to this problem with Monitor mode) is that the single
most recent frame flushed to the source will be returned.  Thus, suppose
the source performs the three flushes A/B/C, and then the sink does a fetch
- the sink will get the most recent "C" frame (because that was the last
channel flushed).  Then the source does another set of flushes on A/B/C;
then the sink does another fetch - again, it will get the  most recent "C"
frame.  This process could continue, and the sink would only get updates on
"C".

Background: A RingBuffer is an internal RBNB data storage object which can
contain data for either a single channel or multiple channels
(multiplexed). A source can have one or more RingBuffers, as dictated by
the number of flushes performed to update the complete set of data channels
in the source.  For instance, if all channels are updated in one ChannelMap
(one flush), then the Source will only have one RingBuffer.  Alternatively,
if some of the channels are flushed at one point, and the rest of the
channels are flushed at another time, then the source will contain 2
RingBuffers.

Fixing this problem will involve RBNB server code changes.  Monitor
requests are handled by com.rbnb.api.StreamRBOListener.  I think the
problem is due to the fact that StreamRBOListener handles all channels
being monitored from an entire source - thus, it is a source-level object,
not a RingBuffer-level object.  StreamRBOListener will keep track of the
most recent frame for an entire source, not the most recent frame for each
RingBuffer.

This problem was observed when working with a source where each channel was
in its own RingBuffer (thus, each channel was individually flushed).  This
type of source/RingBuffer arrangement is very efficient for data playback.

One application which is affected by this problem is RDV (Realtime Data
Viewer; http://it.nees.org/software/rdv/index.php), which uses Monitor to
implement realtime mode.  (As an aside, an alternative to using Monitor
mode would be request/response mode in a "sleepy loop", which is what
rbnbPlot uses for realtime mode).

Here are a couple of Matlab/COMSOL functions that can be used to
demonstrate this problem:

function testSource()
src = com.rbnb.sapi.Source;
src.OpenRBNBConnection('localhost:3333','Foo');
for i=0:1000
   disp(['i = ' num2str(i)]);
   cm = javaObject('com.rbnb.sapi.ChannelMap');
   cm.Add('A');
   intVal = i*3;
   cm.PutDataAsInt32(0,intVal);
   src.Flush(cm);
   cm = javaObject('com.rbnb.sapi.ChannelMap');
   cm.Add('B');
   intVal = intVal + 1;
   cm.PutDataAsInt32(0,intVal);
   src.Flush(cm);
   cm = javaObject('com.rbnb.sapi.ChannelMap');
   cm.Add('C');
   intVal = intVal + 1;
   cm.PutDataAsInt32(0,intVal);
   src.Flush(cm);
   pause(1);
end



function testSink()
snk = com.rbnb.sapi.Sink;
snk.OpenRBNBConnection('localhost:3333','Snk');
cm = javaObject('com.rbnb.sapi.ChannelMap');
cm.Add('Foo/A');
cm.Add('Foo/B');
cm.Add('Foo/C');
snk.Monitor(cm,0);
for j=0:1000
    cm = snk.Fetch(100000);
    if (cm.NumberOfChannels > 0)
        disp(['Got ' num2str(cm.NumberOfChannels) ' channels:']);
        for k=0:(cm.NumberOfChannels - 1)
	    dataStr = num2str(cm.GetDataAsInt32(k));
            disp(['    Got data on channel ' char(cm.GetName(k)) ': '
dataStr]);
	end
    end
end