RVB2601应用开发实战系列六：网络播放器设计(二)

staticvoidnetwork_event(uint32_tevent_id, constvoid*param, void*context)
{
switch(event_id) {
caseEVENT_NETMGR_GOT_IP:
LOGD(TAG, "net got ip");
break;
caseEVENT_NETMGR_NET_DISCON:
LOGD(TAG, "net disconnect");
break;
    }
/*do exception process */app_exception_event(event_id);
}
intmain(void)
{
board_yoc_init();     // 板级配置、kv文件系统、声卡驱动、网卡驱动等初始化player_init();        // 播放器模块初始化cli_reg_cmd_player(); // 播放器命令行注册/* Subscribe */event_subscribe(EVENT_NETMGR_GOT_IP, network_event, NULL);     // 订阅网络连接事件event_subscribe(EVENT_NETMGR_NET_DISCON, network_event, NULL); // 订阅网络断开事件}

staticvoidnetwork_init()
{
w800_wifi_param_tw800_param;
/* init wifi driver and network */w800_param.reset_pin=PA21;
w800_param.baud=1*1000000;
w800_param.cs_pin=PA15;
w800_param.wakeup_pin=PA25;
w800_param.int_pin=PA22;
w800_param.channel_id=0;
w800_param.buffer_size=4*1024;
wifi_w800_register(NULL, &w800_param);
app_netmgr_hdl=netmgr_dev_wifi_init();
if (app_netmgr_hdl) {
utask_t*task=utask_new("netmgr", 2*1024, QUEUE_MSG_COUNT, AOS_DEFAULT_APP_PRI);
netmgr_service_init(task);
netmgr_start(app_netmgr_hdl);
    }
}
voidboard_yoc_init(void)
{
board_init();                                 // 板级初始化event_service_init(NULL);                     // 发布订阅服务初始化console_init(CONSOLE_UART_IDX, 115200, 512);  // 串口初始化ulog_init();                                  // 日志初始化aos_set_log_level(AOS_LL_DEBUG);              // 配置默认日志打印级别intret=partition_init();                   // 分区初始化if (ret<=0) {
LOGE(TAG, "partition init failed");
    } else {
LOGI(TAG, "find %d partitions", ret);
    }
aos_kv_init("kv");                            // kv文件系统初始化，可用于保存网络ssid&psksnd_card_alkaid_register(NULL);               // 声卡初始化，可用于播放&采集network_init();                               // 网络初始化board_cli_init();                             // 命令行初始化并注册默认的命令}

staticintspi_resp_len(void)
{
uint16_ttemp=0;
uint8_ta,b;
uint8_tcmd=SPI_REG_INT_STTS;
intrecv_len=0;
while (1) {
CS_LOW;
csi_spi_send(&spi_handle, &cmd, 1, AOS_WAIT_FOREVER);       // 检查是否存在有效数据csi_spi_receive(&spi_handle, &a, 1, AOS_WAIT_FOREVER);
csi_spi_receive(&spi_handle, &b, 1, AOS_WAIT_FOREVER);
CS_HIGH;
temp=a| (b<<8);
if((temp!=0xffff) && (temp&0x01)) {
cmd=SPI_REG_RX_DAT_LEN;
CS_LOW;
csi_spi_send(&spi_handle, &cmd, 1, AOS_WAIT_FOREVER);   // 获取接收数据长度 csi_spi_receive(&spi_handle, &a, 1, AOS_WAIT_FOREVER);
csi_spi_receive(&spi_handle, &b, 1, AOS_WAIT_FOREVER);
CS_HIGH;
recv_len=a| (b<<8);
// printf("recv len:%d\r\n", recv_len);break;
        }
aos_msleep(100);
    }
returnrecv_len;
}
staticvoidat_spi_recv_task(void*priv)
{
intlen=0;
uint8_t*recv=NULL;
while(1) {
aos_sem_wait(&spi_recv_sem, AOS_WAIT_FOREVER); // 是否有中断过来，通过GIIO来触发中断len=spi_resp_len();               // 获取对端发送过来的数据长度if (len)
recv=aos_malloc_check(len);
elsecontinue;
spi_recv(recv, len);                // 获取实际有效数据while (ringbuffer_available_write_space(&spi_ringbuffer) < (len-1)) {
aos_msleep(100);
        }
intw_len=ringbuffer_write(&spi_ringbuffer, recv, len-1); // 写入到环形缓冲中if (w_len!= (len-1)) {
LOGD(TAG, "spi buffer is full\r\n");
        } else {
spi_channel_cb(AT_CHANNEL_EVENT_READ, spi_channel_priv);
        }
if (recv) {
aos_free(recv);
recv=NULL;
        }
    }
}
staticvoid*at_spi_init(constchar*name, void*config)
{
intret=0;
csi_pin_set_mux(PA16, PA16_SPI0_SCK);                            // 配置管脚复用csi_pin_set_mux(PA17, PA17_SPI0_MOSI);
csi_pin_set_mux(PA18, PA18_SPI0_MISO);
// csi_pin_set_mux(PA15, PA15_SPI0_CS); // CScsi_pin_set_mux(PA15, PIN_FUNC_GPIO); // CScsi_pin_set_mux(PA22, PIN_FUNC_GPIO); // INTcsi_gpio_pin_init(&spi_int_pin, PA22);                           // gpio配置csi_gpio_pin_dir(&spi_int_pin,GPIO_DIRECTION_INPUT);
csi_gpio_pin_mode(&spi_int_pin,GPIO_MODE_PULLNONE);
csi_gpio_pin_debounce(&spi_int_pin, true);
csi_gpio_pin_attach_callback(&spi_int_pin, spi_in_int_cb, NULL); // 根据gpio来通知是否存在网络数据csi_gpio_pin_irq_mode(&spi_int_pin,GPIO_IRQ_MODE_FALLING_EDGE);
csi_gpio_pin_irq_enable(&spi_int_pin, 1);
csi_gpio_pin_init(&spi_cs_pin, PA15);
csi_gpio_pin_mode(&spi_cs_pin,GPIO_MODE_PULLUP);
csi_gpio_pin_dir(&spi_cs_pin,GPIO_DIRECTION_OUTPUT);
CS_HIGH;
csi_gpio_pin_init(&spi_wakeup_pin, PA25);
csi_gpio_pin_mode(&spi_wakeup_pin,GPIO_MODE_PULLUP);
csi_gpio_pin_dir(&spi_wakeup_pin,GPIO_DIRECTION_OUTPUT);
csi_gpio_pin_write(&spi_wakeup_pin, GPIO_PIN_HIGH);
ret=csi_spi_init(&spi_handle, 0);
if (ret<0) {
printf("csi spi init failed\r\n");
returnNULL;
    }
csi_spi_mode(&spi_handle, SPI_MASTER);        // 2601侧作为masterret=csi_spi_baud(&spi_handle, 1*1000000);   // 波特率配置默认1MLOGD(TAG, "#######################spi speed:%d\r\n", ret);
csi_spi_cp_format(&spi_handle, SPI_FORMAT_CPOL0_CPHA0);
csi_spi_frame_len(&spi_handle, SPI_FRAME_LEN_8);
csi_spi_select_slave(&spi_handle, 0);         // 建立与w800间的spi通信,w800网卡作为slave 0aos_task_ttask;
ret=aos_sem_new(&spi_recv_sem, 0);          // 用于gpio中断通知// aos_check(ret, NULL);ret=aos_task_new_ext(&task, "spi_recv", at_spi_recv_task, NULL, 1536, 9);
// aos_check(ret, NULL);spi_recv_buffer= (char*)aos_malloc_check(SPI_RX_BUFFER_LEN); // 创建环形buffer，用于接收网络数据ringbuffer_create(&spi_ringbuffer, spi_recv_buffer, SPI_RX_BUFFER_LEN);
return (void*)1;
}
at_channel_tspi_channel= {
    .init=at_spi_init,
    .set_event=at_spi_set_event,
    .send=at_spi_send,
    .recv=at_spi_recv,
};

