// gst-plugin/gst-audio-source.h

// Copyright 2013  Tanel Alumae, Tallinn University of Technology

// See ../../COPYING for clarification regarding multiple authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//  http://www.apache.org/licenses/LICENSE-2.0
//
// THIS CODE IS PROVIDED *AS IS* BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, EITHER EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION ANY IMPLIED
// WARRANTIES OR CONDITIONS OF TITLE, FITNESS FOR A PARTICULAR PURPOSE,
// MERCHANTABLITY OR NON-INFRINGEMENT.
// See the Apache 2 License for the specific language governing permissions and
// limitations under the License.

#ifndef KALDI_GST_PLUGIN_GST_AUDIO_SOURCE_H_
#define KALDI_GST_PLUGIN_GST_AUDIO_SOURCE_H_

#include <online/online-audio-source.h>
#include <matrix/kaldi-vector.h>
#include <gst/gst.h>

namespace kaldi {


// OnlineAudioSourceItf implementation using a queue of Gst Buffers
class GstBufferSource : public OnlineAudioSourceItf {
 public:
  typedef int16 SampleType;  // hardcoded 16-bit audio

  GstBufferSource();

  // Implementation of the OnlineAudioSourceItf
  bool Read(Vector<BaseFloat> *data);

  void PushBuffer(GstBuffer *buf);

  void SetEnded(bool ended);

  ~GstBufferSource();

 private:

  GAsyncQueue* buf_queue_;
  gint pos_in_current_buf_;
  GstBuffer *current_buffer_;
  bool ended_;
  GMutex lock_;
  GCond data_cond_;
  KALDI_DISALLOW_COPY_AND_ASSIGN(GstBufferSource);
};

}  // namespace kaldi

#endif  // KALDI_GST_PLUGIN_GST_AUDIO_SOURCE_H_