const char *message_port = "ma_streaming_port";
static int g_local_port_id = -1;
+//LCOV_EXCL_START
static void message_port_cb(int local_port_id,
const char *remote_app_id, const char *remote_port,
bool trusted_remote_port, bundle *message, void *user_data)
if (pending_buffer_size >= header.streaming_data_size) {
static int last_serial = 0;
if (header.streaming_data_serial != last_serial + 1) {
- //LCOV_EXCL_START
MA_SLOGE("[ERROR] SERIAL MISMATCH in [%d] : %d => %d",
header.streaming_data_type, last_serial, header.streaming_data_serial);
- //LCOV_EXCL_STOP
}
last_serial = header.streaming_data_serial;
}
}
}
+//LCOV_EXCL_STOP
static int streaming_ipc_initialize()
{
} /* MAS_METHOD_ERROR */
else if (dbus_message_is_signal(msg, "org.freedesktop.DBus", "NameOwnerChanged")) {
+ //LCOV_EXCL_START
MA_SLOGD("[DEBUG] Owner Changed"); //LCOV_EXCL_LINE
DBusError err;
dbus_error_init(&err);
dbus_connection_flush(g_conn_listener);
if (dbus_error_is_set(&err)) {
- //LCOV_EXCL_START
MA_SLOGE("Match Error (%s)", err.message);
dbus_error_free(&err);
- //LCOV_EXCL_STOP
}
__ma_cb_error(MA_ERROR_SERVICE_RESET, "Daemon Reset");
+ //LCOV_EXCL_STOP
} /* NameOwnerChanged */
else {
}
if (NULL == g_conn_listener) {
+ //LCOV_EXCL_START
MA_SLOGE("Fail to get dbus connection "); //LCOV_EXCL_LINE
__ma_dbus_connection_free();
return MA_ERROR_OPERATION_FAILED;
+ //LCOV_EXCL_STOP
}
dbus_connection_set_exit_on_disconnect(g_conn_listener, false);
}
if (DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret) {
+ //LCOV_EXCL_START
MA_SLOGE("fail dbus_bus_request_name()"); //LCOV_EXCL_LINE
__ma_dbus_connection_free();
return -2;
+ //LCOV_EXCL_STOP
}
if (NULL != g_fd_handler) {
+ //LCOV_EXCL_START
MA_SLOGW("The handler already exists."); //LCOV_EXCL_LINE
__ma_dbus_connection_free();
return 0;
+ //LCOV_EXCL_STOP
}
/* Flush messages which are received before fd event handler registration */
int fd = 0;
if (1 != dbus_connection_get_unix_fd(g_conn_listener, &fd)) {
+ //LCOV_EXCL_START
MA_SLOGE("fail to get fd from dbus "); //LCOV_EXCL_LINE
__ma_dbus_connection_free();
return MA_ERROR_OPERATION_FAILED;
+ //LCOV_EXCL_STOP
} else {
MA_SLOGD("Get fd from dbus : %d", fd); //LCOV_EXCL_LINE
}
g_fd_handler = ecore_main_fd_handler_add(fd, ECORE_FD_READ, (Ecore_Fd_Cb)listener_event_callback, g_conn_listener, NULL, NULL);
if (NULL == g_fd_handler) {
MA_SLOGE("fail to get fd handler from ecore "); //LCOV_EXCL_LINE
+ //LCOV_EXCL_START
__ma_dbus_connection_free();
return MA_ERROR_OPERATION_FAILED;
+ //LCOV_EXCL_STOP
}
streaming_ipc_initialize();
bool sender_connected = dbus_connection_get_is_connected(g_conn_sender);
bool listener_connected = dbus_connection_get_is_connected(g_conn_listener);
- //LCOV_EXCL_START
MA_SLOGW("[DBUS] Sender(%s) Listener(%s)",
sender_connected ? "Connected" : "Not connected", listener_connected ? "Connected" : "Not connected");
- //LCOV_EXCL_STOP
if (false == sender_connected || false == listener_connected) {
ma_dbus_close_connection();
MA_SLOGE("@@ multi-assistant finalize : result = %d", result); //LCOV_EXCL_LINE
}
} else {
+ //LCOV_EXCL_START
MA_SLOGE("@@ Result message is NULL "); //LCOV_EXCL_LINE
ma_dbus_reconnect();
result = MA_ERROR_TIMED_OUT;
+ //LCOV_EXCL_STOP
}
return result;
MA_SLOGE("@@ multi-assistant get recording audio format : result = %d", result); //LCOV_EXCL_LINE
}
} else {
+ //LCOV_EXCL_START
MA_SLOGE("@@ Result message is NULL"); //LCOV_EXCL_LINE
ma_dbus_reconnect();
result = MA_ERROR_TIMED_OUT;
+ //LCOV_EXCL_STOP
}
return result;
MA_SLOGE("@@ multi-assistant get recording audio source type : result = %d, type(%p)", result, type); //LCOV_EXCL_LINE
}
} else {
+ //LCOV_EXCL_START
MA_SLOGE("@@ Result message is NULL"); //LCOV_EXCL_LINE
ma_dbus_reconnect();
result = MA_ERROR_TIMED_OUT;
+ //LCOV_EXCL_STOP
}
return result;