linuxrec.h

Go to the documentation of this file.

/*
 * a simple record code. using alsa-lib APIs.
 * keep the function same as winrec.h
 *
 * Common steps:
 *      create_recorder,
 *      open_recorder,
 *      start_record,
 *      stop_record,
 *      close_recorder,
 *      destroy_recorder
 *
 */

#ifndef __IFLY_WINREC_H__
#define __IFLY_WINREC_H__
#include <alsa/asoundlib.h>
#include <pthread.h>
#include <iostream>
#include "file_operation.h"
#include "formats.h"
enum
{
  RECORD_STATE_CREATED, /* Init         */
  RECORD_STATE_CLOSING,
  RECORD_STATE_READY,     /* Opened     */
  RECORD_STATE_STOPPING,  /* During Stop        */
  RECORD_STATE_RECORDING, /* Started    */
};

typedef struct
{
  union
  {
    char* name;
    int index;
    void* resv;
  } u;
} record_dev_id;

/* recorder object. */
struct recorder
{
  void (*on_data_ind)(char* data, unsigned long len, void* user_para);
  void* user_cb_para;
  volatile int state; /* internal record state */
  void* wavein_hdl;
  /* thread id may be a struct. by implementation
   * void * will not be ported!! */
  pthread_t rec_thread;
  /*void * rec_thread_hdl;*/
  void* bufheader;
  unsigned int bufcount;
  char* audiobuf;
  int bits_per_frame;
  unsigned int buffer_time;
  unsigned int period_time;
  size_t period_frames;
  size_t buffer_frames;
  std::string pcm_file_path;
};

#if __cplusplus
extern "C" {
#endif /* C++ */

class RecordAlsaAPI
{
public:
  void initRecord(struct recorder* rec, record_dev_id dev, WAVEFORMATEX* fmt);
  int setRecordDuration(const float duration_time);
  struct DataBuff startRecord();
  void closeRecord();

private:
  struct recorder* record_;
  snd_pcm_hw_params_t* params_;  //指向 snd_pcm_hw_params_t的指针
  unsigned int record_rate_;     //录音时候的采样率
  snd_pcm_format_t format_;
  snd_pcm_uframes_t frames_;
  snd_pcm_t* handle_;
  int audiobuf_size_;
  int duration_time_;
  struct DataBuff audio_pcm_;
  int record_loop_;
};

class VDADetection
{
public:
  float levelEnergy(struct DataBuff pcm_data, const int call_count);
  float energyPerSample(struct DataBuff pcm_data);

private:
  int call_count_ = 0;
  float background_energy_ = 0.0;
  float temp_energy_ = 0.0;
  float mean_energy_ = 0.0;
  float level_ = 0;
  const float forgetfactor_ = 1;
  const float adjustment_ = 0.05;
  int is_speech_count_;
};
record_dev_id getDefaultInputDevice();

int getInputDeviceNum();

int createRecorder(struct recorder** out_rec,

                   void (*on_data_ind)(char* data, unsigned long len, void* user_para),

                   void* user_cb_para);

void destroyRecorder(struct recorder* rec);

int openRecorder(struct recorder* rec, record_dev_id dev, WAVEFORMATEX* fmt, std::string base_path);

void closeRecorder(struct recorder* rec);

int startRecord(struct recorder* rec);

int stopRecord(struct recorder* rec);

int isRecordStopped(struct recorder* rec);

#if __cplusplus
} /* extern "C" */

#endif /* C++ */

#endif