mirror of
https://github.com/nodemcu/nodemcu-firmware.git
synced 2025-01-16 20:52:57 +08:00
526d21dab4
The PR removed the bulk of non-newlib headers from the NodeMCU source base. app/libc has now been cut down to the bare minimum overrides to shadow the corresponding functions in the SDK's libc. The old c_xyz.h headerfiles have been nuked in favour of the standard <xyz.h> headers, with a few exceptions over in sdk-overrides. Again, shipping a libc.a without headers is a terrible thing to do. We're still living on a prayer that libc was configured the same was as a default-configured xtensa gcc toolchain assumes it is. That part I cannot do anything about, unfortunately, but it's no worse than it has been before. This enables our source files to compile successfully using the standard header files, and use the typical malloc()/calloc()/realloc()/free(), the strwhatever()s and memwhatever()s. These end up, through macro and linker magic, mapped to the appropriate SDK or ROM functions.
108 lines
2.8 KiB
C
108 lines
2.8 KiB
C
/*
|
|
This file contains core routines for the PCM sub-system.
|
|
|
|
pcm_data_play_task()
|
|
Triggered by the driver ISR when further data for play mode is required.
|
|
It handles the play buffer allocation and forwards control to 'data' and 'drained'
|
|
callbacks in Lua land.
|
|
|
|
pcm_data_rec_task() - n/a yet
|
|
Triggered by the driver ISR when data for record mode is available.
|
|
|
|
*/
|
|
|
|
#include "lauxlib.h"
|
|
#include "task/task.h"
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
|
|
#include "pcm.h"
|
|
|
|
static void dispatch_callback( lua_State *L, int self_ref, int cb_ref, int returns )
|
|
{
|
|
if (cb_ref != LUA_NOREF) {
|
|
lua_rawgeti( L, LUA_REGISTRYINDEX, cb_ref );
|
|
lua_rawgeti( L, LUA_REGISTRYINDEX, self_ref );
|
|
lua_call( L, 1, returns );
|
|
}
|
|
}
|
|
|
|
void pcm_data_vu( task_param_t param, uint8 prio )
|
|
{
|
|
cfg_t *cfg = (cfg_t *)param;
|
|
lua_State *L = lua_getstate();
|
|
|
|
if (cfg->cb_vu_ref != LUA_NOREF) {
|
|
lua_rawgeti( L, LUA_REGISTRYINDEX, cfg->cb_vu_ref );
|
|
lua_rawgeti( L, LUA_REGISTRYINDEX, cfg->self_ref );
|
|
lua_pushnumber( L, (LUA_NUMBER)(cfg->vu_peak) );
|
|
lua_call( L, 2, 0 );
|
|
}
|
|
}
|
|
|
|
void pcm_data_play( task_param_t param, uint8 prio )
|
|
{
|
|
cfg_t *cfg = (cfg_t *)param;
|
|
pcm_buf_t *buf = &(cfg->bufs[cfg->fbuf_idx]);
|
|
size_t string_len;
|
|
const char *data = NULL;
|
|
uint8_t need_pop = FALSE;
|
|
lua_State *L = lua_getstate();
|
|
|
|
// retrieve new data from callback
|
|
if ((cfg->isr_throttled >= 0) &&
|
|
(cfg->cb_data_ref != LUA_NOREF)) {
|
|
dispatch_callback( L, cfg->self_ref, cfg->cb_data_ref, 1 );
|
|
need_pop = TRUE;
|
|
|
|
if (lua_type( L, -1 ) == LUA_TSTRING) {
|
|
data = lua_tolstring( L, -1, &string_len );
|
|
if (string_len > buf->buf_size) {
|
|
uint8_t *new_data = (uint8_t *) malloc( string_len );
|
|
if (new_data) {
|
|
if (buf->data) free( buf->data );
|
|
buf->buf_size = string_len;
|
|
buf->data = new_data;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (data) {
|
|
size_t to_copy = string_len > buf->buf_size ? buf->buf_size : string_len;
|
|
memcpy( buf->data, data, to_copy );
|
|
|
|
buf->rpos = 0;
|
|
buf->len = to_copy;
|
|
buf->empty = FALSE;
|
|
dbg_platform_gpio_write( PLATFORM_GPIO_HIGH );
|
|
lua_pop( L, 1 );
|
|
|
|
if (cfg->isr_throttled > 0) {
|
|
uint8_t other_buf = cfg->fbuf_idx ^ 1;
|
|
|
|
if (cfg->bufs[other_buf].empty) {
|
|
// rerun data callback to get next buffer chunk
|
|
dbg_platform_gpio_write( PLATFORM_GPIO_LOW );
|
|
cfg->fbuf_idx = other_buf;
|
|
pcm_data_play( param, 0 );
|
|
}
|
|
// unthrottle ISR
|
|
cfg->isr_throttled = 0;
|
|
}
|
|
} else {
|
|
dbg_platform_gpio_write( PLATFORM_GPIO_HIGH );
|
|
if (need_pop) lua_pop( L, 1 );
|
|
|
|
if (cfg->isr_throttled > 0) {
|
|
// ISR found no further data
|
|
// this was the last invocation of the reader task, fire drained cb
|
|
|
|
cfg->isr_throttled = -1;
|
|
|
|
dispatch_callback( L, cfg->self_ref, cfg->cb_drained_ref, 0 );
|
|
}
|
|
}
|
|
|
|
}
|