staticplayer_t*g_player;
staticvoid_player_event(player_t*player, uint8_ttype, constvoid*data, uint32_tlen)
{
intrc;
UNUSED(len);
UNUSED(data);
UNUSED(handle);
LOGD(TAG, "=====%s, %d, type = %d", __FUNCTION__, __LINE__, type);
switch (type) {
casePLAYER_EVENT_ERROR:      // 播放出错事件rc=player_stop(player);
break;
casePLAYER_EVENT_START: {    // 开始播放事件media_info_tminfo;
memset(&minfo, 0, sizeof(media_info_t));
rc=player_get_media_info(player, &minfo);  // 获取媒体时长、大小等信息LOGD(TAG, "=====rc = %d, duration = %llums, bps = %llu, size = %u", rc, minfo.duration, minfo.bps, minfo.size);
break;
    }
casePLAYER_EVENT_FINISH:     // 播放结束事件player_stop(player);      // 停止播放break;
default:
break;
    }
}
player_t*get_player_demo()
{
if (!g_player) {
ply_conf_tply_cnf;
player_conf_init(&ply_cnf);               // 初始化播放器默认配置ply_cnf.vol_en=1;               // 使能数字音量功能ply_cnf.vol_index=160;             // 0~255ply_cnf.event_cb=_player_event;   // 播放事件回调函数ply_cnf.period_num=12;              // 底层音频输出缓冲周期，用于控制音频输出缓冲大小ply_cnf.cache_size=32*1024;       // 网络时的播放缓冲大小g_player=player_new(&ply_cnf);          // 创建播放器    }
returng_player;
}

CONFIG_AEFXER_IPC=0#音效处理，2601不涉及CONFIG_AEFXER_SONA=0#音效处理，2601不涉及CONFIG_AO_MIXER_SUPPORT=0#混音播放，默认关闭CONFIG_ATEMPOER_IPC=0#核间变速播放，2601不涉及CONFIG_ATEMPOER_SONIC=1#变速播放CONFIG_AV_AO_CHANNEL_NUM=1#单声道音频输出CONFIG_AV_PROBE_SIZE_MAX=1024#音频格式探测最大长度CONFIG_AV_SAMPLE_NUM_PER_FRAME_MAX=80#控制wav音频帧的最大采样数CONFIG_AV_STREAM_INNER_BUF_SIZE=256#stream内部buf大小，用于性能优化CONFIG_DECODER_ADPCM_MS=0#adpcm_ms解码CONFIG_DECODER_ALAW=0#alaw解码CONFIG_DECODER_AMRNB=0#amrnb解码CONFIG_DECODER_AMRWB=0#amrwb解码CONFIG_DECODER_FLAC=0#flac解码CONFIG_DECODER_IPC=0#核间解码，2601不涉及CONFIG_DECODER_MULAW=0#ulaw解码CONFIG_DECODER_OPUS=0#opus解码CONFIG_DECODER_PCM=1#pcm裸流解码CONFIG_DECODER_PVMP3=1#mp3解码CONFIG_DECODER_SPEEX=0#speex解码CONFIG_DEMUXER_ADTS=0#adts解复用CONFIG_DEMUXER_AMR=0#amr解复用CONFIG_DEMUXER_ASF=0#asf解复用CONFIG_DEMUXER_FLAC=0#flac解复用CONFIG_DEMUXER_MP3=1#mp3解复用CONFIG_DEMUXER_MP4=0#mp4解复用CONFIG_DEMUXER_OGG=0#ogg解复用CONFIG_DEMUXER_RAWAUDIO=0#rawaudio解复用CONFIG_DEMUXER_TS=0#ts解复用CONFIG_DEMUXER_WAV=0#wav解复用CONFIG_EQXER_IPC=0#量化器，2601不涉及CONFIG_EQXER_SILAN=0#量化器，2601不涉及CONFIG_FFTXER_IPC=0#fft变换，2601不涉及CONFIG_FFTXER_SPEEX=0#fft变换，2601不涉及CONFIG_PLAYER_TASK_STACK_SIZE=2048#播放器任务栈大小CONFIG_RESAMPLER_IPC=0#核间音频重采样CONFIG_RESAMPLER_SPEEX=0#speex重采样CONFIG_STREAMER_CRYPTO=0#加密流CONFIG_STREAMER_FIFO=0#队列流CONFIG_STREAMER_FILE=0#文件流CONFIG_STREAMER_HLS=0#httplivestreamCONFIG_STREAMER_HTTP=1#http网络流CONFIG_STREAMER_MEM=1#内存流CONFIG_WEB_CACHE_TASK_STACK_SIZE=2048#网络流缓冲任务栈大小