java hikaridatasource (null) has been closed

时间: 2023-09-02 12:02:07 浏览: 297

esp8266 mp3

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<minFifoFill) minFifoFill=i; //Do the rest of the calculations plusminus every 100mS (assuming a sample rate of 44KHz) cnt++; if (cnt<1500) return oldVal; cnt=0; if (spiRamFifoLen()<10*1024) { //The FIFO is very small. We can't do calculations on how much it's filled on average, so another //algorithm is called for. int tgt=1600; //we want an average of this amount of bytes as the average minimum buffer fill //Calculate underruns this cycle int udr=spiRamGetUnderrunCt()-prevUdr; //If we have underruns, the minimum buffer fill has been lower than 0. if (udr!=0) minFifoFill=-1; //If we're below our target decrease playback speed, and vice-versa. ret=oldVal+((minFifoFill-tgt)*ADD_DEL_BUFFPERSAMP_NOSPIRAM); prevUdr+=udr; minFifoFill=9999; } else { //We have a larger FIFO; we can adjust according to the FIFO fill rate. int tgt=spiRamFifoLen()/2; ret=(spiRamFifoFill()-tgt)*ADD_DEL_BUFFPERSAMP; } return ret; } //This routine is called by the NXP modifications of libmad. It passes us (for the mono synth) //32 16-bit samples. void render_sample_block(short *short_sample_buff, int no_samples) { //Signed 16.16 fixed point number: the amount of samples we need to add or delete //in every 32-sample static int sampAddDel=0; //Remainder of sampAddDel cumulatives static int sampErr=0; int i; int samp; #ifdef ADD_DEL_SAMPLES sampAddDel=recalcAddDelSamp(sampAddDel); #endif sampErr+=sampAddDel; for (i=0; i<no_samples; i++) { #if defined(PWM_HACK) samp=sampToI2sPwm(short_sample_buff[i]); #elif defined(DELTA_SIGMA_HACK) samp=sampToI2sDeltaSigma(short_sample_buff[i]); #else samp=sampToI2s(short_sample_buff[i]); #endif //Dependent on the amount of buffer we have too much or too little, we're going to add or remove //samples. This basically does error diffusion on the sample added or removed. if (sampErr>(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 (rem<sizeof(readBuf)) { n=(sizeof(readBuf)-rem); //Calculate amount of bytes we need to fill buffer. i=spiRamFifoFill(); if (i<n) n=i; //If the fifo can give us less, only take that amount if (n==0) { //Can't take anything? //Wait until there is enough data in the buffer. This only happens when the data feed //rate is too low, and shouldn't normally be needed! // printf("Buf uflow, need %d bytes.\n", sizeof(readBuf)-rem); bufUnderrunCt++; //We both silence the output as well as wait a while by pushing silent samples into the i2s system. //This waits for about 200mS for (n=0; n<441*2; n++) i2sPushSample(0); } else { //Read some bytes from the FIFO to re-fill the buffer. spiRamFifoRead(&readBuf[rem], n); rem+=n; } } //Okay, let MAD decode the buffer. mad_stream_buffer(stream, readBuf, sizeof(readBuf)); return MAD_FLOW_CONTINUE; } //Routine to print out an error static enum mad_flow ICACHE_FLASH_ATTR error(void *data, struct mad_stream *stream, struct mad_frame *frame) { printf("dec err 0xx (%s)\n", stream->error, 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()<spiRamFifoLen()/2)) { //Buffer is filled. Start up the MAD task. Yes, the 2100 words of stack is a fairly large amount but MAD seems to need it. if (xTaskCreate(tskmad, "tskmad", 2100, NULL, PRIO_MAD, NULL)!=pdPASS) printf("ERROR creating MAD task! Out of memory?\n"); madRunning=1; } t=(t+1)&255; if (t==0) printf("Buffer fill %d, DMA underrun ct %d, buff underrun ct %d\n", spiRamFifoFill(), (int)i2sGetUnderrunCnt(), bufUnderrunCt); } while (n>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); }

提示"java hikaridatasource (null) has been closed"意思是HikariDataSource已经被关闭。 HikariCP是一个高性能的JDBC连接池，而HikariDataSource是HikariCP提供的实现DataSource接口的数据源。当我们使用HikariDataSource连接数据库的时候，如果连接池已经被关闭，就会出现"java hikaridatasource (null) has been closed"的异常提示。这个异常提示通常会出现在以下几种情况下： 1. 在关闭连接之后仍然尝试使用连接。当我们使用完连接之后，应该显式地关闭连接，如果在连接关闭之后还试图进行数据库操作，就会出现该异常。 2. 连接池配置出现问题。我们在创建HikariDataSource时，需要提供连接配置，比如数据库的URL、用户名、密码等，如果这些配置出现问题，就会导致无法获得有效的连接，从而出现该异常。解决该问题的方法有以下几种： 1. 确保在使用完连接之后调用close()方法将连接关闭，以防止再次使用已经关闭的连接。 2. 检查连接池配置，确保配置正确无误。 3. 如果以上方法都没有解决问题，可以尝试重新创建HikariDataSource实例，并配置正确的连接参数。总结起来，"java hikaridatasource (null) has been closed"异常提示表明HikariDataSource连接池已经被关闭。我们需要确保在使用完连接之后及时关闭连接，并检查连接池配置是否正确。如果问题仍然存在，可以尝试重新创建连接池实例。

阅读全文

java hikaridatasource (null) has been closed

相关推荐

JS子窗口调用父窗口

HikariDataSource HikariDataSource (HikariPool-1) has been closed.

Java中的IO与文件操作

深入理解Java中的面向对象编程

【Java宠物管理系统深度剖析】：从设计到实现，全面掌握系统构建技巧

Connection has already been closed

java.lang.IllegalStateException: Surface has already been released.

graphics device is null

Cannot read property 'onOpen' of null websocket

java连接mysql数据库代码

java语言数据库注册事件

Activity com.example.myapplication.MainActivity has leaked window DecorView@f40b33[MainActivity] that was originally added here

MATLAB-四连杆机构的仿真+项目源码+文档说明

ridge_regression:用于岭回归的python代码（已实现以预测下个月的CO2浓度）

Polygon3-3.0.8-cp35-cp35m-win_amd64.whl.rar

【java毕业设计】风俗文化管理系统源码（ssm+mysql+说明文档+LW）.zip

中国城市温度历史数据（2000-2020）-最新全集.zip

中国土地利用现状遥感监测数据（1km）-最新.zip

pgmagick-0.7.5-cp35-cp35m-win_amd64.whl.whl.rar

最新推荐

微软内部资料-SQL性能优化3

MATLAB-四连杆机构的仿真+项目源码+文档说明

ridge_regression:用于岭回归的python代码（已实现以预测下个月的CO2浓度）

Polygon3-3.0.8-cp35-cp35m-win_amd64.whl.rar

【java毕业设计】风俗文化管理系统源码（ssm+mysql+说明文档+LW）.zip

SSM Java项目：StudentInfo 数据管理与可视化分析

管理建模和仿真的文件

负载均衡技术深入解析：确保高可用性的网络服务策略

怎么解决头文件重复包含

pyedgar：Python库简化EDGAR数据交互与文档下载