English
资源说明：esp8266 语音播放
//Priorities of the reader and the decoder thread. Higher = higher prio.
#define PRIO_READER 11
#define PRIO_MAD 1
//The mp3 read buffer size. 2106 bytes should be enough for up to 48KHz mp3s according to the sox sources. Used by libmad.
#define READBUFSZ (2106)
static char readBuf[READBUFSZ];
static long bufUnderrunCt;
//Reformat the 16-bit mono sample to a format we can send to I2S.
static int sampToI2s(short s) {
//We can send a 32-bit sample to the I2S subsystem and the DAC will neatly split it up in 2
//16-bit analog values, one for left and one for right.
//Duplicate 16-bit sample to both the L and R channel
int samp=s;
samp=(samp)&0xffff;
samp=(samp<<16)|samp;
return samp;
}
//Array with 32-bit values which have one bit more set to '1' in every consecutive array index value
const unsigned int ICACHE_RODATA_ATTR fakePwm[]={ 0x00000010, 0x00000410, 0x00400410, 0x00400C10, 0x00500C10, 0x00D00C10, 0x20D00C10, 0x21D00C10, 0x21D80C10,
0xA1D80C10, 0xA1D80D10, 0xA1D80D30, 0xA1DC0D30, 0xA1DC8D30, 0xB1DC8D30, 0xB9DC8D30, 0xB9FC8D30, 0xBDFC8D30, 0xBDFE8D30,
0xBDFE8D32, 0xBDFE8D33, 0xBDFECD33, 0xFDFECD33, 0xFDFECD73, 0xFDFEDD73, 0xFFFEDD73, 0xFFFEDD7B, 0xFFFEFD7B, 0xFFFFFD7B,
0xFFFFFDFB, 0xFFFFFFFB, 0xFFFFFFFF};
static int sampToI2sPwm(short s) {
//Okay, when this is enabled it means a speaker is connected *directly* to the data output. Instead of
//having a nice PCM signal, we fake a PWM signal here.
static int err=0;
int samp=s;
samp=(samp+32768); //to unsigned
samp-=err; //Add the error we made when rounding the previous sample (error diffusion)
//clip value
if (samp>65535) samp=65535;
if (samp<0) samp=0;
//send pwm value for sample value
samp=fakePwm[samp>>11];
err=(samp&0x7ff); //Save rounding error.
return samp;
}
//2nd order delta-sigma DAC
//See http://www.beis.de/Elektronik/DeltaSigma/DeltaSigma.html for a nice explanation
static int sampToI2sDeltaSigma(short s) {
int x;
int val=0;
int w;
static int i1v=0, i2v=0;
static int outReg=0;
for (x=0; x<32; x++) {
val<<=1; //next bit
w=s;
if (outReg>0) w-=32767; else w+=32767; //Difference 1
w+=i1v; i1v=w; //Integrator 1
if (outReg>0) w-=32767; else w+=32767; //Difference 2
w+=i2v; i2v=w; //Integrator 2
outReg=w; //register
if (w>0) val|=1; //comparator
}
return val;
}
//Calculate the number of samples that we add or delete. Added samples means a slightly lower
//playback rate, deleted samples means we increase playout speed a bit. This returns an
//8.24 fixed-point number
int recalcAddDelSamp(int oldVal) {
int ret;
long prevUdr=0;
static int cnt;
int i;
static int minFifoFill=0;
i=spiRamFifoFill();
if (i(1<<24)) {
sampErr-=(1<<24);
//...and don't output an i2s sample
} else if (sampErr<-(1<<24)) {
sampErr+=(1<<24);
//..and output 2 samples instead of one.
i2sPushSample(samp);
i2sPushSample(samp);
} else {
//Just output the sample.
i2sPushSample(samp);
}
}
}
//Called by the NXP modificationss of libmad. Sets the needed output sample rate.
static oldRate=0;
void ICACHE_FLASH_ATTR set_dac_sample_rate(int rate) {
if (rate==oldRate) return;
oldRate=rate;
printf("Rate %d\n", rate);
#ifdef ALLOW_VARY_SAMPLE_BITS
i2sSetRate(rate, 0);
#else
i2sSetRate(rate, 1);
#endif
}
static enum mad_flow ICACHE_FLASH_ATTR input(struct mad_stream *stream) {
int n, i;
int rem, fifoLen;
//Shift remaining contents of buf to the front
rem=stream->bufend-stream->next_frame;
memmove(readBuf, stream->next_frame, rem);
while (remerror, mad_stream_errorstr(stream));
return MAD_FLOW_CONTINUE;
}
//This is the main mp3 decoding task. It will grab data from the input buffer FIFO in the SPI ram and
//output it to the I2S port.
void ICACHE_FLASH_ATTR tskmad(void *pvParameters) {
int r;
struct mad_stream *stream;
struct mad_frame *frame;
struct mad_synth *synth;
//Allocate structs needed for mp3 decoding
stream=malloc(sizeof(struct mad_stream));
frame=malloc(sizeof(struct mad_frame));
synth=malloc(sizeof(struct mad_synth));
if (stream==NULL) { printf("MAD: malloc(stream) failed\n"); return; }
if (synth==NULL) { printf("MAD: malloc(synth) failed\n"); return; }
if (frame==NULL) { printf("MAD: malloc(frame) failed\n"); return; }
//Initialize I2S
i2sInit();
bufUnderrunCt=0;
printf("MAD: Decoder start.\n");
//Initialize mp3 parts
mad_stream_init(stream);
mad_frame_init(frame);
mad_synth_init(synth);
while(1) {
input(stream); //calls mad_stream_buffer internally
while(1) {
r=mad_frame_decode(frame, stream);
if (r==-1) {
if (!MAD_RECOVERABLE(stream->error)) {
//We're most likely out of buffer and need to call input() again
break;
}
error(NULL, stream, frame);
continue;
}
mad_synth_frame(synth, frame);
}
}
}
int getIpForHost(const char *host, struct sockaddr_in *ip) {
struct hostent *he;
struct in_addr **addr_list;
he=gethostbyname(host);
if (he==NULL) return 0;
addr_list=(struct in_addr **)he->h_addr_list;
if (addr_list[0]==NULL) return 0;
ip->sin_family=AF_INET;
memcpy(&ip->sin_addr, addr_list[0], sizeof(ip->sin_addr));
return 1;
}
//Open a connection to a webserver and request an URL. Yes, this possibly is one of the worst ways to do this,
//but RAM is at a premium here, and this works for most of the cases.
int ICACHE_FLASH_ATTR openConn(const char *streamHost, const char *streamPath) {
int n, i;
while(1) {
struct sockaddr_in remote_ip;
bzero(&remote_ip, sizeof(struct sockaddr_in));
if (!getIpForHost(streamHost, &remote_ip)) {
vTaskDelay(1000/portTICK_RATE_MS);
continue;
}
int sock=socket(PF_INET, SOCK_STREAM, 0);
if (sock==-1) {
continue;
}
remote_ip.sin_port = htons(streamPort);
printf("Connecting to server %s...\n", ipaddr_ntoa((const ip_addr_t*)&remote_ip.sin_addr.s_addr));
if (connect(sock, (struct sockaddr *)(&remote_ip), sizeof(struct sockaddr))!=00) {
close(sock);
printf("Conn err.\n");
vTaskDelay(1000/portTICK_RATE_MS);
continue;
}
//Cobble together HTTP request
write(sock, "GET ", 4);
write(sock, streamPath, strlen(streamPath));
write(sock, " HTTP/1.0\r\nHost: ", 17);
write(sock, streamHost, strlen(streamHost));
write(sock, "\r\n\r\n", 4);
//We ignore the headers that the server sends back... it's pretty dirty in general to do that,
//but it works here because the MP3 decoder skips it because it isn't valid MP3 data.
return sock;
}
}
//Reader task. This will try to read data from a TCP socket into the SPI fifo buffer.
void ICACHE_FLASH_ATTR tskreader(void *pvParameters) {
int madRunning=0;
char wbuf[64];
int n, l, inBuf;
int t;
int fd;
int c=0;
while(1) {
fd=openConn(streamHost, streamPath);
printf("Reading into SPI RAM FIFO...\n");
do {
n=read(fd, wbuf, sizeof(wbuf));
if (n>0) spiRamFifoWrite(wbuf, n);
c+=n;
if ((!madRunning) && (spiRamFifoFree()0);
close(fd);
printf("Connection closed.\n");
}
}
//Simple task to connect to an access point, initialize i2s and fire up the reader task.
void ICACHE_FLASH_ATTR tskconnect(void *pvParameters) {
//Wait a few secs for the stack to settle down
vTaskDelay(3000/portTICK_RATE_MS);
//Go to station mode
wifi_station_disconnect();
if (wifi_get_opmode() != STATION_MODE) {
wifi_set_opmode(STATION_MODE);
}
//Connect to the defined access point.
struct station_config *config=malloc(sizeof(struct station_config));
memset(config, 0x00, sizeof(struct station_config));
sprintf(config->ssid, AP_NAME);
sprintf(config->password, AP_PASS);
wifi_station_set_config(config);
wifi_station_connect();
free(config);
//Fire up the reader task. The reader task will fire up the MP3 decoder as soon
//as it has read enough MP3 data.
if (xTaskCreate(tskreader, "tskreader", 230, NULL, PRIO_READER, NULL)!=pdPASS) printf("Error creating reader task!\n");
//We're done. Delete this task.
vTaskDelete(NULL);
}
//We need this to tell the OS we're running at a higher clock frequency.
extern void os_update_cpu_frequency(int mhz);
void ICACHE_FLASH_ATTR user_init(void) {
//Tell hardware to run at 160MHz instead of 80MHz
//This actually is not needed in normal situations... the hardware is quick enough to do
//MP3 decoding at 80MHz. It, however, seems to help with receiving data over long and/or unstable
//links, so you may want to turn it on. Also, the delta-sigma code seems to need a bit more speed
//than the other solutions to keep up with the output samples, so it's also enabled there.
#if defined(DELTA_SIGMA_HACK)
SET_PERI_REG_MASK(0x3ff00014, BIT(0));
os_update_cpu_frequency(160);
#endif
//Set the UART to 115200 baud
UART_SetBaudrate(0, 115200);
//Initialize the SPI RAM chip communications and see if it actually retains some bytes. If it
//doesn't, warn user.
if (!spiRamFifoInit()) {
printf("\n\nSPI RAM chip fail!\n");
while(1);
}
printf("\n\nHardware initialized. Waiting for network.\n");
xTaskCreate(tskconnect, "tskconnect", 200, NULL, 3, NULL);
}
本源码包内暂不包含可直接显示的源代码文件，请下载源码包。
