diff --git a/src/bluez.c b/src/bluez.c
|
index 5f35f87..f69cbed 100644
|
--- a/src/bluez.c
|
+++ b/src/bluez.c
|
@@ -14,8 +14,6 @@
|
#include <stdio.h>
|
#include <stdlib.h>
|
#include <string.h>
|
-#include <sys/socket.h>
|
-#include <sys/un.h>
|
|
#include <gio/gunixfdlist.h>
|
|
@@ -1029,33 +1027,6 @@ static void bluez_signal_interfaces_added(GDBusConnection *conn, const gchar *se
|
g_free(device_path);
|
}
|
|
-static int rockchip_send_volume_to_deviceiolib(int volume)
|
-{
|
- struct sockaddr_un serverAddr;
|
- int snd_cnt = 1;
|
- int sockfd;
|
- char buff[100] = {0};
|
-
|
- sockfd = socket(AF_UNIX, SOCK_DGRAM, 0);
|
- if (sockfd < 0) {
|
- printf("FUNC:%s create sockfd failed!\n", __func__);
|
- return -1;
|
- }
|
-
|
- serverAddr.sun_family = AF_UNIX;
|
- strcpy(serverAddr.sun_path, "/tmp/rk_deviceio_a2dp_volume");
|
- memset(buff, 0, sizeof(buff));
|
- sprintf(buff, "a2dp volume:%03d;", volume);
|
-
|
- while(snd_cnt--) {
|
- sendto(sockfd, buff, strlen(buff), MSG_DONTWAIT, (struct sockaddr *)&serverAddr, sizeof(serverAddr));
|
- usleep(1000); //5ms
|
- }
|
-
|
- close(sockfd);
|
- return 0;
|
-}
|
-
|
static void bluez_signal_transport_changed(GDBusConnection *conn, const gchar *sender,
|
const gchar *path, const gchar *interface, const gchar *signal, GVariant *params,
|
void *userdata) {
|
@@ -1119,8 +1090,6 @@ static void bluez_signal_transport_changed(GDBusConnection *conn, const gchar *s
|
/* received volume is in range [0, 127]*/
|
t->a2dp.ch1_volume = t->a2dp.ch2_volume = g_variant_get_uint16(value);
|
bluealsa_ctl_event(BA_EVENT_UPDATE_VOLUME);
|
- /* Send volume chg to rockchip deviceio */
|
- rockchip_send_volume_to_deviceiolib(t->a2dp.ch2_volume);
|
}
|
|
g_variant_unref(value);
|
diff --git a/utils/aplay.c b/utils/aplay.c
|
index 7b71860..5abb075 100644
|
--- a/utils/aplay.c
|
+++ b/utils/aplay.c
|
@@ -21,6 +21,8 @@
|
#include <stdlib.h>
|
#include <string.h>
|
#include <unistd.h>
|
+#include <sys/socket.h>
|
+#include <sys/un.h>
|
|
#include <alsa/asoundlib.h>
|
#include <gio/gio.h>
|
@@ -285,6 +287,27 @@ static void pcm_worker_routine_exit(struct pcm_worker *worker) {
|
debug("Exiting PCM worker %s", worker->addr);
|
}
|
|
+static int rockchip_send_underrun_to_deviceiolib()
|
+{
|
+ struct sockaddr_un serverAddr;
|
+ int sockfd;
|
+
|
+ sockfd = socket(AF_UNIX, SOCK_DGRAM, 0);
|
+ if (sockfd < 0) {
|
+ printf("FUNC:%s create sockfd failed!\n", __func__);
|
+ return -1;
|
+ }
|
+
|
+ serverAddr.sun_family = AF_UNIX;
|
+ strcpy(serverAddr.sun_path, "/tmp/rk_deviceio_a2dp_underrun");
|
+
|
+ sendto(sockfd, "a2dp underrun;", strlen("a2dp underrun;"), MSG_DONTWAIT, (struct sockaddr *)&serverAddr, sizeof(serverAddr));
|
+ usleep(1000);
|
+
|
+ close(sockfd);
|
+ return 0;
|
+}
|
+
|
static void *pcm_worker_routine(void *arg) {
|
struct pcm_worker *w = (struct pcm_worker *)arg;
|
|
@@ -445,6 +468,8 @@ static void *pcm_worker_routine(void *arg) {
|
switch (-frames) {
|
case EPIPE:
|
debug("An underrun has occurred");
|
+ /* Send underrun msg to rockchip deviceio */
|
+ rockchip_send_underrun_to_deviceiolib();
|
snd_pcm_prepare(w->pcm);
|
usleep(50000);
|
frames = 0;
|
--
|
2.17.1
|
