77 lines
1.9 KiB
C
77 lines
1.9 KiB
C
|
#include "stream_entry.h"
|
||
|
|
|
||
|
|
|
||
|
|
static int stream_entry_data_handler(struct audio_stream_entry *entry,
|
||
|
|
struct audio_data_frame *in,
|
||
|
|
struct audio_data_frame *out)
|
||
|
|
{
|
||
|
|
struct __stream_entry *hdl = container_of(entry, struct __stream_entry, entry);
|
||
|
|
if (in->data_len == 0) {
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (hdl->is_end == 0) {
|
||
|
|
//中间节点才需要往后传数据，终节点不用
|
||
|
|
out->data = in->data;
|
||
|
|
out->data_len = in->data_len;
|
||
|
|
out->channel = in->channel;
|
||
|
|
out->sample_rate = in->sample_rate;
|
||
|
|
if (hdl->data_callback) {
|
||
|
|
if (in->data_len - in->offset > 0) {
|
||
|
|
hdl->data_callback(hdl->data_priv, in);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
if (hdl->data_callback) {
|
||
|
|
return hdl->data_callback(hdl->data_priv, in);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
return in->data_len;
|
||
|
|
}
|
||
|
|
|
||
|
|
static void stream_entry_output_data_process_len(struct audio_stream_entry *entry, int len)
|
||
|
|
{
|
||
|
|
}
|
||
|
|
|
||
|
|
struct __stream_entry *stream_entry_open(void *priv, int (*data_callback)(void *priv, struct audio_data_frame *in), u8 is_end)
|
||
|
|
{
|
||
|
|
struct __stream_entry *hdl;
|
||
|
|
hdl = zalloc(sizeof(struct __stream_entry));
|
||
|
|
if (hdl == NULL) {
|
||
|
|
return NULL;
|
||
|
|
}
|
||
|
|
|
||
|
|
hdl->is_end = is_end;
|
||
|
|
hdl->data_priv = priv;
|
||
|
|
hdl->data_callback = data_callback;
|
||
|
|
hdl->entry.data_process_len = stream_entry_output_data_process_len;
|
||
|
|
hdl->entry.data_handler = stream_entry_data_handler;
|
||
|
|
|
||
|
|
return hdl;
|
||
|
|
}
|
||
|
|
|
||
|
|
void stream_entry_close(struct __stream_entry **hdl)
|
||
|
|
{
|
||
|
|
if (hdl && (*hdl)) {
|
||
|
|
struct __stream_entry *stream = *hdl;
|
||
|
|
audio_stream_del_entry(&stream->entry);
|
||
|
|
local_irq_disable();
|
||
|
|
free(stream);
|
||
|
|
*hdl = NULL;
|
||
|
|
local_irq_enable();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
void stream_entry_resume(struct __stream_entry *hdl)
|
||
|
|
{
|
||
|
|
if (hdl) {
|
||
|
|
audio_stream_resume(&hdl->entry);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|