StorageStreamInfoReader.hpp

/******************************************************************************
 * (c) Copyright, Real-Time Innovations, 2016-.
 * All rights reserved.
 * No duplications, whole or partial, manual or electronic, may be made
 * without express written permission.  Any such copies, or
 * revisions thereof, must display this notice unaltered.
 * This code contains trade secrets of Real-Time Innovations, Inc.
 *****************************************************************************/

#ifndef HPP_RTI_RECORDING_STORAGE_DISCOVERYSTREAMREADER_HPP_
#define HPP_RTI_RECORDING_STORAGE_DISCOVERYSTREAMREADER_HPP_

#include "dds/dds.hpp"
#include "rti/routing/StreamInfo.hpp"

#include "SelectorState.hpp"

namespace rti { namespace recording { namespace storage {

class StorageStreamInfoReader {
public:

    virtual ~StorageStreamInfoReader() {}

    virtual void read(
            std::vector<rti::routing::StreamInfo *>& sample_seq,
            const SelectorState& selector) = 0;

    virtual void return_loan(
            std::vector<rti::routing::StreamInfo *>& sample_seq) = 0;

    virtual int64_t service_start_time() = 0;

    virtual int64_t service_stop_time() = 0;

    virtual bool finished() = 0;

    virtual void reset() = 0;
};

} } } /* namespace rti::recording::storage */

#endif /* HPP_RTI_RECORDING_STORAGE_DISCOVERYSTREAMREADER_HPP_ */