extern pthread_mutex_t mutex;
+/* LCOV_EXCL_START */
static void __free_delay_message_info(delay_message_info_s *message)
{
if (message != NULL) {
FREE_AND_NULL(message);
}
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
static void __free_list_delay_message_info(gpointer data)
{
delay_message_info_s *message = (delay_message_info_s *)data;
if (message != NULL)
__free_delay_message_info(message);
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
static void __clear_disconnect_socket(port_list_info_s *port_info)
{
GError *error = NULL;
port_info->delayed_message_size = 0;
port_info->send_sock_fd = 0;
}
+/* LCOV_EXCL_STOP */
/* LCOV_EXCL_START */
static void __free_port_info(gpointer data)
return ret_val;
}
+/* LCOV_EXCL_START */
static int __send_delayed_message(int sockfd, delay_message_info_s *message)
{
unsigned int nb = 0;
return ret;
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
static gboolean __process_delayed_message(gint fd, GIOCondition cond, gpointer data)
{
port_list_info_s *port_info = (port_list_info_s *)data;
return G_SOURCE_CONTINUE;
}
+/* LCOV_EXCL_STOP */
+/* LCOV_EXCL_START */
static int __insert_delayed_message(port_list_info_s *port_info,
int sequence,
bundle_raw *kb_data,
return ret;
}
+/* LCOV_EXCL_STOP */
static int __message_port_send_async(port_list_info_s *port_info, bundle *kb, const char *local_port,
bool local_trusted, bool is_bidirection)
FREE_AND_NULL(callback_info);
}
+/* LCOV_EXCL_START */
static void __callback_info_free_by_info(message_port_callback_info_s *callback_info)
{
GList *callback_info_list = g_hash_table_lookup(__callback_info_hash, GUINT_TO_POINTER(callback_info->local_id));
__callback_info_free(callback_info);
g_list_free(find_list);
}
+/* LCOV_EXCL_STOP */
static void __hash_destroy_callback_info(gpointer data)
{
}
if (read_string_from_socket(fd, (char **)&pkt->remote_port_name, &pkt->remote_port_name_len) != MESSAGE_PORT_ERROR_NONE) {
+/* LCOV_EXCL_START */
LOGE("read socket fail: port_name");
free(pkt->remote_port_name);
free(pkt);
return NULL;
+/* LCOV_EXCL_STOP */
}
if (read_socket(fd, (char *)&pkt->is_bidirection, sizeof(pkt->is_bidirection), &nb) != MESSAGE_PORT_ERROR_NONE) {
+/* LCOV_EXCL_START */
LOGE("read socket fail: is_bidirection");
free(pkt->remote_port_name);
free(pkt);
return NULL;
+/* LCOV_EXCL_STOP */
}
if (read_socket(fd, (char *)&pkt->is_trusted, sizeof(pkt->is_trusted), &nb) != MESSAGE_PORT_ERROR_NONE) {
+/* LCOV_EXCL_START */
LOGE("read socket fail: is_trusted");
free(pkt->remote_port_name);
free(pkt);
return NULL;
+/* LCOV_EXCL_STOP */
}
if (read_string_from_socket(fd, (char **)&pkt->data, &pkt->data_len) != MESSAGE_PORT_ERROR_NONE) {
+/* LCOV_EXCL_START */
LOGE("read socket fail: data");
if (pkt->data)
free(pkt->data);
free(pkt->remote_port_name);
free(pkt);
return NULL;
+/* LCOV_EXCL_STOP */
}
return pkt;