ffmpeg_audio.h

彩信浏览器

/*
 * This file is part of Ambulant Player, www.ambulantplayer.org.
 *
 * Copyright (C) 2003-2007 Stichting CWI, 
 * Kruislaan 413, 1098 SJ Amsterdam, The Netherlands.
 *
 * Ambulant Player is free software; you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation; either version 2.1 of the License, or
 * (at your option) any later version.
 *
 * Ambulant Player is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with Ambulant Player; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 */

#ifndef AMBULANT_NET_FFMPEG_AUDIO_H
#define AMBULANT_NET_FFMPEG_AUDIO_H


//#include <vector>
//#include <queue>

//#include <sys/types.h>
//#include <sys/stat.h>
//#include <fcntl.h>


#include "ambulant/config/config.h"
//#include "ambulant/lib/callback.h"
//#include "ambulant/lib/refcount.h"
//#include "ambulant/lib/event_processor.h"
//#include "ambulant/lib/mtsync.h"
//#include "ambulant/lib/event_processor.h"
//#include "ambulant/lib/unix/unix_thread.h"
#include "ambulant/net/databuffer.h"
//#include "ambulant/net/posix_datasource.h"
#include "ambulant/net/datasource.h"

#include "avcodec.h"
#include "avformat.h"
//#include "common.h"

// temporary debug messages
//#include <iostream>
//#ifndef AMBULANT_NO_OSTREAM
//#include <ostream>
//#else /*AMBULANT_NO_OSTREAM */
//#include <ostream.h>
//#endif /*AMBULANT_NO_OSTREAM */
//#include <cstring>
//#include <sys/types.h>
//#include <sys/stat.h>
//#include <fcntl.h>
//#include <unistd.h>
//#include <map>

#ifdef AMBULANT_PLATFORM_MACOS
	#define AM_MAC_CONST const
#else
	#define AM_MAC_CONST
#endif


namespace ambulant
{

namespace net
{  
	
class ffmpeg_audio_datasource_factory : public audio_datasource_factory {
  public:
	~ffmpeg_audio_datasource_factory() {};
	audio_datasource* new_audio_datasource(const net::url& url, const audio_format_choices& fmts, timestamp_t clip_begin, timestamp_t clip_end);
};

class ffmpeg_audio_decoder_finder : public audio_decoder_finder {
  public:
	~ffmpeg_audio_decoder_finder() {};
	audio_datasource* new_audio_decoder(pkt_audio_datasource *src, const audio_format_choices& hint);
};

class ffmpeg_audio_filter_finder : public audio_filter_finder {
  public:
	~ffmpeg_audio_filter_finder() {};
	audio_datasource* new_audio_filter(audio_datasource *src, const audio_format_choices& fmts);
};

class ffmpeg_decoder_datasource: virtual public audio_datasource, virtual public lib::ref_counted_obj {
  public:
	static bool supported(const audio_format& fmt);
	static bool supported(const net::url& url);

	ffmpeg_decoder_datasource(const net::url& url, pkt_audio_datasource *src);
	ffmpeg_decoder_datasource(pkt_audio_datasource *src);
	~ffmpeg_decoder_datasource();
     
		  
	void start(lib::event_processor *evp, lib::event *callback);  
	void stop();  

	void readdone(int len);
	void data_avail();
	bool end_of_file();
	bool buffer_full();
	void read_ahead(timestamp_t clip_begin);

	char* get_read_ptr();
	int size() const;   
	common::duration get_dur();
	audio_format& get_audio_format();
	timestamp_t get_clip_end();
  	timestamp_t get_clip_begin();
  	timestamp_t get_start_time() { return m_src->get_start_time(); };

  protected:
	bool _select_decoder(const char* file_ext);
	bool _select_decoder(audio_format &fmt);
	  
  private:
	bool _clip_end() const;
	bool _end_of_file();
	void _need_fmt_uptodate();
	AVCodecContext *m_con;
	audio_format m_fmt;
	lib::event_processor *m_event_processor;
  	pkt_audio_datasource* m_src;
  	timestamp_t m_elapsed;
	bool m_is_audio_ds;
	
	databuffer m_buffer;
	bool m_blocked_full;
		
	lib::event *m_client_callback;  // This is our calllback to the client
	lib::critical_section m_lock;
 
};

class ffmpeg_resample_datasource: virtual public audio_datasource, virtual public lib::ref_counted_obj {
  public:
	ffmpeg_resample_datasource(audio_datasource *src, audio_format_choices fmts);
	~ffmpeg_resample_datasource();
    
	void start(lib::event_processor *evp, lib::event *callback);  
	void stop();  
	void read_ahead(timestamp_t time) {};

	void readdone(int len);
	void data_avail();
  
	bool end_of_file();
	bool buffer_full();
		
	char* get_read_ptr();
	int size() const;   
	   
//    void get_input_format(audio_context &fmt);  
//    void get_output_format(audio_context &fmt);
	audio_format& get_audio_format() { return m_out_fmt; };
	common::duration get_dur();
	timestamp_t get_clip_end();
	timestamp_t get_clip_begin();
	timestamp_t get_start_time() { return m_src->get_start_time(); }
  protected:
    int init(); 
  	
	  
  private:
    bool _end_of_file();
	bool _src_end_of_file() const;
  
    audio_datasource* m_src;

    bool m_context_set;
    ReSampleContext *m_resample_context;
  
    databuffer m_buffer;
  	
    lib::event_processor *m_event_processor;
    lib::event *m_client_callback;  // This is our calllback to the client
    lib::critical_section m_lock;
  	audio_format m_in_fmt;
  	audio_format m_out_fmt;
 
};

}	// end namespace net
}	// end namespace ambulant

#endif // AMBULANT_NET_FFMPEG_AUDIO_H